com.espertech.esper.epl.agg.access

Class AggregationStateMinMaxByEverSpecForge

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateMinMaxByEverSpecForge

public class AggregationStateMinMaxByEverSpecForge
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	streamId

Constructor Summary

Constructors

Constructor and Description
AggregationStateMinMaxByEverSpecForge(int streamId, ExprNode[] criteria, boolean max, java.util.Comparator<java.lang.Object> comparator, java.lang.Object criteriaKeyBinding, ExprForge optionalFilter)

Method Summary

Modifier and Type	Method and Description
java.util.Comparator<java.lang.Object>	getComparator()
ExprNode[]	getCriteria()
java.lang.Object	getCriteriaKeyBinding()
ExprForge	getOptionalFilter()
int	getStreamId()
boolean	isMax()
void	setCriteriaKeyBinding(java.lang.Object criteriaKeyBinding)
AggregationStateMinMaxByEverSpec	toEvaluators(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)

Methods inherited from class java.lang.Object

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

Field Detail

streamId

protected final int streamId

Constructor Detail

AggregationStateMinMaxByEverSpecForge

public AggregationStateMinMaxByEverSpecForge(int streamId,
                                             ExprNode[] criteria,
                                             boolean max,
                                             java.util.Comparator<java.lang.Object> comparator,
                                             java.lang.Object criteriaKeyBinding,
                                             ExprForge optionalFilter)

Method Detail

getStreamId

public int getStreamId()

isMax

public boolean isMax()

getCriteriaKeyBinding

public java.lang.Object getCriteriaKeyBinding()

setCriteriaKeyBinding

public void setCriteriaKeyBinding(java.lang.Object criteriaKeyBinding)

getOptionalFilter

public ExprForge getOptionalFilter()

getCriteria

public ExprNode[] getCriteria()

getComparator

public java.util.Comparator<java.lang.Object> getComparator()

toEvaluators

public AggregationStateMinMaxByEverSpec toEvaluators(EngineImportService engineImportService,
                                                     boolean isFireAndForget,
                                                     java.lang.String statementName)