|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.adapter.AbstractCoordinatedAdapter
net.esper.adapter.csv.CSVInputAdapter
public class CSVInputAdapter
An event Adapter that uses a CSV file for a source.
Field Summary |
---|
Fields inherited from class net.esper.adapter.AbstractCoordinatedAdapter |
---|
eventsToSend, scheduleSlot, stateManager |
Constructor Summary | |
---|---|
CSVInputAdapter(AdapterInputSource adapterInputSource,
String eventTypeAlias)
Ctor for adapters that will be passed to an AdapterCoordinator. |
|
CSVInputAdapter(CSVInputAdapterSpec adapterSpec)
Ctor for adapters that will be passed to an AdapterCoordinator. |
|
CSVInputAdapter(net.esper.client.EPServiceProvider epService,
AdapterInputSource adapterInputSource,
String eventTypeAlias)
Ctor. |
|
CSVInputAdapter(net.esper.client.EPServiceProvider epService,
CSVInputAdapterSpec spec)
Ctor. |
Method Summary | |
---|---|
protected void |
close()
Close the CSVReader. |
SendableEvent |
read()
Get the next event in line to be sent into the runtime , or null if there is no available event. |
protected void |
replaceFirstEventToSend()
Remove the first member of eventsToSend. |
protected void |
reset()
Reset all the changeable state of this ReadableAdapter, as if it were just created. |
void |
setEPService(net.esper.client.EPServiceProvider epService)
Set the epService |
Methods inherited from class net.esper.adapter.AbstractCoordinatedAdapter |
---|
destroy, disallowStateTransitions, getState, pause, resume, setScheduleSlot, setUsingEngineThread, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface net.esper.adapter.InputAdapter |
---|
destroy, getState, pause, resume, start, stop |
Constructor Detail |
---|
public CSVInputAdapter(net.esper.client.EPServiceProvider epService, CSVInputAdapterSpec spec)
epService
- - provides the engine runtime and servicesspec
- - the parameters for this adapterpublic CSVInputAdapter(net.esper.client.EPServiceProvider epService, AdapterInputSource adapterInputSource, String eventTypeAlias)
epService
- - provides the engine runtime and servicesadapterInputSource
- - the source of the CSV fileeventTypeAlias
- - the alias of the Map event to create from the CSV datapublic CSVInputAdapter(CSVInputAdapterSpec adapterSpec)
adapterSpec
- contains parameters that specify the behavior of the input adapterpublic CSVInputAdapter(AdapterInputSource adapterInputSource, String eventTypeAlias)
adapterInputSource
- - the parameters for this adaptereventTypeAlias
- - the event type alias name that the input adapter generates events forMethod Detail |
---|
public SendableEvent read() throws net.esper.client.EPException
CoordinatedAdapter
read
in interface CoordinatedAdapter
net.esper.client.EPException
- in case of errors creating the eventpublic void setEPService(net.esper.client.EPServiceProvider epService)
CoordinatedAdapter
setEPService
in interface CoordinatedAdapter
setEPService
in class AbstractCoordinatedAdapter
epService
- - the value to setprotected void close()
close
in class AbstractCoordinatedAdapter
protected void replaceFirstEventToSend()
replaceFirstEventToSend
in class AbstractCoordinatedAdapter
protected void reset()
reset
in class AbstractCoordinatedAdapter
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |