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

Class StreamingSingleLink<T>

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<T>

All Implemented Interfaces:

StreamingTLink<T,T>, TLink<T,T>, TBase, Buildable, BuildableTLink, java.io.Serializable

Direct Known Subclasses:

SAllReduceTLink, SDirectTLink, SKeyedDirectTLink, SKeyedPartitionTLink, SPartitionTLink, SReduceTLink, SReplicateTLink

public abstract class StreamingSingleLink<T>
extends StreamingTLinkImpl<T,T>

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
<P> SComputeTSet<P,T>	flatmap(FlatMapFunc<P,T> mapFn) Performs flat map operation based on the FlatMapFunc provided
void	forEach(ApplyFunc<T> applyFunction) Applies a function elementwise.
<P> SComputeTSet<P,T>	map(MapFunc<P,T> mapFn) Performs elementwise map operation based on the MapFunc provided
<K,O> SKeyedTSet<K,O>	mapToTuple(MapFunc<Tuple<K,O>,T> genTupleFn) Maps the data passed through the TLink to Tuple based on a MapFunc and thereby creating a TupleTSet

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.BaseTLinkWithSchema

getSchema

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.link.streaming.StreamingTLink

setName

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, getEdge

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

generateID, getTBaseGraph

Method Detail

map

public <P> SComputeTSet<P,T> map(MapFunc<P,T> mapFn)

Description copied from interface: TLink

Performs elementwise map operation based on the MapFunc provided

Type Parameters:

P - output type

Parameters:

mapFn - map function T0 to O

Returns:

Compute tset

flatmap

public <P> SComputeTSet<P,T> flatmap(FlatMapFunc<P,T> mapFn)

Description copied from interface: TLink

Performs flat map operation based on the FlatMapFunc provided

Type Parameters:

P - map function to T0 to multiple elements of <O>

Parameters:

mapFn - map function which can produce multiple elements for a single <T0> element

Returns:

Compute TSet

forEach

public void forEach(ApplyFunc<T> applyFunction)

Description copied from interface: TLink

Applies a function elementwise. Similar to compute, but the ApplyFunc does not return anything.

Parameters:

applyFunction - apply function

mapToTuple

public <K,O> SKeyedTSet<K,O> mapToTuple(MapFunc<Tuple<K,O>,T> genTupleFn)

Description copied from interface: TLink

Maps the data passed through the TLink to Tuple based on a MapFunc and thereby creating a TupleTSet

Type Parameters:

K - key type

O - value type

Parameters:

genTupleFn - MapFunc to generate a Tuple

Returns:

Keyed TSet