com.espertech.esperio.csv

Class AbstractCoordinatedAdapter

java.lang.Object

com.espertech.esperio.csv.AbstractCoordinatedAdapter

All Implemented Interfaces:

com.espertech.esper.runtime.client.util.Adapter, com.espertech.esper.runtime.client.util.InputAdapter, CoordinatedAdapter

Direct Known Subclasses:

AdapterCoordinatorImpl, CSVInputAdapter

public abstract class AbstractCoordinatedAdapter
extends java.lang.Object
implements CoordinatedAdapter

A skeleton implementation for coordinated adapter reading, for adapters that can do timestamp-coordinated input.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.SortedSet<SendableEvent>	eventsToSend Sorted events to be sent.
protected long	scheduleSlot Slot for scheduling.
protected com.espertech.esper.runtime.client.util.AdapterStateManager	stateManager Statement management.

Fields inherited from interface com.espertech.esper.runtime.client.util.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor and Description
AbstractCoordinatedAdapter(com.espertech.esper.runtime.client.EPRuntime runtime, boolean usingRuntimeThread, boolean usingExternalTimer, boolean usingTimeSpanEvents) Ctor.

Method Summary

Modifier and Type	Method and Description
protected abstract void	close() Perform any actions specific to this Adapter that should be completed before the Adapter is stopped.
void	destroy()
void	disallowStateTransitions() Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.
com.espertech.esper.runtime.client.EPEventService	getProcessEvent() Returns the processEvent.
com.espertech.esper.runtime.client.util.AdapterState	getState()
void	pause()
protected abstract void	replaceFirstEventToSend() Remove the first member of eventsToSend and insert another event chosen in some fashion specific to this Adapter.
protected abstract void	reset() Reset all the changeable state of this Adapter, as if it were just created.
void	resume()
void	setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime) Set the runtime
void	setScheduleSlot(long scheduleSlot) Set the scheduleSlot for this Adapter.
void	setSender(AbstractSender sender) Sets a new sender to use.
void	setUsingExternalTimer(boolean usingExternalTimer) Set to true to use esper's external timer mechanism instead of internal timing
void	setUsingRuntimeThread(boolean usingRuntimeThread) Set the usingRuntimeThread value
void	start()
void	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.esperio.csv.CoordinatedAdapter

read

Field Detail

stateManager

protected final com.espertech.esper.runtime.client.util.AdapterStateManager stateManager

Statement management.

eventsToSend

protected final java.util.SortedSet<SendableEvent> eventsToSend

Sorted events to be sent.

scheduleSlot

protected long scheduleSlot

Slot for scheduling.

Constructor Detail

AbstractCoordinatedAdapter

public AbstractCoordinatedAdapter(com.espertech.esper.runtime.client.EPRuntime runtime,
                                  boolean usingRuntimeThread,
                                  boolean usingExternalTimer,
                                  boolean usingTimeSpanEvents)

Ctor.

Parameters:

runtime - - the runtime for the runtimeprocessEvent and services

usingRuntimeThread - - true if the Adapter should set time by the scheduling service in the runtime, false if it should set time externally through the calling thread

usingExternalTimer - - true to use esper's external timer mechanism instead of internal timing

usingTimeSpanEvents - - true for time span events

Method Detail

getState

public com.espertech.esper.runtime.client.util.AdapterState getState()

Specified by:

getState in interface com.espertech.esper.runtime.client.util.Adapter

start

public void start()
           throws com.espertech.esper.common.client.EPException

Specified by:

start in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

pause

public void pause()
           throws com.espertech.esper.common.client.EPException

Specified by:

pause in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

resume

public void resume()
            throws com.espertech.esper.common.client.EPException

Specified by:

resume in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

destroy

public void destroy()
             throws com.espertech.esper.common.client.EPException

Specified by:

destroy in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

stop

public void stop()
          throws com.espertech.esper.common.client.EPException

Specified by:

stop in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

disallowStateTransitions

public void disallowStateTransitions()

Description copied from interface: CoordinatedAdapter

Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.

Specified by:

disallowStateTransitions in interface CoordinatedAdapter

setUsingRuntimeThread

public void setUsingRuntimeThread(boolean usingRuntimeThread)

Description copied from interface: CoordinatedAdapter

Set the usingRuntimeThread value

Specified by:

setUsingRuntimeThread in interface CoordinatedAdapter

Parameters:

usingRuntimeThread - - the value to set

setUsingExternalTimer

public void setUsingExternalTimer(boolean usingExternalTimer)

Set to true to use esper's external timer mechanism instead of internal timing

Specified by:

setUsingExternalTimer in interface CoordinatedAdapter

Parameters:

usingExternalTimer - true for external timer

setScheduleSlot

public void setScheduleSlot(long scheduleSlot)

Description copied from interface: CoordinatedAdapter

Set the scheduleSlot for this Adapter.

Specified by:

setScheduleSlot in interface CoordinatedAdapter

Parameters:

scheduleSlot - - the scheduleSlot to set

setRuntime

public void setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime)

Description copied from interface: CoordinatedAdapter

Set the runtime

Specified by:

setRuntime in interface CoordinatedAdapter

Parameters:

runtime - - the value to set

close

protected abstract void close()

Perform any actions specific to this Adapter that should be completed before the Adapter is stopped.

replaceFirstEventToSend

protected abstract void replaceFirstEventToSend()

Remove the first member of eventsToSend and insert another event chosen in some fashion specific to this Adapter.

reset

protected abstract void reset()

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

getProcessEvent

public com.espertech.esper.runtime.client.EPEventService getProcessEvent()

Returns the processEvent.

Returns:

processEvent

setSender

public void setSender(AbstractSender sender)

Sets a new sender to use.

Parameters:

sender - for sending