NES::JsonFormat Class Reference

#include <JsonFormat.hpp>

Collaboration diagram for NES::JsonFormat:

Public Member Functions
	JsonFormat (SchemaPtr schema, Runtime::BufferManagerPtr bufferManager)
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

JsonFormat()

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

Member Function Documentation

getFormattedBuffer()

std::string NES::JsonFormat::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_NOT_IMPLEMENTED.

getFormattedSchema()

std::string NES::JsonFormat::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_NOT_IMPLEMENTED.

getSinkFormat()

FormatTypes NES::JsonFormat::getSinkFormat ( )

overridevirtual

return sink format

Returns

sink format

Implements NES::SinkFormat.

References NES::JSON_FORMAT.

getTupleIterator()

FormatIterator NES::JsonFormat::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::JSON_FORMAT, and NES::SinkFormat::schema.

toString()

std::string NES::JsonFormat::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/JsonFormat.hpp
• /nebulastream/nes-runtime/src/Sinks/Formats/JsonFormat.cpp