| 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
SerializedPartitions in a specific hash range. |
Iterable<SerializedPartition<K>> |
SerializedMemoryBlock.getSerializedPartitions(KeyRange keyRange)
Retrieves the
SerializedPartitions in a specific hash range. |
Iterable<SerializedPartition<K>> |
FileBlock.getSerializedPartitions(KeyRange keyRange)
Retrieves the
SerializedPartitions in a specific key range. |
Iterable<SerializedPartition<K>> |
Block.getSerializedPartitions(KeyRange<K> keyRange)
Retrieves the
SerializedPartitions in a specific key range. |
| Modifier and Type | Method and Description |
|---|---|
List<Long> |
NonSerializedMemoryBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartitions to this block. |
List<Long> |
SerializedMemoryBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartitions to this block. |
List<Long> |
FileBlock.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Writes
SerializedPartitions to this block. |
List<Long> |
Block.putSerializedPartitions(Iterable<SerializedPartition<K>> partitions)
Stores
SerializedPartitions to this block. |
| Modifier and Type | Method and Description |
|---|---|
BlockOutputStream |
BlockOutputStream.writeSerializedPartitions(Iterable<SerializedPartition> serializedPartitions)
Writes a collection of
SerializedPartitions. |
| Modifier and Type | Method and Description |
|---|---|
<K extends Serializable> |
BlockStore.getSerializedPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
SerializedPartitions 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
SerializedPartitions 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.