edu.iu.dsc.tws.tset.links.streaming

Class SKeyedPartitionTLink<K,V>

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.streaming.StreamingTLinkImpl<T,T>

edu.iu.dsc.tws.tset.links.streaming.StreamingSingleLink<Tuple<K,V>>

edu.iu.dsc.tws.tset.links.streaming.SKeyedPartitionTLink<K,V>

All Implemented Interfaces:

StreamingTLink<Tuple<K,V>,Tuple<K,V>>, TLink<Tuple<K,V>,Tuple<K,V>>, TBase, Buildable, BuildableTLink, java.io.Serializable

public class SKeyedPartitionTLink<K,V>
extends StreamingSingleLink<Tuple<K,V>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SKeyedPartitionTLink(StreamingEnvironment tSetEnv, PartitionFunc<K> parFn, int sourceParallelism, KeyedSchema schema)

Method Summary

Modifier and Type	Method and Description
Edge	getEdge()
protected KeyedSchema	getSchema()
SKeyedPartitionTLink<K,V>	setName(java.lang.String n) Name of the TSet and return the same tlink

Methods inherited from class edu.iu.dsc.tws.tset.links.streaming.StreamingSingleLink

flatmap, forEach, map, mapToTuple

Methods inherited from class edu.iu.dsc.tws.tset.links.streaming.StreamingTLinkImpl

compute, compute, compute, compute, countWindow, countWindow, getTSetEnv, sink, timeWindow, timeWindow

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.links.BuildableTLink

build

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

generateID, getTBaseGraph

Constructor Detail

SKeyedPartitionTLink

public SKeyedPartitionTLink(StreamingEnvironment tSetEnv,
                            PartitionFunc<K> parFn,
                            int sourceParallelism,
                            KeyedSchema schema)

Method Detail

getEdge

public Edge getEdge()

setName

public SKeyedPartitionTLink<K,V> setName(java.lang.String n)

Description copied from interface: TLink

Name of the TSet and return the same tlink

Parameters:

n - name

Returns:

this tlink

getSchema

protected KeyedSchema getSchema()

Overrides:

getSchema in class BaseTLinkWithSchema<Tuple<K,V>,Tuple<K,V>>