NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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>
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... | |