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

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

createCollectSink(SchemaPtr outputSchema)NES::Testing::TestExecutionEngineinline
createDataSink(const SchemaPtr &outputSchema, uint32_t expectedTuples=1)NES::Testing::TestExecutionEngine
createDataSource(SchemaPtr inputSchema)NES::Testing::TestExecutionEngine
emitBuffer(std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, Runtime::TupleBuffer buffer)NES::Testing::TestExecutionEngine
getBuffer(const SchemaPtr &schema)NES::Testing::TestExecutionEngine
getBufferManager() constNES::Testing::TestExecutionEngine
getDataSource(std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, uint32_t source)NES::Testing::TestExecutionEngine
getNodeEngine() constNES::Testing::TestExecutionEngine
stop()NES::Testing::TestExecutionEngine
stopQuery(std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, Runtime::QueryTerminationType type=Runtime::QueryTerminationType::HardStop)NES::Testing::TestExecutionEngine
submitQuery(DecomposedQueryPlanPtr decomposedQueryPlan)NES::Testing::TestExecutionEngine
TestExecutionEngine(const QueryCompilation::DumpMode &dumpMode=QueryCompilation::DumpMode::NONE, const uint64_t numWorkerThreads=1, const QueryCompilation::StreamJoinStrategy &joinStrategy=QueryCompilation::StreamJoinStrategy::NESTED_LOOP_JOIN, const QueryCompilation::WindowingStrategy &windowingStrategy=QueryCompilation::WindowingStrategy::SLICING)NES::Testing::TestExecutionEngineexplicit