edu.iu.dsc.tws.tset.links.batch

Class JoinTLink<K,VL,VR>

java.lang.Object

edu.iu.dsc.tws.tset.links.BaseTLink<T1,T0>

edu.iu.dsc.tws.tset.links.BaseTLinkWithSchema<T1,T0>

edu.iu.dsc.tws.tset.links.batch.BatchTLinkImpl<java.util.Iterator<T>,T>

edu.iu.dsc.tws.tset.links.batch.BatchIteratorLink<T>

edu.iu.dsc.tws.tset.links.batch.BatchIteratorLinkWrapper<JoinedTuple<K,VL,VR>>

edu.iu.dsc.tws.tset.links.batch.JoinTLink<K,VL,VR>

All Implemented Interfaces:

BatchTLink<java.util.Iterator<JoinedTuple<K,VL,VR>>,JoinedTuple<K,VL,VR>>, TLink<java.util.Iterator<JoinedTuple<K,VL,VR>>,JoinedTuple<K,VL,VR>>, StoringData<JoinedTuple<K,VL,VR>>, TBase, Buildable, BuildableTLink, java.io.Serializable

public class JoinTLink<K,VL,VR>
extends BatchIteratorLinkWrapper<JoinedTuple<K,VL,VR>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinTLink(BatchEnvironment env, CommunicationContext.JoinType type, java.util.Comparator<K> kComparator, TaskPartitioner<K> partitioner, TupleTSet leftT, TupleTSet rightT, JoinSchema joinSchema)
JoinTLink(BatchEnvironment env, CommunicationContext.JoinType type, java.util.Comparator<K> kComparator, TupleTSet leftT, TupleTSet rightT, JoinSchema joinSchema)

Method Summary

Modifier and Type	Method and Description
void	build(GraphBuilder graphBuilder, java.util.Collection<? extends TBase> buildSequence) Uses a different build pattern than the usual TLinks
Edge	getEdge()
protected JoinSchema	getSchema()
JoinTLink<K,VL,VR>	setName(java.lang.String name) Name of the TSet and return the same tlink
JoinTLink<K,VL,VR>	useDisk()
JoinTLink<K,VL,VR>	useHashAlgorithm()

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.BatchIteratorLinkWrapper

cache, lazyCache, lazyPersist, persist

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.BatchIteratorLink

flatmap, forEach, lazyForEach, map, mapToTuple

Methods inherited from class edu.iu.dsc.tws.tset.links.batch.BatchTLinkImpl

compute, compute, compute, compute, getTSetEnv, sink

Methods inherited from class edu.iu.dsc.tws.tset.links.BaseTLink

addChildToGraph, equals, getId, getName, getSourceParallelism, getTargetParallelism, hashCode, rename, setTSetEnv, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

getId, getName

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Constructor Detail

JoinTLink

public JoinTLink(BatchEnvironment env,
                 CommunicationContext.JoinType type,
                 java.util.Comparator<K> kComparator,
                 TupleTSet leftT,
                 TupleTSet rightT,
                 JoinSchema joinSchema)

JoinTLink

public JoinTLink(BatchEnvironment env,
                 CommunicationContext.JoinType type,
                 java.util.Comparator<K> kComparator,
                 TaskPartitioner<K> partitioner,
                 TupleTSet leftT,
                 TupleTSet rightT,
                 JoinSchema joinSchema)

Method Detail

setName

public JoinTLink<K,VL,VR> setName(java.lang.String name)

Description copied from interface: TLink

Name of the TSet and return the same tlink

Parameters:

name - name

Returns:

this tlink

getEdge

public Edge getEdge()

getSchema

protected JoinSchema getSchema()

Overrides:

getSchema in class BaseTLinkWithSchema<java.util.Iterator<JoinedTuple<K,VL,VR>>,JoinedTuple<K,VL,VR>>

build

public void build(GraphBuilder graphBuilder,
                  java.util.Collection<? extends TBase> buildSequence)

Uses a different build pattern than the usual TLinks

Parameters:

graphBuilder - graph builder

buildSequence - build seq

useHashAlgorithm

public JoinTLink<K,VL,VR> useHashAlgorithm()

useDisk

public JoinTLink<K,VL,VR> useDisk()