edu.iu.dsc.tws.comms.utils

Class HashJoinUtils

java.lang.Object

edu.iu.dsc.tws.comms.utils.HashJoinUtils

public final class HashJoinUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.util.List<java.lang.Object>	innerJoin(java.util.List<Tuple> leftRelation, java.util.List<Tuple> rightRelation, MessageType messageType)
static java.util.Iterator<JoinedTuple>	innerJoin(ResettableIterator<Tuple<?,?>> leftIt, ResettableIterator<Tuple<?,?>> rightIt, MessageType keyType)
static java.util.Iterator<JoinedTuple>	join(java.util.List<Tuple> leftRelation, java.util.List<Tuple> rightRelation, CommunicationContext.JoinType joinType, MessageType messageType)
static java.util.Iterator<JoinedTuple>	join(ResettableIterator<Tuple<?,?>> leftIt, ResettableIterator<Tuple<?,?>> rightIt, CommunicationContext.JoinType joinType, MessageType keyType) Disk based inner join
static java.util.Iterator<JoinedTuple>	leftJoin(ResettableIterator<Tuple<?,?>> leftIt, ResettableIterator<Tuple<?,?>> rightIt, MessageType keyType)
static java.util.List<java.lang.Object>	leftOuterJoin(java.util.List<Tuple> leftRelation, java.util.List<Tuple> rightRelation, MessageType messageType)
static java.util.Iterator<JoinedTuple>	rightJoin(ResettableIterator<Tuple<?,?>> leftIt, ResettableIterator<Tuple<?,?>> rightIt, MessageType keyType)
static java.util.List<java.lang.Object>	rightOuterJoin(java.util.List<Tuple> leftRelation, java.util.List<Tuple> rightRelation, MessageType messageType)

Methods inherited from class java.lang.Object

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

Method Detail

rightOuterJoin

public static java.util.List<java.lang.Object> rightOuterJoin(java.util.List<Tuple> leftRelation,
                                                              java.util.List<Tuple> rightRelation,
                                                              MessageType messageType)

leftOuterJoin

public static java.util.List<java.lang.Object> leftOuterJoin(java.util.List<Tuple> leftRelation,
                                                             java.util.List<Tuple> rightRelation,
                                                             MessageType messageType)

innerJoin

public static java.util.List<java.lang.Object> innerJoin(java.util.List<Tuple> leftRelation,
                                                         java.util.List<Tuple> rightRelation,
                                                         MessageType messageType)

innerJoin

public static java.util.Iterator<JoinedTuple> innerJoin(ResettableIterator<Tuple<?,?>> leftIt,
                                                        ResettableIterator<Tuple<?,?>> rightIt,
                                                        MessageType keyType)

leftJoin

public static java.util.Iterator<JoinedTuple> leftJoin(ResettableIterator<Tuple<?,?>> leftIt,
                                                       ResettableIterator<Tuple<?,?>> rightIt,
                                                       MessageType keyType)

rightJoin

public static java.util.Iterator<JoinedTuple> rightJoin(ResettableIterator<Tuple<?,?>> leftIt,
                                                        ResettableIterator<Tuple<?,?>> rightIt,
                                                        MessageType keyType)

join

public static java.util.Iterator<JoinedTuple> join(java.util.List<Tuple> leftRelation,
                                                   java.util.List<Tuple> rightRelation,
                                                   CommunicationContext.JoinType joinType,
                                                   MessageType messageType)

join

public static java.util.Iterator<JoinedTuple> join(ResettableIterator<Tuple<?,?>> leftIt,
                                                   ResettableIterator<Tuple<?,?>> rightIt,
                                                   CommunicationContext.JoinType joinType,
                                                   MessageType keyType)

Disk based inner join