Class ByteTransferContext

    • Method Detail

      • getRemoteExecutorId

        public final String getRemoteExecutorId()
        Returns:
        the remote executor id.
      • getContextId

        public final org.apache.nemo.runtime.executor.bytetransfer.ByteTransferContext.ContextId getContextId()
        Returns:
        the identifier for this transfer context.
      • getContextDescriptor

        public final byte[] getContextDescriptor()
        Returns:
        user-provided context descriptor.
      • hasException

        public final boolean hasException()
        Returns:
        Whether this context has exception or not.
      • getException

        public final Throwable getException()
        Returns:
        The exception involved with this context, or null.
      • onChannelError

        public abstract void onChannelError​(@Nullable
                                            Throwable cause)
        Handles exception.
        Parameters:
        cause - the cause of exception handling
      • setChannelError

        protected final void setChannelError​(@Nullable
                                             Throwable cause)
        Sets exception.
        Parameters:
        cause - the exception to set
      • deregister

        protected final void deregister()
        De-registers this context from ContextManager.