| Package | Description |
|---|---|
| edu.snu.coral.runtime.executor.data | |
| edu.snu.coral.runtime.executor.data.block | |
| edu.snu.coral.runtime.executor.data.stores |
| Modifier and Type | Method and Description |
|---|---|
static <K extends Serializable> |
DataUtil.deserializePartition(long elementsInPartition,
Coder coder,
K key,
InputStream inputStream)
Reads the data of a partition from an input stream and deserializes it.
|
| Modifier and Type | Method and Description |
|---|---|
static <K extends Serializable> |
DataUtil.convertToNonSerPartitions(Coder coder,
Iterable<SerializedPartition<K>> partitionsToConvert)
|
| Modifier and Type | Method and Description |
|---|---|
static long |
DataUtil.serializePartition(Coder coder,
NonSerializedPartition nonSerializedPartition,
ByteArrayOutputStream bytesOutputStream)
Serializes the elements in a non-serialized partition into an output stream.
|
| Modifier and Type | Method and Description |
|---|---|
static Iterable |
DataUtil.concatNonSerPartitions(Iterable<NonSerializedPartition> partitionsToConcat)
Concatenates an iterable of non-serialized
Partitions into a single iterable of elements. |
static <K extends Serializable> |
DataUtil.convertToSerPartitions(Coder coder,
Iterable<NonSerializedPartition<K>> partitionsToConvert)
|
| Modifier and Type | Method and Description |
|---|---|
Iterable<NonSerializedPartition<K>> |
NonSerializedMemoryBlock.getPartitions(KeyRange keyRange)
Retrieves the
NonSerializedPartitions in a specific hash range from this block. |
Iterable<NonSerializedPartition<K>> |
SerializedMemoryBlock.getPartitions(KeyRange keyRange)
Retrieves the
NonSerializedPartitions in a specific hash range from this block. |
Iterable<NonSerializedPartition<K>> |
FileBlock.getPartitions(KeyRange keyRange)
Retrieves the partitions of this block from the file in a specific key range and deserializes it.
|
Iterable<NonSerializedPartition<K>> |
Block.getPartitions(KeyRange<K> keyRange)
Retrieves the
NonSerializedPartitions in a specific key range from this block. |
| Modifier and Type | Method and Description |
|---|---|
Optional<List<Long>> |
NonSerializedMemoryBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Stores
NonSerializedPartitions to this block. |
Optional<List<Long>> |
SerializedMemoryBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Serialized and stores
NonSerializedPartitions to this block. |
Optional<List<Long>> |
FileBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Writes
NonSerializedPartitions to this block. |
Optional<List<Long>> |
Block.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Stores
NonSerializedPartitions to this block. |
| Modifier and Type | Method and Description |
|---|---|
<K extends Serializable> |
BlockStore.getPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
NonSerializedPartitions. |
<K extends Serializable> |
LocalBlockStore.getPartitions(String blockId,
KeyRange<K> keyRange) |
<K extends Serializable> |
GlusterFileStore.getPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
NonSerializedPartitions in a specific KeyRange from a block. |
| Modifier and Type | Method and Description |
|---|---|
<K extends Serializable> |
BlockStore.putPartitions(String blockId,
Iterable<NonSerializedPartition<K>> partitions)
Saves an iterable of
NonSerializedPartitions 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) |
Copyright © 2018. All rights reserved.