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.
|
Modifier and Type | Field and Description |
---|---|
static UniformPair |
UniformPair.EMPTY_PAIR |
Modifier and Type | Method and Description |
---|---|
ArrayDeque<UniformPair<EventBean[]>> |
StatementDispatchTLEntry.getResults() |
Modifier and Type | Method and Description |
---|---|
void |
StatementResultService.indicate(UniformPair<EventBean[]> results,
StatementDispatchTLEntry dispatchTLEntry) |
void |
ContextMergeView.newResult(UniformPair<EventBean[]> result) |
Modifier and Type | Method and Description |
---|---|
List<UniformPair<ExprNode>> |
ExprCaseNodeForge.getWhenThenNodeList() |
List<UniformPair<ExprNode>> |
ExprCaseNode.CaseAnalysis.getWhenThenNodeList() |
Constructor and Description |
---|
CaseAnalysis(List<UniformPair<ExprNode>> whenThenNodeList,
ExprNode optionalCompareExprNode,
ExprNode optionalElseExprNode) |
ExprCaseNodeForgeEvalSyntax1(ExprCaseNodeForge forge,
List<UniformPair<ExprEvaluator>> whenThenNodeList,
ExprEvaluator optionalElseExprNode) |
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.
|
Modifier and Type | Method and Description |
---|---|
UniformPair<Integer> |
QueryGraphKey.getStreams() |
Constructor and Description |
---|
QueryGraph(Map<UniformPair<Integer>,QueryGraphValue> streamJoinMap) |
Modifier and Type | Method and Description |
---|---|
void |
OutputProcessViewConditionDefaultPostProcess.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
Modifier and Type | Method and Description |
---|---|
static void |
OutputStrategyUtil.indicateEarlyReturn(StatementContext statementContext,
UniformPair<EventBean[]> newOldEvents)
Indicate statement result.
|
void |
OutputProcessViewConditionSnapshot.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
void |
OutputProcessViewConditionLastAllUnordPostProcessAll.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
static void |
OutputStrategyUtil.output(boolean forceUpdate,
UniformPair<EventBean[]> result,
UpdateDispatchView finalView) |
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() |
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) |
void |
OutputProcessViewConditionSnapshotPostProcess.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
protected void |
OutputProcessViewConditionLastAllUnord.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
void |
OutputProcessViewConditionFirstPostProcess.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
protected void |
OutputProcessViewConditionFirst.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
protected void |
OutputProcessViewConditionDefault.output(boolean forceUpdate,
UniformPair<EventBean[]> results) |
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) |
Modifier and Type | Method and Description |
---|---|
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[]> |
ResultSetProcessorAggregateGroupedOutputLastHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedOutputLastHelper.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedOutputAllHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorAggregateGroupedOutputAllHelper.outputView(boolean isSynthesize) |
Modifier and Type | Method and Description |
---|---|
UniformPair<EventBean[]> |
ResultSetProcessor.continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessor.continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize) |
static UniformPair<EventBean[]> |
ResultSetProcessorUtil.finalizeOutputMaySortMayRStream(List<EventBean> newEvents,
List<Object> newEventsSortKey,
List<EventBean> oldEvents,
List<Object> oldEventsSortKey,
boolean selectRStream,
OrderByProcessor orderByProcessor,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
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[]> |
ResultSetProcessor.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
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).
|
static UniformPair<EventBean[]> |
ResultSetProcessorUtil.toPairNullIfAllNull(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static UniformPair<EventBean[]> |
ResultSetProcessorUtil.toPairNullIfAllNullSingle(EventBean istream,
EventBean rstream)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static UniformPair<EventBean[]> |
ResultSetProcessorUtil.toPairNullIfNullIStream(EventBean istream)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Modifier and Type | Method and Description |
---|---|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
UniformPair<EventBean[]> |
ResultSetProcessor.processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
Modifier and Type | Method and Description |
---|---|
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[]> |
ResultSetProcessorRowForAllOutputLastHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllOutputLastHelper.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllOutputAllHelperImpl.outputView(boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
ResultSetProcessorRowForAllOutputAllHelper.outputView(boolean isGenerateSynthetic) |
Modifier and Type | Method and Description |
---|---|
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventOutputLastHelperImpl.output() |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventOutputLastHelper.output() |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventOutputAllHelperImpl.output() |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerEventOutputAllHelper.output() |
Modifier and Type | Method and Description |
---|---|
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[]> |
ResultSetProcessorRowPerGroupOutputLastHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupOutputLastHelper.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupOutputAllHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupOutputAllHelper.outputView(boolean isSynthesize) |
Modifier and Type | Method and Description |
---|---|
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[]> |
ResultSetProcessorRowPerGroupRollupOutputLastHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupOutputLastHelper.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupOutputAllHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorRowPerGroupRollupOutputAllHelper.outputView(boolean isSynthesize) |
Modifier and Type | Method and Description |
---|---|
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[]> |
ResultSetProcessorSimpleOutputLastHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleOutputLastHelper.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleOutputAllHelperImpl.outputView(boolean isSynthesize) |
UniformPair<EventBean[]> |
ResultSetProcessorSimpleOutputAllHelper.outputView(boolean isSynthesize) |
Modifier and Type | Method and Description |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
NOTE: Code-generation-invoked method, method name and parameter order matters
Flattens a list of pairs of join result sets.
|
static UniformPair<EventBean[]> |
EventBeanUtility.flattenBatchStream(List<UniformPair<EventBean[]>> updateVector)
NOTE: Code-generation-invoked method, method name and parameter order matters
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.
|
Modifier and Type | Method and Description |
---|---|
static UniformPair<Set<MultiKey<EventBean>>> |
EventBeanUtility.flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)
NOTE: Code-generation-invoked method, method name and parameter order matters
Flattens a list of pairs of join result sets.
|
static UniformPair<EventBean[]> |
EventBeanUtility.flattenBatchStream(List<UniformPair<EventBean[]>> updateVector)
NOTE: Code-generation-invoked method, method name and parameter order matters
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.
|
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationCommonDefault.aJoinExecStrategy(UniformPair<Set<MultiKey<EventBean>>> joinSet) |
void |
InstrumentationCommon.aJoinExecStrategy(UniformPair<Set<MultiKey<EventBean>>> joinSet) |
void |
InstrumentationCommonDefault.qJoinExecProcess(UniformPair<Set<MultiKey<EventBean>>> joinSet) |
void |
InstrumentationCommon.qJoinExecProcess(UniformPair<Set<MultiKey<EventBean>>> joinSet) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateDispatchView.newResult(UniformPair<EventBean[]> result)
Convenience method that accepts a pair of new and old data
as this is the most treated unit.
|
Modifier and Type | Method and Description |
---|---|
protected static UniformPair<Integer> |
EPStatementStartMethodHelperValidate.validateOuterJoinPropertyPair(ExprIdentNode leftNode,
ExprIdentNode rightNode,
int outerJoinCount,
StreamTypeService typeService,
ViewResourceDelegateExpr viewResourceDelegate,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices compileTimeServices) |
Copyright © 2005–2018. All rights reserved.