|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MultiKey | |
---|---|
net.esper.eql.expression | EQL expression nodes, aggregation, result set processing |
net.esper.eql.join | Join process interfaces and glue code |
net.esper.eql.view | Internal processing views for output rate limiting, filtering and internal event routing |
net.esper.util | Utility classes that center around Java type handling, printing, reflection, debugging |
net.esper.view.ext | Extension views that providing services such as sorting, which don't fit much into other categories. |
Uses of MultiKey in net.esper.eql.expression |
---|
Methods in net.esper.eql.expression that return types with arguments of type MultiKey | |
---|---|
protected static Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(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 |
AggregationServiceNull.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
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 |
AggregationServiceNull.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
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 |
AggregationServiceNull.setCurrentRow(MultiKey groupKey)
|
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. |
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
Method parameters in net.esper.eql.expression with type arguments of type MultiKey | |
---|---|
protected static Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectListEvents(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
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(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processJoinResult(Set<MultiKey<EventBean>> newEvents,
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(Set<MultiKey<EventBean>> newEvents,
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<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
UniformPair<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,
Set<MultiKey<EventBean>> events)
Filter event by applying the filter nodes evaluation method. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
Look up events return tuples of joined events. |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
|
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
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(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessView.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
Uses of MultiKey in net.esper.util |
---|
Methods in net.esper.util with parameters of type MultiKey | |
---|---|
int |
MultiKeyComparator.compare(MultiKey firstValues,
MultiKey secondValues)
|
int |
MultiKeyComparator.compare(MultiKey firstValues,
MultiKey secondValues)
|
Uses of MultiKey in net.esper.view.ext |
---|
Constructor parameters in net.esper.view.ext with type arguments of type MultiKey | |
---|---|
SortWindowIterator(SortedMap<MultiKey,LinkedList<EventBean>> window)
Ctor. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |