NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
This is the complete list of members for NES::Testing::TestExecutionEngine, including all inherited members.
createCollectSink(SchemaPtr outputSchema) | NES::Testing::TestExecutionEngine | inline |
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() const | NES::Testing::TestExecutionEngine | |
getDataSource(std::shared_ptr< Runtime::Execution::ExecutableQueryPlan > plan, uint32_t source) | NES::Testing::TestExecutionEngine | |
getNodeEngine() const | NES::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::TestExecutionEngine | explicit |