Class ControlMessage.TaskStateChangedMsg
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessage
-
- org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsg
-
- All Implemented Interfaces:
com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
,ControlMessage.TaskStateChangedMsgOrBuilder
- Enclosing class:
- ControlMessage
public static final class ControlMessage.TaskStateChangedMsg extends com.google.protobuf.GeneratedMessage implements ControlMessage.TaskStateChangedMsgOrBuilder
Protobuf typeprotobuf.TaskStateChangedMsg
Messages from Executors to Master
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ControlMessage.TaskStateChangedMsg.Builder
Protobuf typeprotobuf.TaskStateChangedMsg
-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.BuilderParent, com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessage.ExtendableBuilder>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends com.google.protobuf.Message,Type extends Object>
-
-
Field Summary
Fields Modifier and Type Field Description static int
ATTEMPTIDX_FIELD_NUMBER
static int
EXECUTORID_FIELD_NUMBER
static int
FAILURECAUSE_FIELD_NUMBER
static com.google.protobuf.Parser<ControlMessage.TaskStateChangedMsg>
PARSER
static int
STATE_FIELD_NUMBER
static int
TASKID_FIELD_NUMBER
static int
VERTEXPUTONHOLDID_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getAttemptIdx()
required int32 attemptIdx = 6;
static ControlMessage.TaskStateChangedMsg
getDefaultInstance()
ControlMessage.TaskStateChangedMsg
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
String
getExecutorId()
required string executorId = 1;
com.google.protobuf.ByteString
getExecutorIdBytes()
required string executorId = 1;
ControlMessage.RecoverableFailureCause
getFailureCause()
optional .protobuf.RecoverableFailureCause failureCause = 5;
com.google.protobuf.Parser<ControlMessage.TaskStateChangedMsg>
getParserForType()
int
getSerializedSize()
ControlMessage.TaskStateFromExecutor
getState()
required .protobuf.TaskStateFromExecutor state = 3;
String
getTaskId()
required string taskId = 2;
com.google.protobuf.ByteString
getTaskIdBytes()
required string taskId = 2;
com.google.protobuf.UnknownFieldSet
getUnknownFields()
String
getVertexPutOnHoldId()
optional string vertexPutOnHoldId = 4;
com.google.protobuf.ByteString
getVertexPutOnHoldIdBytes()
optional string vertexPutOnHoldId = 4;
boolean
hasAttemptIdx()
required int32 attemptIdx = 6;
boolean
hasExecutorId()
required string executorId = 1;
boolean
hasFailureCause()
optional .protobuf.RecoverableFailureCause failureCause = 5;
boolean
hasState()
required .protobuf.TaskStateFromExecutor state = 3;
boolean
hasTaskId()
required string taskId = 2;
boolean
hasVertexPutOnHoldId()
optional string vertexPutOnHoldId = 4;
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static ControlMessage.TaskStateChangedMsg.Builder
newBuilder()
static ControlMessage.TaskStateChangedMsg.Builder
newBuilder(ControlMessage.TaskStateChangedMsg prototype)
ControlMessage.TaskStateChangedMsg.Builder
newBuilderForType()
protected ControlMessage.TaskStateChangedMsg.Builder
newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
static ControlMessage.TaskStateChangedMsg
parseDelimitedFrom(InputStream input)
static ControlMessage.TaskStateChangedMsg
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.TaskStateChangedMsg
parseFrom(byte[] data)
static ControlMessage.TaskStateChangedMsg
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.TaskStateChangedMsg
parseFrom(com.google.protobuf.ByteString data)
static ControlMessage.TaskStateChangedMsg
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.TaskStateChangedMsg
parseFrom(com.google.protobuf.CodedInputStream input)
static ControlMessage.TaskStateChangedMsg
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.TaskStateChangedMsg
parseFrom(InputStream input)
static ControlMessage.TaskStateChangedMsg
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ControlMessage.TaskStateChangedMsg.Builder
toBuilder()
protected Object
writeReplace()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessage
getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, hasField, makeExtensionsImmutable, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension, parseUnknownField
-
Methods inherited from class com.google.protobuf.AbstractMessage
equals, findInitializationErrors, getInitializationErrorString, hashBoolean, hashCode, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
PARSER
public static com.google.protobuf.Parser<ControlMessage.TaskStateChangedMsg> PARSER
-
EXECUTORID_FIELD_NUMBER
public static final int EXECUTORID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TASKID_FIELD_NUMBER
public static final int TASKID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STATE_FIELD_NUMBER
public static final int STATE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
VERTEXPUTONHOLDID_FIELD_NUMBER
public static final int VERTEXPUTONHOLDID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
FAILURECAUSE_FIELD_NUMBER
public static final int FAILURECAUSE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ATTEMPTIDX_FIELD_NUMBER
public static final int ATTEMPTIDX_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
getDefaultInstance
public static ControlMessage.TaskStateChangedMsg getDefaultInstance()
-
getDefaultInstanceForType
public ControlMessage.TaskStateChangedMsg getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
getUnknownFields
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFields
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getUnknownFields
in classcom.google.protobuf.GeneratedMessage
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessage
-
getParserForType
public com.google.protobuf.Parser<ControlMessage.TaskStateChangedMsg> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessage
-
hasExecutorId
public boolean hasExecutorId()
required string executorId = 1;
- Specified by:
hasExecutorId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getExecutorId
public String getExecutorId()
required string executorId = 1;
- Specified by:
getExecutorId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getExecutorIdBytes
public com.google.protobuf.ByteString getExecutorIdBytes()
required string executorId = 1;
- Specified by:
getExecutorIdBytes
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
hasTaskId
public boolean hasTaskId()
required string taskId = 2;
- Specified by:
hasTaskId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getTaskId
public String getTaskId()
required string taskId = 2;
- Specified by:
getTaskId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getTaskIdBytes
public com.google.protobuf.ByteString getTaskIdBytes()
required string taskId = 2;
- Specified by:
getTaskIdBytes
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
hasState
public boolean hasState()
required .protobuf.TaskStateFromExecutor state = 3;
- Specified by:
hasState
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getState
public ControlMessage.TaskStateFromExecutor getState()
required .protobuf.TaskStateFromExecutor state = 3;
- Specified by:
getState
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
hasVertexPutOnHoldId
public boolean hasVertexPutOnHoldId()
optional string vertexPutOnHoldId = 4;
- Specified by:
hasVertexPutOnHoldId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getVertexPutOnHoldId
public String getVertexPutOnHoldId()
optional string vertexPutOnHoldId = 4;
- Specified by:
getVertexPutOnHoldId
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getVertexPutOnHoldIdBytes
public com.google.protobuf.ByteString getVertexPutOnHoldIdBytes()
optional string vertexPutOnHoldId = 4;
- Specified by:
getVertexPutOnHoldIdBytes
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
hasFailureCause
public boolean hasFailureCause()
optional .protobuf.RecoverableFailureCause failureCause = 5;
- Specified by:
hasFailureCause
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getFailureCause
public ControlMessage.RecoverableFailureCause getFailureCause()
optional .protobuf.RecoverableFailureCause failureCause = 5;
- Specified by:
getFailureCause
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
hasAttemptIdx
public boolean hasAttemptIdx()
required int32 attemptIdx = 6;
- Specified by:
hasAttemptIdx
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
getAttemptIdx
public int getAttemptIdx()
required int32 attemptIdx = 6;
- Specified by:
getAttemptIdx
in interfaceControlMessage.TaskStateChangedMsgOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessage
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.AbstractMessage
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.AbstractMessage
-
writeReplace
protected Object writeReplace() throws ObjectStreamException
- Overrides:
writeReplace
in classcom.google.protobuf.GeneratedMessage
- Throws:
ObjectStreamException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ControlMessage.TaskStateChangedMsg parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ControlMessage.TaskStateChangedMsg parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ControlMessage.TaskStateChangedMsg parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilder
public static ControlMessage.TaskStateChangedMsg.Builder newBuilder()
-
newBuilderForType
public ControlMessage.TaskStateChangedMsg.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static ControlMessage.TaskStateChangedMsg.Builder newBuilder(ControlMessage.TaskStateChangedMsg prototype)
-
toBuilder
public ControlMessage.TaskStateChangedMsg.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected ControlMessage.TaskStateChangedMsg.Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessage
-
-