Uses of Class
org.apache.nemo.common.ir.executionproperty.ExecutionPropertyMap
-
-
Uses of ExecutionPropertyMap in org.apache.nemo.common.ir.edge
Methods in org.apache.nemo.common.ir.edge that return ExecutionPropertyMap Modifier and Type Method Description ExecutionPropertyMap<EdgeExecutionProperty>
IREdge. getExecutionProperties()
-
Uses of ExecutionPropertyMap in org.apache.nemo.common.ir.executionproperty
Methods in org.apache.nemo.common.ir.executionproperty that return ExecutionPropertyMap Modifier and Type Method Description static ExecutionPropertyMap<EdgeExecutionProperty>
ExecutionPropertyMap. of(IREdge irEdge, CommunicationPatternProperty.Value commPattern)
Static initializer for irEdges.static ExecutionPropertyMap<VertexExecutionProperty>
ExecutionPropertyMap. of(IRVertex irVertex)
Static initializer for irVertex. -
Uses of ExecutionPropertyMap in org.apache.nemo.common.ir.vertex
Methods in org.apache.nemo.common.ir.vertex that return ExecutionPropertyMap Modifier and Type Method Description ExecutionPropertyMap<VertexExecutionProperty>
IRVertex. getExecutionProperties()
-
Uses of ExecutionPropertyMap in org.apache.nemo.common.partitioner
Methods in org.apache.nemo.common.partitioner with parameters of type ExecutionPropertyMap Modifier and Type Method Description static Partitioner
Partitioner. getPartitioner(ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, ExecutionPropertyMap<VertexExecutionProperty> dstProperties)
-
Uses of ExecutionPropertyMap in org.apache.nemo.runtime.common.plan
Methods in org.apache.nemo.runtime.common.plan that return ExecutionPropertyMap Modifier and Type Method Description ExecutionPropertyMap<EdgeExecutionProperty>
RuntimeEdge. getExecutionProperties()
ExecutionPropertyMap<VertexExecutionProperty>
Stage. getExecutionProperties()
ExecutionPropertyMap<VertexExecutionProperty>
Task. getExecutionProperties()
Methods in org.apache.nemo.runtime.common.plan with parameters of type ExecutionPropertyMap Modifier and Type Method Description void
Stage. setExecutionProperties(ExecutionPropertyMap<VertexExecutionProperty> executionProperties)
Constructors in org.apache.nemo.runtime.common.plan with parameters of type ExecutionPropertyMap Constructor Description RuntimeEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> executionProperties, V src, V dst)
Constructs the edge given the below parameters.Stage(java.lang.String stageId, java.util.List<java.lang.Integer> taskIndices, DAG<IRVertex,RuntimeEdge<IRVertex>> irDag, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, java.util.List<java.util.Map<java.lang.String,Readable>> vertexIdToReadables)
Constructor.StageEdge(java.lang.String runtimeEdgeId, ExecutionPropertyMap<EdgeExecutionProperty> edgeProperties, IRVertex srcVertex, IRVertex dstVertex, Stage srcStage, Stage dstStage)
Constructor.Task(java.lang.String planId, java.lang.String taskId, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, byte[] serializedIRDag, java.util.List<StageEdge> taskIncomingEdges, java.util.List<StageEdge> taskOutgoingEdges, java.util.Map<java.lang.String,Readable> irVertexIdToReadable)
Constructor. -
Uses of ExecutionPropertyMap in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type ExecutionPropertyMap 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 ExecutionPropertyMap in org.apache.nemo.runtime.executor.datatransfer
Methods in org.apache.nemo.runtime.executor.datatransfer that return ExecutionPropertyMap Modifier and Type Method Description ExecutionPropertyMap<EdgeExecutionProperty>
BlockInputReader. getProperties()
ExecutionPropertyMap<EdgeExecutionProperty>
InputReader. getProperties()
ExecutionPropertyMap<EdgeExecutionProperty>
PipeInputReader. getProperties()
-