Uses of Class
org.apache.nemo.runtime.common.plan.RuntimeEdge
-
Packages that use RuntimeEdge Package Description org.apache.nemo.runtime.common.plan org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.datatransfer org.apache.nemo.runtime.executor.task -
-
Uses of RuntimeEdge in org.apache.nemo.runtime.common.plan
Subclasses of RuntimeEdge in org.apache.nemo.runtime.common.plan Modifier and Type Class Description class
StageEdge
Edge of a stage that connects an IRVertex of the source stage to an IRVertex of the destination stage.Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type RuntimeEdge Modifier and Type Method Description DAG<IRVertex,RuntimeEdge<IRVertex>>
Stage. getIRDAG()
Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type RuntimeEdge Constructor Description 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. -
Uses of RuntimeEdge in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type RuntimeEdge Modifier and Type Method Description java.util.List<OutputContext>
PipeManagerWorker. getOutputContexts(RuntimeEdge runtimeEdge, long srcTaskIndex)
(SYNCHRONIZATION) Called by task threads.java.util.concurrent.CompletableFuture<DataUtil.IteratorWithNumBytes>
PipeManagerWorker. read(int srcTaskIndex, RuntimeEdge runtimeEdge, int dstTaskIndex)
-
Uses of RuntimeEdge in org.apache.nemo.runtime.executor.datatransfer
Methods in org.apache.nemo.runtime.executor.datatransfer with parameters of type RuntimeEdge Modifier and Type Method Description InputReader
IntermediateDataIOFactory. createReader(java.lang.String dstTaskId, IRVertex srcIRVertex, RuntimeEdge runtimeEdge)
Creates anInputReader
between two stages.OutputWriter
IntermediateDataIOFactory. createWriter(java.lang.String srcTaskId, RuntimeEdge<?> runtimeEdge)
Creates anOutputWriter
between two stages. -
Uses of RuntimeEdge in org.apache.nemo.runtime.executor.task
Constructor parameters in org.apache.nemo.runtime.executor.task with type arguments of type RuntimeEdge Constructor Description TaskExecutor(Task task, DAG<IRVertex,RuntimeEdge<IRVertex>> irVertexDag, TaskStateManager taskStateManager, IntermediateDataIOFactory intermediateDataIOFactory, BroadcastManagerWorker broadcastManagerWorker, MetricMessageSender metricMessageSender, PersistentConnectionToMasterMap persistentConnectionToMasterMap, int latencyMarkPeriod)
Constructor.
-