com.espertech.esper.dataflow.ops
Class Select

java.lang.Object
  com.espertech.esper.dataflow.ops.Select

All Implemented Interfaces:

DataFlowOpLifecycle, OutputProcessViewCallback

public class Select
extends java.lang.Object
implements OutputProcessViewCallback, DataFlowOpLifecycle

Constructor Summary

Select()

Method Summary

void	close(DataFlowOpCloseContext openContext)
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
void	onInput(int originatingStream, java.lang.Object row)
void	onSignal(EPDataFlowSignal signal)
void	open(DataFlowOpOpenContext openContext)
void	outputOutputRateLimited(UniformPair<EventBean[]> result)
void	outputViaCallback(EventBean[] events)

Methods inherited from class java.lang.Object

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

Constructor Detail

Select

public Select()

Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws ExprValidationException

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

ExprValidationException

onInput

public void onInput(int originatingStream,
                    java.lang.Object row)

onSignal

public void onSignal(EPDataFlowSignal signal)

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle

outputViaCallback

public void outputViaCallback(EventBean[] events)

Specified by:

outputViaCallback in interface OutputProcessViewCallback

outputOutputRateLimited

public void outputOutputRateLimited(UniformPair<EventBean[]> result)