com.espertech.esperio.dataflow
Class FileSinkCSV

java.lang.Object
  com.espertech.esperio.dataflow.FileSinkCSV

All Implemented Interfaces:

com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle, com.espertech.esper.dataflow.interfaces.EPDataFlowSignalHandler

public class FileSinkCSV
extends java.lang.Object
implements com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle, com.espertech.esper.dataflow.interfaces.EPDataFlowSignalHandler

Constructor Summary

FileSinkCSV(java.lang.String filename, boolean classpathFile, boolean append)

Method Summary

void	close(com.espertech.esper.dataflow.interfaces.DataFlowOpCloseContext openContext)
com.espertech.esper.dataflow.interfaces.DataFlowOpInitializeResult	initialize(com.espertech.esper.dataflow.interfaces.DataFlowOpInitializateContext context)
void	onInput(java.lang.Object object)
void	onSignal(com.espertech.esper.client.dataflow.EPDataFlowSignal signal)
void	open(com.espertech.esper.dataflow.interfaces.DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSinkCSV

public FileSinkCSV(java.lang.String filename,
                   boolean classpathFile,
                   boolean append)

Method Detail

initialize

public com.espertech.esper.dataflow.interfaces.DataFlowOpInitializeResult initialize(com.espertech.esper.dataflow.interfaces.DataFlowOpInitializateContext context)
                                                                              throws java.lang.Exception

Specified by:

initialize in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle

Throws:

java.lang.Exception

open

public void open(com.espertech.esper.dataflow.interfaces.DataFlowOpOpenContext openContext)

Specified by:

open in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle

onInput

public void onInput(java.lang.Object object)

onSignal

public void onSignal(com.espertech.esper.client.dataflow.EPDataFlowSignal signal)

Specified by:

onSignal in interface com.espertech.esper.dataflow.interfaces.EPDataFlowSignalHandler

close

public void close(com.espertech.esper.dataflow.interfaces.DataFlowOpCloseContext openContext)

Specified by:

close in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle