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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 com.espertech.esper.common.internal.view.core.View

getParent, setParent

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

getChild, setChild

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SelectOp

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

Method Detail

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 com.espertech.esper.common.internal.view.core.Viewable

Specified by:

iterator in interface Iterable<com.espertech.esper.common.client.EventBean>

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