public class DiskPersistGatherSink<T> extends StoreIterSink<Tuple<java.lang.Integer,T>,T>
StoreIterSink.ValueExtractor<O,I>
Constructor and Description |
---|
DiskPersistGatherSink() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close method for cleaning up the resources
|
protected DiskBackedCollectionPartition<T> |
getPartition()
Returns the
CollectionPartition that would accept the values. |
protected StoreIterSink.ValueExtractor<T,Tuple<java.lang.Integer,T>> |
getValueExtractor()
A map function that would extract value type T1 from input type T
|
void |
prepare(TSetContext ctx)
Prepare the function.
|
add, get
getInput, getTSetContext
public void prepare(TSetContext ctx)
TFunction
prepare
in interface TFunction<java.util.Iterator<Tuple<java.lang.Integer,T>>,java.util.Iterator<Tuple<java.lang.Integer,T>>>
prepare
in class BaseTFunction<java.util.Iterator<Tuple<java.lang.Integer,T>>,java.util.Iterator<Tuple<java.lang.Integer,T>>>
ctx
- CONTEXTprotected DiskBackedCollectionPartition<T> getPartition()
StoreIterSink
CollectionPartition
that would accept the values. This could be an in-mem
collection or a disk-backed collectiongetPartition
in class StoreIterSink<Tuple<java.lang.Integer,T>,T>
protected StoreIterSink.ValueExtractor<T,Tuple<java.lang.Integer,T>> getValueExtractor()
StoreIterSink
getValueExtractor
in class StoreIterSink<Tuple<java.lang.Integer,T>,T>
public void close()
Closable