NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Public Member Functions | List of all members
NES::NESBinaryParser Class Reference

#include <NESBinaryParser.hpp>

Collaboration diagram for NES::NESBinaryParser:
[legend]

Public Member Functions

 NESBinaryParser (const SchemaPtr &schema, bool addIngestionTime=false)
 public constructor for NES input data parser More...
 
bool writeInputTupleToTupleBuffer (std::string_view binaryBuffer, uint64_t tupleCount, Runtime::MemoryLayouts::TestTupleBuffer &tupleBuffer, const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager) override
 takes a binary nes tuple buffer as string_view and copies it into a TupleBuffer More...
 
- Public Member Functions inherited from NES::Parser
 Parser (std::vector< PhysicalTypePtr > physicalTypes)
 public constructor for input data parser More...
 
virtual ~Parser ()=default
 
void writeFieldValueToTupleBuffer (std::string value, uint64_t schemaFieldIndex, Runtime::MemoryLayouts::TestTupleBuffer &tupleBuffer, const SchemaPtr &schema, uint64_t tupleCount, const Runtime::BufferManagerPtr &bufferManager)
 casts a value in string format to the correct type and writes it to the TupleBuffer More...
 

Detailed Description

Parser for NebulasSteram

Constructor & Destructor Documentation

◆ NESBinaryParser()

NES::NESBinaryParser::NESBinaryParser ( const SchemaPtr &  schema,
bool  addIngestionTime = false 
)

public constructor for NES input data parser

Parameters
schemaschema of the tuple
addIngestionTimeadd ingestion time to the incoming record

Member Function Documentation

◆ writeInputTupleToTupleBuffer()

bool NES::NESBinaryParser::writeInputTupleToTupleBuffer ( std::string_view  binaryBuffer,
uint64_t  tupleCount,
Runtime::MemoryLayouts::TestTupleBuffer &  tupleBuffer,
const SchemaPtr &  schema,
const Runtime::BufferManagerPtr &  bufferManager 
)
overridevirtual

takes a binary nes tuple buffer as string_view and copies it into a TupleBuffer

Parameters
binaryBufferstring value that is cast to the PhysicalType and written to the TupleBuffer
tupleCountthe number of tuples already written to the current TupleBuffer
tupleBufferthe TupleBuffer to which the value is written containing the currently chosen memory layout
schemadata schema
bufferManagerthe buffer manager

Implements NES::Parser.

References NES::Runtime::MemoryLayouts::TestTupleBuffer::getBuffer(), NES::Runtime::TupleBuffer::getBuffer(), NES::Runtime::TupleBuffer::getBufferSize(), NES::Runtime::MemoryLayouts::TestTupleBuffer::getMemoryLayout(), apex::memcpy(), NES_ASSERT, NES_TRACE, and NES::Runtime::TupleBuffer::setNumberOfTuples().

Here is the call graph for this function:
The documentation for this class was generated from the following files: