com.espertech.esper.epl.core

Class BindProcessor

java.lang.Object

com.espertech.esper.epl.core.BindProcessor

public class BindProcessor
extends Object

Works in conjunction with SelectExprResultProcessor to present a result as an object array for 'natural' delivery.

Constructor Summary

Constructors

Constructor and Description
BindProcessor(SelectClauseElementCompiled[] selectionList, EventType[] typesPerStream, String[] streamNames, TableService tableService, EngineImportService engineImportService, boolean isFireAndForget, Annotation[] annotations, String statementName) Ctor.

Method Summary

Modifier and Type	Method and Description
String[]	getColumnNamesAssigned() Returns the column names of select-clause expressions.
Class[]	getExpressionTypes() Returns the expression types generated by the select-clause expressions.
Object[]	process(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Process select expressions into columns for native dispatch.

Methods inherited from class java.lang.Object

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

Constructor Detail

BindProcessor

public BindProcessor(SelectClauseElementCompiled[] selectionList,
                     EventType[] typesPerStream,
                     String[] streamNames,
                     TableService tableService,
                     EngineImportService engineImportService,
                     boolean isFireAndForget,
                     Annotation[] annotations,
                     String statementName)
              throws ExprValidationException

Ctor.

Parameters:

selectionList - the select clause

typesPerStream - the event types per stream

streamNames - the stream names

tableService - table service

engineImportService - engine imports

statementName - statement name

annotations - annotations

isFireAndForget - fire-and-forget flag

Throws:

ExprValidationException - when the validation of the select clause failed

Method Detail

process

public Object[] process(EventBean[] eventsPerStream,
                        boolean isNewData,
                        ExprEvaluatorContext exprEvaluatorContext)

Process select expressions into columns for native dispatch.

Parameters:

eventsPerStream - each stream's events

isNewData - true for new events

exprEvaluatorContext - context for expression evaluatiom

Returns:

object array with select-clause results

getExpressionTypes

public Class[] getExpressionTypes()

Returns the expression types generated by the select-clause expressions.

Returns:

types

getColumnNamesAssigned

public String[] getColumnNamesAssigned()

Returns the column names of select-clause expressions.

Returns:

column names