Package 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_JSON_EVENT_TYPE, ESPERIO_MAP_EVENT_TYPE

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • 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