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

Class AggregationForgeFactoryPlugin

java.lang.Object

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

com.espertech.esper.common.internal.epl.agg.method.plugin.AggregationForgeFactoryPlugin

All Implemented Interfaces:

AggregationForgeFactory

public class AggregationForgeFactoryPlugin
extends AggregationForgeFactoryBase

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationFunctionForge	aggregationFunctionForge
protected ExprPlugInAggNode	parent

Constructor Summary

Constructors

Constructor and Description
AggregationForgeFactoryPlugin(ExprPlugInAggNode parent, AggregationFunctionForge aggregationFunctionForge, AggregationFunctionMode mode, EPType aggregatedValueType, DataInputOutputSerdeForge distinctSerde)

Method Summary

Modifier and Type	Method and Description
EPType	getAggregatedValueType()
ExprAggregateNodeBase	getAggregationExpression()
AggregationFunctionForge	getAggregationFunctionForge()
AggregationPortableValidation	getAggregationPortableValidation()
AggregatorMethod	getAggregator()
DataInputOutputSerdeForge	getDistinctSerde()
ExprForge[]	getMethodAggregationForge(boolean join, EventType[] typesPerStream)
AggregationFunctionMode	getMode()
ExprPlugInAggNode	getParent()
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 ExprPlugInAggNode parent

aggregationFunctionForge

protected final AggregationFunctionForge aggregationFunctionForge

Constructor Detail

AggregationForgeFactoryPlugin

public AggregationForgeFactoryPlugin(ExprPlugInAggNode parent,
                                     AggregationFunctionForge aggregationFunctionForge,
                                     AggregationFunctionMode mode,
                                     EPType aggregatedValueType,
                                     DataInputOutputSerdeForge distinctSerde)

Method Detail

getResultType

public EPType getResultType()

getMethodAggregationForge

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

Throws:

ExprValidationException

getAggregator

public AggregatorMethod getAggregator()

getAggregationPortableValidation

public AggregationPortableValidation getAggregationPortableValidation()

getAggregationExpression

public ExprAggregateNodeBase getAggregationExpression()

getAggregationFunctionForge

public AggregationFunctionForge getAggregationFunctionForge()

getParent

public ExprPlugInAggNode getParent()

getMode

public AggregationFunctionMode getMode()

getAggregatedValueType

public EPType getAggregatedValueType()

getDistinctSerde

public DataInputOutputSerdeForge getDistinctSerde()