edu.iu.dsc.tws.tset.sinks

Class StreamingCacheSink<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.StreamingCacheSink<T>

All Implemented Interfaces:

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

public class StreamingCacheSink<T>
extends BaseSinkFunc<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamingCacheSink()

Method Summary

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

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

getInput, getTSetContext

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

Constructor Detail

StreamingCacheSink

public StreamingCacheSink()

Method Detail

prepare

public void prepare(TSetContext ctx)

Description copied from interface: TFunction

Prepare the function. Use this context in case you need to add/get inputs

Specified by:

prepare in interface TFunction<T,T>

Overrides:

prepare in class BaseTFunction<T,T>

Parameters:

ctx - CONTEXT

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