net.esper.adapter.csv
Class CSVInputAdapter

java.lang.Object
  net.esper.adapter.AbstractCoordinatedAdapter
      net.esper.adapter.csv.CSVInputAdapter

All Implemented Interfaces:

Adapter, CoordinatedAdapter, InputAdapter

public class CSVInputAdapter
extends AbstractCoordinatedAdapter
implements InputAdapter

An event Adapter that uses a CSV file for a source.

Field Summary

Fields inherited from class net.esper.adapter.AbstractCoordinatedAdapter

eventsToSend, scheduleSlot, stateManager

Fields inherited from interface net.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

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.Adapter

destroy, getState, pause, resume, start, stop

Constructor Detail

CSVInputAdapter

public CSVInputAdapter(net.esper.client.EPServiceProvider epService,
                       CSVInputAdapterSpec spec)

Ctor.

Parameters:

epService - - provides the engine runtime and services

spec - - the parameters for this adapter

CSVInputAdapter

public CSVInputAdapter(net.esper.client.EPServiceProvider epService,
                       AdapterInputSource adapterInputSource,
                       String eventTypeAlias)

Ctor.

Parameters:

epService - - provides the engine runtime and services

adapterInputSource - - the source of the CSV file

eventTypeAlias - - the alias of the Map event to create from the CSV data

CSVInputAdapter

public CSVInputAdapter(CSVInputAdapterSpec adapterSpec)

Ctor for adapters that will be passed to an AdapterCoordinator.

Parameters:

adapterSpec - contains parameters that specify the behavior of the input adapter

CSVInputAdapter

public CSVInputAdapter(AdapterInputSource adapterInputSource,
                       String eventTypeAlias)

Ctor for adapters that will be passed to an AdapterCoordinator.

Parameters:

adapterInputSource - - the parameters for this adapter

eventTypeAlias - - the event type alias name that the input adapter generates events for

Method Detail

read

public SendableEvent read()
                   throws net.esper.client.EPException

Description copied from interface: CoordinatedAdapter

Get the next event in line to be sent into the runtime , or null if there is no available event.

Specified by:

read in interface CoordinatedAdapter

Returns:

an instance of SendableEvent that wraps the next event to send, or null if none

Throws:

net.esper.client.EPException - in case of errors creating the event

setEPService

public void setEPService(net.esper.client.EPServiceProvider epService)

Description copied from interface: CoordinatedAdapter

Set the epService

Specified by:

setEPService in interface CoordinatedAdapter

Overrides:

setEPService in class AbstractCoordinatedAdapter

Parameters:

epService - - the value to set

close

protected void close()

Close the CSVReader.

Specified by:

close in class AbstractCoordinatedAdapter

replaceFirstEventToSend

protected void replaceFirstEventToSend()

Remove the first member of eventsToSend. If there is another record in the CSV file, insert the event created from it into eventsToSend.

Specified by:

replaceFirstEventToSend in class AbstractCoordinatedAdapter

reset

protected void reset()

Reset all the changeable state of this ReadableAdapter, as if it were just created.

Specified by:

reset in class AbstractCoordinatedAdapter