#include <Monitoring/MetricCollectors/MetricCollector.hpp>
#include <Operators/LogicalOperators/Network/NesPartition.hpp>
#include <Operators/LogicalOperators/Network/NodeLocation.hpp>
#include <Operators/LogicalOperators/Sources/CsvSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/KafkaSourceDescriptor.hpp>
#include <Operators/LogicalOperators/Sources/MQTTSourceDescriptor.hpp>
#include <Sources/BenchmarkSource.hpp>
#include <Sources/DataSource.hpp>
#include <Sources/GeneratorSource.hpp>
#include <Sources/MemorySource.hpp>
#include <Sources/TCPSource.hpp>
#include <chrono>

Include dependency graph for SourceCreator.hpp:

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

Namespaces
	NES
	This exception represents a network error.

	NES::Experimental
	create a table source

Functions
DataSourcePtr	NES::createDefaultDataSourceWithSchemaForOneBuffer (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a test source which produces 10 tuples within one buffer with value one based on a schema More...

DataSourcePtr	NES::createDefaultDataSourceWithSchemaForVarBuffers (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, uint64_t numberOfBuffersToProduce, uint64_t gatheringInterval, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a test source which produces tuples with value one in N buffers of based on a schema More...

DataSourcePtr	NES::createDefaultSourceWithoutSchemaForOneBuffer (const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a test source which produces 10 tuples with value one without a schema More...

DataSourcePtr	NES::createLambdaSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, uint64_t numberOfBuffersToProduce, uint64_t gatheringValue, std::function< void(NES::Runtime::TupleBuffer &buffer, uint64_t numberOfTuplesToProduce)> &&generationFunction, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, uint64_t sourceAffinity, uint64_t taskQueueId, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a lambda source More...

DataSourcePtr	NES::createZmqSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const std::string &host, uint16_t port, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create an empty zmq source More...

DataSourcePtr	NES::createBinaryFileSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const std::string &pathToFile, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a binary file source More...

DataSourcePtr	NES::createSenseSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const std::string &udfs, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a sense source More...

DataSourcePtr	NES::createCSVFileSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const CSVSourceTypePtr &csvSourceType, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function to create a csvfile source More...

DataSourcePtr	NES::createMemorySource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const std::shared_ptr< uint8_t > &memoryArea, size_t memoryAreaSize, uint64_t numBuffersToProcess, uint64_t gatheringValue, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, uint64_t sourceAffinity, uint64_t taskQueueId, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	function which creates a memory source More...

DataSourcePtr	NES::Experimental::createStaticDataSource (const SchemaPtr &schema, const std::string pathTableFile, const bool lateStart, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)

DataSourcePtr	NES::createBenchmarkSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const std::shared_ptr< uint8_t > &memoryArea, size_t memoryAreaSize, uint64_t numberOfBuffersToProcess, uint64_t gatheringValue, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, SourceMode sourceMode, uint64_t sourceAffinity, uint64_t taskQueueId, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)
	create a benchmark source More...

DataSourcePtr	NES::createNetworkSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const Network::NetworkManagerPtr &networkManager, Network::NesPartition nesPartition, Network::NodeLocation sinkLocation, size_t numSourceLocalBuffers, std::chrono::milliseconds waitTime, uint8_t retryTimes, const std::string &physicalSourceName, DecomposedQueryPlanVersion version, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors, OperatorId uniqueNetworkSourceId)
	function to create a network source More...

DataSourcePtr	NES::createMonitoringSource (Monitoring::MetricCollectorPtr metricCollector, std::chrono::milliseconds waitTime, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors)
	function to create a monitoring source More...

DataSourcePtr	NES::createTCPSource (const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager, const Runtime::QueryManagerPtr &queryManager, const TCPSourceTypePtr &tcpSourceType, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, const std::vector< Runtime::Execution::SuccessorExecutablePipeline > &successors)

Namespaces

Functions