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

Class AggregationForgeFactoryNth

java.lang.Object

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

com.espertech.esper.common.internal.epl.agg.method.nth.AggregationForgeFactoryNth

All Implemented Interfaces:

AggregationForgeFactory

public class AggregationForgeFactoryNth
extends AggregationForgeFactoryBase

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregatorNth	aggregator
protected EPTypeClass	childType
protected DataInputOutputSerdeForge	distinctSerde
protected ExprNthAggNode	parent
protected DataInputOutputSerdeForge	serde
protected int	size

Constructor Summary

Constructors

Constructor and Description
AggregationForgeFactoryNth(ExprNthAggNode parent, EPTypeClass childType, DataInputOutputSerdeForge serde, DataInputOutputSerdeForge distinctSerde, int size)

Method Summary

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

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 ExprNthAggNode parent

childType

protected final EPTypeClass childType

serde

protected final DataInputOutputSerdeForge serde

distinctSerde

protected final DataInputOutputSerdeForge distinctSerde

size

protected final int size

aggregator

protected final AggregatorNth aggregator

Constructor Detail

AggregationForgeFactoryNth

public AggregationForgeFactoryNth(ExprNthAggNode parent,
                                  EPTypeClass childType,
                                  DataInputOutputSerdeForge serde,
                                  DataInputOutputSerdeForge distinctSerde,
                                  int size)

Method Detail

getResultType

public EPType getResultType()

getAggregator

public AggregatorMethod getAggregator()

getParent

public ExprNthAggNode getParent()

getAggregationExpression

public ExprAggregateNodeBase getAggregationExpression()

getAggregationPortableValidation

public AggregationPortableValidation getAggregationPortableValidation()

getMethodAggregationForge

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

Throws:

ExprValidationException

getChildType

public EPTypeClass getChildType()

getSizeOfBuf

public int getSizeOfBuf()