com.espertech.esperio.csv

Class CSVInputAdapter

java.lang.Object

com.espertech.esperio.csv.AbstractCoordinatedAdapter

com.espertech.esperio.csv.CSVInputAdapter

All Implemented Interfaces:

com.espertech.esper.adapter.Adapter, com.espertech.esper.adapter.InputAdapter, CoordinatedAdapter

public class CSVInputAdapter
extends AbstractCoordinatedAdapter
implements com.espertech.esper.adapter.InputAdapter

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

Field Summary

Fields inherited from class com.espertech.esperio.csv.AbstractCoordinatedAdapter

eventsToSend, scheduleSlot, stateManager

Fields inherited from interface com.espertech.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor and Description
CSVInputAdapter(AdapterInputSource adapterInputSource, java.lang.String eventTypeName) Ctor for adapters that will be passed to an AdapterCoordinator.
CSVInputAdapter(CSVInputAdapterSpec adapterSpec) Ctor for adapters that will be passed to an AdapterCoordinator.
CSVInputAdapter(com.espertech.esper.client.EPServiceProvider epService, AdapterInputSource adapterInputSource, java.lang.String eventTypeName) Ctor.
CSVInputAdapter(com.espertech.esper.client.EPServiceProvider epService, CSVInputAdapterSpec spec) Ctor.

Method Summary

Modifier and Type	Method and Description
protected void	close() Close the CSVReader.
int	getRowCount() Returns row count.
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	setCoercer(AbstractTypeCoercer coercer) Sets the coercing provider.
void	setEPService(com.espertech.esper.client.EPServiceProvider epService) Set the epService

Methods inherited from class com.espertech.esperio.csv.AbstractCoordinatedAdapter

destroy, disallowStateTransitions, getRuntime, getState, pause, resume, setScheduleSlot, setSender, setUsingEngineThread, setUsingExternalTimer, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.espertech.esper.adapter.Adapter

destroy, getState, pause, resume, start, stop

Constructor Detail

CSVInputAdapter

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

Ctor.

Parameters:

epService - - provides the engine runtime and services

spec - - the parameters for this adapter

CSVInputAdapter

public CSVInputAdapter(com.espertech.esper.client.EPServiceProvider epService,
                       AdapterInputSource adapterInputSource,
                       java.lang.String eventTypeName)

Ctor.

Parameters:

epService - - provides the engine runtime and services

adapterInputSource - - the source of the CSV file

eventTypeName - - the type name 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,
                       java.lang.String eventTypeName)

Ctor for adapters that will be passed to an AdapterCoordinator.

Parameters:

adapterInputSource - - the parameters for this adapter

eventTypeName - - the event type name that the input adapter generates events for

Method Detail

read

public SendableEvent read()
                   throws com.espertech.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:

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

setEPService

public void setEPService(com.espertech.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

setCoercer

public void setCoercer(AbstractTypeCoercer coercer)

Sets the coercing provider.

Parameters:

coercer - to use for coercing

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

getRowCount

public int getRowCount()

Returns row count.

Returns:

row count