com.espertech.esper.core.start

Class EPStatementStartMethodHelperUtil

java.lang.Object

com.espertech.esper.core.start.EPStatementStartMethodHelperUtil

public class EPStatementStartMethodHelperUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
EPStatementStartMethodHelperUtil()

Method Summary

Modifier and Type	Method and Description
protected static 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, boolean isSubquery, Integer subqueryNumber)

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,
                                                                                       boolean isSubquery,
                                                                                       Integer subqueryNumber)

determineStreamNames

protected static 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)