Package com.espertech.esper.common.internal.epl.agg.method.count

Class AggregationForgeFactoryCount

java.lang.Object

com.espertech.esper.common.internal.epl.agg.method.core.AggregationForgeFactoryBase

com.espertech.esper.common.internal.epl.agg.method.count.AggregationForgeFactoryCount

All Implemented Interfaces:

AggregationForgeFactory

public class AggregationForgeFactoryCount
extends AggregationForgeFactoryBase

Field Summary

Fields

Modifier and Type	Field	Description
protected final EPType	countedValueType
protected final DataInputOutputSerdeForge	distinctValueSerde
protected final boolean	ignoreNulls
protected final ExprCountNode	parent

Constructor Summary

Constructors

Constructor	Description
AggregationForgeFactoryCount(ExprCountNode parent, boolean ignoreNulls, EPType countedValueType, DataInputOutputSerdeForge distinctValueSerde)

Method Summary

Modifier and Type	Method	Description
ExprAggregateNodeBase	getAggregationExpression()
AggregationPortableValidation	getAggregationPortableValidation()
AggregatorMethod	getAggregator()
ExprForge[]	getMethodAggregationForge(boolean join, EventType[] typesPerStream)
EPType	getResultType()

Methods inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregationForgeFactoryBase

getAccessorForge, getAggregationStateAgent, getAggregationStateFactory, getAggregationStateKey, isAccessAggregation

Methods inherited from class java.lang.Object

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

Field Details

parent

protected final ExprCountNode parent

ignoreNulls

protected final boolean ignoreNulls

countedValueType

protected final EPType countedValueType

distinctValueSerde

protected final DataInputOutputSerdeForge distinctValueSerde

Constructor Details

AggregationForgeFactoryCount

public AggregationForgeFactoryCount(ExprCountNode parent,
 boolean ignoreNulls,
 EPType countedValueType,
 DataInputOutputSerdeForge distinctValueSerde)

Method Details

getResultType

public EPType getResultType()

getAggregator

public AggregatorMethod getAggregator()

getMethodAggregationForge

public ExprForge[] getMethodAggregationForge(boolean join,
 EventType[] typesPerStream)
                                      throws ExprValidationException

Throws:

ExprValidationException

getAggregationExpression

public ExprAggregateNodeBase getAggregationExpression()

getAggregationPortableValidation

public AggregationPortableValidation getAggregationPortableValidation()