NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::JoinOperatorBuilder::Join Class Reference

#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 & Destructor Documentation

◆ Join()

NES::JoinOperatorBuilder::Join::Join ( const Query subQueryRhs,
Query originalQuery 
)

Constructor. Initialises always subQueryRhs and original Query.

Parameters
subQueryRhs
originalQuery

Member Function Documentation

◆ where()

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

Parameters
joinExpression: a set of binary expressions to compare left and right tuples
Returns
object of type JoinWhere on which window function is defined and can be called.

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().

Here is the caller graph for this function:

The documentation for this class was generated from the following files: