Package | Description |
---|---|
edu.snu.coral.runtime.executor.data | |
edu.snu.coral.runtime.executor.data.block | |
edu.snu.coral.runtime.executor.data.blocktransfer |
Responsible for transferring block content from one executor to another.
|
edu.snu.coral.runtime.executor.data.stores |
Modifier and Type | Method and Description |
---|---|
static <K extends Serializable> |
DataUtil.convertToSerPartitions(Coder coder,
Iterable<NonSerializedPartition<K>> partitionsToConvert)
|
Modifier and Type | Method and Description |
---|---|
static <K extends Serializable> |
DataUtil.convertToNonSerPartitions(Coder coder,
Iterable<SerializedPartition<K>> partitionsToConvert)
|
Modifier and Type | Method and Description |
---|---|
Iterable<SerializedPartition<K>> |
NonSerializedMemoryBlock.getSerializedPartitions(KeyRange keyRange)
Retrieves the
SerializedPartition s in a specific hash range. |
Iterable<SerializedPartition<K>> |
SerializedMemoryBlock.getSerializedPartitions(KeyRange keyRange)
Retrieves the
SerializedPartition s in a specific hash range. |
Iterable<SerializedPartition<K>> |
FileBlock.getSerializedPartitions(KeyRange keyRange)
Retrieves the
SerializedPartition s in a specific key range. |
Iterable<SerializedPartition<K>> |
Block.getSerializedPartitions(KeyRange<K> keyRange)
Retrieves the
SerializedPartition s in a specific key range. |
Modifier and Type | Method and Description |
---|---|
List<Long> |
NonSerializedMemoryBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartition s to this block. |
List<Long> |
SerializedMemoryBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartition s to this block. |
List<Long> |
FileBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Writes
SerializedPartition s to this block. |
List<Long> |
Block.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartition s to this block. |
Modifier and Type | Method and Description |
---|---|
BlockOutputStream |
BlockOutputStream.writeSerializedPartitions(Iterable<SerializedPartition> serializedPartitions)
Writes a collection of
SerializedPartition s. |
Modifier and Type | Method and Description |
---|---|
<K extends Serializable> |
BlockStore.getSerializedPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
SerializedPartition s in a specific KeyRange from a block. |
<K extends Serializable> |
LocalBlockStore.getSerializedPartitions(String blockId,
KeyRange<K> keyRange) |
<K extends Serializable> |
GlusterFileStore.getSerializedPartitions(String blockId,
KeyRange<K> keyRange) |
Modifier and Type | Method and Description |
---|---|
<K extends Serializable> |
BlockStore.putSerializedPartitions(String blockId,
Iterable<SerializedPartition<K>> partitions)
Saves an iterable of
SerializedPartition s to a block. |
<K extends Serializable> |
LocalBlockStore.putSerializedPartitions(String blockId,
Iterable<SerializedPartition<K>> partitions) |
<K extends Serializable> |
GlusterFileStore.putSerializedPartitions(String blockId,
Iterable<SerializedPartition<K>> partitions) |
Copyright © 2018. All rights reserved.