Package org.apache.nemo.runtime.executor.transfer

Class LocalTransferContext

  • Direct Known Subclasses:
    LocalInputContext, LocalOutputContext
    public abstract class LocalTransferContext
extends java.lang.Object
    This class represents the data transfer context when both the sender and the receiver are in the same executor. The data transfer via local transfer contexts doesn't involve data serialization and deserialization.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int getDstTaskIndex()
      Accessor method for the destination task index.
      java.lang.String getEdgeId()
      Accessor method for the edge id.
      java.lang.String getExecutorId()
      Accessor method for the executor id.
      int getSrcTaskIndex()
      Accessor method for the source task index.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • getExecutorId

        public final java.lang.String getExecutorId()
        Accessor method for the executor id.
        Returns:
        executor id

      • getEdgeId

        public final java.lang.String getEdgeId()
        Accessor method for the edge id.
        Returns:
        edge id

      • getSrcTaskIndex

        public final int getSrcTaskIndex()
        Accessor method for the source task index.
        Returns:
        source task index

      • getDstTaskIndex

        public final int getDstTaskIndex()
        Accessor method for the destination task index.
        Returns:
        destination task index