public class Filter extends java.lang.Object implements DataFlowOpLifecycle
Constructor and Description |
---|
Filter() |
Modifier and Type | Method and Description |
---|---|
void |
close(DataFlowOpCloseContext openContext) |
DataFlowOpInitializeResult |
initialize(DataFlowOpInitializateContext prepareContext) |
void |
onInput(java.lang.Object row) |
void |
open(DataFlowOpOpenContext openContext) |
public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext prepareContext) throws java.lang.Exception
initialize
in interface DataFlowOpLifecycle
java.lang.Exception
public void onInput(java.lang.Object row)
public void open(DataFlowOpOpenContext openContext)
open
in interface DataFlowOpLifecycle
public void close(DataFlowOpCloseContext openContext)
close
in interface DataFlowOpLifecycle