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