Uses of Class
net.esper.collection.MultiKey

Packages that use MultiKey
net.esper.eql.core Contains EQL statement specification classes define the constructs that make up an EQL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. 
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.core
 

Methods in net.esper.eql.core 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.core 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.core 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.getSelectEventsHaving(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, java.util.Set<MultiKey<EventBean>> events, ExprNode optionalHavingNode, boolean isOutputLimiting, boolean isOutputLimitLastOnly)
          Applies the select-clause to the given events returning the selected events.
protected static EventBean[] ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, 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.
 

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(java.util.SortedMap<MultiKey,java.util.LinkedList<EventBean>> window)
          Ctor.