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

Class StreamingTLinkImpl<T1,T0>

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<T1,T0>

All Implemented Interfaces:

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

Direct Known Subclasses:

StreamingGatherLink, StreamingIteratorLink, StreamingSingleLink

public abstract class StreamingTLinkImpl<T1,T0>
extends BaseTLinkWithSchema<T1,T0>
implements StreamingTLink<T1,T0>

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
<P> SComputeTSet<P,T1>	compute(ComputeCollectorFunc<P,T1> computeFunction) Creates a Compute TSet based on the ComputeCollectorFunc provided.
<P> SComputeTSet<P,T1>	compute(ComputeFunc<P,T1> computeFunction) Creates a Compute TSet based on the ComputeFunc provided.
<P> SComputeTSet<P,T1>	compute(java.lang.String n, ComputeCollectorFunc<P,T1> computeFunction)
<P> SComputeTSet<P,T1>	compute(java.lang.String n, ComputeFunc<P,T1> computeFunction)
<P> WindowComputeTSet<P,java.util.Iterator<T1>>	countWindow(long windowLen)
<P> WindowComputeTSet<P,java.util.Iterator<T1>>	countWindow(long windowLen, long slidingLen)
StreamingEnvironment	getTSetEnv() tset env
SSinkTSet<T1>	sink(SinkFunc<T1> sinkFunction) Creates a Sink TSet based on the SinkFunc.
<P> WindowComputeTSet<P,java.util.Iterator<T1>>	timeWindow(long windowLen, java.util.concurrent.TimeUnit windowLenTimeUnit)
<P> WindowComputeTSet<P,java.util.Iterator<T1>>	timeWindow(long windowLen, java.util.concurrent.TimeUnit windowLenTimeUnit, long slidingLen, java.util.concurrent.TimeUnit slidingWindowTimeUnit)

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

flatmap, forEach, map, mapToTuple, 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

getTSetEnv

public StreamingEnvironment getTSetEnv()

Description copied from interface: Buildable

tset env

Specified by:

getTSetEnv in interface Buildable

Overrides:

getTSetEnv in class BaseTLink<T1,T0>

Returns:

tset env

compute

public <P> SComputeTSet<P,T1> compute(java.lang.String n,
                                      ComputeFunc<P,T1> computeFunction)

compute

public <P> SComputeTSet<P,T1> compute(java.lang.String n,
                                      ComputeCollectorFunc<P,T1> computeFunction)

compute

public <P> SComputeTSet<P,T1> compute(ComputeFunc<P,T1> computeFunction)

Description copied from interface: TLink

Creates a Compute TSet based on the ComputeFunc provided.

Specified by:

compute in interface StreamingTLink<T1,T0>

Specified by:

compute in interface TLink<T1,T0>

Type Parameters:

P - output tset base type

Parameters:

computeFunction - comp function. Takes in T0 type object and map to the output type O

Returns:

Compute TSet

compute

public <P> SComputeTSet<P,T1> compute(ComputeCollectorFunc<P,T1> computeFunction)

Description copied from interface: TLink

Creates a Compute TSet based on the ComputeCollectorFunc provided.

Specified by:

compute in interface StreamingTLink<T1,T0>

Specified by:

compute in interface TLink<T1,T0>

Type Parameters:

P - output type (for the RecordCollector)

Parameters:

computeFunction - compute function with collector

Returns:

Compute TSet

sink

public SSinkTSet<T1> sink(SinkFunc<T1> sinkFunction)

Description copied from interface: TLink

Creates a Sink TSet based on the SinkFunc.

Specified by:

sink in interface StreamingTLink<T1,T0>

Specified by:

sink in interface TLink<T1,T0>

Parameters:

sinkFunction - sink function which takes in <T1>. Similar to a compute, but would not return any TSet

Returns:

Sink tset. This would would be a terminal TSet with no transformation capabilities.

countWindow

public <P> WindowComputeTSet<P,java.util.Iterator<T1>> countWindow(long windowLen)

countWindow

public <P> WindowComputeTSet<P,java.util.Iterator<T1>> countWindow(long windowLen,
                                                                   long slidingLen)

timeWindow

public <P> WindowComputeTSet<P,java.util.Iterator<T1>> timeWindow(long windowLen,
                                                                  java.util.concurrent.TimeUnit windowLenTimeUnit)

timeWindow

public <P> WindowComputeTSet<P,java.util.Iterator<T1>> timeWindow(long windowLen,
                                                                  java.util.concurrent.TimeUnit windowLenTimeUnit,
                                                                  long slidingLen,
                                                                  java.util.concurrent.TimeUnit slidingWindowTimeUnit)