Package com.espertech.esper.runtime.internal.dataflow.op.select

Class SelectOp

java.lang.Object
com.espertech.esper.common.internal.view.core.ViewSupport
com.espertech.esper.runtime.internal.dataflow.op.select.SelectOp
All Implemented Interfaces:
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, 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>
public class SelectOp extends com.espertech.esper.common.internal.view.core.ViewSupport implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView

  • Field Summary

    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
    SelectOp(SelectFactory factory, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext closeContext)
     
    com.espertech.esper.common.client.EventType
    getEventType()
     
    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
    onInput(int originatingStream, Object row)
     
    void
    onSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)
     
    void
    open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)
     
    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

  • Constructor Details

    • SelectOp

      public SelectOp(SelectFactory factory, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext)

  • Method Details

    • open

      public void open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)
      Specified by:
      open in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

    • onInput

      public void onInput(int originatingStream, Object row)

    • onSignal

      public void onSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)

    • close

      public void close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext closeContext)
      Specified by:
      close in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

    • 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

    • 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

    • 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