edu.iu.dsc.tws.tset.sinks

Class CacheSingleSink<T>

java.lang.Object

edu.iu.dsc.tws.api.tset.fn.BaseTFunction<T,T>

edu.iu.dsc.tws.api.tset.fn.BaseSinkFunc<T>

edu.iu.dsc.tws.tset.sinks.CacheSingleSink<T>

All Implemented Interfaces:

SinkFunc<T>, TFunction<T,T>, java.io.Serializable

public class CacheSingleSink<T>
extends BaseSinkFunc<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CacheSingleSink()

Method Summary

Modifier and Type	Method and Description
boolean	add(T value) Every time an edge produces a value, this method is called.
EntityPartition<T>	get() Return the data partition associated with this task instance.

Methods inherited from class edu.iu.dsc.tws.api.tset.fn.BaseTFunction

getInput, getTSetContext, prepare

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction

close, end, prepare

Constructor Detail

CacheSingleSink

public CacheSingleSink()

Method Detail

add

public boolean add(T value)

Description copied from interface: SinkFunc

Every time an edge produces a value, this method is called.

Parameters:

value - the value to add

Returns:

true if success

get

public EntityPartition<T> get()

Description copied from interface: SinkFunc

Return the data partition associated with this task instance. Specifically to be used for caching functionality.

Returns:

data partition - type remains unknown as the output of sunk data can be a different type than T. Example, caching gatherTlink,T -> Tuple<int, T> but the output would be T