Package | Description |
---|---|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.grouped |
Result set processor utility classes for general grouped-aggregation
|
com.espertech.esper.epl.core.resultset.handthru |
Result set processor for Un-Aggregated and Un-Grouped with having or output-rate-limiting or order-by
|
com.espertech.esper.epl.core.resultset.rowforall |
Result set processor for Fully-Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowperevent |
Result set processor for Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.event |
This package defines the internal event APIs.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorAggregateGroupedImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorAggregateGroupedImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Object[] |
ResultSetProcessorAggregateGroupedImpl.generateGroupKeyArrayJoin(Set<MultiKey<EventBean>> resultSet,
boolean isNewData) |
Object[] |
ResultSetProcessorAggregateGrouped.generateGroupKeyArrayJoin(Set<MultiKey<EventBean>> newData,
boolean isNewData) |
void |
ResultSetProcessorAggregateGroupedImpl.generateOutputBatchedJoinPerKey(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Map<Object,EventBean> resultEvents,
Map<Object,Object> optSortKeys) |
void |
ResultSetProcessorAggregateGrouped.generateOutputBatchedJoinPerKey(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Map<Object,EventBean> resultEvents,
Map<Object,Object> optSortKeys) |
void |
ResultSetProcessorAggregateGroupedImpl.generateOutputBatchedJoinUnkeyed(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> resultEvents,
List<Object> optSortKeys) |
void |
ResultSetProcessorAggregateGrouped.generateOutputBatchedJoinUnkeyed(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> resultEvents,
List<Object> optSortKeys) |
Iterator<EventBean> |
ResultSetProcessorAggregateGroupedImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
void |
ResultSetProcessorAggregateGroupedOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorAggregateGroupedImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateGroupedImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
void |
ResultSetProcessor.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessor.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessor.getIterator(Set<MultiKey<EventBean>> joinSet)
Returns the iterator for iterating over a join-result.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static void |
ResultSetProcessorUtil.populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<EventBean[]> |
ResultSetProcessor.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize)
For use by joins posting their result, process the event rows that are entered and removed (new and old events).
|
UniformPair<EventBean[]> |
ResultSetProcessor.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize)
For use by joins posting their result, process the event rows that are entered and removed (new and old events).
|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
void |
ResultSetProcessor.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessor.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetProcessorGroupedUtil.applyAggJoinResultKeyedJoin(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
Set<MultiKey<EventBean>> newEvents,
Object[] newDataMultiKey,
Set<MultiKey<EventBean>> oldEvents,
Object[] oldDataMultiKey)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorGroupedUtil.applyAggJoinResultKeyedJoin(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext,
Set<MultiKey<EventBean>> newEvents,
Object[] newDataMultiKey,
Set<MultiKey<EventBean>> oldEvents,
Object[] oldDataMultiKey)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorSimpleImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorHandThrough.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorHandThrough.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessorSimpleImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorHandThrough.getIterator(Set<MultiKey<EventBean>> joinSet) |
static EventBean[] |
ResultSetProcessorHandThroughUtil.getSelectEventsNoHavingHandThruJoin(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
Applies the select-clause to the given events returning the selected events.
|
void |
ResultSetProcessorSimpleOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimpleOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorHandThrough.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorHandThrough.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorHandThrough.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorSimpleImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorSimpleImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorHandThrough.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorHandThrough.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowForAllImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowForAllImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessorRowForAllImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
void |
ResultSetProcessorRowForAllOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorRowForAllImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowForAllImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowPerEventImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerEventImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessorRowPerEventImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
void |
ResultSetProcessorRowPerEventOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorRowPerEventImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerEventImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowPerGroupImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroupImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessorRowPerGroupImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
void |
ResultSetProcessorRowPerGroupOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorRowPerGroupImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowPerGroupRollupImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroupRollupImpl.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Iterator<EventBean> |
ResultSetProcessorRowPerGroupRollupImpl.getIterator(Set<MultiKey<EventBean>> joinSet) |
void |
ResultSetProcessorRowPerGroupRollupOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupImpl.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupImpl.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorRowPerGroupRollupImpl.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
Modifier and Type | Field and Description |
---|---|
protected Set<MultiKey<EventBean>> |
JoinSetComposerImpl.newResults |
protected Set<MultiKey<EventBean>> |
JoinSetComposerImpl.oldResults |
Modifier and Type | Method and Description |
---|---|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerHistoricalImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerFAFImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerAllUnidirectionalOuter.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Return join tuple result set from new data and old data for each stream.
|
Set<MultiKey<EventBean>> |
JoinSetComposerStreamToWinImpl.staticJoin() |
Set<MultiKey<EventBean>> |
JoinSetComposerImpl.staticJoin() |
Set<MultiKey<EventBean>> |
JoinSetComposerHistoricalImpl.staticJoin() |
Set<MultiKey<EventBean>> |
JoinSetComposerFAFImpl.staticJoin() |
Set<MultiKey<EventBean>> |
JoinSetComposerAllUnidirectionalOuter.staticJoin() |
Set<MultiKey<EventBean>> |
JoinSetComposer.staticJoin()
For use in iteration over join statements, this must build a join tuple result set from
all events in indexes, executing query strategies for each.
|
Set<MultiKey<EventBean>> |
JoinExecutionStrategyImpl.staticJoin() |
Set<MultiKey<EventBean>> |
JoinExecutionStrategy.staticJoin()
A static join is for use with iterating over join statements.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
JoinSetFilter.filter(ExprEvaluator filterExprNode,
Set<MultiKey<EventBean>> events,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Filter event by applying the filter nodes evaluation method.
|
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext)
Look up events returning tuples of joined events.
|
void |
HistoricalDataQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext) |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
Process join result set.
|
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
Process join result set.
|
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
static Set<MultiKey<EventBean>> |
NamedWindowOnSelectView.buildJoinResult(EventBean[] triggerEvents,
EventBean[] matchingEvents) |
Modifier and Type | Method and Description |
---|---|
List<UniformPair<Set<MultiKey<EventBean>>>> |
OutputProcessViewConditionDeltaSetImpl.getJoinEventsSet() |
List<UniformPair<Set<MultiKey<EventBean>>>> |
OutputProcessViewConditionDeltaSet.getJoinEventsSet() |
Modifier and Type | Method and Description |
---|---|
void |
OutputProcessViewConditionDeltaSetImpl.addJoin(UniformPair<Set<MultiKey<EventBean>>> setUniformPair) |
void |
OutputProcessViewConditionDeltaSet.addJoin(UniformPair<Set<MultiKey<EventBean>>> events) |
boolean |
OutputProcessViewBaseWAfter.checkAfterCondition(Set<MultiKey<EventBean>> newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterStateNone.checkUpdateAfterCondition(Set<MultiKey<EventBean>> newEvents,
StatementContext statementContext) |
boolean |
OutputProcessViewAfterStateImpl.checkUpdateAfterCondition(Set<MultiKey<EventBean>> newEvents,
StatementContext statementContext)
Returns true if the after-condition is satisfied.
|
boolean |
OutputProcessViewAfterState.checkUpdateAfterCondition(Set<MultiKey<EventBean>> newEvents,
StatementContext statementContext) |
void |
OutputProcessViewDirectDistinctOrAfter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewDirectDistinctOrAfter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewDirect.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewDirect.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionSnapshot.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionSnapshot.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionLastAllUnord.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionLastAllUnord.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionFirst.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionFirst.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionDefault.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionDefault.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewBaseCallback.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
void |
OutputProcessViewBaseCallback.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
static MultiKey<EventBean> |
EventBeanUtility.getLastInSet(Set<MultiKey<EventBean>> events) |
Modifier and Type | Method and Description |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
NOTE: Code-generation-invoked method, method name and parameter order matters
Flattens a list of pairs of join result sets.
|
static Set<MultiKey<EventBean>> |
EventBeanUtility.toLinkedHashSetNullIfEmpty(Collection<MultiKey<EventBean>> events) |
static Set<MultiKey<EventBean>> |
EventBeanUtility.toSingletonSetIfNotNull(MultiKey<EventBean> row) |
Modifier and Type | Method and Description |
---|---|
static Set<MultiKey<EventBean>> |
EventBeanUtility.toSingletonSetIfNotNull(MultiKey<EventBean> row) |
Modifier and Type | Method and Description |
---|---|
static void |
EventBeanUtility.addToCollection(Set<MultiKey<EventBean>> toAdd,
Collection<MultiKey<EventBean>> events) |
static void |
EventBeanUtility.addToCollection(Set<MultiKey<EventBean>> toAdd,
Collection<MultiKey<EventBean>> events) |
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
NOTE: Code-generation-invoked method, method name and parameter order matters
Flattens a list of pairs of join result sets.
|
static MultiKey<EventBean> |
EventBeanUtility.getLastInSet(Set<MultiKey<EventBean>> events) |
static Set<MultiKey<EventBean>> |
EventBeanUtility.toLinkedHashSetNullIfEmpty(Collection<MultiKey<EventBean>> events) |