T
- TSet data typepublic class DiskPersistIterSink<T> extends StoreIterSink<T,T>
StoreIterSink.ValueExtractor<O,I>
Constructor and Description |
---|
DiskPersistIterSink(java.lang.String referencePrefix)
Creates an instance of
DiskPersistIterSink with a referencePrefix |
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,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 DiskPersistIterSink(java.lang.String referencePrefix)
DiskPersistIterSink
with a referencePrefixreferencePrefix
- referencePrefix will be used to uniquely identify the set of
disk partitions created with this functionpublic void prepare(TSetContext ctx)
TFunction
public void close()
Closable
protected 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<T,T>
protected StoreIterSink.ValueExtractor<T,T> getValueExtractor()
StoreIterSink
getValueExtractor
in class StoreIterSink<T,T>