org.apache.beam.runners.twister2.translators.functions

Class Twister2SinkFunction<T>

java.lang.Object

org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction<T>

All Implemented Interfaces:

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

public class Twister2SinkFunction<T>
extends java.lang.Object
implements SinkFunc<T>

Sink Function that collects results.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Twister2SinkFunction()

Method Summary

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

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

end

Constructor Detail

Twister2SinkFunction

public Twister2SinkFunction()

Method Detail

add

public boolean add(T value)

Description copied from interface: SinkFunc

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

Specified by:

add in interface SinkFunc<T>

Parameters:

value - the value to add

Returns:

true if success

close

public void close()

Specified by:

close in interface TFunction<T,T>

get

public DataPartition<?> get()

Description copied from interface: SinkFunc

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

Specified by:

get in interface SinkFunc<T>

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

prepare

public void prepare(TSetContext context)

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>

Parameters:

context - CONTEXT