public class AggregationMethodFactoryFirstEver extends Object implements AggregationMethodFactory
Modifier and Type | Field and Description |
---|---|
protected Class |
childType |
protected ExprFirstEverNode |
parent |
Constructor and Description |
---|
AggregationMethodFactoryFirstEver(ExprFirstEverNode parent,
Class childType) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessor |
getAccessor() |
ExprAggregateNodeBase |
getAggregationExpression() |
AggregationAgent |
getAggregationStateAgent(EngineImportService engineImportService,
String statementName) |
AggregationStateFactory |
getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateKey |
getAggregationStateKey(boolean isMatchRecognize) |
ExprEvaluator |
getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
Class |
getResultType() |
boolean |
isAccessAggregation() |
AggregationMethod |
make() |
void |
validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
protected final ExprFirstEverNode parent
protected final Class childType
public AggregationMethodFactoryFirstEver(ExprFirstEverNode parent, Class childType)
public boolean isAccessAggregation()
isAccessAggregation
in interface AggregationMethodFactory
public Class getResultType()
getResultType
in interface AggregationMethodFactory
public AggregationStateKey getAggregationStateKey(boolean isMatchRecognize)
getAggregationStateKey
in interface AggregationMethodFactory
public AggregationStateFactory getAggregationStateFactory(boolean isMatchRecognize)
getAggregationStateFactory
in interface AggregationMethodFactory
public AggregationAccessor getAccessor()
getAccessor
in interface AggregationMethodFactory
public AggregationMethod make()
make
in interface AggregationMethodFactory
public ExprAggregateNodeBase getAggregationExpression()
getAggregationExpression
in interface AggregationMethodFactory
public void validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) throws ExprValidationException
validateIntoTableCompatible
in interface AggregationMethodFactory
ExprValidationException
public AggregationAgent getAggregationStateAgent(EngineImportService engineImportService, String statementName)
getAggregationStateAgent
in interface AggregationMethodFactory
public ExprEvaluator getMethodAggregationEvaluator(boolean join, EventType[] typesPerStream) throws ExprValidationException
getMethodAggregationEvaluator
in interface AggregationMethodFactory
ExprValidationException