Uses of Interface
edu.snu.coral.runtime.common.data.KeyRange

Packages that use KeyRange

Package	Description
edu.snu.coral.runtime.common.data
edu.snu.coral.runtime.common.optimizer.pass.runtime
edu.snu.coral.runtime.common.plan.physical
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

Uses of KeyRange in edu.snu.coral.runtime.common.data

Classes in edu.snu.coral.runtime.common.data that implement KeyRange

Modifier and Type	Class and Description
class	HashRange Descriptor for hash range.

Uses of KeyRange in edu.snu.coral.runtime.common.optimizer.pass.runtime

Methods in edu.snu.coral.runtime.common.optimizer.pass.runtime that return types with arguments of type KeyRange

Modifier and Type	Method and Description
List<KeyRange>	DataSkewRuntimePass.calculateHashRanges(Map<String,List<Long>> metricData, Integer taskGroupListSize) Method for calculating key ranges to evenly distribute the skewed metric data.

Uses of KeyRange in edu.snu.coral.runtime.common.plan.physical

Methods in edu.snu.coral.runtime.common.plan.physical that return types with arguments of type KeyRange

Modifier and Type	Method and Description
List<KeyRange>	PhysicalStageEdge.getTaskGroupIdxToKeyRange()

Method parameters in edu.snu.coral.runtime.common.plan.physical with type arguments of type KeyRange

Modifier and Type	Method and Description
void	PhysicalStageEdge.setTaskGroupIdxToKeyRange(List<KeyRange> taskGroupIdxToKeyRange) Sets the task group idx to key range list.

Uses of KeyRange in edu.snu.coral.runtime.executor.data

Methods in edu.snu.coral.runtime.executor.data with parameters of type KeyRange

Modifier and Type	Method and Description
CompletableFuture<Iterator>	BlockManagerWorker.queryBlock(String blockId, String runtimeEdgeId, DataStoreProperty.Value blockStore, KeyRange keyRange) Inquiries the location of the specific block and routes the request to the local block manager worker or to the lower data plane.

Uses of KeyRange in edu.snu.coral.runtime.executor.data.block

Methods in edu.snu.coral.runtime.executor.data.block with parameters of type KeyRange

Modifier and Type	Method and Description
List<FileArea>	FileBlock.asFileAreas(KeyRange keyRange) Retrieves the list of FileAreas for the specified KeyRange.
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.
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.

Uses of KeyRange in edu.snu.coral.runtime.executor.data.blocktransfer

Methods in edu.snu.coral.runtime.executor.data.blocktransfer that return KeyRange

Modifier and Type	Method and Description
KeyRange	BlockInputStream.getKeyRange()
KeyRange	BlockStream.getKeyRange() Gets the key range.
KeyRange	BlockOutputStream.getKeyRange()

Methods in edu.snu.coral.runtime.executor.data.blocktransfer with parameters of type KeyRange

Modifier and Type	Method and Description
BlockInputStream	BlockTransfer.initiatePull(String executorId, boolean encodePartialBlock, DataStoreProperty.Value blockStoreValue, String blockId, String runtimeEdgeId, KeyRange keyRange) Initiate a pull-based block transfer.
BlockOutputStream	BlockTransfer.initiatePush(String executorId, boolean encodePartialBlock, String blockId, String runtimeEdgeId, KeyRange keyRange) Initiate a push-based block transfer.

Uses of KeyRange in edu.snu.coral.runtime.executor.data.stores

Methods in edu.snu.coral.runtime.executor.data.stores with parameters of type KeyRange

Modifier and Type	Method and Description
List<FileArea>	FileStore.getFileAreas(String blockId, KeyRange keyRange) Gets the list of FileAreas for the specified block.
List<FileArea>	LocalFileStore.getFileAreas(String blockId, KeyRange keyRange)
List<FileArea>	GlusterFileStore.getFileAreas(String blockId, KeyRange keyRange)
<K extends Serializable> Optional<Iterable<NonSerializedPartition<K>>>	BlockStore.getPartitions(String blockId, KeyRange<K> keyRange) Retrieves NonSerializedPartitions.
<K extends Serializable> Optional<Iterable<NonSerializedPartition<K>>>	LocalBlockStore.getPartitions(String blockId, KeyRange<K> keyRange)
<K extends Serializable> Optional<Iterable<NonSerializedPartition<K>>>	GlusterFileStore.getPartitions(String blockId, KeyRange<K> keyRange) Retrieves NonSerializedPartitions in a specific KeyRange from a block.
<K extends Serializable> Optional<Iterable<SerializedPartition<K>>>	BlockStore.getSerializedPartitions(String blockId, KeyRange<K> keyRange) Retrieves SerializedPartitions in a specific KeyRange from a block.
<K extends Serializable> Optional<Iterable<SerializedPartition<K>>>	LocalBlockStore.getSerializedPartitions(String blockId, KeyRange<K> keyRange)
<K extends Serializable> Optional<Iterable<SerializedPartition<K>>>	GlusterFileStore.getSerializedPartitions(String blockId, KeyRange<K> keyRange)