com.espertech.esper.dataflow.ops
Class Filter

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

All Implemented Interfaces:

DataFlowOpLifecycle

public class Filter
extends java.lang.Object
implements DataFlowOpLifecycle

Constructor Summary

Filter()

Method Summary

void	close(DataFlowOpCloseContext openContext)
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext prepareContext)
void	onInput(java.lang.Object row)
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

Filter

public Filter()

Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext prepareContext)
                                      throws java.lang.Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

onInput

public void onInput(java.lang.Object row)

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle