com.espertech.esper.core.start
Class EPStatementStartMethodHelperUtil

java.lang.Object
  com.espertech.esper.core.start.EPStatementStartMethodHelperUtil

public class EPStatementStartMethodHelperUtil
extends java.lang.Object

Constructor Summary

EPStatementStartMethodHelperUtil()

Method Summary

protected static java.lang.String[]	determineStreamNames(StreamSpecCompiled[] streams) Returns a stream name assigned for each stream, generated if none was supplied.
protected static boolean	determineSubquerySameStream(StatementSpecCompiled statementSpec, FilterStreamSpecCompiled filterStreamSpec)
protected static boolean[]	getHasIStreamOnly(boolean[] isNamedWindow, ViewFactoryChain[] unmaterializedViewChain)
protected static boolean	isConsumingFilters(EvalFactoryNode evalNode)
static Pair<ResultSetProcessor,AggregationService>	startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype, AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

EPStatementStartMethodHelperUtil

public EPStatementStartMethodHelperUtil()

Method Detail

startResultSetAndAggregation

public static Pair<ResultSetProcessor,AggregationService> startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
                                                                                       AgentInstanceContext agentInstanceContext)

determineStreamNames

protected static java.lang.String[] determineStreamNames(StreamSpecCompiled[] streams)

Returns a stream name assigned for each stream, generated if none was supplied.

Parameters:

streams - - stream specifications

Returns:

array of stream names

getHasIStreamOnly

protected static boolean[] getHasIStreamOnly(boolean[] isNamedWindow,
                                             ViewFactoryChain[] unmaterializedViewChain)

determineSubquerySameStream

protected static boolean determineSubquerySameStream(StatementSpecCompiled statementSpec,
                                                     FilterStreamSpecCompiled filterStreamSpec)

isConsumingFilters

protected static boolean isConsumingFilters(EvalFactoryNode evalNode)