edu.iu.dsc.tws.tset.sinks

Class DiskPersistGatherIterSink<T>

java.lang.Object

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

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

edu.iu.dsc.tws.tset.sinks.StoreIterSink<T,T1>

edu.iu.dsc.tws.tset.sinks.BaseDiskPersistIterSink<Tuple<java.lang.Integer,T>,T>

edu.iu.dsc.tws.tset.sinks.DiskPersistGatherIterSink<T>

All Implemented Interfaces:

SinkFunc<java.util.Iterator<Tuple<java.lang.Integer,T>>>, TFunction<java.util.Iterator<Tuple<java.lang.Integer,T>>,java.util.Iterator<Tuple<java.lang.Integer,T>>>, java.io.Serializable

public class DiskPersistGatherIterSink<T>
extends BaseDiskPersistIterSink<Tuple<java.lang.Integer,T>,T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DiskPersistGatherIterSink(java.lang.String referencePrefix)

Method Summary

Modifier and Type	Method and Description
protected T	extractValue(Tuple<java.lang.Integer,T> input) Extracts value from an input value of the iterator

Methods inherited from class edu.iu.dsc.tws.tset.sinks.BaseDiskPersistIterSink

close, get, prepare

Methods inherited from class edu.iu.dsc.tws.tset.sinks.StoreIterSink

add

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

end

Constructor Detail

DiskPersistGatherIterSink

public DiskPersistGatherIterSink(java.lang.String referencePrefix)

Method Detail

extractValue

protected T extractValue(Tuple<java.lang.Integer,T> input)

Description copied from class: StoreIterSink

Extracts value from an input value of the iterator

Specified by:

extractValue in class StoreIterSink<Tuple<java.lang.Integer,T>,T>