NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::TestHarness Member List

This is the complete list of members for NES::TestHarness, including all inherited members.

addFileSink()NES::TestHarness
addLogicalSource(const std::string &logicalSourceName, const SchemaPtr &schema)NES::TestHarness
attachWorkerToCoordinator()NES::TestHarness
attachWorkerToWorkerWithId(WorkerId parentId)NES::TestHarness
attachWorkerWithCSVSourceToCoordinator(const CSVSourceTypePtr &csvSourceType)NES::TestHarness
attachWorkerWithCSVSourceToWorkerWithId(const CSVSourceTypePtr &csvSourceType, WorkerId parentId)NES::TestHarness
attachWorkerWithLambdaSourceToCoordinator(PhysicalSourceTypePtr physicalSourceType, WorkerConfigurationPtr workerConfiguration)NES::TestHarness
attachWorkerWithMemorySourceToCoordinator(const std::string &logicalSourceName)NES::TestHarness
attachWorkerWithMemorySourceToWorkerWithId(const std::string &logicalSourceName, WorkerId parentId, WorkerConfigurationPtr workerConfiguration=WorkerConfiguration::create())NES::TestHarness
checkAndAddLogicalSources()NES::TestHarness
checkFailedOrTimeout() constNES::TestHarness
createPhysicalSourceOfLambdaType(TestHarnessWorkerConfigurationPtr workerConf)NES::TestHarness
createPhysicalSourceOfMemoryType(TestHarnessWorkerConfigurationPtr workerConf)NES::TestHarness
getBufferManager() constNES::TestHarness
getExecutionPlan() constNES::TestHarness
getOutput()NES::TestHarness
getOutputSchema()NES::TestHarness
getQueryPlan() constNES::TestHarness
getTopology()NES::TestHarness
getWorkerCount()NES::TestHarness
pushElement(T element, WorkerId::Underlying workerId)NES::TestHarnessinline
pushElement(T element, WorkerId workerId)NES::TestHarnessinline
runQuery(uint64_t numberOfBytesToExpect, const std::string &placementStrategyName="BottomUp", uint64_t testTimeoutInSeconds=60)NES::TestHarness
setAppendMode(const std::string_view newAppendMode)NES::TestHarness
setJoinStrategy(QueryCompilation::StreamJoinStrategy &newJoinStrategy)NES::TestHarness
setOutputFilePath(const std::string &newOutputFilePath)NES::TestHarness
setupTopology(std::function< void(CoordinatorConfigurationPtr)> crdConfigFunctor=[](CoordinatorConfigurationPtr) { }, const std::vector< nlohmann::json > &distributionList={})NES::TestHarness
setWindowingStrategy(QueryCompilation::WindowingStrategy &newWindowingStrategy)NES::TestHarness
stopCoordinatorAndWorkers()NES::TestHarness
TestHarness(Query queryWithoutSink, uint16_t restPort, uint16_t rpcPort, std::filesystem::path testHarnessResourcePath, uint64_t memSrcFrequency=0, uint64_t memSrcNumBuffToProcess=1)NES::TestHarnessexplicit
validate()NES::TestHarness
validateAndQueueAddQueryRequest(const Optimizer::PlacementStrategy &placementStrategy=Optimizer::PlacementStrategy::BottomUp)NES::TestHarness