SinkCreator.hpp File Reference

#include <Monitoring/MonitoringForwardRefs.hpp>
#include <Operators/LogicalOperators/Sinks/StatisticSinkDescriptor.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>

Include dependency graph for SinkCreator.hpp:

This graph shows which files directly or indirectly include this file:

Namespaces
	NES
	This exception represents a network error.

Functions
DataSinkPtr	NES::createCSVFileSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t activeProducers, const std::string &filePath, bool append, bool addTimestamp=false, uint64_t numberOfOrigins=1)
	create a csv test sink without a schema and append to existing file More...
DataSinkPtr	NES::createMigrateFileSink (SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, const std::string &filePath, bool append, uint64_t numberOfOrigins=1)
	create a migrate test sink More...
DataSinkPtr	NES::createBinaryNESFileSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers, const std::string &filePath, bool append, uint64_t numberOfOrigins=1)
	create a binary test sink with a schema into the nes More...
DataSinkPtr	NES::createJSONFileSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers, const std::string &filePath, bool append, uint64_t numberOfOrigins=1)
	create a JSON test sink with a schema int More...
DataSinkPtr	NES::createCsvZmqSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers, const std::string &host, uint16_t port, uint64_t numberOfOrigins=1)
	create a ZMQ test sink with a schema and Csv format output More...
DataSinkPtr	NES::createCSVZmqSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers, const std::string &host, uint16_t port, uint64_t numberOfOrigins=1)
	create a ZMQ test sink with a schema and CSV format output More...
DataSinkPtr	NES::createBinaryZmqSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t activeProducers, const std::string &host, uint16_t port, bool internal, uint64_t numberOfOrigins=1)
	create a ZMQ test sink with a schema and NES_FORMAT format output More...
DataSinkPtr	NES::createCsvPrintSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t activeProducers, std::ostream &out, uint64_t numberOfOrigins=1)
	create a print test sink with a schema More...
DataSinkPtr	NES::createNullOutputSink (SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t activeProducers, uint64_t numberOfOrigins=1)
	create a print that does not output something More...
DataSinkPtr	NES::createCSVPrintSink (const SchemaPtr &schema, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Runtime::NodeEnginePtr &nodeEngine, uint32_t activeProducers, std::ostream &out, uint64_t numberOfOrigins=1)
	create a print test sink with a schema More...
DataSinkPtr	NES::createNetworkSink (const SchemaPtr &schema, OperatorId uniqueNetworkSinkDescriptorId, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const Network::NodeLocation &nodeLocation, Network::NesPartition nesPartition, const Runtime::NodeEnginePtr &nodeEngine, size_t numOfProducers, std::chrono::milliseconds waitTime, DecomposedQueryPlanVersion version, uint64_t numberOfOrigins=1, uint8_t retryTimes=5)
	create a network data sink More...
DataSinkPtr	NES::createMonitoringSink (Monitoring::MetricStorePtr metricStore, Monitoring::MetricCollectorType collectorType, const SchemaPtr &schema, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins=1)
	create a monitoring data sink More...
DataSinkPtr	NES::createStatisticSink (const SchemaPtr &schema, const Runtime::NodeEnginePtr &nodeEngine, size_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryIdVersion, uint64_t numberOfOrigins, Statistic::StatisticSynopsisType sinkFormatType, Statistic::StatisticDataCodec sinkDataCodec)
	Creates a StatisticSink. More...