Uses of Interface
org.apache.nemo.common.KeyRange

Packages that use KeyRange

Package	Description
org.apache.nemo.common
org.apache.nemo.common.ir.edge.executionproperty
org.apache.nemo.runtime.common.plan
org.apache.nemo.runtime.executor.data
org.apache.nemo.runtime.executor.data.block

Uses of KeyRange in org.apache.nemo.common

Classes in org.apache.nemo.common that implement KeyRange

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

Uses of KeyRange in org.apache.nemo.common.ir.edge.executionproperty

Method parameters in org.apache.nemo.common.ir.edge.executionproperty with type arguments of type KeyRange

Modifier and Type	Method	Description
static PartitionSetProperty	PartitionSetProperty.of(java.util.ArrayList<KeyRange> value)	Static method exposing the constructor.
static SubPartitionSetProperty	SubPartitionSetProperty.of(java.util.ArrayList<KeyRange> value)	Static method exposing the constructor.

Constructor parameters in org.apache.nemo.common.ir.edge.executionproperty with type arguments of type KeyRange

Constructor	Description
SubPartitionSetProperty(java.util.ArrayList<KeyRange> value)	Default constructor.

Uses of KeyRange in org.apache.nemo.runtime.common.plan

Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type KeyRange

Modifier and Type	Method	Description
java.util.List<KeyRange>	StageEdge.getKeyRanges()	Get keyRanges for shuffle edge.

Uses of KeyRange in org.apache.nemo.runtime.executor.data

Methods in org.apache.nemo.runtime.executor.data with parameters of type KeyRange

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>	BlockManagerWorker.readBlock(java.lang.String blockIdWildcard, java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, 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 org.apache.nemo.runtime.executor.data.block

Methods in org.apache.nemo.runtime.executor.data.block with parameters of type KeyRange

Modifier and Type	Method	Description
java.util.List<FileArea>	FileBlock.asFileAreas(KeyRange keyRange)	Retrieves the list of FileAreas for the specified KeyRange.
java.lang.Iterable<NonSerializedPartition<K>>	Block.readPartitions(KeyRange<K> keyRange)	Retrieves the NonSerializedPartitions in a specific key range from this block.
java.lang.Iterable<NonSerializedPartition<K>>	FileBlock.readPartitions(KeyRange keyRange)	Retrieves the partitions of this block from the file in a specific key range and deserializes it.
java.lang.Iterable<NonSerializedPartition<K>>	NonSerializedMemoryBlock.readPartitions(KeyRange keyRange)	Retrieves the NonSerializedPartitions in a specific hash range from this block.
java.lang.Iterable<NonSerializedPartition<K>>	SerializedMemoryBlock.readPartitions(KeyRange keyRange)	Retrieves the NonSerializedPartitions in a specific hash range from this block.
java.lang.Iterable<SerializedPartition<K>>	Block.readSerializedPartitions(KeyRange<K> keyRange)	Retrieves the SerializedPartitions in a specific key range.
java.lang.Iterable<SerializedPartition<K>>	FileBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific key range.
java.lang.Iterable<SerializedPartition<K>>	NonSerializedMemoryBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific hash range.
java.lang.Iterable<SerializedPartition<K>>	SerializedMemoryBlock.readSerializedPartitions(KeyRange keyRange)	Retrieves the SerializedPartitions in a specific hash range.