A C D E G I M N P R S T V

A

AbstractCoordinatedAdapter - Class in net.esper.adapter
A skeleton implementation of the ReadableAdapter interface.
AbstractCoordinatedAdapter(EPServiceProvider, boolean) - Constructor for class net.esper.adapter.AbstractCoordinatedAdapter
Ctor.
AdapterCoordinator - Interface in net.esper.adapter
A AdapterCoordinator coordinates several Adapters so that the events they send into the runtime engine arrive in some well-defined order, in effect making the several Adapters into one large sending Adapter.
AdapterCoordinatorImpl - Class in net.esper.adapter
An implementation of AdapterCoordinator.
AdapterCoordinatorImpl(EPServiceProvider, boolean) - Constructor for class net.esper.adapter.AdapterCoordinatorImpl
Ctor.
AdapterInputSource - Class in net.esper.adapter
An input source for adapters.
AdapterInputSource(String) - Constructor for class net.esper.adapter.AdapterInputSource
Ctor.
AdapterInputSource(URL) - Constructor for class net.esper.adapter.AdapterInputSource
Ctor.
AdapterInputSource(File) - Constructor for class net.esper.adapter.AdapterInputSource
Ctor.
AdapterInputSource(InputStream) - Constructor for class net.esper.adapter.AdapterInputSource
Ctor.
AdapterInputSource(Reader) - Constructor for class net.esper.adapter.AdapterInputSource
 
AdapterState - Enum in net.esper.adapter
The state of a Adapter.
AdapterStateManager - Class in net.esper.adapter
A utility to manage the state transitions for an InputAdapter.
AdapterStateManager() - Constructor for class net.esper.adapter.AdapterStateManager
 

C

close() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
Perform any actions specific to this Adapter that should be completed before the Adapter is stopped.
close() - Method in class net.esper.adapter.AdapterCoordinatorImpl
Does nothing.
close() - Method in class net.esper.adapter.csv.CSVInputAdapter
Close the CSVReader.
close() - Method in class net.esper.adapter.csv.CSVReader
Close the source and release the input source.
close() - Method in class net.esper.adapter.csv.CSVSource
Close the underlying resource.
compare(SendableEvent, SendableEvent) - Method in class net.esper.adapter.SendableEventComparator
 
coordinate(InputAdapter) - Method in interface net.esper.adapter.AdapterCoordinator
Coordinate an InputAdapter.
coordinate(InputAdapter) - Method in class net.esper.adapter.AdapterCoordinatorImpl
 
CoordinatedAdapter - Interface in net.esper.adapter
An Adapter that can be coordinated by an AdapterCoordinator.
CSVInputAdapter - Class in net.esper.adapter.csv
An event Adapter that uses a CSV file for a source.
CSVInputAdapter(EPServiceProvider, CSVInputAdapterSpec) - Constructor for class net.esper.adapter.csv.CSVInputAdapter
Ctor.
CSVInputAdapter(EPServiceProvider, AdapterInputSource, String) - Constructor for class net.esper.adapter.csv.CSVInputAdapter
Ctor.
CSVInputAdapter(CSVInputAdapterSpec) - Constructor for class net.esper.adapter.csv.CSVInputAdapter
Ctor for adapters that will be passed to an AdapterCoordinator.
CSVInputAdapter(AdapterInputSource, String) - Constructor for class net.esper.adapter.csv.CSVInputAdapter
Ctor for adapters that will be passed to an AdapterCoordinator.
CSVInputAdapterSpec - Class in net.esper.adapter.csv
A spec for CSVAdapters.
CSVInputAdapterSpec(AdapterInputSource, String) - Constructor for class net.esper.adapter.csv.CSVInputAdapterSpec
Ctor.
CSVPropertyOrderHelper - Class in net.esper.adapter.csv
A utility for resolving property order information based on a propertyTypes map and the first record of a CSV file (which might represent the title row).
CSVPropertyOrderHelper() - Constructor for class net.esper.adapter.csv.CSVPropertyOrderHelper
 
CSVReader - Class in net.esper.adapter.csv
A source that processes a CSV file and returns CSV records from that file.
CSVReader(AdapterInputSource) - Constructor for class net.esper.adapter.csv.CSVReader
Ctor.
CSVSource - Class in net.esper.adapter.csv
A wrapper for a Reader or an InputStream.
CSVSource(AdapterInputSource) - Constructor for class net.esper.adapter.csv.CSVSource
Ctor.

