com.espertech.esper.epl.agg.service

Class AggSvcGroupByReclaimAgedImpl

java.lang.Object

com.espertech.esper.epl.agg.service.AggregationServiceBaseGrouped

com.espertech.esper.epl.agg.service.AggSvcGroupByReclaimAgedImpl

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

public class AggSvcGroupByReclaimAgedImpl
extends AggregationServiceBaseGrouped

Implementation for handling aggregation with grouping by group-keys.

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationStateFactory[]	accessAggregations
protected Map<Object,AggregationMethodRowAged>	aggregatorsPerGroup
static long	DEFAULT_MAX_AGE_MSEC
protected boolean	isJoin

Fields inherited from class com.espertech.esper.epl.agg.service.AggregationServiceBaseGrouped

aggregators, evaluators

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupByReclaimAgedImpl(ExprEvaluator[] evaluators, AggregationMethodFactory[] aggregators, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean join, AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionMaxAge, AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionFrequency, TimeAbacus timeAbacus)

Method Summary

Modifier and Type	Method and Description
void	accept(AggregationServiceVisitor visitor)
void	acceptGroupDetail(AggregationServiceVisitorWGroupDetail visitor)
void	applyEnter(EventBean[] eventsPerStream, Object groupByKey, ExprEvaluatorContext exprEvaluatorContext) Apply events as entering a window (new events).
void	applyLeave(EventBean[] eventsPerStream, Object groupByKey, ExprEvaluatorContext exprEvaluatorContext) Apply events as leaving a window (old events).
void	clearResults(ExprEvaluatorContext exprEvaluatorContext) Clear current aggregation state.
Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	getGroupKey(int agentInstanceId)
Collection<Object>	getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
Object	getValue(int column, int agentInstanceId, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns current aggregation state, for use by expression node representing an aggregation function.
protected void	handleRemovedKeys()
void	internalHandleRemoved(Object key)
void	internalHandleUpdated(Object groupByKey, AggregationMethodRowAged row)
boolean	isGrouped()
void	setCurrentAccess(Object groupByKey, int agentInstanceId, AggregationGroupByRollupLevel rollupLevel) Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.
void	setRemovedCallback(AggregationRowRemovedCallback callback)

Methods inherited from class com.espertech.esper.epl.agg.service.AggregationServiceBaseGrouped

getContextPartitionAggregationService, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_MAX_AGE_MSEC

public static final long DEFAULT_MAX_AGE_MSEC

See Also:

Constant Field Values

accessAggregations

protected final AggregationStateFactory[] accessAggregations

isJoin

protected final boolean isJoin

aggregatorsPerGroup

protected Map<Object,AggregationMethodRowAged> aggregatorsPerGroup

Constructor Detail

AggSvcGroupByReclaimAgedImpl

public AggSvcGroupByReclaimAgedImpl(ExprEvaluator[] evaluators,
                                    AggregationMethodFactory[] aggregators,
                                    AggregationAccessorSlotPair[] accessors,
                                    AggregationStateFactory[] accessAggregations,
                                    boolean join,
                                    AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionMaxAge,
                                    AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionFrequency,
                                    TimeAbacus timeAbacus)

Method Detail

clearResults

public void clearResults(ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationService

Clear current aggregation state.

Parameters:

exprEvaluatorContext - context

applyEnter

public void applyEnter(EventBean[] eventsPerStream,
                       Object groupByKey,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationService

Apply events as entering a window (new events).

Parameters:

eventsPerStream - - events for each stream entering window

groupByKey - - can be null if grouping without keys is desired, else the keys or array of keys to use for grouping, each distinct key value results in a new row of aggregation state.

exprEvaluatorContext - context for expression evaluatiom

applyLeave

public void applyLeave(EventBean[] eventsPerStream,
                       Object groupByKey,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationService

Apply events as leaving a window (old events).

Parameters:

eventsPerStream - - events for each stream entering window

groupByKey - - can be null if grouping without keys is desired, else the keys or array of keys to use for grouping, each distinct key value results in a new row of aggregation state.

exprEvaluatorContext - context for expression evaluatiom

setCurrentAccess

public void setCurrentAccess(Object groupByKey,
                             int agentInstanceId,
                             AggregationGroupByRollupLevel rollupLevel)

Description copied from interface: AggregationService

Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.

Parameters:

groupByKey - - single key identifying the row of aggregation states

agentInstanceId - context partition id

rollupLevel - rollup level

getValue

public Object getValue(int column,
                       int agentInstanceId,
                       EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationResultFuture

Returns current aggregation state, for use by expression node representing an aggregation function.

Parameters:

column - is assigned to the aggregation expression node and passed as an column (index) into a row

agentInstanceId - the context partition id

eventsPerStream - events per stream

isNewData - new vs removed indicator

exprEvaluatorContext - context

Returns:

current aggragation state

getCollectionOfEvents

public Collection<EventBean> getCollectionOfEvents(int column,
                                                   EventBean[] eventsPerStream,
                                                   boolean isNewData,
                                                   ExprEvaluatorContext context)

getCollectionScalar

public Collection<Object> getCollectionScalar(int column,
                                              EventBean[] eventsPerStream,
                                              boolean isNewData,
                                              ExprEvaluatorContext context)

getEventBean

public EventBean getEventBean(int column,
                              EventBean[] eventsPerStream,
                              boolean isNewData,
                              ExprEvaluatorContext context)

setRemovedCallback

public void setRemovedCallback(AggregationRowRemovedCallback callback)

internalHandleUpdated

public void internalHandleUpdated(Object groupByKey,
                                  AggregationMethodRowAged row)

internalHandleRemoved

public void internalHandleRemoved(Object key)

accept

public void accept(AggregationServiceVisitor visitor)

acceptGroupDetail

public void acceptGroupDetail(AggregationServiceVisitorWGroupDetail visitor)

isGrouped

public boolean isGrouped()

handleRemovedKeys

protected void handleRemovedKeys()

getGroupKey

public Object getGroupKey(int agentInstanceId)

getGroupKeys

public Collection<Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)