public class DiskPersistGatherIterSink<T> extends BaseDiskPersistIterSink<Tuple<java.lang.Integer,T>,T>
Constructor and Description |
---|
DiskPersistGatherIterSink(java.lang.String referencePrefix) |
Modifier and Type | Method and Description |
---|---|
protected T |
extractValue(Tuple<java.lang.Integer,T> input)
Extracts value from an input value of the iterator
|
close, get, prepare
add
getInput, getTSetContext
public DiskPersistGatherIterSink(java.lang.String referencePrefix)
protected T extractValue(Tuple<java.lang.Integer,T> input)
StoreIterSink
extractValue
in class StoreIterSink<Tuple<java.lang.Integer,T>,T>