Package | Description |
---|---|
edu.snu.coral.runtime.executor.data.stores |
Modifier and Type | Method and Description |
---|---|
void |
BlockStore.commitBlock(String blockId)
Notifies that all writes for a block is end.
|
void |
GlusterFileStore.commitBlock(String blockId)
Notifies that all writes for a block is end.
|
void |
BlockStore.createBlock(String blockId)
Creates a new block.
|
<K extends Serializable> |
BlockStore.putPartitions(String blockId,
Iterable<NonSerializedPartition<K>> partitions)
Saves an iterable of
NonSerializedPartition s to a block. |
<K extends Serializable> |
LocalBlockStore.putPartitions(String blockId,
Iterable<NonSerializedPartition<K>> partitions) |
<K extends Serializable> |
GlusterFileStore.putPartitions(String blockId,
Iterable<NonSerializedPartition<K>> partitions) |
<K extends Serializable> |
BlockStore.putSerializedPartitions(String blockId,
Iterable<SerializedPartition<K>> partitions)
Saves an iterable of
SerializedPartition s to a block. |
Copyright © 2018. All rights reserved.