http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/b5b468b9/myriad-commons/src/main/java/org/apache/mesos/Protos.java ---------------------------------------------------------------------- diff --git a/myriad-commons/src/main/java/org/apache/mesos/Protos.java b/myriad-commons/src/main/java/org/apache/mesos/Protos.java new file mode 100644 index 0000000..6a97384 --- /dev/null +++ b/myriad-commons/src/main/java/org/apache/mesos/Protos.java @@ -0,0 +1,162923 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: mesos/mesos.proto + +package org.apache.mesos; + +public final class Protos { + private Protos() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + } + /** + * Protobuf enum {@code mesos.Status} + * + * <pre> + ** + * Status is used to indicate the state of the scheduler and executor + * driver after function calls. + * </pre> + */ + public enum Status + implements com.google.protobuf.ProtocolMessageEnum { + /** + * <code>DRIVER_NOT_STARTED = 1;</code> + */ + DRIVER_NOT_STARTED(0, 1), + /** + * <code>DRIVER_RUNNING = 2;</code> + */ + DRIVER_RUNNING(1, 2), + /** + * <code>DRIVER_ABORTED = 3;</code> + */ + DRIVER_ABORTED(2, 3), + /** + * <code>DRIVER_STOPPED = 4;</code> + */ + DRIVER_STOPPED(3, 4), + ; + + /** + * <code>DRIVER_NOT_STARTED = 1;</code> + */ + public static final int DRIVER_NOT_STARTED_VALUE = 1; + /** + * <code>DRIVER_RUNNING = 2;</code> + */ + public static final int DRIVER_RUNNING_VALUE = 2; + /** + * <code>DRIVER_ABORTED = 3;</code> + */ + public static final int DRIVER_ABORTED_VALUE = 3; + /** + * <code>DRIVER_STOPPED = 4;</code> + */ + public static final int DRIVER_STOPPED_VALUE = 4; + + + public final int getNumber() { return value; } + + public static Status valueOf(int value) { + switch (value) { + case 1: return DRIVER_NOT_STARTED; + case 2: return DRIVER_RUNNING; + case 3: return DRIVER_ABORTED; + case 4: return DRIVER_STOPPED; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap<Status> + internalGetValueMap() { + return internalValueMap; + } + private static com.google.protobuf.Internal.EnumLiteMap<Status> + internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap<Status>() { + public Status findValueByNumber(int number) { + return Status.valueOf(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor + getValueDescriptor() { + return getDescriptor().getValues().get(index); + } + public final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptorForType() { + return getDescriptor(); + } + public static final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptor() { + return org.apache.mesos.Protos.getDescriptor().getEnumTypes().get(0); + } + + private static final Status[] VALUES = values(); + + public static Status valueOf( + com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException( + "EnumValueDescriptor is not for this type."); + } + return VALUES[desc.getIndex()]; + } + + private final int index; + private final int value; + + private Status(int index, int value) { + this.index = index; + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:mesos.Status) + } + + /** + * Protobuf enum {@code mesos.TaskState} + * + * <pre> + ** + * Describes possible task states. IMPORTANT: Mesos assumes tasks that + * enter terminal states (see below) imply the task is no longer + * running and thus clean up any thing associated with the task + * (ultimately offering any resources being consumed by that task to + * another task). + * </pre> + */ + public enum TaskState + implements com.google.protobuf.ProtocolMessageEnum { + /** + * <code>TASK_STAGING = 6;</code> + * + * <pre> + * Initial state. Framework status updates should not use. + * </pre> + */ + TASK_STAGING(0, 6), + /** + * <code>TASK_STARTING = 0;</code> + * + * <pre> + * The task is being launched by the executor. + * </pre> + */ + TASK_STARTING(1, 0), + /** + * <code>TASK_RUNNING = 1;</code> + */ + TASK_RUNNING(2, 1), + /** + * <code>TASK_KILLING = 8;</code> + * + * <pre> + * NOTE: This should only be sent when the framework has + * the TASK_KILLING_STATE capability. + * </pre> + */ + TASK_KILLING(3, 8), + /** + * <code>TASK_FINISHED = 2;</code> + * + * <pre> + * TERMINAL: The task finished successfully. + * </pre> + */ + TASK_FINISHED(4, 2), + /** + * <code>TASK_FAILED = 3;</code> + * + * <pre> + * TERMINAL: The task failed to finish successfully. + * </pre> + */ + TASK_FAILED(5, 3), + /** + * <code>TASK_KILLED = 4;</code> + * + * <pre> + * TERMINAL: The task was killed by the executor. + * </pre> + */ + TASK_KILLED(6, 4), + /** + * <code>TASK_ERROR = 7;</code> + * + * <pre> + * TERMINAL: The task description contains an error. + * </pre> + */ + TASK_ERROR(7, 7), + /** + * <code>TASK_LOST = 5;</code> + * + * <pre> + * In Mesos 1.3, this will only be sent when the framework does NOT + * opt-in to the PARTITION_AWARE capability. + * + * NOTE: This state is not always terminal. For example, tasks might + * transition from TASK_LOST to TASK_RUNNING or other states when a + * partitioned agent re-registers. + * </pre> + */ + TASK_LOST(8, 5), + /** + * <code>TASK_DROPPED = 9;</code> + * + * <pre> + * The task failed to launch because of a transient error. The + * task's executor never started running. Unlike TASK_ERROR, the + * task description is valid -- attempting to launch the task again + * may be successful. + * </pre> + */ + TASK_DROPPED(9, 9), + /** + * <code>TASK_UNREACHABLE = 10;</code> + * + * <pre> + * The task was running on an agent that has lost contact with the + * master, typically due to a network failure or partition. The task + * may or may not still be running. + * </pre> + */ + TASK_UNREACHABLE(10, 10), + /** + * <code>TASK_GONE = 11;</code> + * + * <pre> + * The task is no longer running. This can occur if the agent has + * been terminated along with all of its tasks (e.g., the host that + * was running the agent was rebooted). It might also occur if the + * task was terminated due to an agent or containerizer error, or if + * the task was preempted by the QoS controller in an + * oversubscription scenario. + * </pre> + */ + TASK_GONE(11, 11), + /** + * <code>TASK_GONE_BY_OPERATOR = 12;</code> + * + * <pre> + * The task was running on an agent that the master cannot contact; + * the operator has asserted that the agent has been shutdown, but + * this has not been directly confirmed by the master. If the + * operator is correct, the task is not running and this is a + * terminal state; if the operator is mistaken, the task may still + * be running and might return to RUNNING in the future. + * </pre> + */ + TASK_GONE_BY_OPERATOR(12, 12), + /** + * <code>TASK_UNKNOWN = 13;</code> + * + * <pre> + * The master has no knowledge of the task. This is typically + * because either (a) the master never had knowledge of the task, or + * (b) the master forgot about the task because it garbage collected + * its metadata about the task. The task may or may not still be + * running. + * </pre> + */ + TASK_UNKNOWN(13, 13), + ; + + /** + * <code>TASK_STAGING = 6;</code> + * + * <pre> + * Initial state. Framework status updates should not use. + * </pre> + */ + public static final int TASK_STAGING_VALUE = 6; + /** + * <code>TASK_STARTING = 0;</code> + * + * <pre> + * The task is being launched by the executor. + * </pre> + */ + public static final int TASK_STARTING_VALUE = 0; + /** + * <code>TASK_RUNNING = 1;</code> + */ + public static final int TASK_RUNNING_VALUE = 1; + /** + * <code>TASK_KILLING = 8;</code> + * + * <pre> + * NOTE: This should only be sent when the framework has + * the TASK_KILLING_STATE capability. + * </pre> + */ + public static final int TASK_KILLING_VALUE = 8; + /** + * <code>TASK_FINISHED = 2;</code> + * + * <pre> + * TERMINAL: The task finished successfully. + * </pre> + */ + public static final int TASK_FINISHED_VALUE = 2; + /** + * <code>TASK_FAILED = 3;</code> + * + * <pre> + * TERMINAL: The task failed to finish successfully. + * </pre> + */ + public static final int TASK_FAILED_VALUE = 3; + /** + * <code>TASK_KILLED = 4;</code> + * + * <pre> + * TERMINAL: The task was killed by the executor. + * </pre> + */ + public static final int TASK_KILLED_VALUE = 4; + /** + * <code>TASK_ERROR = 7;</code> + * + * <pre> + * TERMINAL: The task description contains an error. + * </pre> + */ + public static final int TASK_ERROR_VALUE = 7; + /** + * <code>TASK_LOST = 5;</code> + * + * <pre> + * In Mesos 1.3, this will only be sent when the framework does NOT + * opt-in to the PARTITION_AWARE capability. + * + * NOTE: This state is not always terminal. For example, tasks might + * transition from TASK_LOST to TASK_RUNNING or other states when a + * partitioned agent re-registers. + * </pre> + */ + public static final int TASK_LOST_VALUE = 5; + /** + * <code>TASK_DROPPED = 9;</code> + * + * <pre> + * The task failed to launch because of a transient error. The + * task's executor never started running. Unlike TASK_ERROR, the + * task description is valid -- attempting to launch the task again + * may be successful. + * </pre> + */ + public static final int TASK_DROPPED_VALUE = 9; + /** + * <code>TASK_UNREACHABLE = 10;</code> + * + * <pre> + * The task was running on an agent that has lost contact with the + * master, typically due to a network failure or partition. The task + * may or may not still be running. + * </pre> + */ + public static final int TASK_UNREACHABLE_VALUE = 10; + /** + * <code>TASK_GONE = 11;</code> + * + * <pre> + * The task is no longer running. This can occur if the agent has + * been terminated along with all of its tasks (e.g., the host that + * was running the agent was rebooted). It might also occur if the + * task was terminated due to an agent or containerizer error, or if + * the task was preempted by the QoS controller in an + * oversubscription scenario. + * </pre> + */ + public static final int TASK_GONE_VALUE = 11; + /** + * <code>TASK_GONE_BY_OPERATOR = 12;</code> + * + * <pre> + * The task was running on an agent that the master cannot contact; + * the operator has asserted that the agent has been shutdown, but + * this has not been directly confirmed by the master. If the + * operator is correct, the task is not running and this is a + * terminal state; if the operator is mistaken, the task may still + * be running and might return to RUNNING in the future. + * </pre> + */ + public static final int TASK_GONE_BY_OPERATOR_VALUE = 12; + /** + * <code>TASK_UNKNOWN = 13;</code> + * + * <pre> + * The master has no knowledge of the task. This is typically + * because either (a) the master never had knowledge of the task, or + * (b) the master forgot about the task because it garbage collected + * its metadata about the task. The task may or may not still be + * running. + * </pre> + */ + public static final int TASK_UNKNOWN_VALUE = 13; + + + public final int getNumber() { return value; } + + public static TaskState valueOf(int value) { + switch (value) { + case 6: return TASK_STAGING; + case 0: return TASK_STARTING; + case 1: return TASK_RUNNING; + case 8: return TASK_KILLING; + case 2: return TASK_FINISHED; + case 3: return TASK_FAILED; + case 4: return TASK_KILLED; + case 7: return TASK_ERROR; + case 5: return TASK_LOST; + case 9: return TASK_DROPPED; + case 10: return TASK_UNREACHABLE; + case 11: return TASK_GONE; + case 12: return TASK_GONE_BY_OPERATOR; + case 13: return TASK_UNKNOWN; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap<TaskState> + internalGetValueMap() { + return internalValueMap; + } + private static com.google.protobuf.Internal.EnumLiteMap<TaskState> + internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap<TaskState>() { + public TaskState findValueByNumber(int number) { + return TaskState.valueOf(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor + getValueDescriptor() { + return getDescriptor().getValues().get(index); + } + public final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptorForType() { + return getDescriptor(); + } + public static final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptor() { + return org.apache.mesos.Protos.getDescriptor().getEnumTypes().get(1); + } + + private static final TaskState[] VALUES = values(); + + public static TaskState valueOf( + com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException( + "EnumValueDescriptor is not for this type."); + } + return VALUES[desc.getIndex()]; + } + + private final int index; + private final int value; + + private TaskState(int index, int value) { + this.index = index; + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:mesos.TaskState) + } + + public interface FrameworkIDOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string value = 1; + /** + * <code>required string value = 1;</code> + */ + boolean hasValue(); + /** + * <code>required string value = 1;</code> + */ + java.lang.String getValue(); + /** + * <code>required string value = 1;</code> + */ + com.google.protobuf.ByteString + getValueBytes(); + } + /** + * Protobuf type {@code mesos.FrameworkID} + * + * <pre> + ** + * A unique ID assigned to a framework. A framework can reuse this ID + * in order to do failover (see MesosSchedulerDriver). + * </pre> + */ + public static final class FrameworkID extends + com.google.protobuf.GeneratedMessage + implements FrameworkIDOrBuilder { + // Use FrameworkID.newBuilder() to construct. + private FrameworkID(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private FrameworkID(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final FrameworkID defaultInstance; + public static FrameworkID getDefaultInstance() { + return defaultInstance; + } + + public FrameworkID getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private FrameworkID( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + value_ = input.readBytes(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_FrameworkID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_FrameworkID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.FrameworkID.class, org.apache.mesos.Protos.FrameworkID.Builder.class); + } + + public static com.google.protobuf.Parser<FrameworkID> PARSER = + new com.google.protobuf.AbstractParser<FrameworkID>() { + public FrameworkID parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new FrameworkID(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<FrameworkID> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string value = 1; + public static final int VALUE_FIELD_NUMBER = 1; + private java.lang.Object value_; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + value_ = s; + } + return s; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + value_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasValue()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getValueBytes()); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getValueBytes()); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static org.apache.mesos.Protos.FrameworkID parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.FrameworkID parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.mesos.Protos.FrameworkID parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.FrameworkID parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.mesos.Protos.FrameworkID prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code mesos.FrameworkID} + * + * <pre> + ** + * A unique ID assigned to a framework. A framework can reuse this ID + * in order to do failover (see MesosSchedulerDriver). + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.mesos.Protos.FrameworkIDOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_FrameworkID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_FrameworkID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.FrameworkID.class, org.apache.mesos.Protos.FrameworkID.Builder.class); + } + + // Construct using org.apache.mesos.Protos.FrameworkID.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + value_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.mesos.Protos.internal_static_mesos_FrameworkID_descriptor; + } + + public org.apache.mesos.Protos.FrameworkID getDefaultInstanceForType() { + return org.apache.mesos.Protos.FrameworkID.getDefaultInstance(); + } + + public org.apache.mesos.Protos.FrameworkID build() { + org.apache.mesos.Protos.FrameworkID result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.mesos.Protos.FrameworkID buildPartial() { + org.apache.mesos.Protos.FrameworkID result = new org.apache.mesos.Protos.FrameworkID(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.value_ = value_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.mesos.Protos.FrameworkID) { + return mergeFrom((org.apache.mesos.Protos.FrameworkID)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.mesos.Protos.FrameworkID other) { + if (other == org.apache.mesos.Protos.FrameworkID.getDefaultInstance()) return this; + if (other.hasValue()) { + bitField0_ |= 0x00000001; + value_ = other.value_; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasValue()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.mesos.Protos.FrameworkID parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.mesos.Protos.FrameworkID) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required string value = 1; + private java.lang.Object value_ = ""; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + value_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValue( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder clearValue() { + bitField0_ = (bitField0_ & ~0x00000001); + value_ = getDefaultInstance().getValue(); + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValueBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:mesos.FrameworkID) + } + + static { + defaultInstance = new FrameworkID(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:mesos.FrameworkID) + } + + public interface OfferIDOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string value = 1; + /** + * <code>required string value = 1;</code> + */ + boolean hasValue(); + /** + * <code>required string value = 1;</code> + */ + java.lang.String getValue(); + /** + * <code>required string value = 1;</code> + */ + com.google.protobuf.ByteString + getValueBytes(); + } + /** + * Protobuf type {@code mesos.OfferID} + * + * <pre> + ** + * A unique ID assigned to an offer. + * </pre> + */ + public static final class OfferID extends + com.google.protobuf.GeneratedMessage + implements OfferIDOrBuilder { + // Use OfferID.newBuilder() to construct. + private OfferID(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private OfferID(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final OfferID defaultInstance; + public static OfferID getDefaultInstance() { + return defaultInstance; + } + + public OfferID getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private OfferID( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + value_ = input.readBytes(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_OfferID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_OfferID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.OfferID.class, org.apache.mesos.Protos.OfferID.Builder.class); + } + + public static com.google.protobuf.Parser<OfferID> PARSER = + new com.google.protobuf.AbstractParser<OfferID>() { + public OfferID parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new OfferID(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<OfferID> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string value = 1; + public static final int VALUE_FIELD_NUMBER = 1; + private java.lang.Object value_; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + value_ = s; + } + return s; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + value_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasValue()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getValueBytes()); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getValueBytes()); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static org.apache.mesos.Protos.OfferID parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.OfferID parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.OfferID parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.OfferID parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.OfferID parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.OfferID parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.OfferID parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.mesos.Protos.OfferID parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.OfferID parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.OfferID parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.mesos.Protos.OfferID prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code mesos.OfferID} + * + * <pre> + ** + * A unique ID assigned to an offer. + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.mesos.Protos.OfferIDOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_OfferID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_OfferID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.OfferID.class, org.apache.mesos.Protos.OfferID.Builder.class); + } + + // Construct using org.apache.mesos.Protos.OfferID.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + value_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.mesos.Protos.internal_static_mesos_OfferID_descriptor; + } + + public org.apache.mesos.Protos.OfferID getDefaultInstanceForType() { + return org.apache.mesos.Protos.OfferID.getDefaultInstance(); + } + + public org.apache.mesos.Protos.OfferID build() { + org.apache.mesos.Protos.OfferID result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.mesos.Protos.OfferID buildPartial() { + org.apache.mesos.Protos.OfferID result = new org.apache.mesos.Protos.OfferID(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.value_ = value_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.mesos.Protos.OfferID) { + return mergeFrom((org.apache.mesos.Protos.OfferID)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.mesos.Protos.OfferID other) { + if (other == org.apache.mesos.Protos.OfferID.getDefaultInstance()) return this; + if (other.hasValue()) { + bitField0_ |= 0x00000001; + value_ = other.value_; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasValue()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.mesos.Protos.OfferID parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.mesos.Protos.OfferID) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required string value = 1; + private java.lang.Object value_ = ""; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + value_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValue( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder clearValue() { + bitField0_ = (bitField0_ & ~0x00000001); + value_ = getDefaultInstance().getValue(); + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValueBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:mesos.OfferID) + } + + static { + defaultInstance = new OfferID(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:mesos.OfferID) + } + + public interface SlaveIDOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string value = 1; + /** + * <code>required string value = 1;</code> + */ + boolean hasValue(); + /** + * <code>required string value = 1;</code> + */ + java.lang.String getValue(); + /** + * <code>required string value = 1;</code> + */ + com.google.protobuf.ByteString + getValueBytes(); + } + /** + * Protobuf type {@code mesos.SlaveID} + * + * <pre> + ** + * A unique ID assigned to a slave. Currently, a slave gets a new ID + * whenever it (re)registers with Mesos. Framework writers shouldn't + * assume any binding between a slave ID and and a hostname. + * </pre> + */ + public static final class SlaveID extends + com.google.protobuf.GeneratedMessage + implements SlaveIDOrBuilder { + // Use SlaveID.newBuilder() to construct. + private SlaveID(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private SlaveID(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final SlaveID defaultInstance; + public static SlaveID getDefaultInstance() { + return defaultInstance; + } + + public SlaveID getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private SlaveID( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + value_ = input.readBytes(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_SlaveID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_SlaveID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.SlaveID.class, org.apache.mesos.Protos.SlaveID.Builder.class); + } + + public static com.google.protobuf.Parser<SlaveID> PARSER = + new com.google.protobuf.AbstractParser<SlaveID>() { + public SlaveID parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new SlaveID(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<SlaveID> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string value = 1; + public static final int VALUE_FIELD_NUMBER = 1; + private java.lang.Object value_; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + value_ = s; + } + return s; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + value_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasValue()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getValueBytes()); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getValueBytes()); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static org.apache.mesos.Protos.SlaveID parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.SlaveID parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.SlaveID parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.SlaveID parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.SlaveID parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.SlaveID parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.SlaveID parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.mesos.Protos.SlaveID parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.SlaveID parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.SlaveID parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.mesos.Protos.SlaveID prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code mesos.SlaveID} + * + * <pre> + ** + * A unique ID assigned to a slave. Currently, a slave gets a new ID + * whenever it (re)registers with Mesos. Framework writers shouldn't + * assume any binding between a slave ID and and a hostname. + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.mesos.Protos.SlaveIDOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_SlaveID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_SlaveID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.SlaveID.class, org.apache.mesos.Protos.SlaveID.Builder.class); + } + + // Construct using org.apache.mesos.Protos.SlaveID.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + value_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.mesos.Protos.internal_static_mesos_SlaveID_descriptor; + } + + public org.apache.mesos.Protos.SlaveID getDefaultInstanceForType() { + return org.apache.mesos.Protos.SlaveID.getDefaultInstance(); + } + + public org.apache.mesos.Protos.SlaveID build() { + org.apache.mesos.Protos.SlaveID result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.mesos.Protos.SlaveID buildPartial() { + org.apache.mesos.Protos.SlaveID result = new org.apache.mesos.Protos.SlaveID(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.value_ = value_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.mesos.Protos.SlaveID) { + return mergeFrom((org.apache.mesos.Protos.SlaveID)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.mesos.Protos.SlaveID other) { + if (other == org.apache.mesos.Protos.SlaveID.getDefaultInstance()) return this; + if (other.hasValue()) { + bitField0_ |= 0x00000001; + value_ = other.value_; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasValue()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.mesos.Protos.SlaveID parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.mesos.Protos.SlaveID) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required string value = 1; + private java.lang.Object value_ = ""; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + value_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValue( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder clearValue() { + bitField0_ = (bitField0_ & ~0x00000001); + value_ = getDefaultInstance().getValue(); + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValueBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:mesos.SlaveID) + } + + static { + defaultInstance = new SlaveID(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:mesos.SlaveID) + } + + public interface TaskIDOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string value = 1; + /** + * <code>required string value = 1;</code> + */ + boolean hasValue(); + /** + * <code>required string value = 1;</code> + */ + java.lang.String getValue(); + /** + * <code>required string value = 1;</code> + */ + com.google.protobuf.ByteString + getValueBytes(); + } + /** + * Protobuf type {@code mesos.TaskID} + * + * <pre> + ** + * A framework-generated ID to distinguish a task. The ID must remain + * unique while the task is active. A framework can reuse an ID _only_ + * if the previous task with the same ID has reached a terminal state + * (e.g., TASK_FINISHED, TASK_KILLED, etc.). However, reusing task IDs + * is strongly discouraged (MESOS-2198). + * </pre> + */ + public static final class TaskID extends + com.google.protobuf.GeneratedMessage + implements TaskIDOrBuilder { + // Use TaskID.newBuilder() to construct. + private TaskID(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private TaskID(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final TaskID defaultInstance; + public static TaskID getDefaultInstance() { + return defaultInstance; + } + + public TaskID getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private TaskID( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + value_ = input.readBytes(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_TaskID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_TaskID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.TaskID.class, org.apache.mesos.Protos.TaskID.Builder.class); + } + + public static com.google.protobuf.Parser<TaskID> PARSER = + new com.google.protobuf.AbstractParser<TaskID>() { + public TaskID parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new TaskID(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<TaskID> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string value = 1; + public static final int VALUE_FIELD_NUMBER = 1; + private java.lang.Object value_; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + value_ = s; + } + return s; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + value_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasValue()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getValueBytes()); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getValueBytes()); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static org.apache.mesos.Protos.TaskID parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.TaskID parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.TaskID parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.TaskID parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.TaskID parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.TaskID parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.TaskID parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.mesos.Protos.TaskID parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.mesos.Protos.TaskID parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.mesos.Protos.TaskID parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.mesos.Protos.TaskID prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code mesos.TaskID} + * + * <pre> + ** + * A framework-generated ID to distinguish a task. The ID must remain + * unique while the task is active. A framework can reuse an ID _only_ + * if the previous task with the same ID has reached a terminal state + * (e.g., TASK_FINISHED, TASK_KILLED, etc.). However, reusing task IDs + * is strongly discouraged (MESOS-2198). + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.mesos.Protos.TaskIDOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_TaskID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_TaskID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.TaskID.class, org.apache.mesos.Protos.TaskID.Builder.class); + } + + // Construct using org.apache.mesos.Protos.TaskID.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + private static Builder create() { + return new Builder(); + } + + public Builder clear() { + super.clear(); + value_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.mesos.Protos.internal_static_mesos_TaskID_descriptor; + } + + public org.apache.mesos.Protos.TaskID getDefaultInstanceForType() { + return org.apache.mesos.Protos.TaskID.getDefaultInstance(); + } + + public org.apache.mesos.Protos.TaskID build() { + org.apache.mesos.Protos.TaskID result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.mesos.Protos.TaskID buildPartial() { + org.apache.mesos.Protos.TaskID result = new org.apache.mesos.Protos.TaskID(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.value_ = value_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.mesos.Protos.TaskID) { + return mergeFrom((org.apache.mesos.Protos.TaskID)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.mesos.Protos.TaskID other) { + if (other == org.apache.mesos.Protos.TaskID.getDefaultInstance()) return this; + if (other.hasValue()) { + bitField0_ |= 0x00000001; + value_ = other.value_; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasValue()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.mesos.Protos.TaskID parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.mesos.Protos.TaskID) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required string value = 1; + private java.lang.Object value_ = ""; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + value_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValue( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder clearValue() { + bitField0_ = (bitField0_ & ~0x00000001); + value_ = getDefaultInstance().getValue(); + onChanged(); + return this; + } + /** + * <code>required string value = 1;</code> + */ + public Builder setValueBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + value_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:mesos.TaskID) + } + + static { + defaultInstance = new TaskID(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:mesos.TaskID) + } + + public interface ExecutorIDOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string value = 1; + /** + * <code>required string value = 1;</code> + */ + boolean hasValue(); + /** + * <code>required string value = 1;</code> + */ + java.lang.String getValue(); + /** + * <code>required string value = 1;</code> + */ + com.google.protobuf.ByteString + getValueBytes(); + } + /** + * Protobuf type {@code mesos.ExecutorID} + * + * <pre> + ** + * A framework-generated ID to distinguish an executor. Only one + * executor with the same ID can be active on the same slave at a + * time. However, reusing executor IDs is discouraged. + * </pre> + */ + public static final class ExecutorID extends + com.google.protobuf.GeneratedMessage + implements ExecutorIDOrBuilder { + // Use ExecutorID.newBuilder() to construct. + private ExecutorID(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private ExecutorID(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final ExecutorID defaultInstance; + public static ExecutorID getDefaultInstance() { + return defaultInstance; + } + + public ExecutorID getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private ExecutorID( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + value_ = input.readBytes(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.mesos.Protos.internal_static_mesos_ExecutorID_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.mesos.Protos.internal_static_mesos_ExecutorID_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.mesos.Protos.ExecutorID.class, org.apache.mesos.Protos.ExecutorID.Builder.class); + } + + public static com.google.protobuf.Parser<ExecutorID> PARSER = + new com.google.protobuf.AbstractParser<ExecutorID>() { + public ExecutorID parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new ExecutorID(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<ExecutorID> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string value = 1; + public static final int VALUE_FIELD_NUMBER = 1; + private java.lang.Object value_; + /** + * <code>required string value = 1;</code> + */ + public boolean hasValue() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string value = 1;</code> + */ + public java.lang.String getValue() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + value_ = s; + } + return s; + } + } + /** + * <code>required string value = 1;</code> + */ + public com.google.protobuf.ByteString + getValueBytes() { + java.lang.Object ref = value_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + value_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + value_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasValue()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, getValueBytes()); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getValueBytes()); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + public static org.apache.mesos.Protos.ExecutorID parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.mesos.Protos.ExecutorID parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.mesos.Protos.ExecutorID parseFrom(byte[] data) +
<TRUNCATED>
