![]() | CSVInputAdapter Class |
Namespace: com.espertech.esperio.csv
public class CSVInputAdapter : AbstractCoordinatedAdapter, InputAdapter, Adapter
The CSVInputAdapter type exposes the following members.
Name | Description | |
---|---|---|
![]() | CSVInputAdapter(CSVInputAdapterSpec) |
Ctor for adapters that will be passed to an AdapterCoordinator.
|
![]() | CSVInputAdapter(AdapterInputSource, String) |
Ctor for adapters that will be passed to an AdapterCoordinator.
|
![]() | CSVInputAdapter(EPRuntime, CSVInputAdapterSpec) |
Ctor.
|
![]() | CSVInputAdapter(EPRuntime, AdapterInputSource, String) |
Ctor.
|
Name | Description | |
---|---|---|
![]() | Coercer |
Gets or sets the coercing provider.
|
![]() | ProcessEvent |
Gets the process event.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Runtime | (Overrides AbstractCoordinatedAdapterRuntime.) |
![]() | ScheduleSlot |
Gets or sets the schedule slot.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Sender |
Gets or sets the sender.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | State |
Get the state of this Adapter.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | UsingEngineThread |
Gets or sets the using engine thread.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | UsingExternalTimer |
Gets or sets a value indicating whether to use esper's external timer mechanism
instead of internal timing
(Inherited from AbstractCoordinatedAdapter.) |
![]() | UsingTimeSpanEvents |
Gets or sets a value indicating whether to use timespan events.
(Inherited from AbstractCoordinatedAdapter.) |
Name | Description | |
---|---|---|
![]() | Close |
Close the CSVReader.
(Overrides AbstractCoordinatedAdapterClose.) |
![]() | Destroy |
Dispose the Adapter, stopping the sending of all events and releasing all
the resources, and disallowing any further state changes on the Adapter.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | DisallowStateTransitions |
Disallow subsequent state changes and throw an IllegalStateTransitionException
if they are attempted.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Pause |
Pause the sending of events after a Adapter has been started.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Read | (Overrides AbstractCoordinatedAdapterRead.) |
![]() | ReplaceFirstEventToSend |
Remove the first member of eventsToSend. If there is another record in the CSV file,
insert the event created from it into eventsToSend.
(Overrides AbstractCoordinatedAdapterReplaceFirstEventToSend.) |
![]() | Reset |
Reset all the changeable state of this ReadableAdapter, as if it were just created.
(Overrides AbstractCoordinatedAdapterReset.) |
![]() | Resume |
Resume sending events after the Adapter has been paused.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Start |
Start the sending of events into the runtime egine.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | Stop |
Stop sending events and return the Adapter to the OPENED state, ready to be
started once again.
(Inherited from AbstractCoordinatedAdapter.) |
Name | Description | |
---|---|---|
![]() | EventsToSend |
Sorted events to be sent.
(Inherited from AbstractCoordinatedAdapter.) |
![]() | StateManager |
Statement management.
(Inherited from AbstractCoordinatedAdapter.) |