Package org.apache.nemo.runtime.common.message

Class MessageUtils

java.lang.Object

org.apache.nemo.runtime.common.message.MessageUtils

public final class MessageUtils
extends java.lang.Object

Utility class for messages.

Method Summary

Modifier and Type	Method	Description
static TaskState.RecoverableTaskFailureCause	convertFailureCause(ControlMessage.RecoverableFailureCause cause)
static ControlMessage.RecoverableFailureCause	convertFailureCause(TaskState.RecoverableTaskFailureCause cause)
static ControlMessage.TaskStateFromExecutor	convertState(TaskState.State state)
static TaskState.State	convertTaskState(ControlMessage.TaskStateFromExecutor state)

Methods inherited from class java.lang.Object

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

Method Detail

convertTaskState

public static TaskState.State convertTaskState(ControlMessage.TaskStateFromExecutor state)

convertState

public static ControlMessage.TaskStateFromExecutor convertState(TaskState.State state)

convertFailureCause

public static TaskState.RecoverableTaskFailureCause convertFailureCause(ControlMessage.RecoverableFailureCause cause)

convertFailureCause

public static ControlMessage.RecoverableFailureCause convertFailureCause(TaskState.RecoverableTaskFailureCause cause)