com.espertech.esperio.csv

Interface CoordinatedAdapter

All Superinterfaces:

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

All Known Implementing Classes:

AbstractCoordinatedAdapter, AdapterCoordinatorImpl, CSVInputAdapter

public interface CoordinatedAdapter
extends com.espertech.esper.runtime.client.util.InputAdapter

An Adapter that can be coordinated by an AdapterCoordinator.

Field Summary

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

ESPERIO_MAP_EVENT_TYPE

Method Summary

Modifier and Type	Method and Description
void	disallowStateTransitions() Disallow subsequent state changes and throw an IllegalStateTransitionException if they are attempted.
SendableEvent	read() Get the next event in line to be sent into the runtime , or null if there is no available event.
void	setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime) Set the runtime
void	setScheduleSlot(long scheduleSlot) Set the scheduleSlot for this Adapter.
void	setUsingExternalTimer(boolean usingExternalTimer) Set the usingExternalTimer value
void	setUsingRuntimeThread(boolean usingRuntimeThread) Set the usingRuntimeThread value

Methods inherited from interface com.espertech.esper.runtime.client.util.Adapter

destroy, getState, pause, resume, start, stop

Method Detail

read

SendableEvent read()
            throws com.espertech.esper.common.client.EPException

Get the next event in line to be sent into the runtime , or null if there is no available event.

Returns:

an instance of SendableEvent that wraps the next event to send, or null if none

Throws:

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

setUsingRuntimeThread

void setUsingRuntimeThread(boolean usingRuntimeThread)

Set the usingRuntimeThread value

Parameters:

usingRuntimeThread - - the value to set

setUsingExternalTimer

void setUsingExternalTimer(boolean usingExternalTimer)

Set the usingExternalTimer value

Parameters:

usingExternalTimer - - the value to set

disallowStateTransitions

void disallowStateTransitions()

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

setScheduleSlot

void setScheduleSlot(long scheduleSlot)

Set the scheduleSlot for this Adapter.

Parameters:

scheduleSlot - - the scheduleSlot to set

setRuntime

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

Set the runtime

Parameters:

runtime - - the value to set