Package | Description |
---|---|
com.espertech.esper.epl.core |
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.
|
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.
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
Modifier and Type | Method and Description |
---|---|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimple.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorSimple.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroupRollup.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroupRollup.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroup.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowPerGroup.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowForAll.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorRowForAll.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) |
void |
ResultSetProcessorAggregateGrouped.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorAggregateGrouped.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorAggregateAll.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessorAggregateAll.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessor.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
void |
ResultSetProcessor.applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
Object[] |
ResultSetProcessorAggregateGrouped.generateGroupKeys(Set<MultiKey<EventBean>> resultSet,
boolean isNewData) |
void |
ResultSetProcessorAggregateGrouped.generateOutputBatchedJoinPerKey(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Map<Object,EventBean> resultEvents,
Map<Object,Object> optSortKeys) |
void |
ResultSetProcessorAggregateGrouped.generateOutputBatchedJoinUnkeyed(Set<MultiKey<EventBean>> outputEvents,
Object[] groupByKeys,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> resultEvents,
List<Object> optSortKeys) |
Iterator<EventBean> |
ResultSetProcessorSimple.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorRowPerGroupRollup.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorRowPerGroup.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorRowForAll.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorHandThrough.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorAggregateGrouped.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessorAggregateAll.getIterator(Set<MultiKey<EventBean>> joinSet) |
Iterator<EventBean> |
ResultSetProcessor.getIterator(Set<MultiKey<EventBean>> joinSet)
Returns the iterator for iterating over a join-result.
|
protected static EventBean[] |
ResultSetProcessorHandThrough.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
Applies the select-clause to the given events returning the selected events.
|
protected 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.
|
protected 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.
|
protected 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.
|
protected 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.
|
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected 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) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
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) |
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) |
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) |
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) |
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) |
void |
ResultSetProcessorAggregateAllOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputLastHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputLastHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputAllHelperImpl.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
void |
ResultSetProcessorAggregateAllOutputAllHelper.processJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.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[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isSynthesize) |
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[]> |
ResultSetProcessorRowPerGroupRollup.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessorBaseSimple.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGrouped.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType) |
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
Processes batched events in case of output-rate limiting.
|
void |
ResultSetProcessorSimple.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorSimple.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowPerGroupRollup.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowPerGroupRollup.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowPerGroup.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowPerGroup.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowForAll.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorRowForAll.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorHandThrough.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorHandThrough.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorAggregateGrouped.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorAggregateGrouped.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorAggregateAll.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessorAggregateAll.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessor.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
void |
ResultSetProcessor.processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic,
boolean isAll) |
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)
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)
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) |
Modifier and Type | Field and Description |
---|---|
static Set<MultiKey<EventBean>> |
CollectionUtil.EMPTY_ROW_SET |