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

Class SideInputSinkFunction<T,VT>

java.lang.Object

org.apache.beam.runners.twister2.translators.functions.SideInputSinkFunction<T,VT>

All Implemented Interfaces:

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

public class SideInputSinkFunction<T,VT>
extends java.lang.Object
implements SinkFunc<T>

Sink Function that collects results.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SideInputSinkFunction(<any> key)

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

SideInputSinkFunction

public SideInputSinkFunction(<any> key)

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