com.espertech.esperio.dataflow
Class FileSourceCSV

java.lang.Object
  extended by com.espertech.esperio.dataflow.FileSourceCSV
All Implemented Interfaces:
DataFlowOpLifecycle, DataFlowSourceOperator

public class FileSourceCSV
extends java.lang.Object
implements DataFlowSourceOperator


Field Summary
protected  EPDataFlowEmitter graphContext
           
 
Constructor Summary
FileSourceCSV(AdapterInputSource adapterInputSource, boolean hasHeaderLine, boolean hasTitleLine, java.lang.Integer numLoops, java.lang.String[] propertyNames)
           
 
Method Summary
 void close(DataFlowOpCloseContext openContext)
           
 DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
           
 void next()
           
 void open(DataFlowOpOpenContext openContext)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

graphContext

protected EPDataFlowEmitter graphContext
Constructor Detail

FileSourceCSV

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

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws java.lang.Exception
Specified by:
initialize in interface DataFlowOpLifecycle
Throws:
java.lang.Exception

open

public void open(DataFlowOpOpenContext openContext)
Specified by:
open in interface DataFlowOpLifecycle

next

public void next()
Specified by:
next in interface DataFlowSourceOperator

close

public void close(DataFlowOpCloseContext openContext)
Specified by:
close in interface DataFlowOpLifecycle

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com