NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Struct for storing all parameter for the join. More...
#include <TestUtils.hpp>
Public Member Functions | |
JoinParams (const std::vector< SchemaPtr > &inputSchemas) | |
Public Attributes | |
const std::vector< SchemaPtr > | inputSchemas |
SchemaPtr | outputSchema |
Struct for storing all parameter for the join.
|
inline |
References NES_ASSERT.
const std::vector<SchemaPtr> NES::TestUtils::JoinParams::inputSchemas |
Referenced by NES::Runtime::Execution::StreamJoinQuerySharedExecutionTest::prepareRunTwoEqualQueriesDeployedDifferentTime(), NES::Runtime::Execution::JoinDeploymentTest::runAndValidateJoinQueryTwoLogicalStreams(), NES::Runtime::Execution::MultipleJoinsTest::runJoinQuery(), NES::Runtime::Execution::StreamIntervalJoinQueryExecutionTest::runSingleJoinQuery(), and NES::Runtime::Execution::StreamJoinQueryExecutionTest::runSingleJoinQuery().
SchemaPtr NES::TestUtils::JoinParams::outputSchema |
Referenced by NES::Runtime::Execution::StreamJoinQuerySharedExecutionTest::prepareRunTwoEqualQueriesDeployedDifferentTime(), NES::Runtime::Execution::JoinDeploymentTest::runAndValidateJoinQueryTwoLogicalStreams(), NES::Runtime::Execution::StreamIntervalJoinQueryExecutionTest::runSingleJoinQuery(), and NES::Runtime::Execution::StreamJoinQueryExecutionTest::runSingleJoinQuery().