NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Core.hpp File Reference
#include <API/Schema.hpp>
#include <Common/PhysicalTypes/BasicPhysicalType.hpp>
#include <Identifiers/Identifiers.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Util/Logger/Logger.hpp>
#include <algorithm>
#include <any>
#include <functional>
#include <map>
#include <set>
#include <string>
Include dependency graph for Core.hpp:
This graph shows which files directly or indirectly include this file:

Namespaces

 NES
 This exception represents a network error.
 
 NES::Catalogs
 
 NES::Catalogs::Source
 
 NES::Catalogs::Query
 
 NES::Util
 

Functions

std::string NES::Util::printTupleBufferAsText (Runtime::TupleBuffer &buffer)
 Outputs a tuple buffer in text format. More...
 
std::string NES::Util::printTupleBufferAsCSV (Runtime::TupleBuffer tbuffer, const SchemaPtr &schema, const std::string &lineSuffix="")
 create CSV lines from the tuples More...
 
std::vector< PhysicalTypePtr > NES::Util::getPhysicalTypes (SchemaPtr schema)
 Returns the physical types of all fields of the schema. More...
 
std::string NES::Util::toCSVString (const SchemaPtr &schema)
 method to get the schema as a csv string More...
 
Runtime::MemoryLayouts::MemoryLayoutPtr NES::Util::createMemoryLayout (SchemaPtr schema, uint64_t bufferSize)
 Creates a memory layout from the schema and the buffer Size. More...
 
bool NES::Util::assignPropertiesToQueryOperators (const QueryPlanPtr &queryPlan, std::vector< std::map< std::string, std::any >> properties)
 
std::vector< Runtime::TupleBuffer > NES::Util::createBuffersFromCSVFile (const std::string &csvFile, const SchemaPtr &schema, Runtime::BufferManagerPtr bufferManager, const std::string &timeStampFieldName, uint64_t lastTimeStamp)
 Creates multiple TupleBuffers from the csv file until the lastTimeStamp has been read. More...