#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Network/NetworkSource.hpp>
#include <Runtime/QueryManager.hpp>
#include <Sources/BinarySource.hpp>
#include <Sources/CSVSource.hpp>
#include <Sources/DataSource.hpp>
#include <Sources/DefaultSource.hpp>
#include <Sources/KafkaSource.hpp>
#include <Sources/LambdaSource.hpp>
#include <Sources/MemorySource.hpp>
#include <Sources/MonitoringSource.hpp>
#include <Sources/SenseSource.hpp>
#include <Sources/SourceCreator.hpp>
#include <Sources/StaticDataSource.hpp>
#include <Sources/TCPSource.hpp>
#include <Sources/ZmqSource.hpp>
#include <chrono>

Include dependency graph for SourceCreator.cpp:

Namespaces
	NES
	This exception represents a network error.

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::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::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::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::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