com.espertech.esper.epl.join.plan
Class InnerJoinGraph

java.lang.Object
  com.espertech.esper.epl.join.plan.InnerJoinGraph

public class InnerJoinGraph
extends java.lang.Object

Constructor Summary

InnerJoinGraph(int numStreams, boolean isAllInnerJoin)

InnerJoinGraph(int numStreams, java.util.Set<InterchangeablePair<java.lang.Integer,java.lang.Integer>> innerJoins)

Method Summary

void	addRequiredStreams(int streamNum, java.util.Set<java.lang.Integer> requiredStreams, java.util.Set<java.lang.Integer> completedStreams)
static InnerJoinGraph	graphInnerJoins(int numStreams, OuterJoinDesc[] outerJoinDescList)
boolean	hasInnerJoin(int toStream)
boolean	isAllInnerJoin()
boolean	isEmpty()

Methods inherited from class java.lang.Object

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

Constructor Detail

InnerJoinGraph

public InnerJoinGraph(int numStreams,
                      java.util.Set<InterchangeablePair<java.lang.Integer,java.lang.Integer>> innerJoins)

InnerJoinGraph

public InnerJoinGraph(int numStreams,
                      boolean isAllInnerJoin)

Method Detail

isAllInnerJoin

public boolean isAllInnerJoin()

isEmpty

public boolean isEmpty()

hasInnerJoin

public boolean hasInnerJoin(int toStream)

graphInnerJoins

public static InnerJoinGraph graphInnerJoins(int numStreams,
                                             OuterJoinDesc[] outerJoinDescList)

addRequiredStreams

public void addRequiredStreams(int streamNum,
                               java.util.Set<java.lang.Integer> requiredStreams,
                               java.util.Set<java.lang.Integer> completedStreams)