Package org.apache.nemo.runtime.common.comm

Class ControlMessage

java.lang.Object

org.apache.nemo.runtime.common.comm.ControlMessage

public final class ControlMessage
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ControlMessage.BlockLocationInfoMsg	Protobuf type protobuf.BlockLocationInfoMsg
static interface	ControlMessage.BlockLocationInfoMsgOrBuilder
static class	ControlMessage.BlockStateChangedMsg	Protobuf type protobuf.BlockStateChangedMsg
static interface	ControlMessage.BlockStateChangedMsgOrBuilder
static class	ControlMessage.BlockStateFromExecutor	Protobuf enum protobuf.BlockStateFromExecutor
static class	ControlMessage.BlockStore	Protobuf enum protobuf.BlockStore
static class	ControlMessage.BlockTransferContextDescriptor	Protobuf type protobuf.BlockTransferContextDescriptor
static interface	ControlMessage.BlockTransferContextDescriptorOrBuilder
static class	ControlMessage.ByteTransferContextSetupMessage	Protobuf type protobuf.ByteTransferContextSetupMessage
static interface	ControlMessage.ByteTransferContextSetupMessageOrBuilder
static class	ControlMessage.ByteTransferDataDirection	Messages between Executors
static class	ControlMessage.ClientToDriverMessage	Protobuf type protobuf.ClientToDriverMessage
static interface	ControlMessage.ClientToDriverMessageOrBuilder
static class	ControlMessage.ClientToDriverMessageType	Messages from client to driver
static class	ControlMessage.ContainerFailedMsg	Protobuf type protobuf.ContainerFailedMsg
static interface	ControlMessage.ContainerFailedMsgOrBuilder
static class	ControlMessage.DataCollectMessage	Protobuf type protobuf.DataCollectMessage
static interface	ControlMessage.DataCollectMessageOrBuilder
static class	ControlMessage.DriverToClientMessage	Protobuf type protobuf.DriverToClientMessage
static interface	ControlMessage.DriverToClientMessageOrBuilder
static class	ControlMessage.DriverToClientMessageType	Messages from driver to client
static class	ControlMessage.ExecutorFailedMsg	Protobuf type protobuf.ExecutorFailedMsg
static interface	ControlMessage.ExecutorFailedMsgOrBuilder
static class	ControlMessage.InMasterBroadcastVariableMessage	Protobuf type protobuf.InMasterBroadcastVariableMessage
static interface	ControlMessage.InMasterBroadcastVariableMessageOrBuilder
static class	ControlMessage.LaunchDAGMessage	Protobuf type protobuf.LaunchDAGMessage
static interface	ControlMessage.LaunchDAGMessageOrBuilder
static class	ControlMessage.Message	Protobuf type protobuf.Message
static interface	ControlMessage.MessageOrBuilder
static class	ControlMessage.MessageType	Protobuf enum protobuf.MessageType
static class	ControlMessage.Metric	Common messages
static class	ControlMessage.MetricMsg	Protobuf type protobuf.MetricMsg
static interface	ControlMessage.MetricMsgOrBuilder
static interface	ControlMessage.MetricOrBuilder
static class	ControlMessage.NotificationMessage	Protobuf type protobuf.NotificationMessage
static interface	ControlMessage.NotificationMessageOrBuilder
static class	ControlMessage.OptimizationType	Protobuf enum protobuf.OptimizationType
static class	ControlMessage.PipeInitMessage	Protobuf type protobuf.PipeInitMessage
static interface	ControlMessage.PipeInitMessageOrBuilder
static class	ControlMessage.PipeLocationInfoMessage	Protobuf type protobuf.PipeLocationInfoMessage
static interface	ControlMessage.PipeLocationInfoMessageOrBuilder
static class	ControlMessage.PipeTransferContextDescriptor	Protobuf type protobuf.PipeTransferContextDescriptor
static interface	ControlMessage.PipeTransferContextDescriptorOrBuilder
static class	ControlMessage.RecoverableFailureCause	Protobuf enum protobuf.RecoverableFailureCause
static class	ControlMessage.RequestBlockLocationMsg	Protobuf type protobuf.RequestBlockLocationMsg
static interface	ControlMessage.RequestBlockLocationMsgOrBuilder
static class	ControlMessage.RequestBroadcastVariableMessage	Protobuf type protobuf.RequestBroadcastVariableMessage
static interface	ControlMessage.RequestBroadcastVariableMessageOrBuilder
static class	ControlMessage.RequestPipeLocationMessage	Protobuf type protobuf.RequestPipeLocationMessage
static interface	ControlMessage.RequestPipeLocationMessageOrBuilder
static class	ControlMessage.RunTimePassMessageEntry	Protobuf type protobuf.RunTimePassMessageEntry
static interface	ControlMessage.RunTimePassMessageEntryOrBuilder
static class	ControlMessage.RunTimePassMessageMsg	Protobuf type protobuf.RunTimePassMessageMsg
static interface	ControlMessage.RunTimePassMessageMsgOrBuilder
static class	ControlMessage.ScheduleTaskMsg	Messages from Master to Executors
static interface	ControlMessage.ScheduleTaskMsgOrBuilder
static class	ControlMessage.TaskStateChangedMsg	Messages from Executors to Master
static interface	ControlMessage.TaskStateChangedMsgOrBuilder
static class	ControlMessage.TaskStateFromExecutor	Protobuf enum protobuf.TaskStateFromExecutor

Method Summary

Modifier and Type	Method	Description
static com.google.protobuf.Descriptors.FileDescriptor	getDescriptor()
static void	registerAllExtensions(com.google.protobuf.ExtensionRegistry registry)
static void	registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry)

Methods inherited from class java.lang.Object

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

Method Detail

registerAllExtensions

public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry)

registerAllExtensions

public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry)

getDescriptor

public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor()