|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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.event | This package defines the Esper Client event API. |
Uses of MultiKey in net.esper.eql.core |
---|
Methods in net.esper.eql.core 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. |
Method parameters in net.esper.eql.core 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. |
Iterator<EventBean> |
ResultSetProcessorSimple.getIterator(Set<MultiKey<EventBean>> joinSet)
|
Iterator<EventBean> |
ResultSetProcessorRowPerGroup.getIterator(Set<MultiKey<EventBean>> joinSet)
|
Iterator<EventBean> |
ResultSetProcessorRowForAll.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[] |
ResultSetProcessorSimple.getSelectEventsHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly,
boolean isNewData)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly,
boolean isNewData)
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. |
Set<MultiKey<EventBean>> |
JoinSetComposerImpl.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. |
Method parameters in net.esper.eql.join with type arguments of type MultiKey | |
---|---|
protected static void |
JoinSetFilter.filter(ExprNode filterExprNode,
Set<MultiKey<EventBean>> events,
boolean isNewData)
Filter event by applying the filter nodes evaluation method. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
Look up events returning tuples of joined events. |
void |
HistoricalDataQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
|
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 |
OutputProcessViewPolicy.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessViewPolicy.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessViewDirect.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessViewDirect.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.event |
---|
Methods in net.esper.event that return types with arguments of type MultiKey | |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
Flattens a list of pairs of join result sets. |
Method parameters in net.esper.event with type arguments of type MultiKey | |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
Flattens a list of pairs of join result sets. |
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |