net.esper.eql.join
Class JoinSetFilter

java.lang.Object
  extended by net.esper.eql.join.JoinSetFilter
All Implemented Interfaces:
JoinSetProcessor

public class JoinSetFilter
extends Object
implements JoinSetProcessor

Processes join tuple set by filtering out tuples.


Constructor Summary
JoinSetFilter(ExprNode filterExprNode)
          Ctor.
 
Method Summary
protected static void filter(ExprNode filterExprNode, Set<MultiKey<EventBean>> events, boolean isNewData)
          Filter event by applying the filter nodes evaluation method.
 void process(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents)
          Process join result set.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JoinSetFilter

public JoinSetFilter(ExprNode filterExprNode)
Ctor.

Parameters:
filterExprNode - - filter tree
Method Detail

process

public void process(Set<MultiKey<EventBean>> newEvents,
                    Set<MultiKey<EventBean>> oldEvents)
Description copied from interface: JoinSetProcessor
Process join result set.

Specified by:
process in interface JoinSetProcessor
Parameters:
newEvents - - set of event tuples representing new data
oldEvents - - set of event tuples representing old data

filter

protected static void filter(ExprNode filterExprNode,
                             Set<MultiKey<EventBean>> events,
                             boolean isNewData)
Filter event by applying the filter nodes evaluation method.

Parameters:
filterExprNode - - top node of the filter expression tree.
events - - set of tuples of events
isNewData - - true to indicate filter new data (istream) and not old data (rstream)