All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor) |
void |
applyJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
static void |
applyJoinResultCodegen(ResultSetProcessorRowPerGroupRollupForge forge,
CodegenClassScope classScope,
CodegenMethodNode method,
ResultSetProcessorCodegenInstance instance) |
void |
applyViewResult(EventBean[] newData,
EventBean[] oldData) |
void |
clear()
Clear out current state.
|
UniformPair<EventBean[]> |
continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize) |
static void |
continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge,
CodegenMethodNode method) |
UniformPair<EventBean[]> |
continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize) |
Object |
generateGroupKeySingle(EventBean[] eventsPerStream,
boolean isNewData) |
void |
generateOutputBatched(boolean join,
Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
List<EventBean> resultEvents,
List<Object> optSortKeys) |
void |
generateOutputBatchedMapUnsorted(boolean join,
Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
Map<Object,EventBean> resultEvents) |
ExprEvaluatorContext |
getAgentInstanceContext() |
AggregationService |
getAggregationService() |
AggregationGroupByRollupDesc |
getGroupByRollupDesc() |
Iterator<EventBean> |
getIterator(Set<MultiKey<EventBean>> joinSet)
Returns the iterator for iterating over a join-result.
|
Iterator<EventBean> |
getIterator(Viewable parent)
Returns the iterator implementing the group-by and aggregation and order-by logic
specific to each case of use of these construct.
|
EventType |
getResultEventType()
Returns the event type of processed results.
|
boolean |
isSelectRStream() |
UniformPair<EventBean[]> |
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[]> |
processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
static void |
processOutputLimitedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge,
CodegenClassScope classScope,
CodegenMethodNode method,
ResultSetProcessorCodegenInstance instance) |
void |
processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
boolean isGenerateSynthetic) |
static void |
processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge,
CodegenClassScope classScope,
CodegenMethodNode method,
ResultSetProcessorCodegenInstance instance) |
void |
processOutputLimitedLastAllNonBufferedView(EventBean[] newData,
EventBean[] oldData,
boolean isGenerateSynthetic) |
UniformPair<EventBean[]> |
processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList,
boolean generateSynthetic)
Processes batched events in case of output-rate limiting.
|
UniformPair<EventBean[]> |
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).
|
void |
removedAggregationGroupKey(Object key) |
void |
setAgentInstanceContext(AgentInstanceContext agentInstanceContext) |
void |
stop()
Stops the underlying resources.
|