edu.iu.dsc.tws.tset.sinks

Class DiskPersistIterIterSink<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<T,T>

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

Type Parameters:

T - TSet data type

All Implemented Interfaces:

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

public class DiskPersistIterIterSink<T>
extends BaseDiskPersistIterSink<T,T>

A disk based persisted TSet

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DiskPersistIterIterSink(java.lang.String referencePrefix) Creates an instance of DiskPersistIterIterSink with a referencePrefix

Method Summary

Modifier and Type	Method and Description
protected T	extractValue(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

DiskPersistIterIterSink

public DiskPersistIterIterSink(java.lang.String referencePrefix)

Creates an instance of DiskPersistIterIterSink with a referencePrefix

Parameters:

referencePrefix - referencePrefix will be used to uniquely identify the set of disk partitions created with this function

Method Detail

extractValue

protected T extractValue(T input)

Description copied from class: StoreIterSink

Extracts value from an input value of the iterator

Specified by:

extractValue in class StoreIterSink<T,T>