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

Packages that use UniformPair

Package	Description
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

Modifier and Type	Method and Description
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<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

Modifier and Type	Method and Description
static void	EPAssertionUtil.assertProps(UniformPair<EventBean> received, String[] propertyNames, Object[] expectedInsert, 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, String[] propertyNames, Object[][] expectedInsert, 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, String propertyName, Object[] expectedInsert, 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.assertPropsPerRowAnyOrder(UniformPair<EventBean[]> pair, String[] propertyNames, Object[][] expectedNew, Object[][] expectedOld) Compare property values for insert and remove stream pair
static void	EPAssertionUtil.assertUnderlyingPerRow(UniformPair<EventBean[]> received, Object[] expectedUnderlyingInsert, 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

Modifier and Type	Method and Description
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

Modifier and Type	Field and Description
protected ThreadLocal<ArrayDeque<UniformPair<EventBean[]>>>	StatementResultServiceImpl.lastResults Buffer for holding dispatchable events.

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

Modifier and Type	Method and Description
void	ResultDeliveryStrategyTypeArrWStmt.execute(UniformPair<EventBean[]> result)
void	ResultDeliveryStrategyTypeArr.execute(UniformPair<EventBean[]> result)
void	ResultDeliveryStrategyObjectArrWStmt.execute(UniformPair<EventBean[]> result)
void	ResultDeliveryStrategyObjectArr.execute(UniformPair<EventBean[]> result)
void	ResultDeliveryStrategyMapWStmt.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

Modifier and Type	Method and Description
protected static UniformPair<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

Constructor and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
UniformPair<EventBean[]>	ResultSetProcessorSimple.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorHandThrough.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessor.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorSimple.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroup.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorRowForAll.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorHandThrough.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGrouped.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAll.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessor.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	ResultSetProcessorAggregateAllOutputLastHelperImpl.output()
UniformPair<EventBean[]>	ResultSetProcessorAggregateAllOutputLastHelper.output()
UniformPair<EventBean[]>	ResultSetProcessorAggregateAllOutputAllHelperImpl.output()
UniformPair<EventBean[]>	ResultSetProcessorAggregateAllOutputAllHelper.output()
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputLastHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputLastHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputAllHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputAllHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputLastHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputLastHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputAllHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputAllHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputLastHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputLastHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputAllHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputAllHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputLastHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputLastHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputAllHelperImpl.outputJoin(boolean isGenerateSynthetic)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputAllHelper.outputJoin(boolean isGenerateSynthetic)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputLastHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputLastHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputAllHelperImpl.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputAllHelper.outputJoin(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputLastHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputLastHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputAllHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimpleOutputAllHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputLastHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputLastHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputAllHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollupOutputAllHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputLastHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputLastHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputAllHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupOutputAllHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputLastHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputLastHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputAllHelperImpl.outputView(boolean isGenerateSynthetic)
UniformPair<EventBean[]>	ResultSetProcessorRowForAllOutputAllHelper.outputView(boolean isGenerateSynthetic)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputLastHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputLastHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputAllHelperImpl.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorAggregateGroupedOutputAllHelper.outputView(boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize)
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.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[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
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[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
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[]>	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

Modifier and Type	Method and Description
UniformPair<EventBean[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
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[]>	ResultSetProcessorRowPerGroupRollup.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType)
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.expression.funcs

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

Modifier and Type	Method and Description
List<UniformPair<ExprNode>>	ExprCaseNodeForge.getWhenThenNodeList()
List<UniformPair<ExprNode>>	ExprCaseNode.CaseAnalysis.getWhenThenNodeList()

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

Constructor and Description
CaseAnalysis(List<UniformPair<ExprNode>> whenThenNodeList, ExprNode optionalCompareExprNode, ExprNode optionalElseExprNode)
ExprCaseNodeForgeEvalSyntax1(ExprCaseNodeForge forge, List<UniformPair<ExprEvaluator>> whenThenNodeList, ExprEvaluator optionalElseExprNode)

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

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

Modifier and Type	Method and Description
UniformPair<Set<MultiKey<EventBean>>>	JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<Set<MultiKey<EventBean>>>	JoinSetComposerImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<Set<MultiKey<EventBean>>>	JoinSetComposerHistoricalImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<Set<MultiKey<EventBean>>>	JoinSetComposerFAFImpl.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<Set<MultiKey<EventBean>>>	JoinSetComposerAllUnidirectionalOuter.join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream, ExprEvaluatorContext exprEvaluatorContext)
UniformPair<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

Modifier and Type	Method and Description
static UniformPair<String>	ExceptionConvertor.convert(org.antlr.v4.runtime.RecognitionException e, 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 that return types with arguments of type UniformPair

Modifier and Type	Method and Description
List<UniformPair<Set<MultiKey<EventBean>>>>	OutputProcessViewConditionDeltaSetImpl.getJoinEventsSet()
List<UniformPair<Set<MultiKey<EventBean>>>>	OutputProcessViewConditionDeltaSet.getJoinEventsSet()
List<UniformPair<EventBean[]>>	OutputProcessViewConditionDeltaSetImpl.getViewEventsSet()
List<UniformPair<EventBean[]>>	OutputProcessViewConditionDeltaSet.getViewEventsSet()

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

Modifier and Type	Method and Description
void	OutputProcessViewConditionDeltaSetImpl.addJoin(UniformPair<Set<MultiKey<EventBean>>> setUniformPair)
void	OutputProcessViewConditionDeltaSet.addJoin(UniformPair<Set<MultiKey<EventBean>>> events)
void	OutputProcessViewConditionDeltaSetImpl.addView(UniformPair<EventBean[]> uniformPair)
void	OutputProcessViewConditionDeltaSet.addView(UniformPair<EventBean[]> events)
boolean	OutputProcessViewBaseWAfter.checkAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
boolean	OutputProcessViewAfterStateNone.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext)
boolean	OutputProcessViewAfterStateImpl.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext) Returns true if the after-condition is satisfied.
boolean	OutputProcessViewAfterState.checkUpdateAfterCondition(UniformPair<EventBean[]> newOldEvents, StatementContext statementContext)
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	OutputProcessViewConditionLastAllUnordPostProcessAll.output(boolean forceUpdate, UniformPair<EventBean[]> results)
protected void	OutputProcessViewConditionLastAllUnord.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

Modifier and Type	Method and Description
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(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

Modifier and Type	Method and Description
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(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

Modifier and Type	Method and Description
void	InstrumentationDefault.aJoinExecStrategy(UniformPair<Set<MultiKey<EventBean>>> joinSet)
void	Instrumentation.aJoinExecStrategy(UniformPair<Set<MultiKey<EventBean>>> joinSet)
void	InstrumentationDefault.qaStatementResultExecute(UniformPair<EventBean[]> events, int statementId, String statementName, int agentInstanceId, long threadId)
void	Instrumentation.qaStatementResultExecute(UniformPair<EventBean[]> events, int statementId, String statementName, int agentInstanceId, long threadId)
void	InstrumentationDefault.qJoinExecProcess(UniformPair<Set<MultiKey<EventBean>>> joinSet)
void	Instrumentation.qJoinExecProcess(UniformPair<Set<MultiKey<EventBean>>> joinSet)

Uses of UniformPair in com.espertech.esper.view

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

Modifier and Type	Method and Description
static void	ViewSupport.dumpUpdateParams(String prefix, UniformPair<EventBean[]> result) Convenience method for logging the parameters passed to the update method.