com.espertech.esper.epl.agg.service

Class AggSvcGroupLocalGroupByBase

java.lang.Object

com.espertech.esper.epl.agg.service.AggSvcGroupLocalGroupByBase

All Implemented Interfaces:

AggregationResultFuture, AggregationService, StopCallback

Direct Known Subclasses:

AggSvcGroupAllLocalGroupBy, AggSvcGroupByLocalGroupBy

public abstract class AggSvcGroupLocalGroupByBase
extends Object
implements AggregationService

Implementation for handling aggregation with grouping by group-keys.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Object,AggregationMethodPairRow>[]	aggregatorsPerLevelAndGroup
protected AggregationMethod[]	aggregatorsTopLevel
protected boolean	isJoin
protected AggregationLocalGroupByPlan	localGroupByPlan
protected List<Pair<Integer,Object>>	removedKeys
protected AggregationState[]	statesTopLevel

Constructor Summary

Constructors

Constructor and Description
AggSvcGroupLocalGroupByBase(boolean isJoin, AggregationLocalGroupByPlan localGroupByPlan)

Method Summary

Modifier and Type	Method and Description
void	accept(AggregationServiceVisitor visitor)
void	acceptGroupDetail(AggregationServiceVisitorWGroupDetail visitor)
static void	aggregateIntoEnter(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
static void	aggregateIntoLeave(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	applyEnter(EventBean[] eventsPerStream, Object groupByKeyProvided, ExprEvaluatorContext exprEvaluatorContext) Apply events as entering a window (new events).
void	applyLeave(EventBean[] eventsPerStream, Object groupByKeyProvided, ExprEvaluatorContext exprEvaluatorContext) Apply events as leaving a window (old events).
void	clearResults(ExprEvaluatorContext exprEvaluatorContext) Clear current aggregation state.
protected static void	clearResults(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup, AggregationMethod[] aggregatorsTopLevel, AggregationState[] statesTopLevel)
protected abstract Object	computeGroupKey(AggregationLocalGroupByLevel level, Object groupKey, ExprEvaluator[] partitionEval, EventBean[] eventsPerStream, boolean newData, ExprEvaluatorContext exprEvaluatorContext)
static Object	computeGroupKey(ExprEvaluator[] partitionEval, EventBean[] eventsPerStream, boolean b, ExprEvaluatorContext exprEvaluatorContext)
Map<Object,AggregationMethodPairRow>[]	getAggregatorsPerLevelAndGroup()
AggregationMethod[]	getAggregatorsTopLevel()
Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
AggregationService	getContextPartitionAggregationService(int agentInstanceId)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	getGroupKey(int agentInstanceId)
Collection<Object>	getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
List<Pair<Integer,Object>>	getRemovedKeys()
AggregationState[]	getStatesTopLevel()
void	handleRemovedKeys()
void	internalHandleGroupRemove(Pair<Integer,Object> groupByKey)
void	internalHandleUpdatedGroup(int level, Object groupByKey, AggregationMethodPairRow row)
void	internalHandleUpdatedTop()
boolean	isGrouped()
void	setAggregatorsPerLevelAndGroup(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup)
void	setAggregatorsTopLevel(AggregationMethod[] aggregatorsTopLevel)
void	setRemovedCallback(AggregationRowRemovedCallback callback)
void	setRemovedKeys(List<Pair<Integer,Object>> removedKeys)
void	setStatesTopLevel(AggregationState[] statesTopLevel)
void	stop() Stops the underlying resources.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.agg.service.AggregationService

setCurrentAccess

Methods inherited from interface com.espertech.esper.epl.agg.service.AggregationResultFuture

getValue

Field Detail

isJoin

protected final boolean isJoin

localGroupByPlan

protected final AggregationLocalGroupByPlan localGroupByPlan

aggregatorsTopLevel

protected AggregationMethod[] aggregatorsTopLevel

statesTopLevel

protected AggregationState[] statesTopLevel

aggregatorsPerLevelAndGroup

protected Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup

removedKeys

protected List<Pair<Integer,Object>> removedKeys

Constructor Detail

AggSvcGroupLocalGroupByBase

public AggSvcGroupLocalGroupByBase(boolean isJoin,
                                   AggregationLocalGroupByPlan localGroupByPlan)

Method Detail

computeGroupKey

protected abstract Object computeGroupKey(AggregationLocalGroupByLevel level,
                                          Object groupKey,
                                          ExprEvaluator[] partitionEval,
                                          EventBean[] eventsPerStream,
                                          boolean newData,
                                          ExprEvaluatorContext exprEvaluatorContext)

clearResults

public void clearResults(ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationService

Clear current aggregation state.

Specified by:

clearResults in interface AggregationService

Parameters:

exprEvaluatorContext - context

applyEnter

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

Description copied from interface: AggregationService

Apply events as entering a window (new events).

Specified by:

applyEnter in interface AggregationService

Parameters:

eventsPerStream - - events for each stream entering window

groupByKeyProvided - - 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 groupByKeyProvided,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationService

Apply events as leaving a window (old events).

Specified by:

applyLeave in interface AggregationService

Parameters:

eventsPerStream - - events for each stream entering window

groupByKeyProvided - - 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

getCollectionOfEvents

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

Specified by:

getCollectionOfEvents in interface AggregationResultFuture

getCollectionScalar

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

Specified by:

getCollectionScalar in interface AggregationResultFuture

getEventBean

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

Specified by:

getEventBean in interface AggregationResultFuture

isGrouped

public boolean isGrouped()

Specified by:

isGrouped in interface AggregationService

setRemovedCallback

public void setRemovedCallback(AggregationRowRemovedCallback callback)

Specified by:

setRemovedCallback in interface AggregationService

accept

public void accept(AggregationServiceVisitor visitor)

Specified by:

accept in interface AggregationService

acceptGroupDetail

public void acceptGroupDetail(AggregationServiceVisitorWGroupDetail visitor)

Specified by:

acceptGroupDetail in interface AggregationService

internalHandleUpdatedGroup

public void internalHandleUpdatedGroup(int level,
                                       Object groupByKey,
                                       AggregationMethodPairRow row)

internalHandleUpdatedTop

public void internalHandleUpdatedTop()

internalHandleGroupRemove

public void internalHandleGroupRemove(Pair<Integer,Object> groupByKey)

handleRemovedKeys

public void handleRemovedKeys()

getGroupKey

public Object getGroupKey(int agentInstanceId)

Specified by:

getGroupKey in interface AggregationResultFuture

getGroupKeys

public Collection<Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)

Specified by:

getGroupKeys in interface AggregationResultFuture

computeGroupKey

public static Object computeGroupKey(ExprEvaluator[] partitionEval,
                                     EventBean[] eventsPerStream,
                                     boolean b,
                                     ExprEvaluatorContext exprEvaluatorContext)

aggregateIntoEnter

public static void aggregateIntoEnter(AggregationLocalGroupByLevel level,
                                      AggregationMethod[] methods,
                                      AggregationState[] states,
                                      EventBean[] eventsPerStream,
                                      ExprEvaluatorContext exprEvaluatorContext)

aggregateIntoLeave

public static void aggregateIntoLeave(AggregationLocalGroupByLevel level,
                                      AggregationMethod[] methods,
                                      AggregationState[] states,
                                      EventBean[] eventsPerStream,
                                      ExprEvaluatorContext exprEvaluatorContext)

clearResults

protected static void clearResults(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup,
                                   AggregationMethod[] aggregatorsTopLevel,
                                   AggregationState[] statesTopLevel)

getAggregatorsTopLevel

public AggregationMethod[] getAggregatorsTopLevel()

setAggregatorsTopLevel

public void setAggregatorsTopLevel(AggregationMethod[] aggregatorsTopLevel)

getStatesTopLevel

public AggregationState[] getStatesTopLevel()

setStatesTopLevel

public void setStatesTopLevel(AggregationState[] statesTopLevel)

getAggregatorsPerLevelAndGroup

public Map<Object,AggregationMethodPairRow>[] getAggregatorsPerLevelAndGroup()

setAggregatorsPerLevelAndGroup

public void setAggregatorsPerLevelAndGroup(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup)

getRemovedKeys

public List<Pair<Integer,Object>> getRemovedKeys()

setRemovedKeys

public void setRemovedKeys(List<Pair<Integer,Object>> removedKeys)

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

getContextPartitionAggregationService

public AggregationService getContextPartitionAggregationService(int agentInstanceId)

Specified by:

getContextPartitionAggregationService in interface AggregationService