public class FileSinkCSV
extends java.lang.Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowSignalHandler
Constructor and Description |
---|
FileSinkCSV(FileSinkFactory factory,
java.lang.String filename,
boolean classpathFile,
boolean append) |
Modifier and Type | Method and Description |
---|---|
void |
close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext) |
void |
onInput(java.lang.Object object) |
void |
onSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal) |
void |
open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext) |
public FileSinkCSV(FileSinkFactory factory, java.lang.String filename, boolean classpathFile, boolean append)
public void open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)
open
in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle
public void onInput(java.lang.Object object)
public void onSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)
onSignal
in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowSignalHandler
public void close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)
close
in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle