Package 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:

edu.iu.dsc.tws.api.compute.modifiers.Closable, edu.iu.dsc.tws.api.tset.fn.SinkFunc<T>, edu.iu.dsc.tws.api.tset.fn.TFunction<T,T>, Serializable

public class Twister2SinkFunction<T>
extends Object
implements edu.iu.dsc.tws.api.tset.fn.SinkFunc<T>

Sink Function that collects results.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Twister2SinkFunction()

Method Summary

Modifier and Type	Method	Description
boolean	add(T value)
void	close()
edu.iu.dsc.tws.api.dataset.DataPartition<?>	get()
void	prepare(edu.iu.dsc.tws.api.tset.TSetContext context)

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.compute.modifiers.Closable

reset

Constructor Details

Twister2SinkFunction

public Twister2SinkFunction()

Method Details

add

public boolean add(T value)

Specified by:

add in interface edu.iu.dsc.tws.api.tset.fn.SinkFunc<T>

close

public void close()

Specified by:

close in interface edu.iu.dsc.tws.api.compute.modifiers.Closable

Specified by:

close in interface edu.iu.dsc.tws.api.tset.fn.TFunction<T,T>

get

public edu.iu.dsc.tws.api.dataset.DataPartition<?> get()

Specified by:

get in interface edu.iu.dsc.tws.api.tset.fn.SinkFunc<T>

prepare

public void prepare(edu.iu.dsc.tws.api.tset.TSetContext context)

Specified by:

prepare in interface edu.iu.dsc.tws.api.tset.fn.TFunction<T,T>