D

destroy() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
destroy() - Method in class net.esper.adapter.AdapterStateManager
Transition into the DESTROYED state.
destroy() - Method in interface net.esper.adapter.InputAdapter
Destroy the InputAdapter, stopping the sending of all events and releasing all the resources, and disallowing any further state changes on the InputAdapter.
disallowStateTransitions() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
disallowStateTransitions() - Method in class net.esper.adapter.AdapterStateManager
Disallow future state changes, and throw an IllegalStateTransitionException if they are attempted.
disallowStateTransitions() - Method in interface net.esper.adapter.CoordinatedAdapter
Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.

E

eventsToSend - Variable in class net.esper.adapter.AbstractCoordinatedAdapter
 

G

getAdapterInputSource() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
getAndClearIsReset() - Method in class net.esper.adapter.csv.CSVReader
Return and set to false the isReset value, which is set to true whenever the CSVReader is reset.
getAsReader() - Method in class net.esper.adapter.AdapterInputSource
Return the reader if it was set, null otherwise.
getAsStream() - Method in class net.esper.adapter.AdapterInputSource
Get the resource as an input stream.
getEventsPerSec() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
getEventTypeAlias() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
getNextRecord() - Method in class net.esper.adapter.csv.CSVReader
Get the next record from the CSV file.
getPropertyOrder() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
getPropertyTypes() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
getScheduleSlot() - Method in interface net.esper.adapter.SendableEvent
Get the schedule slot for the entity that created this event
getScheduleSlot() - Method in class net.esper.adapter.SendableMapEvent
 
getSendTime() - Method in interface net.esper.adapter.SendableEvent
Get the send time of this event, relative to all the other events sent or read by the same entity
getSendTime() - Method in class net.esper.adapter.SendableMapEvent
 
getState() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
getState() - Method in class net.esper.adapter.AdapterStateManager
 
getState() - Method in interface net.esper.adapter.InputAdapter
Get the state of this InputAdapter.
getTimestampColumn() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 

I

IllegalStateTransitionException - Exception in net.esper.adapter
Thrown when an illegal Adapter state transition is attempted.
IllegalStateTransitionException(String) - Constructor for exception net.esper.adapter.IllegalStateTransitionException
 
InputAdapter - Interface in net.esper.adapter
An InputAdapter takes some external data, converts it into events, and sends it into the runtime engine.
isLooping() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
isResettable() - Method in class net.esper.adapter.AdapterInputSource
Return true if calling getStream() will return a new InputStream created from the resource, which, assuming that the resource hasn't been changed, will have the same information as all the previous InputStreams returned by getStream() before they were manipulated; return false if the call will return the same instance of InputStream that has already been obtained.
isResettable() - Method in class net.esper.adapter.csv.CSVReader
Return true if this CSVReader supports the reset() method.
isResettable() - Method in class net.esper.adapter.csv.CSVSource
Return true if the underlying resource is resettable.
isUsingEngineThread() - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 

M

mark(int) - Method in class net.esper.adapter.csv.CSVSource
Set the mark position.

N

net.esper.adapter - package net.esper.adapter
This package contains adapter framework classes applicable to multiple adapter implementations.
net.esper.adapter.csv - package net.esper.adapter.csv
CSV input adapter classes for reading comma-separated-value formatted data and for CSV-based simulatation of events streams

P

pause() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
pause() - Method in class net.esper.adapter.AdapterStateManager
Transition into the PAUSED state.
pause() - Method in interface net.esper.adapter.InputAdapter
Pause the sending of events after a Adapter has been started.

R

read() - Method in class net.esper.adapter.AdapterCoordinatorImpl
 
read() - Method in interface net.esper.adapter.CoordinatedAdapter
Get the next event in line to be sent into the runtime , or null if there is no available event.
read() - Method in class net.esper.adapter.csv.CSVInputAdapter
 
