com.espertech.esper.epl.join.base
Class JoinSetFilter

java.lang.Object
  extended by com.espertech.esper.epl.join.base.JoinSetFilter
All Implemented Interfaces:
JoinSetProcessor

public class JoinSetFilter
extends java.lang.Object
implements JoinSetProcessor

Processes join tuple set by filtering out tuples.


Constructor Summary
JoinSetFilter(ExprEvaluator filterExprNode)
          Ctor.
 
Method Summary
protected static void filter(ExprEvaluator filterExprNode, java.util.Set<MultiKey<EventBean>> events, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
          Filter event by applying the filter nodes evaluation method.
 void process(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, ExprEvaluatorContext exprEvaluatorContext)
          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(ExprEvaluator filterExprNode)
Ctor.

Parameters:
filterExprNode - - filter tree
Method Detail

process

public void process(java.util.Set<MultiKey<EventBean>> newEvents,
                    java.util.Set<MultiKey<EventBean>> oldEvents,
                    ExprEvaluatorContext exprEvaluatorContext)
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
exprEvaluatorContext - expression evaluation context

filter

protected static void filter(ExprEvaluator filterExprNode,
                             java.util.Set<MultiKey<EventBean>> events,
                             boolean isNewData,
                             ExprEvaluatorContext exprEvaluatorContext)
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)
exprEvaluatorContext - expression evaluation context

© 2006-2014 EsperTech Inc.
All rights reserved.
Visit us at espertech.com