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

Class AggregationForgeFactoryCountEver

java.lang.Object

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

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

All Implemented Interfaces:

AggregationForgeFactory

public class AggregationForgeFactoryCountEver
extends AggregationForgeFactoryBase

Field Summary

Fields

Modifier and Type	Field and Description
protected EPType	childType
protected DataInputOutputSerdeForge	distinctSerde
protected boolean	ignoreNulls
protected ExprCountEverNode	parent

Constructor Summary

Constructors

Constructor and Description
AggregationForgeFactoryCountEver(ExprCountEverNode parent, boolean ignoreNulls, EPType childType, DataInputOutputSerdeForge distinctSerde)

Method Summary

Modifier and Type	Method and 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 Detail

parent

protected final ExprCountEverNode parent

ignoreNulls

protected final boolean ignoreNulls

childType

protected final EPType childType

distinctSerde

protected final DataInputOutputSerdeForge distinctSerde

Constructor Detail

AggregationForgeFactoryCountEver

public AggregationForgeFactoryCountEver(ExprCountEverNode parent,
                                        boolean ignoreNulls,
                                        EPType childType,
                                        DataInputOutputSerdeForge distinctSerde)

Method Detail

getResultType

public EPType getResultType()

getAggregationExpression

public ExprAggregateNodeBase getAggregationExpression()

getAggregator

public AggregatorMethod getAggregator()

getAggregationPortableValidation

public AggregationPortableValidation getAggregationPortableValidation()

getMethodAggregationForge

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

Throws:

ExprValidationException