public class AggregationStateFactoryLinear extends Object implements AggregationStateFactory
Modifier and Type | Field and Description |
---|---|
protected ExprAggMultiFunctionLinearAccessNode |
expr |
protected int |
streamNum |
Constructor and Description |
---|
AggregationStateFactoryLinear(ExprAggMultiFunctionLinearAccessNode expr,
int streamNum) |
Modifier and Type | Method and Description |
---|---|
AggregationState |
createAccess(int agentInstanceId,
boolean join,
Object groupKey,
AggregationServicePassThru passThru) |
ExprNode |
getAggregationExpression() |
protected final ExprAggMultiFunctionLinearAccessNode expr
protected final int streamNum
public AggregationStateFactoryLinear(ExprAggMultiFunctionLinearAccessNode expr, int streamNum)
public AggregationState createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)
createAccess
in interface AggregationStateFactory
public ExprNode getAggregationExpression()
getAggregationExpression
in interface AggregationStateFactory