com.espertech.esper.epl.agg.access

Class AggregationStateSortedSpecForge

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateSortedSpecForge

public class AggregationStateSortedSpecForge
extends java.lang.Object

Constructor Summary

Constructors

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

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	isJoin()
void	setCriteriaKeyBinding(java.lang.Object criteriaKeyBinding)
AggregationStateSortedSpec	toEvaluator(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

Constructor Detail

AggregationStateSortedSpecForge

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

Method Detail

getStreamId

public int getStreamId()

getCriteria

public ExprNode[] getCriteria()

getCriteriaKeyBinding

public java.lang.Object getCriteriaKeyBinding()

setCriteriaKeyBinding

public void setCriteriaKeyBinding(java.lang.Object criteriaKeyBinding)

getOptionalFilter

public ExprForge getOptionalFilter()

getComparator

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

isJoin

public boolean isJoin()

toEvaluator

public AggregationStateSortedSpec toEvaluator(EngineImportService engineImportService,
                                              boolean isFireAndForget,
                                              java.lang.String statementName)