read() - Method in class net.esper.adapter.csv.CSVSource
Read from the underlying resource.
replaceFirstEventToSend() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
Remove the first member of eventsToSend and insert another event chosen in some fashion specific to this Adapter.
replaceFirstEventToSend() - Method in class net.esper.adapter.AdapterCoordinatorImpl
Replace the first member of eventsToSend with the next event returned by the read() method of the same Adapter that provided the first event.
replaceFirstEventToSend() - Method in class net.esper.adapter.csv.CSVInputAdapter
Remove the first member of eventsToSend.
reset() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
Reset all the changeable state of this Adapter, as if it were just created.
reset() - Method in class net.esper.adapter.AdapterCoordinatorImpl
Reset all the changeable state of this ReadableAdapter, as if it were just created.
reset() - Method in class net.esper.adapter.csv.CSVInputAdapter
Reset all the changeable state of this ReadableAdapter, as if it were just created.
reset() - Method in class net.esper.adapter.csv.CSVReader
Reset the source to the beginning of the file.
reset() - Method in class net.esper.adapter.csv.CSVSource
Reset to the beginning of the resource.
resetToMark() - Method in class net.esper.adapter.csv.CSVSource
Reset to the last mark position.
resolvePropertyOrder(String[], Map<String, Class>) - Static method in class net.esper.adapter.csv.CSVPropertyOrderHelper
Resolve the order of the properties that appear in the CSV file, from the first row of the CSV file.
resume() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
resume() - Method in class net.esper.adapter.AdapterStateManager
Transition into the STARTED state (from the PAUSED state).
resume() - Method in interface net.esper.adapter.InputAdapter
Resume sending events after the InputAdapter has been paused.

S

scheduleSlot - Variable in class net.esper.adapter.AbstractCoordinatedAdapter
 
send(EPRuntime) - Method in interface net.esper.adapter.SendableEvent
Send the event into the runtime.
send(EPRuntime) - Method in class net.esper.adapter.SendableMapEvent
 
SendableEvent - Interface in net.esper.adapter
A wrapper that packages an event up so that it can be sent into the caller-specified runtime.
SendableEventComparator - Class in net.esper.adapter
A comparator that orders SendableEvents first on sendTime, and then on schedule slot.
SendableEventComparator() - Constructor for class net.esper.adapter.SendableEventComparator
 
SendableMapEvent - Class in net.esper.adapter
An implementation of SendableEvent that wraps a Map event for sending into the runtime.
SendableMapEvent(Map<String, Object>, String, long, ScheduleSlot) - Constructor for class net.esper.adapter.SendableMapEvent
Ctor.
setAdapterInputSource(AdapterInputSource) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
setEPService(EPServiceProvider) - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
setEPService(EPServiceProvider) - Method in interface net.esper.adapter.CoordinatedAdapter
Set the epService
setEPService(EPServiceProvider) - Method in class net.esper.adapter.csv.CSVInputAdapter
 
setEventsPerSec(int) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
Sets the number of events per seconds.
setEventTypeAlias(String) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
setIsUsingTitleRow(boolean) - Method in class net.esper.adapter.csv.CSVReader
Set the isUsingTitleRow value.
setLooping(boolean) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
setLooping(boolean) - Method in class net.esper.adapter.csv.CSVReader
Set the looping value.
setPropertyOrder(String[]) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
setPropertyTypes(Map<String, Class>) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
Set the propertyTypes value
setScheduleSlot(ScheduleSlot) - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
setScheduleSlot(ScheduleSlot) - Method in interface net.esper.adapter.CoordinatedAdapter
Set the scheduleSlot for this Adapter.
setTimestampColumn(String) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
Set the timestamp column name.
setUsingEngineThread(boolean) - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
setUsingEngineThread(boolean) - Method in interface net.esper.adapter.CoordinatedAdapter
Set the usingEngineThread value
setUsingEngineThread(boolean) - Method in class net.esper.adapter.csv.CSVInputAdapterSpec
 
start() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
start() - Method in class net.esper.adapter.AdapterStateManager
Transition into the STARTED state (from the OPENED state).
start() - Method in interface net.esper.adapter.InputAdapter
Start the sending of events into the runtime egine.
stateManager - Variable in class net.esper.adapter.AbstractCoordinatedAdapter
 
stop() - Method in class net.esper.adapter.AbstractCoordinatedAdapter
 
stop() - Method in class net.esper.adapter.AdapterStateManager
Transition into the OPENED state.
stop() - Method in interface net.esper.adapter.InputAdapter
Stop sending events and return the Adapter to the OPENED state, ready to be started once again.

T

toString() - Method in class net.esper.adapter.SendableMapEvent
 

V

valueOf(String) - Static method in enum net.esper.adapter.AdapterState
Returns the enum constant of this type with the specified name.
values() - Static method in enum net.esper.adapter.AdapterState
Returns an array containing the constants of this enum type, in the order they're declared.

A C D E G I M N P R S T V