com.espertech.esper.epl.view

Class OutputProcessViewConditionFactory

java.lang.Object

com.espertech.esper.epl.view.OutputProcessViewDirectFactory

com.espertech.esper.epl.view.OutputProcessViewDirectDistinctOrAfterFactory

com.espertech.esper.epl.view.OutputProcessViewConditionFactory

All Implemented Interfaces:

OutputProcessViewFactory

public class OutputProcessViewConditionFactory
extends OutputProcessViewDirectDistinctOrAfterFactory

A view that handles the "output snapshot" keyword in output rate stabilizing.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OutputProcessViewConditionFactory.ConditionType

Field Summary

Fields inherited from class com.espertech.esper.epl.view.OutputProcessViewDirectDistinctOrAfterFactory

afterConditionNumberOfEvents, afterTimePeriod

Fields inherited from class com.espertech.esper.epl.view.OutputProcessViewDirectFactory

postProcessFactory

Constructor Summary

Constructors

Constructor and Description

OutputProcessViewConditionFactory(StatementContext statementContext, OutputStrategyPostProcessFactory postProcessFactory, boolean distinct, ExprTimePeriod afterTimePeriod, Integer afterConditionNumberOfEvents, EventType resultEventType, OutputConditionFactory outputConditionFactory, int streamCount, OutputProcessViewConditionFactory.ConditionType conditionType, OutputLimitLimitType outputLimitLimitType, boolean terminable, boolean hasAfter, boolean isUnaggregatedUngrouped, SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum, ResultSetProcessorHelperFactory resultSetProcessorHelperFactory)

Method Summary

Modifier and Type	Method and Description
OutputConditionFactory	getOutputConditionFactory()
OutputLimitLimitType	getOutputLimitLimitType()
SelectClauseStreamSelectorEnum	getSelectClauseStreamSelectorEnum()
int	getStreamCount()
boolean	isHasAfter()
boolean	isTerminable()
boolean	isUnaggregatedUngrouped()
OutputProcessViewBase	makeView(ResultSetProcessor resultSetProcessor, AgentInstanceContext agentInstanceContext)

Methods inherited from class com.espertech.esper.epl.view.OutputProcessViewDirectDistinctOrAfterFactory

getEventBeanReader, isDistinct

Methods inherited from class com.espertech.esper.epl.view.OutputProcessViewDirectFactory

getStatementContext, getStatementResultService

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputProcessViewConditionFactory

public OutputProcessViewConditionFactory(StatementContext statementContext,
                                         OutputStrategyPostProcessFactory postProcessFactory,
                                         boolean distinct,
                                         ExprTimePeriod afterTimePeriod,
                                         Integer afterConditionNumberOfEvents,
                                         EventType resultEventType,
                                         OutputConditionFactory outputConditionFactory,
                                         int streamCount,
                                         OutputProcessViewConditionFactory.ConditionType conditionType,
                                         OutputLimitLimitType outputLimitLimitType,
                                         boolean terminable,
                                         boolean hasAfter,
                                         boolean isUnaggregatedUngrouped,
                                         SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
                                         ResultSetProcessorHelperFactory resultSetProcessorHelperFactory)

Method Detail

makeView

public OutputProcessViewBase makeView(ResultSetProcessor resultSetProcessor,
                                      AgentInstanceContext agentInstanceContext)

Specified by:

makeView in interface OutputProcessViewFactory

Overrides:

makeView in class OutputProcessViewDirectDistinctOrAfterFactory

getOutputConditionFactory

public OutputConditionFactory getOutputConditionFactory()

getStreamCount

public int getStreamCount()

getOutputLimitLimitType

public OutputLimitLimitType getOutputLimitLimitType()

isTerminable

public boolean isTerminable()

isHasAfter

public boolean isHasAfter()

isUnaggregatedUngrouped

public boolean isUnaggregatedUngrouped()

getSelectClauseStreamSelectorEnum

public SelectClauseStreamSelectorEnum getSelectClauseStreamSelectorEnum()