Uses of Class
com.espertech.esper.collection.UniformPair

Packages that use UniformPair

com.espertech.esper.client.scopetest	Test framework classes.
com.espertech.esper.core.context.util	Context partition utility or reference classes.
com.espertech.esper.core.service	Implementation of client package interfaces, glue code
com.espertech.esper.core.start	Classes related to start and stop of statements
com.espertech.esper.core.thread	This package contains classes to advanced threading options.
com.espertech.esper.dataflow.ops	Data flow built-in operators.
com.espertech.esper.dataflow.ops.epl	Data flow built-in operator's helper classes.
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.expression.funcs	Function expressions.
com.espertech.esper.epl.join.base	Join process interfaces and glue code
com.espertech.esper.epl.parse	Parsers and AST tree walkers and helper classes transforming AST into business objects
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 internal event APIs.
com.espertech.esper.metrics.instrumentation	EPL instrumentation helpers.
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.client.scopetest

Methods in com.espertech.esper.client.scopetest that return UniformPair

UniformPair<EventBean[]>	SupportUpdateListener.assertInvokedAndReset() Returns a pair of insert and remove stream event arrays considering the last invocation only, asserting that only a single invocation occured, and resetting the listener.
UniformPair<EventBean>	SupportUpdateListener.assertPairGetIRAndReset() Asserts that exactly one insert stream event and exactly one remove stream event was received, resets the listener clearing all state and returns the received events as a pair.
UniformPair<EventBean[]>	SupportUpdateListener.getAndResetDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations, and resets the listener.
UniformPair<EventBean[]>	SupportUpdateListener.getDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations.
UniformPair<java.lang.Object[]>	SupportSubscriber.getDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations.

Methods in com.espertech.esper.client.scopetest with parameters of type UniformPair

static void	EPAssertionUtil.assertProps(UniformPair<EventBean> received, java.lang.String[] propertyNames, java.lang.Object[] expectedInsert, java.lang.Object[] expectedRemoved) Assert that the property values of a new event and a removed event match the expected insert and removed values.
static void	EPAssertionUtil.assertPropsPerRow(UniformPair<EventBean[]> received, java.lang.String[] propertyNames, java.lang.Object[][] expectedInsert, java.lang.Object[][] expectedRemoved) Assert that the property values of a new event and a removed event match the expected insert and removed values.
static void	EPAssertionUtil.assertPropsPerRow(UniformPair<EventBean[]> received, java.lang.String propertyName, java.lang.Object[] expectedInsert, java.lang.Object[] expectedRemoved) Assert that the property values of the events (insert and remove pair) match the expected insert and removed values for a single property.
static void	EPAssertionUtil.assertUnderlyingPerRow(UniformPair<EventBean[]> received, java.lang.Object[] expectedUnderlyingInsert, java.lang.Object[] expectedUnderlyingRemove) Assert that the underlying objects of the events (insert and remove pair) match the expected insert and removed objects.

Uses of UniformPair in com.espertech.esper.core.context.util

Methods in com.espertech.esper.core.context.util with parameters of type UniformPair

void	ContextMergeView.newResult(UniformPair<EventBean[]> result)

Uses of UniformPair in com.espertech.esper.core.service

Fields in com.espertech.esper.core.service with type parameters of type UniformPair

protected java.lang.ThreadLocal<java.util.ArrayDeque<UniformPair<EventBean[]>>>

StatementResultServiceImpl.lastResults Buffer for holding dispatchable events.

Methods in com.espertech.esper.core.service 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.
void	StatementResultServiceImpl.processDispatch(UniformPair<EventBean[]> events) Indicate an outbound result.

Uses of UniformPair in com.espertech.esper.core.start

Methods in com.espertech.esper.core.start that return UniformPair

protected static UniformPair<java.lang.Integer>

EPStatementStartMethodHelperValidate.validateOuterJoinPropertyPair(StatementContext statementContext, ExprIdentNode leftNode, ExprIdentNode rightNode, int outerJoinCount, StreamTypeService typeService, ViewResourceDelegateUnverified viewResourceDelegate)

Uses of UniformPair in com.espertech.esper.core.thread

Constructors in com.espertech.esper.core.thread with parameters of type UniformPair

OutboundUnitRunnable(UniformPair<EventBean[]> events, StatementResultServiceImpl statementResultService)
Ctor.

Uses of UniformPair in com.espertech.esper.dataflow.ops

Methods in com.espertech.esper.dataflow.ops with parameters of type UniformPair

void	Select.outputOutputRateLimited(UniformPair<EventBean[]> result)

Uses of UniformPair in com.espertech.esper.dataflow.ops.epl

Methods in com.espertech.esper.dataflow.ops.epl with parameters of type UniformPair

void	EPLSelectUpdateDispatchView.newResult(UniformPair<EventBean[]> result)

Uses of UniformPair in com.espertech.esper.epl.core

Methods in com.espertech.esper.epl.core that return UniformPair

