com.espertech.esper.epl.core
Class ResultSetProcessorHandThroughFactory

java.lang.Object
  com.espertech.esper.epl.core.ResultSetProcessorHandThroughFactory

All Implemented Interfaces:

ResultSetProcessorFactory

public class ResultSetProcessorHandThroughFactory
extends java.lang.Object
implements ResultSetProcessorFactory

Result set processor prototye for the hand-through case: no aggregation functions used in the select clause, and no group-by, no having and ordering.

Constructor Summary

ResultSetProcessorHandThroughFactory(SelectExprProcessor selectExprProcessor, boolean selectRStream)
Ctor.

Method Summary

EventType	getResultEventType() Returns the event type of processed results.
ResultSetProcessorType	getResultSetProcessorType() Returns the type of result set processor.
boolean	hasAggregation()
ResultSetProcessor	instantiate(OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
boolean	isSelectRStream()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSetProcessorHandThroughFactory

public ResultSetProcessorHandThroughFactory(SelectExprProcessor selectExprProcessor,
                                            boolean selectRStream)

Ctor.

Parameters:

selectExprProcessor - - for processing the select expression and generting the final output rows a row per group even if groups didn't change

selectRStream - - true if remove stream events should be generated

Method Detail

instantiate

public ResultSetProcessor instantiate(OrderByProcessor orderByProcessor,
                                      AggregationService aggregationService,
                                      AgentInstanceContext agentInstanceContext)

Specified by:

instantiate in interface ResultSetProcessorFactory

getResultEventType

public EventType getResultEventType()

Description copied from interface: ResultSetProcessorFactory

Returns the event type of processed results.

Specified by:

getResultEventType in interface ResultSetProcessorFactory

Returns:

event type of the resulting events posted by the processor.

hasAggregation

public boolean hasAggregation()

Specified by:

hasAggregation in interface ResultSetProcessorFactory

isSelectRStream

public boolean isSelectRStream()

getResultSetProcessorType

public ResultSetProcessorType getResultSetProcessorType()

Description copied from interface: ResultSetProcessorFactory

Returns the type of result set processor.

Specified by:

getResultSetProcessorType in interface ResultSetProcessorFactory

Returns:

result set processor type