NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Query.hpp>
Public Member Functions | |
Join (const Query &subQueryRhs, Query &originalQuery) | |
Constructor. Initialises always subQueryRhs and original Query. More... | |
JoinWhere | where (ExpressionNodePtr joinExpression) const |
is called to append all joinExpressions (key predicates) to the previous defined join, i.e., it sets all condition for the join matches More... | |
Constructor. Initialises always subQueryRhs and original Query.
subQueryRhs | |
originalQuery |
JoinWhere NES::JoinOperatorBuilder::Join::where | ( | ExpressionNodePtr | joinExpression | ) | const |
is called to append all joinExpressions (key predicates) to the previous defined join, i.e., it sets all condition for the join matches
joinExpression | : a set of binary expressions to compare left and right tuples |
Referenced by NES::Runtime::Execution::StreamJoinQuerySharedExecutionTest::prepareRunTwoEqualQueriesDeployedDifferentTime(), NES::Runtime::Execution::StreamJoinQueryExecutionTest::runSingleJoinQuery(), NES::RequestProcessor::TEST_F(), NES::TEST_F(), NES::Runtime::Execution::TEST_P(), and NES::TEST_P().