edu.iu.dsc.tws.api.tset.fn

Class BaseSinkFunc<T>

java.lang.Object

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

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

Type Parameters:

T - data type

All Implemented Interfaces:

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

Direct Known Subclasses:

ArrowBasedSinkFunction, CacheSingleSink, DiskPersistSingleSink, StoreIterSink, StreamingCacheSink, StreamingDiskPersistSink

public abstract class BaseSinkFunc<T>
extends BaseTFunction<T,T>
implements SinkFunc<T>

Extended SinkFunc with access to TSetContext

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BaseSinkFunc()

Method Summary

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.SinkFunc

add, get

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

close, end, prepare

Constructor Detail

BaseSinkFunc

public BaseSinkFunc()