com.espertech.esperio.dataflow
Class FileSourceCSV

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

All Implemented Interfaces:

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

public class FileSourceCSV
extends java.lang.Object
implements com.espertech.esper.dataflow.interfaces.DataFlowSourceOperator

Field Summary

protected com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter

graphContext

Constructor Summary

FileSourceCSV(AdapterInputSource adapterInputSource, boolean hasHeaderLine, boolean hasTitleLine, java.lang.Integer numLoops, java.lang.String[] propertyNames, java.lang.String dateFormat)

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	next()
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

Field Detail

graphContext

protected com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter graphContext

Constructor Detail

FileSourceCSV

public FileSourceCSV(AdapterInputSource adapterInputSource,
                     boolean hasHeaderLine,
                     boolean hasTitleLine,
                     java.lang.Integer numLoops,
                     java.lang.String[] propertyNames,
                     java.lang.String dateFormat)

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

next

public void next()

Specified by:

next in interface com.espertech.esper.dataflow.interfaces.DataFlowSourceOperator

close

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

Specified by:

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