com.espertech.esper.epl.view
Class OutputProcessViewDirectDistinctOrAfter

java.lang.Object
  com.espertech.esper.epl.view.OutputProcessViewBase
      com.espertech.esper.epl.view.OutputProcessViewBaseWAfter
          com.espertech.esper.epl.view.OutputProcessViewDirectDistinctOrAfter

All Implemented Interfaces:

JoinSetIndicator, JoinSetProcessor, OutputProcessViewTerminable, EventCollection, View, Viewable, java.lang.Iterable<EventBean>

Direct Known Subclasses:

OutputProcessViewDirectDistinctOrAfterPostProcess

public class OutputProcessViewDirectDistinctOrAfter
extends OutputProcessViewBaseWAfter

Output process view that does not enforce any output policies and may simply hand over events to child views, but works with distinct and after-output policies

Field Summary

Fields inherited from class com.espertech.esper.epl.view.OutputProcessViewBaseWAfter

isAfterConditionSatisfied

Fields inherited from class com.espertech.esper.epl.view.OutputProcessViewBase

childView, joinExecutionStrategy, parentView, resultSetProcessor

Constructor Summary

OutputProcessViewDirectDistinctOrAfter(ResultSetProcessor resultSetProcessor, java.lang.Long afterConditionTime, java.lang.Integer afterConditionNumberOfEvents, boolean afterConditionSatisfied, OutputProcessViewDirectDistinctOrAfterFactory parent)

Method Summary

java.util.Iterator<EventBean>	iterator() Allows iteration through all elements in this event collection.
protected void	postProcess(boolean force, UniformPair<EventBean[]> newOldEvents, UpdateDispatchView childView)
void	process(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, ExprEvaluatorContext exprEvaluatorContext) This process (update) method is for participation in a join.
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.epl.view.OutputProcessViewBaseWAfter

checkAfterCondition, checkAfterCondition, checkAfterCondition

Methods inherited from class com.espertech.esper.epl.view.OutputProcessViewBase

addView, getEventType, getParent, getViews, hasViews, removeAllViews, removeView, setJoinExecutionStrategy, setParent

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputProcessViewDirectDistinctOrAfter

public OutputProcessViewDirectDistinctOrAfter(ResultSetProcessor resultSetProcessor,
                                              java.lang.Long afterConditionTime,
                                              java.lang.Integer afterConditionNumberOfEvents,
                                              boolean afterConditionSatisfied,
                                              OutputProcessViewDirectDistinctOrAfterFactory parent)

Method Detail

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(java.util.Set<MultiKey<EventBean>> newEvents,
                    java.util.Set<MultiKey<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 java.util.Iterator<EventBean> iterator()

Description copied from interface: EventCollection

Allows iteration through all elements in this event collection. 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()