|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MultiKey | |
---|---|
net.esper.eql.expression | |
net.esper.eql.join | |
net.esper.eql.view |
Uses of MultiKey in net.esper.eql.expression |
---|
Methods in net.esper.eql.expression that return types with arguments of type MultiKey | |
---|---|
protected static java.util.Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(java.util.Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
Methods in net.esper.eql.expression with parameters of type MultiKey | |
---|---|
void |
AggregationServiceGroupByImpl.applyEnter(EventBean[] eventsPerStream,
MultiKey groupByKey)
|
void |
AggregationServiceGroupAllImpl.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationService.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as entering a window (new events). |
void |
AggregationServiceGroupByImpl.applyLeave(EventBean[] eventsPerStream,
MultiKey groupByKey)
|
void |
AggregationServiceGroupAllImpl.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationService.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as leaving a window (old events). |
void |
AggregationServiceGroupByImpl.setCurrentRow(MultiKey groupByKey)
|
void |
AggregationServiceGroupAllImpl.setCurrentRow(MultiKey groupKey)
|
void |
AggregationService.setCurrentRow(MultiKey groupKey)
Set the current aggregation state row - for use when evaluation nodes are asked to evaluate. |
Method parameters in net.esper.eql.expression with type arguments of type MultiKey | |
---|---|
protected static java.util.Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(java.util.Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectListEvents(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
Uses of MultiKey in net.esper.eql.join |
---|
Methods in net.esper.eql.join that return types with arguments of type MultiKey | |
---|---|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Return join tuple result set from new data and old data for each stream. |
Method parameters in net.esper.eql.join with type arguments of type MultiKey | |
---|---|
protected static void |
JoinSetFilter.filter(ExprNode filterExprNode,
java.util.Set<MultiKey<EventBean>> events)
Filter event by applying the filter nodes evaluation method. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
java.util.Set<MultiKey<EventBean>> joinSet)
Look up events return tuples of joined events. |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
java.util.Set<MultiKey<EventBean>> joinSet)
|
void |
JoinSetProcessor.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetProcessor.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetFilter.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
void |
JoinSetFilter.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
Uses of MultiKey in net.esper.eql.view |
---|
Method parameters in net.esper.eql.view with type arguments of type MultiKey | |
---|---|
void |
OutputProcessView.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessView.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |