Package com.espertech.esper.common.internal.epl.output.view

Class OutputProcessViewDirect

java.lang.Object

com.espertech.esper.common.internal.epl.output.core.OutputProcessView

com.espertech.esper.common.internal.epl.output.view.OutputProcessViewDirect

All Implemented Interfaces:

AgentInstanceMgmtCallback, JoinSetIndicator, JoinSetProcessor, OutputProcessViewTerminable, View, Viewable, Iterable<EventBean>

Direct Known Subclasses:

OutputProcessViewDirectPostProcess

public class OutputProcessViewDirect
extends OutputProcessView

Output process view that does not enforce any output policies and may simply hand over events to child views, does not handle distinct.

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.output.core.OutputProcessView

child, EPTYPE, joinExecutionStrategy, parentView

Fields inherited from interface com.espertech.esper.common.internal.context.util.AgentInstanceMgmtCallback

INSTANCE_NO_ACTION

Constructor Summary

Constructors

Constructor	Description
OutputProcessViewDirect(AgentInstanceContext agentInstanceContext, ResultSetProcessor resultSetProcessor)

Method Summary

Modifier and Type	Method	Description
EventType	getEventType()	Provides metadata information about the type of object the event collection contains.
int	getNumChangesetRows()
OutputCondition	getOptionalOutputCondition()
Iterator<EventBean>	iterator()	Allows iteration through all elements in this viewable.
protected void	postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)
void	process(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents, ExprEvaluatorContext exprEvaluatorContext)	This process (update) method is for participation in a join.
void	stop(AgentInstanceStopServices services)
void	terminated()
void	update(EventBean[] newData, EventBean[] oldData)	The update method is called if the view does not participate in a join.

Methods inherited from class com.espertech.esper.common.internal.epl.output.core.OutputProcessView

getChild, getParent, setChild, setJoinExecutionStrategy, 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.context.util.AgentInstanceMgmtCallback

transfer

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

OutputProcessViewDirect

public OutputProcessViewDirect(AgentInstanceContext agentInstanceContext,
 ResultSetProcessor resultSetProcessor)

Method Details

getNumChangesetRows

public int getNumChangesetRows()

Specified by:

getNumChangesetRows in class OutputProcessView

getOptionalOutputCondition

public OutputCondition getOptionalOutputCondition()

Specified by:

getOptionalOutputCondition in class OutputProcessView

getEventType

public EventType getEventType()

Description copied from interface: Viewable

Provides metadata information about the type of object the event collection contains.

Returns:

metadata for the objects in the collection

update

public void update(EventBean[] newData,
 EventBean[] oldData)

The update method is called if the view does not participate in a join.

Parameters:

newData - - new events

oldData - - old events

process

public void process(Set<MultiKeyArrayOfKeys<EventBean>> newEvents,
 Set<MultiKeyArrayOfKeys<EventBean>> oldEvents,
 ExprEvaluatorContext exprEvaluatorContext)

This process (update) method is for participation in a join.

Parameters:

newEvents - - new events

oldEvents - - old events

exprEvaluatorContext - expression evaluation context

postProcess

protected void postProcess(boolean force,
 UniformPair<EventBean[]> newOldEvents,
 UpdateDispatchView childView)

iterator

public Iterator<EventBean> iterator()

Description copied from interface: Viewable

Allows iteration through all elements in this viewable. The iterator will return the elements in the collection in their natural order, or, if there is no natural ordering, in some unpredictable order.

Returns:

an iterator which will go through all current elements in the collection.

terminated

public void terminated()

stop

public void stop(AgentInstanceStopServices services)