UniformPair<EventBean[]>	ResultSetProcessorSimple.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorHandThrough.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessor.processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.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[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorBaseSimple.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessor.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorBaseSimple.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessor.processOutputLimitedView(java.util.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[]>	ResultSetProcessorRowPerGroupUnbound.processViewResult(EventBean[] newData, EventBean[] oldData, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupUnbound.processViewResult(EventBean[] newData, EventBean[] oldData, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.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).
UniformPair<EventBean[]>	ResultSetProcessorSimple.processViewResultIterator(EventBean[] newData) Process view results for the iterator.

Method parameters in com.espertech.esper.epl.core with type arguments of type UniformPair

UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorBaseSimple.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessor.processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorBaseSimple.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
UniformPair<EventBean[]>	ResultSetProcessor.processOutputLimitedView(java.util.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.expression.funcs

Methods in com.espertech.esper.epl.expression.funcs that return types with arguments of type UniformPair

java.util.List<UniformPair<ExprNode>>

ExprCaseNode.CaseAnalysis.getWhenThenNodeList()

Constructor parameters in com.espertech.esper.epl.expression.funcs with type arguments of type UniformPair

ExprCaseNode.CaseAnalysis(java.util.List<UniformPair<ExprNode>> whenThenNodeList, ExprNode optionalCompareExprNode, ExprNode optionalElseExprNode)

Uses of UniformPair in com.espertech.esper.epl.join.base

Methods in com.espertech.esper.epl.join.base that return UniformPair

UniformPair<java.util.Set<MultiKey<EventBean>>>	JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<java.util.Set<MultiKey<EventBean>>>	JoinSetComposerImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<java.util.Set<MultiKey<EventBean>>>	JoinSetComposerHistoricalImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<java.util.Set<MultiKey<EventBean>>>	JoinSetComposerFAFImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<java.util.Set<MultiKey<EventBean>>>	JoinSetComposer.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext) Return join tuple result set from new data and old data for each stream.

Uses of UniformPair in com.espertech.esper.epl.parse

Methods in com.espertech.esper.epl.parse that return UniformPair

static UniformPair<java.lang.String>

ExceptionConvertor.convert(org.antlr.v4.runtime.RecognitionException e, java.lang.String expression, boolean addPleaseCheck, EsperEPL2GrammarParser parser) Converts from a syntax error to a nice exception.

Uses of UniformPair in com.espertech.esper.epl.view

Methods in com.espertech.esper.epl.view with parameters of type UniformPair

boolean	OutputProcessViewBaseWAfter.checkAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
static void	OutputStrategyUtil.indicateEarlyReturn(StatementContext statementContext, UniformPair<EventBean[]> newOldEvents) Indicate statement result.
void	OutputProcessViewConditionSnapshotPostProcess.output(boolean forceUpdate, UniformPair<EventBean[]> results)
void	OutputProcessViewConditionSnapshot.output(boolean forceUpdate, UniformPair<EventBean[]> results)
void	OutputProcessViewConditionFirstPostProcess.output(boolean forceUpdate, UniformPair<EventBean[]> results)
void	OutputProcessViewConditionDefaultPostProcess.output(boolean forceUpdate, UniformPair<EventBean[]> results)
protected void	OutputProcessViewConditionDefault.output(boolean forceUpdate, UniformPair<EventBean[]> results)
static void	OutputStrategyUtil.output(boolean forceUpdate, UniformPair<EventBean[]> result, UpdateDispatchView finalView)
void	OutputStrategyPostProcess.output(boolean forceUpdate, UniformPair<EventBean[]> result, UpdateDispatchView finalView)
protected void	OutputProcessViewDirectPostProcess.postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)
protected void	OutputProcessViewDirectDistinctOrAfterPostProcess.postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)
protected void	OutputProcessViewDirectDistinctOrAfter.postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)
protected void	OutputProcessViewDirect.postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)

Uses of UniformPair in com.espertech.esper.event

Methods in com.espertech.esper.event that return UniformPair

static UniformPair<java.util.Set<MultiKey<EventBean>>>	EventBeanUtility.flattenBatchJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinPostings) Flattens a list of pairs of join result sets.
static UniformPair<EventBean[]>	EventBeanUtility.flattenBatchStream(java.util.List<UniformPair<EventBean[]>> updateVector) Flatten the vector of arrays to an array.
static UniformPair<EventBean[]>	EventBeanUtility.flattenList(java.util.ArrayDeque<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<java.util.Set<MultiKey<EventBean>>>	EventBeanUtility.flattenBatchJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinPostings) Flattens a list of pairs of join result sets.
static UniformPair<EventBean[]>	EventBeanUtility.flattenBatchStream(java.util.List<UniformPair<EventBean[]>> updateVector) Flatten the vector of arrays to an array.
static UniformPair<EventBean[]>	EventBeanUtility.flattenList(java.util.ArrayDeque<UniformPair<EventBean[]>> eventVector) Flatten the vector of arrays to an array.

Uses of UniformPair in com.espertech.esper.metrics.instrumentation

Methods in com.espertech.esper.metrics.instrumentation with parameters of type UniformPair

void	InstrumentationDefault.aJoinExecStrategy(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
void	Instrumentation.aJoinExecStrategy(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
void	InstrumentationDefault.qaStatementResultExecute(UniformPair<EventBean[]> events, java.lang.String statementId, java.lang.String statementName, int agentInstanceId, long threadId)
void	Instrumentation.qaStatementResultExecute(UniformPair<EventBean[]> events, java.lang.String statementId, java.lang.String statementName, int agentInstanceId, long threadId)
void	InstrumentationDefault.qJoinExecProcess(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
void	Instrumentation.qJoinExecProcess(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)

Uses of UniformPair in com.espertech.esper.view

Methods in com.espertech.esper.view with parameters of type UniformPair

static void

ViewSupport.dumpUpdateParams(java.lang.String prefix, UniformPair<EventBean[]> result) Convenience method for logging the parameters passed to the update method.