Uses of Class
org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty

Packages that use EdgeExecutionProperty

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

Uses of EdgeExecutionProperty in org.apache.nemo.common.ir.edge

Methods in org.apache.nemo.common.ir.edge that return types with arguments of type EdgeExecutionProperty

Modifier and Type	Method	Description
ExecutionPropertyMap<EdgeExecutionProperty>	IREdge.getExecutionProperties()

Methods in org.apache.nemo.common.ir.edge with parameters of type EdgeExecutionProperty

Modifier and Type	Method	Description
IREdge	IREdge.setProperty(EdgeExecutionProperty<?> executionProperty)	Set an executionProperty of the IREdge.
IREdge	IREdge.setPropertyPermanently(EdgeExecutionProperty<?> executionProperty)	Set an executionProperty of the IREdge, permanently.

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

Modifier and Type	Method	Description
<T extends java.io.Serializable> java.util.Optional<T>	IREdge.getPropertyValue(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)	Get the executionProperty of the IREdge.

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

Subclasses of EdgeExecutionProperty in org.apache.nemo.common.ir.edge.executionproperty

Modifier and Type	Class	Description
class	AdditionalOutputTagProperty	Additional Output Tag Execution Property for edge that contains tag for additional outputs.
class	BlockFetchFailureProperty	Decides how to react to a data block fetch failure.
class	CacheIDProperty	Cache ID ExecutionProperty.
class	CommunicationPatternProperty	DataCommunicationPattern ExecutionProperty.
class	CompressionProperty	Compression ExecutionProperty.
class	DataFlowProperty	DataFlowModel ExecutionProperty.
class	DataPersistenceProperty	Data persistence ExecutionProperty.
class	DataStoreProperty	DataStore ExecutionProperty.
class	DecoderProperty	Decoder ExecutionProperty.
class	DecompressionProperty	Decompression ExecutionProperty.
class	DuplicateEdgeGroupProperty	Invariant data ExecutionProperty.
class	EncoderProperty	Encoder ExecutionProperty.
class	KeyDecoderProperty	KeyDecoder ExecutionProperty.
class	KeyEncoderProperty	KeyEncoder ExecutionProperty.
class	KeyExtractorProperty	KeyExtractor ExecutionProperty.
class	MessageIdEdgeProperty	Vertices and edges with the same MessageId are subject to the same run-time optimization.
class	PartitionerProperty	Partitioner ExecutionProperty.
class	PartitionSetProperty	This property decides which partitions the tasks of the destination IRVertex should fetch.
class	SubPartitionSetProperty	This property decides the hash partition set of sampled and optimized tasks in Dynamic Task Sizing Policy.

Uses of EdgeExecutionProperty in org.apache.nemo.common.ir.executionproperty

Methods in org.apache.nemo.common.ir.executionproperty that return types with arguments of type EdgeExecutionProperty

Modifier and Type	Method	Description
static ExecutionPropertyMap<EdgeExecutionProperty>	ExecutionPropertyMap.of(IREdge irEdge, CommunicationPatternProperty.Value commPattern)	Static initializer for irEdges.

Uses of EdgeExecutionProperty in org.apache.nemo.common.partitioner

Method parameters in org.apache.nemo.common.partitioner with type arguments of type EdgeExecutionProperty

Modifier and Type	Method	Description
static Partitioner	Partitioner.getPartitioner(ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, ExecutionPropertyMap<VertexExecutionProperty> dstProperties)

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

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

Modifier and Type	Method	Description
ExecutionPropertyMap<EdgeExecutionProperty>	RuntimeEdge.getExecutionProperties()

Method parameters in org.apache.nemo.runtime.common.plan with type arguments of type EdgeExecutionProperty

Modifier and Type	Method	Description
<T extends java.io.Serializable> java.util.Optional<T>	RuntimeEdge.getPropertyValue(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)	Get the execution property of the Runtime Edge.
<T extends java.io.Serializable> T	RuntimeEdge.getPropertyValueOrRuntimeException(java.lang.Class<? extends EdgeExecutionProperty<T>> executionPropertyKey)

Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type EdgeExecutionProperty

Constructor	Description
RuntimeEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> executionProperties, V src, V dst)	Constructs the edge given the below parameters.
StageEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, IRVertex srcVertex, IRVertex dstVertex, Stage srcStage, Stage dstStage)	Constructor.

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

Method parameters in org.apache.nemo.runtime.executor.data with type arguments of type EdgeExecutionProperty

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 EdgeExecutionProperty in org.apache.nemo.runtime.executor.datatransfer

Methods in org.apache.nemo.runtime.executor.datatransfer that return types with arguments of type EdgeExecutionProperty

Modifier and Type	Method	Description
ExecutionPropertyMap<EdgeExecutionProperty>	BlockInputReader.getProperties()
ExecutionPropertyMap<EdgeExecutionProperty>	InputReader.getProperties()
ExecutionPropertyMap<EdgeExecutionProperty>	PipeInputReader.getProperties()