Click or drag to resize

CSVInputAdapter Class

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

Namespace:  com.espertech.esperio.csv
Assembly:  NEsper.IO (in NEsper.IO.dll) Version: 8.0.0.0
Syntax
C#
public class CSVInputAdapter : AbstractCoordinatedAdapter, 
	InputAdapter, Adapter

The CSVInputAdapter type exposes the following members.

Constructors
  NameDescription
Public methodCSVInputAdapter(CSVInputAdapterSpec)
Ctor for adapters that will be passed to an AdapterCoordinator.
Public methodCSVInputAdapter(AdapterInputSource, String)
Ctor for adapters that will be passed to an AdapterCoordinator.
Public methodCSVInputAdapter(EPRuntime, CSVInputAdapterSpec)
Ctor.
Public methodCSVInputAdapter(EPRuntime, AdapterInputSource, String)
Ctor.
Top
Properties
  NameDescription
Public propertyCoercer
Gets or sets the coercing provider.
Public propertyProcessEvent
Gets the process event.
(Inherited from AbstractCoordinatedAdapter.)
Public propertyRuntime (Overrides AbstractCoordinatedAdapterRuntime.)
Public propertyScheduleSlot
Gets or sets the schedule slot.
(Inherited from AbstractCoordinatedAdapter.)
Public propertySender
Gets or sets the sender.
(Inherited from AbstractCoordinatedAdapter.)
Public propertyState
Get the state of this Adapter.
(Inherited from AbstractCoordinatedAdapter.)
Public propertyUsingEngineThread
Gets or sets the using engine thread.
(Inherited from AbstractCoordinatedAdapter.)
Public propertyUsingExternalTimer
Gets or sets a value indicating whether to use esper's external timer mechanism instead of internal timing
(Inherited from AbstractCoordinatedAdapter.)
Public propertyUsingTimeSpanEvents
Gets or sets a value indicating whether to use timespan events.
(Inherited from AbstractCoordinatedAdapter.)
Top
Methods
  NameDescription
Protected methodClose
Close the CSVReader.
(Overrides AbstractCoordinatedAdapterClose.)
Public methodDestroy
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.)
Public methodDisallowStateTransitions
Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.
(Inherited from AbstractCoordinatedAdapter.)
Public methodPause
Pause the sending of events after a Adapter has been started.
(Inherited from AbstractCoordinatedAdapter.)
Public methodRead (Overrides AbstractCoordinatedAdapterRead.)
Protected methodReplaceFirstEventToSend
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.)
Protected methodReset
Reset all the changeable state of this ReadableAdapter, as if it were just created.
(Overrides AbstractCoordinatedAdapterReset.)
Public methodResume
Resume sending events after the Adapter has been paused.
(Inherited from AbstractCoordinatedAdapter.)
Public methodStart
Start the sending of events into the runtime egine.
(Inherited from AbstractCoordinatedAdapter.)
Public methodStop
Stop sending events and return the Adapter to the OPENED state, ready to be started once again.
(Inherited from AbstractCoordinatedAdapter.)
Top
Fields
  NameDescription
Protected fieldEventsToSend
Sorted events to be sent.
(Inherited from AbstractCoordinatedAdapter.)
Protected fieldStateManager
Statement management.
(Inherited from AbstractCoordinatedAdapter.)
Top
See Also