NES::NesFormat Class Reference

#include <NesFormat.hpp>

Collaboration diagram for NES::NesFormat:

Public Member Functions
	NesFormat (SchemaPtr schema, Runtime::BufferManagerPtr bufferManager)
virtual	~NesFormat () noexcept=default
std::string	getFormattedSchema () override
	Returns the schema of formatted according to the specific SinkFormat represented as string. More...
std::string	getFormattedBuffer (Runtime::TupleBuffer &inputBuffer) override
	method to write a TupleBuffer More...
FormatIterator	getTupleIterator (Runtime::TupleBuffer &inputBuffer) override
	method to write a TupleBuffer More...
std::string	toString () override
	method to return the format as a string More...
FormatTypes	getSinkFormat () override
	return sink format More...
Public Member Functions inherited from NES::SinkFormat
	SinkFormat (SchemaPtr schema, Runtime::BufferManagerPtr bufferManager)
	constructor for a sink format More...
	SinkFormat (SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, bool addTimestamp)
	constructor for a sink format More...
virtual	~SinkFormat () noexcept=default
SchemaPtr	getSchemaPtr ()
void	setSchemaPtr (SchemaPtr schema)
Runtime::BufferManagerPtr	getBufferManager ()
void	setBufferManager (Runtime::BufferManagerPtr bufferManager)
bool	getAddTimestamp ()
void	setAddTimestamp (bool addTimestamp)

Additional Inherited Members
Protected Attributes inherited from NES::SinkFormat
SchemaPtr	schema
Runtime::BufferManagerPtr	bufferManager
bool	addTimestamp

Constructor & Destructor Documentation

NesFormat()

NES::NesFormat::NesFormat	(	SchemaPtr	schema,
		Runtime::BufferManagerPtr	bufferManager
	)

~NesFormat()

virtual NES::NesFormat::~NesFormat ( )

virtualdefaultnoexcept

Member Function Documentation

getFormattedBuffer()

std::string NES::NesFormat::getFormattedBuffer ( Runtime::TupleBuffer &  inputBuffer )

overridevirtual

method to write a TupleBuffer

Parameters

a	tuple buffers pointer

Returns

vector of Tuple buffer containing the content of the tuplebuffer

Implements NES::SinkFormat.

References NES::Runtime::TupleBuffer::getBuffer(), NES::Runtime::TupleBuffer::getNumberOfTuples(), and NES::SinkFormat::getSchemaPtr().

Here is the call graph for this function:

getFormattedSchema()

std::string NES::NesFormat::getFormattedSchema ( )

overridevirtual

Returns the schema of formatted according to the specific SinkFormat represented as string.

Returns

The formatted schema as string

Implements NES::SinkFormat.

References NES::SinkFormat::schema.

getSinkFormat()

FormatTypes NES::NesFormat::getSinkFormat ( )

overridevirtual

return sink format

Returns

sink format

Implements NES::SinkFormat.

References NES::NES_FORMAT.

getTupleIterator()

FormatIterator NES::NesFormat::getTupleIterator ( Runtime::TupleBuffer &  inputBuffer )

overridevirtual

method to write a TupleBuffer

Parameters

a	tuple buffers pointer

Returns

vector of Tuple buffer containing the content of the tuplebuffer

Implements NES::SinkFormat.

References NES_NOT_IMPLEMENTED.

toString()

std::string NES::NesFormat::toString ( )

overridevirtual

method to return the format as a string

Returns

format as string

Implements NES::SinkFormat.

---

The documentation for this class was generated from the following files:

• /nebulastream/nes-runtime/include/Sinks/Formats/NesFormat.hpp
• /nebulastream/nes-runtime/src/Sinks/Formats/NesFormat.cpp