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
Partition s 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
NonSerializedPartition s in a specific hash range from this block. |
Iterable<NonSerializedPartition<K>> |
SerializedMemoryBlock.getPartitions(KeyRange keyRange)
Retrieves the
NonSerializedPartition s 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
NonSerializedPartition s in a specific key range from this block. |
Modifier and Type | Method and Description |
---|---|
Optional<List<Long>> |
NonSerializedMemoryBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Stores
NonSerializedPartition s to this block. |
Optional<List<Long>> |
SerializedMemoryBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Serialized and stores
NonSerializedPartition s to this block. |
Optional<List<Long>> |
FileBlock.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Writes
NonSerializedPartition s to this block. |
Optional<List<Long>> |
Block.putPartitions(Iterable<NonSerializedPartition<K>> partitions)
Stores
NonSerializedPartition s to this block. |
Modifier and Type | Method and Description |
---|---|
<K extends Serializable> |
BlockStore.getPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
NonSerializedPartition s. |
<K extends Serializable> |
LocalBlockStore.getPartitions(String blockId,
KeyRange<K> keyRange) |
<K extends Serializable> |
GlusterFileStore.getPartitions(String blockId,
KeyRange<K> keyRange)
Retrieves
NonSerializedPartition s 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
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) |
Copyright © 2018. All rights reserved.