|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.join.JoinSetFilter
public class JoinSetFilter
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 |
---|
public JoinSetFilter(ExprNode filterExprNode)
filterExprNode
- - filter treeMethod Detail |
---|
public void process(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents)
JoinSetProcessor
process
in interface JoinSetProcessor
newEvents
- - set of event tuples representing new dataoldEvents
- - set of event tuples representing old dataprotected static void filter(ExprNode filterExprNode, Set<MultiKey<EventBean>> events, boolean isNewData)
filterExprNode
- - top node of the filter expression tree.events
- - set of tuples of eventsisNewData
- - true to indicate filter new data (istream) and not old data (rstream)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |