public class FileSourceCSV extends Object implements com.espertech.esper.dataflow.interfaces.DataFlowSourceOperator
Modifier and Type | Field and Description |
---|---|
protected com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter |
graphContext |
Constructor and Description |
---|
FileSourceCSV(AdapterInputSource adapterInputSource,
boolean hasHeaderLine,
boolean hasTitleLine,
Integer numLoops,
String[] propertyNames,
String dateFormat) |
Modifier and Type | Method and Description |
---|---|
void |
close(com.espertech.esper.dataflow.interfaces.DataFlowOpCloseContext openContext) |
com.espertech.esper.dataflow.interfaces.DataFlowOpInitializeResult |
initialize(com.espertech.esper.dataflow.interfaces.DataFlowOpInitializateContext context) |
void |
next() |
void |
open(com.espertech.esper.dataflow.interfaces.DataFlowOpOpenContext openContext) |
protected com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter graphContext
public FileSourceCSV(AdapterInputSource adapterInputSource, boolean hasHeaderLine, boolean hasTitleLine, Integer numLoops, String[] propertyNames, String dateFormat)
public com.espertech.esper.dataflow.interfaces.DataFlowOpInitializeResult initialize(com.espertech.esper.dataflow.interfaces.DataFlowOpInitializateContext context) throws Exception
initialize
in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle
Exception
public void open(com.espertech.esper.dataflow.interfaces.DataFlowOpOpenContext openContext)
open
in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle
public void next()
next
in interface com.espertech.esper.dataflow.interfaces.DataFlowSourceOperator
public void close(com.espertech.esper.dataflow.interfaces.DataFlowOpCloseContext openContext)
close
in interface com.espertech.esper.dataflow.interfaces.DataFlowOpLifecycle