Package com.espertech.esper.runtime.internal.kernel.updatedispatch

Class UpdateDispatchViewBase

java.lang.Object
com.espertech.esper.common.internal.view.core.ViewSupport
com.espertech.esper.runtime.internal.kernel.updatedispatch.UpdateDispatchViewBase
All Implemented Interfaces:
com.espertech.esper.common.internal.statement.dispatch.Dispatchable, com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView, com.espertech.esper.common.internal.view.core.View, com.espertech.esper.common.internal.view.core.Viewable, Iterable<com.espertech.esper.common.client.EventBean>
Direct Known Subclasses:
UpdateDispatchViewBlockingSpin, UpdateDispatchViewBlockingWait, UpdateDispatchViewNonBlocking
public abstract class UpdateDispatchViewBase extends com.espertech.esper.common.internal.view.core.ViewSupport implements com.espertech.esper.common.internal.statement.dispatch.Dispatchable, com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView
Convenience view for dispatching view updates received from a parent view to update listeners via the dispatch service.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final com.espertech.esper.common.internal.statement.dispatch.DispatchService
    dispatchService
    Dispatches events to listeners.
    protected final com.espertech.esper.common.client.EventType
    eventType
     
    protected com.espertech.esper.common.client.EventBean
    lastIterableEvent
    For iteration with patterns.
    protected final com.espertech.esper.common.internal.context.util.StatementResultService
    statementResultService
    Handles result delivery

    Fields inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

    child, parent

    Fields inherited from interface com.espertech.esper.common.internal.view.core.Viewable

    EPTYPE

  • Constructor Summary

    Constructors
    Constructor
    Description
    UpdateDispatchViewBase(com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.context.util.StatementResultService statementResultServiceImpl, com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService)
    Ctor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cancelled()
     
    void
    clear()
    Remove event reference to last event.
    void
    execute()
     
    com.espertech.esper.common.client.EventType
    getEventType()
     
    com.espertech.esper.common.internal.context.util.StatementResultService
    getStatementResultService()
     
    com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView
    getView()
     
    Iterator<com.espertech.esper.common.client.EventBean>
    iterator()
     
    void
    newResult(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)
     
    void
    update(com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData)
     

    Methods inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

    getChild, getParent, setChild, setParent

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface java.lang.Iterable

    forEach, spliterator

    Methods inherited from interface com.espertech.esper.common.internal.view.core.View

    getParent, setParent

    Methods inherited from interface com.espertech.esper.common.internal.view.core.Viewable

    getChild, setChild

  • Field Details

    • eventType

      protected final com.espertech.esper.common.client.EventType eventType

    • statementResultService

      protected final com.espertech.esper.common.internal.context.util.StatementResultService statementResultService
      Handles result delivery

    • dispatchService

      protected final com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService
      Dispatches events to listeners.

    • lastIterableEvent

      protected com.espertech.esper.common.client.EventBean lastIterableEvent
      For iteration with patterns.

  • Constructor Details

    • UpdateDispatchViewBase

      public UpdateDispatchViewBase(com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.context.util.StatementResultService statementResultServiceImpl, com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService)
      Ctor.
      Parameters:
      dispatchService - - for performing the dispatch
      statementResultServiceImpl - - handles result delivery
      eventType - event type

  • Method Details

    • getEventType

      public com.espertech.esper.common.client.EventType getEventType()
      Specified by:
      getEventType in interface com.espertech.esper.common.internal.view.core.Viewable

    • iterator

      public Iterator<com.espertech.esper.common.client.EventBean> iterator()
      Specified by:
      iterator in interface Iterable<com.espertech.esper.common.client.EventBean>
      Specified by:
      iterator in interface com.espertech.esper.common.internal.view.core.Viewable

    • execute

      public void execute()
      Specified by:
      execute in interface com.espertech.esper.common.internal.statement.dispatch.Dispatchable

    • clear

      public void clear()
      Remove event reference to last event.

    • getStatementResultService

      public com.espertech.esper.common.internal.context.util.StatementResultService getStatementResultService()

    • getView

      public com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView getView()
      Specified by:
      getView in interface com.espertech.esper.common.internal.statement.dispatch.Dispatchable

    • newResult

      public void newResult(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)
      Specified by:
      newResult in interface com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView

    • update

      public void update(com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData)
      Specified by:
      update in interface com.espertech.esper.common.internal.view.core.View

    • cancelled

      public void cancelled()
      Specified by:
      cancelled in interface com.espertech.esper.common.internal.statement.dispatch.Dispatchable