|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use UniformPair | |
---|---|
com.espertech.esper.core | Implementation of client package interfaces, glue code |
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 | Join process interfaces and glue code |
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 Esper Client event API. |
com.espertech.esper.view | View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering. |
Uses of UniformPair in com.espertech.esper.core |
---|
Fields in com.espertech.esper.core with type parameters of type UniformPair | |
---|---|
protected ThreadLocal<ArrayDequeJDK6Backport<UniformPair<EventBean[]>>> |
StatementResultServiceImpl.lastResults
Buffer for holding dispatchable events. |
Methods in com.espertech.esper.core with parameters of type UniformPair | |
---|---|
void |
ResultDeliveryStrategyTypeArr.execute(UniformPair<EventBean[]> result)
|
void |
ResultDeliveryStrategyObjectArr.execute(UniformPair<EventBean[]> result)
|
void |
ResultDeliveryStrategyMap.execute(UniformPair<EventBean[]> result)
|
void |
ResultDeliveryStrategyImpl.execute(UniformPair<EventBean[]> result)
|
void |
ResultDeliveryStrategy.execute(UniformPair<EventBean[]> result)
Execute the dispatch. |
void |
StatementResultServiceImpl.indicate(UniformPair<EventBean[]> results)
|
void |
StatementResultService.indicate(UniformPair<EventBean[]> results)
Stores for dispatching the statement results. |
void |
UpdateDispatchViewNonBlocking.newResult(UniformPair<EventBean[]> results)
|
void |
UpdateDispatchViewBlockingWait.newResult(UniformPair<EventBean[]> results)
|
void |
UpdateDispatchViewBlockingSpin.newResult(UniformPair<EventBean[]> result)
|
void |
UpdateDispatchView.newResult(UniformPair<EventBean[]> result)
Convenience method that accepts a pair of new and old data as this is the most treated unit. |
Uses of UniformPair in com.espertech.esper.epl.core |
---|
Methods in com.espertech.esper.epl.core that return UniformPair | |
---|---|
UniformPair<EventBean[]> |
ResultSetProcessorSimple.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[]> |
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[]> |
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[]> |
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. |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorBaseSimple.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGrouped.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
Processes batched events in case of output-rate limiting. |
UniformPair<EventBean[]> |
ResultSetProcessorSimple.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessorHandThrough.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGrouped.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
|
UniformPair<EventBean[]> |
ResultSetProcessor.processViewResult(EventBean[] newData,
EventBean[] oldData,
boolean isSynthesize)
For use by views posting their result, process the event rows that are entered and removed (new and old events). |
Method parameters in com.espertech.esper.epl.core with type arguments of type UniformPair | |
---|---|
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. |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroup.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorRowForAll.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorBaseSimple.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGrouped.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessorAggregateAll.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic,
OutputLimitLimitType outputLimitLimitType)
Processes batched events in case of output-rate limiting. |
Uses of UniformPair in com.espertech.esper.epl.join |
---|
Methods in com.espertech.esper.epl.join that return UniformPair | |
---|---|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
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. |
Uses of UniformPair in com.espertech.esper.epl.view |
---|
Methods in com.espertech.esper.epl.view with parameters of type UniformPair | |
---|---|
void |
OutputStrategySimple.output(boolean forceUpdate,
UniformPair<EventBean[]> result,
UpdateDispatchView finalView)
|
void |
OutputStrategyPostProcess.output(boolean forceUpdate,
UniformPair<EventBean[]> result,
UpdateDispatchView finalView)
|
void |
OutputStrategy.output(boolean forceUpdate,
UniformPair<EventBean[]> result,
UpdateDispatchView outputView)
Outputs the result to the output view and following update policy. |
Uses of UniformPair in com.espertech.esper.event |
---|
Methods in com.espertech.esper.event that return UniformPair | |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
Flattens a list of pairs of join result sets. |
static UniformPair<EventBean[]> |
EventBeanUtility.flattenBatchStream(List<UniformPair<EventBean[]>> updateVector)
Flatten the vector of arrays to an array. |
static UniformPair<EventBean[]> |
EventBeanUtility.flattenList(ArrayDequeJDK6Backport<UniformPair<EventBean[]>> eventVector)
Flatten the vector of arrays to an array. |
Method parameters in com.espertech.esper.event with type arguments of type UniformPair | |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
Flattens a list of pairs of join result sets. |
static UniformPair<EventBean[]> |
EventBeanUtility.flattenBatchStream(List<UniformPair<EventBean[]>> updateVector)
Flatten the vector of arrays to an array. |
static UniformPair<EventBean[]> |
EventBeanUtility.flattenList(ArrayDequeJDK6Backport<UniformPair<EventBean[]>> eventVector)
Flatten the vector of arrays to an array. |
Uses of UniformPair in com.espertech.esper.view |
---|
Methods in com.espertech.esper.view with parameters of type UniformPair | |
---|---|
static void |
ViewSupport.dumpUpdateParams(String prefix,
UniformPair<EventBean[]> result)
Convenience method for logging the parameters passed to the update method. |
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |