Package | Description |
---|---|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
Modifier and Type | Method and Description |
---|---|
static JoinSetComposerPrototype |
JoinSetComposerPrototypeFactory.makeComposerPrototype(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery,
boolean allowIndexInit) |
Constructor and Description |
---|
JoinSetComposerPrototypeHistorical2StreamImpl(ExprEvaluator optionalFilterEval,
EventType[] streamTypes,
ExprEvaluatorContext exprEvaluatorContext,
int polledViewNum,
int streamViewNum,
boolean outerJoin,
ExprEvaluator outerJoinEqualsEval,
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> indexStrategies,
boolean allHistoricalNoSubordinate,
OuterJoinDesc[] outerJoinDescList,
boolean allowIndexInit) |
JoinSetComposerPrototypeImpl(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
Annotation[] annotations,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
QueryPlanIndex[] indexSpecs,
QueryPlan queryPlan,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean joinRemoveStream,
boolean isOuterJoins,
TableService tableService,
EventTableIndexService eventTableIndexService,
EngineImportService engineImportService,
boolean isFireAndForget) |
Modifier and Type | Method and Description |
---|---|
static QueryGraph |
OuterJoinAnalyzer.analyze(OuterJoinDesc[] outerJoinDescList,
QueryGraph queryGraph)
Analyzes the outer join descriptor list to build a query graph model.
|
protected static QueryPlan |
NStreamOuterQueryPlanBuilder.build(QueryGraph queryGraph,
OuterJoinDesc[] outerJoinDescList,
String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
ExprEvaluatorContext exprEvaluatorContext,
String[][][] indexedStreamsUniqueProps,
TableMetadata[] tablesPerStream,
EngineImportService engineImportService,
boolean isFireAndForget)
Build a query plan based on the stream property relationships indicated in queryGraph.
|
static QueryPlan |
QueryPlanBuilder.getPlan(EventType[] typesPerStream,
OuterJoinDesc[] outerJoinDescList,
QueryGraph queryGraph,
String[] streamNames,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean isQueryPlanLogging,
Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext,
EngineImportService engineImportService,
boolean isFireAndForget)
Build query plan using the filter.
|
static InnerJoinGraph |
InnerJoinGraph.graphInnerJoins(int numStreams,
OuterJoinDesc[] outerJoinDescList) |
protected static OuterInnerDirectionalGraph |
NStreamOuterQueryPlanBuilder.graphOuterJoins(int numStreams,
OuterJoinDesc[] outerJoinDescList)
Builds a graph of outer joins given the outer join information from the statement.
|
Modifier and Type | Field and Description |
---|---|
static OuterJoinDesc[] |
OuterJoinDesc.EMPTY_OUTERJOIN_ARRAY |
Modifier and Type | Method and Description |
---|---|
OuterJoinDesc[] |
StatementSpecCompiled.getOuterJoinDescList()
Returns the LEFT/RIGHT/FULL OUTER JOIN-type and property name descriptor, if applicable.
|
static OuterJoinDesc[] |
OuterJoinDesc.toArray(Collection<OuterJoinDesc> expressions) |
Modifier and Type | Method and Description |
---|---|
List<OuterJoinDesc> |
StatementSpecRaw.getOuterJoinDescList()
Returns the LEFT/RIGHT/FULL OUTER JOIN-type and property name descriptor, if applicable.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
OuterJoinDesc.consistsOfAllInnerJoins(OuterJoinDesc[] outerJoinDescList) |
static boolean |
OuterJoinDesc.hasOnClauses(OuterJoinDesc[] outerJoinDescList) |
Modifier and Type | Method and Description |
---|---|
static OuterJoinDesc[] |
OuterJoinDesc.toArray(Collection<OuterJoinDesc> expressions) |
Constructor and Description |
---|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
Set<String> variableReferences,
RowLimitSpec rowLimitSpec,
String[] eventTypeReferences,
Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
Map<Integer,List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |