// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: reef_service_protos.proto

package org.apache.reef.proto;

public final class ReefServiceProtos {
  private ReefServiceProtos() {}
  public static void registerAllExtensions(
      com.google.protobuf.ExtensionRegistry registry) {
  }
  /**
   * Protobuf enum {@code State}
   */
  public enum State
      implements com.google.protobuf.ProtocolMessageEnum {
    /**
     * <code>INIT = 0;</code>
     */
    INIT(0, 0),
    /**
     * <code>RUNNING = 1;</code>
     */
    RUNNING(1, 1),
    /**
     * <code>DONE = 2;</code>
     */
    DONE(2, 2),
    /**
     * <code>SUSPEND = 3;</code>
     */
    SUSPEND(3, 3),
    /**
     * <code>FAILED = 4;</code>
     */
    FAILED(4, 4),
    /**
     * <code>KILLED = 5;</code>
     */
    KILLED(5, 5),
    ;

    /**
     * <code>INIT = 0;</code>
     */
    public static final int INIT_VALUE = 0;
    /**
     * <code>RUNNING = 1;</code>
     */
    public static final int RUNNING_VALUE = 1;
    /**
     * <code>DONE = 2;</code>
     */
    public static final int DONE_VALUE = 2;
    /**
     * <code>SUSPEND = 3;</code>
     */
    public static final int SUSPEND_VALUE = 3;
    /**
     * <code>FAILED = 4;</code>
     */
    public static final int FAILED_VALUE = 4;
    /**
     * <code>KILLED = 5;</code>
     */
    public static final int KILLED_VALUE = 5;


    public final int getNumber() { return value; }

    public static State valueOf(int value) {
      switch (value) {
        case 0: return INIT;
        case 1: return RUNNING;
        case 2: return DONE;
        case 3: return SUSPEND;
        case 4: return FAILED;
        case 5: return KILLED;
        default: return null;
      }
    }

    public static com.google.protobuf.Internal.EnumLiteMap<State>
        internalGetValueMap() {
      return internalValueMap;
    }
    private static com.google.protobuf.Internal.EnumLiteMap<State>
        internalValueMap =
          new com.google.protobuf.Internal.EnumLiteMap<State>() {
            public State findValueByNumber(int number) {
              return State.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.reef.proto.ReefServiceProtos.getDescriptor().getEnumTypes().get(0);
    }

    private static final State[] VALUES = values();

    public static State 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 State(int index, int value) {
      this.index = index;
      this.value = value;
    }

    // @@protoc_insertion_point(enum_scope:State)
  }

  /**
   * Protobuf enum {@code FileType}
   */
  public enum FileType
      implements com.google.protobuf.ProtocolMessageEnum {
    /**
     * <code>PLAIN = 0;</code>
     */
    PLAIN(0, 0),
    /**
     * <code>LIB = 1;</code>
     */
    LIB(1, 1),
    /**
     * <code>ARCHIVE = 2;</code>
     */
    ARCHIVE(2, 2),
    ;

    /**
     * <code>PLAIN = 0;</code>
     */
    public static final int PLAIN_VALUE = 0;
    /**
     * <code>LIB = 1;</code>
     */
    public static final int LIB_VALUE = 1;
    /**
     * <code>ARCHIVE = 2;</code>
     */
    public static final int ARCHIVE_VALUE = 2;


    public final int getNumber() { return value; }

    public static FileType valueOf(int value) {
      switch (value) {
        case 0: return PLAIN;
        case 1: return LIB;
        case 2: return ARCHIVE;
        default: return null;
      }
    }

    public static com.google.protobuf.Internal.EnumLiteMap<FileType>
        internalGetValueMap() {
      return internalValueMap;
    }
    private static com.google.protobuf.Internal.EnumLiteMap<FileType>
        internalValueMap =
          new com.google.protobuf.Internal.EnumLiteMap<FileType>() {
            public FileType findValueByNumber(int number) {
              return FileType.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.reef.proto.ReefServiceProtos.getDescriptor().getEnumTypes().get(1);
    }

    private static final FileType[] VALUES = values();

    public static FileType 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 FileType(int index, int value) {
      this.index = index;
      this.value = value;
    }

    // @@protoc_insertion_point(enum_scope:FileType)
  }

  /**
   * Protobuf enum {@code ProcessType}
   */
  public enum ProcessType
      implements com.google.protobuf.ProtocolMessageEnum {
    /**
     * <code>JVM = 0;</code>
     */
    JVM(0, 0),
    /**
     * <code>CLR = 1;</code>
     */
    CLR(1, 1),
    ;

    /**
     * <code>JVM = 0;</code>
     */
    public static final int JVM_VALUE = 0;
    /**
     * <code>CLR = 1;</code>
     */
    public static final int CLR_VALUE = 1;


    public final int getNumber() { return value; }

    public static ProcessType valueOf(int value) {
      switch (value) {
        case 0: return JVM;
        case 1: return CLR;
        default: return null;
      }
    }

    public static com.google.protobuf.Internal.EnumLiteMap<ProcessType>
        internalGetValueMap() {
      return internalValueMap;
    }
    private static com.google.protobuf.Internal.EnumLiteMap<ProcessType>
        internalValueMap =
          new com.google.protobuf.Internal.EnumLiteMap<ProcessType>() {
            public ProcessType findValueByNumber(int number) {
              return ProcessType.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.reef.proto.ReefServiceProtos.getDescriptor().getEnumTypes().get(2);
    }

    private static final ProcessType[] VALUES = values();

    public static ProcessType 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 ProcessType(int index, int value) {
      this.index = index;
      this.value = value;
    }

    // @@protoc_insertion_point(enum_scope:ProcessType)
  }

  public interface FileResourceProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required .FileType type = 1;
    /**
     * <code>required .FileType type = 1;</code>
     */
    boolean hasType();
    /**
     * <code>required .FileType type = 1;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.FileType getType();

    // required string name = 2;
    /**
     * <code>required string name = 2;</code>
     */
    boolean hasName();
    /**
     * <code>required string name = 2;</code>
     */
    java.lang.String getName();
    /**
     * <code>required string name = 2;</code>
     */
    com.google.protobuf.ByteString
        getNameBytes();

    // required string path = 3;
    /**
     * <code>required string path = 3;</code>
     */
    boolean hasPath();
    /**
     * <code>required string path = 3;</code>
     */
    java.lang.String getPath();
    /**
     * <code>required string path = 3;</code>
     */
    com.google.protobuf.ByteString
        getPathBytes();
  }
  /**
   * Protobuf type {@code FileResourceProto}
   */
  public static final class FileResourceProto extends
      com.google.protobuf.GeneratedMessage
      implements FileResourceProtoOrBuilder {
    // Use FileResourceProto.newBuilder() to construct.
    private FileResourceProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private FileResourceProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final FileResourceProto defaultInstance;
    public static FileResourceProto getDefaultInstance() {
      return defaultInstance;
    }

    public FileResourceProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private FileResourceProto(
        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 8: {
              int rawValue = input.readEnum();
              org.apache.reef.proto.ReefServiceProtos.FileType value = org.apache.reef.proto.ReefServiceProtos.FileType.valueOf(rawValue);
              if (value == null) {
                unknownFields.mergeVarintField(1, rawValue);
              } else {
                bitField0_ |= 0x00000001;
                type_ = value;
              }
              break;
            }
            case 18: {
              bitField0_ |= 0x00000002;
              name_ = input.readBytes();
              break;
            }
            case 26: {
              bitField0_ |= 0x00000004;
              path_ = 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.reef.proto.ReefServiceProtos.internal_static_FileResourceProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_FileResourceProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.FileResourceProto.class, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder.class);
    }

    public static com.google.protobuf.Parser<FileResourceProto> PARSER =
        new com.google.protobuf.AbstractParser<FileResourceProto>() {
      public FileResourceProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new FileResourceProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<FileResourceProto> getParserForType() {
      return PARSER;
    }

    private int bitField0_;
    // required .FileType type = 1;
    public static final int TYPE_FIELD_NUMBER = 1;
    private org.apache.reef.proto.ReefServiceProtos.FileType type_;
    /**
     * <code>required .FileType type = 1;</code>
     */
    public boolean hasType() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required .FileType type = 1;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.FileType getType() {
      return type_;
    }

    // required string name = 2;
    public static final int NAME_FIELD_NUMBER = 2;
    private java.lang.Object name_;
    /**
     * <code>required string name = 2;</code>
     */
    public boolean hasName() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required string name = 2;</code>
     */
    public java.lang.String getName() {
      java.lang.Object ref = name_;
      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()) {
          name_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string name = 2;</code>
     */
    public com.google.protobuf.ByteString
        getNameBytes() {
      java.lang.Object ref = name_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        name_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required string path = 3;
    public static final int PATH_FIELD_NUMBER = 3;
    private java.lang.Object path_;
    /**
     * <code>required string path = 3;</code>
     */
    public boolean hasPath() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>required string path = 3;</code>
     */
    public java.lang.String getPath() {
      java.lang.Object ref = path_;
      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()) {
          path_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string path = 3;</code>
     */
    public com.google.protobuf.ByteString
        getPathBytes() {
      java.lang.Object ref = path_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        path_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    private void initFields() {
      type_ = org.apache.reef.proto.ReefServiceProtos.FileType.PLAIN;
      name_ = "";
      path_ = "";
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasType()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasName()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasPath()) {
        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.writeEnum(1, type_.getNumber());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeBytes(2, getNameBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeBytes(3, getPathBytes());
      }
      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
          .computeEnumSize(1, type_.getNumber());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(2, getNameBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(3, getPathBytes());
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.FileResourceProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.FileResourceProto other = (org.apache.reef.proto.ReefServiceProtos.FileResourceProto) obj;

      boolean result = true;
      result = result && (hasType() == other.hasType());
      if (hasType()) {
        result = result &&
            (getType() == other.getType());
      }
      result = result && (hasName() == other.hasName());
      if (hasName()) {
        result = result && getName()
            .equals(other.getName());
      }
      result = result && (hasPath() == other.hasPath());
      if (hasPath()) {
        result = result && getPath()
            .equals(other.getPath());
      }
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasType()) {
        hash = (37 * hash) + TYPE_FIELD_NUMBER;
        hash = (53 * hash) + hashEnum(getType());
      }
      if (hasName()) {
        hash = (37 * hash) + NAME_FIELD_NUMBER;
        hash = (53 * hash) + getName().hashCode();
      }
      if (hasPath()) {
        hash = (37 * hash) + PATH_FIELD_NUMBER;
        hash = (53 * hash) + getPath().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto 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.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.FileResourceProto 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.reef.proto.ReefServiceProtos.FileResourceProto 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 FileResourceProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_FileResourceProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_FileResourceProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.FileResourceProto.class, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.FileResourceProto.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();
        type_ = org.apache.reef.proto.ReefServiceProtos.FileType.PLAIN;
        bitField0_ = (bitField0_ & ~0x00000001);
        name_ = "";
        bitField0_ = (bitField0_ & ~0x00000002);
        path_ = "";
        bitField0_ = (bitField0_ & ~0x00000004);
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_FileResourceProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.FileResourceProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.FileResourceProto build() {
        org.apache.reef.proto.ReefServiceProtos.FileResourceProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.FileResourceProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.FileResourceProto result = new org.apache.reef.proto.ReefServiceProtos.FileResourceProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.type_ = type_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.name_ = name_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.path_ = path_;
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.FileResourceProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.FileResourceProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.FileResourceProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance()) return this;
        if (other.hasType()) {
          setType(other.getType());
        }
        if (other.hasName()) {
          bitField0_ |= 0x00000002;
          name_ = other.name_;
          onChanged();
        }
        if (other.hasPath()) {
          bitField0_ |= 0x00000004;
          path_ = other.path_;
          onChanged();
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasType()) {
          
          return false;
        }
        if (!hasName()) {
          
          return false;
        }
        if (!hasPath()) {
          
          return false;
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.FileResourceProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.FileResourceProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required .FileType type = 1;
      private org.apache.reef.proto.ReefServiceProtos.FileType type_ = org.apache.reef.proto.ReefServiceProtos.FileType.PLAIN;
      /**
       * <code>required .FileType type = 1;</code>
       */
      public boolean hasType() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required .FileType type = 1;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.FileType getType() {
        return type_;
      }
      /**
       * <code>required .FileType type = 1;</code>
       */
      public Builder setType(org.apache.reef.proto.ReefServiceProtos.FileType value) {
        if (value == null) {
          throw new NullPointerException();
        }
        bitField0_ |= 0x00000001;
        type_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required .FileType type = 1;</code>
       */
      public Builder clearType() {
        bitField0_ = (bitField0_ & ~0x00000001);
        type_ = org.apache.reef.proto.ReefServiceProtos.FileType.PLAIN;
        onChanged();
        return this;
      }

      // required string name = 2;
      private java.lang.Object name_ = "";
      /**
       * <code>required string name = 2;</code>
       */
      public boolean hasName() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required string name = 2;</code>
       */
      public java.lang.String getName() {
        java.lang.Object ref = name_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          name_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string name = 2;</code>
       */
      public com.google.protobuf.ByteString
          getNameBytes() {
        java.lang.Object ref = name_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          name_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string name = 2;</code>
       */
      public Builder setName(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        name_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string name = 2;</code>
       */
      public Builder clearName() {
        bitField0_ = (bitField0_ & ~0x00000002);
        name_ = getDefaultInstance().getName();
        onChanged();
        return this;
      }
      /**
       * <code>required string name = 2;</code>
       */
      public Builder setNameBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        name_ = value;
        onChanged();
        return this;
      }

      // required string path = 3;
      private java.lang.Object path_ = "";
      /**
       * <code>required string path = 3;</code>
       */
      public boolean hasPath() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>required string path = 3;</code>
       */
      public java.lang.String getPath() {
        java.lang.Object ref = path_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          path_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string path = 3;</code>
       */
      public com.google.protobuf.ByteString
          getPathBytes() {
        java.lang.Object ref = path_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          path_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string path = 3;</code>
       */
      public Builder setPath(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        path_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string path = 3;</code>
       */
      public Builder clearPath() {
        bitField0_ = (bitField0_ & ~0x00000004);
        path_ = getDefaultInstance().getPath();
        onChanged();
        return this;
      }
      /**
       * <code>required string path = 3;</code>
       */
      public Builder setPathBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        path_ = value;
        onChanged();
        return this;
      }

      // @@protoc_insertion_point(builder_scope:FileResourceProto)
    }

    static {
      defaultInstance = new FileResourceProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:FileResourceProto)
  }

  public interface RuntimeErrorProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required string name = 1;
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    boolean hasName();
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    java.lang.String getName();
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    com.google.protobuf.ByteString
        getNameBytes();

    // required string message = 2;
    /**
     * <code>required string message = 2;</code>
     */
    boolean hasMessage();
    /**
     * <code>required string message = 2;</code>
     */
    java.lang.String getMessage();
    /**
     * <code>required string message = 2;</code>
     */
    com.google.protobuf.ByteString
        getMessageBytes();

    // optional bytes exception = 3;
    /**
     * <code>optional bytes exception = 3;</code>
     */
    boolean hasException();
    /**
     * <code>optional bytes exception = 3;</code>
     */
    com.google.protobuf.ByteString getException();

    // optional string identifier = 5;
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    boolean hasIdentifier();
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    java.lang.String getIdentifier();
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    com.google.protobuf.ByteString
        getIdentifierBytes();
  }
  /**
   * Protobuf type {@code RuntimeErrorProto}
   */
  public static final class RuntimeErrorProto extends
      com.google.protobuf.GeneratedMessage
      implements RuntimeErrorProtoOrBuilder {
    // Use RuntimeErrorProto.newBuilder() to construct.
    private RuntimeErrorProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private RuntimeErrorProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final RuntimeErrorProto defaultInstance;
    public static RuntimeErrorProto getDefaultInstance() {
      return defaultInstance;
    }

    public RuntimeErrorProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private RuntimeErrorProto(
        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;
              name_ = input.readBytes();
              break;
            }
            case 18: {
              bitField0_ |= 0x00000002;
              message_ = input.readBytes();
              break;
            }
            case 26: {
              bitField0_ |= 0x00000004;
              exception_ = input.readBytes();
              break;
            }
            case 42: {
              bitField0_ |= 0x00000008;
              identifier_ = 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.reef.proto.ReefServiceProtos.internal_static_RuntimeErrorProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_RuntimeErrorProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.class, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder.class);
    }

    public static com.google.protobuf.Parser<RuntimeErrorProto> PARSER =
        new com.google.protobuf.AbstractParser<RuntimeErrorProto>() {
      public RuntimeErrorProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new RuntimeErrorProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<RuntimeErrorProto> getParserForType() {
      return PARSER;
    }

    private int bitField0_;
    // required string name = 1;
    public static final int NAME_FIELD_NUMBER = 1;
    private java.lang.Object name_;
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    public boolean hasName() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    public java.lang.String getName() {
      java.lang.Object ref = name_;
      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()) {
          name_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string name = 1;</code>
     *
     * <pre>
     * e.g., local, yarn21
     * </pre>
     */
    public com.google.protobuf.ByteString
        getNameBytes() {
      java.lang.Object ref = name_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        name_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required string message = 2;
    public static final int MESSAGE_FIELD_NUMBER = 2;
    private java.lang.Object message_;
    /**
     * <code>required string message = 2;</code>
     */
    public boolean hasMessage() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required string message = 2;</code>
     */
    public java.lang.String getMessage() {
      java.lang.Object ref = message_;
      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()) {
          message_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string message = 2;</code>
     */
    public com.google.protobuf.ByteString
        getMessageBytes() {
      java.lang.Object ref = message_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        message_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // optional bytes exception = 3;
    public static final int EXCEPTION_FIELD_NUMBER = 3;
    private com.google.protobuf.ByteString exception_;
    /**
     * <code>optional bytes exception = 3;</code>
     */
    public boolean hasException() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>optional bytes exception = 3;</code>
     */
    public com.google.protobuf.ByteString getException() {
      return exception_;
    }

    // optional string identifier = 5;
    public static final int IDENTIFIER_FIELD_NUMBER = 5;
    private java.lang.Object identifier_;
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    public boolean hasIdentifier() {
      return ((bitField0_ & 0x00000008) == 0x00000008);
    }
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    public java.lang.String getIdentifier() {
      java.lang.Object ref = identifier_;
      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()) {
          identifier_ = s;
        }
        return s;
      }
    }
    /**
     * <code>optional string identifier = 5;</code>
     *
     * <pre>
     * e.g., evaluator id
     * </pre>
     */
    public com.google.protobuf.ByteString
        getIdentifierBytes() {
      java.lang.Object ref = identifier_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        identifier_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    private void initFields() {
      name_ = "";
      message_ = "";
      exception_ = com.google.protobuf.ByteString.EMPTY;
      identifier_ = "";
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasName()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasMessage()) {
        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, getNameBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeBytes(2, getMessageBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeBytes(3, exception_);
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        output.writeBytes(5, getIdentifierBytes());
      }
      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, getNameBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(2, getMessageBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(3, exception_);
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(5, getIdentifierBytes());
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto other = (org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto) obj;

      boolean result = true;
      result = result && (hasName() == other.hasName());
      if (hasName()) {
        result = result && getName()
            .equals(other.getName());
      }
      result = result && (hasMessage() == other.hasMessage());
      if (hasMessage()) {
        result = result && getMessage()
            .equals(other.getMessage());
      }
      result = result && (hasException() == other.hasException());
      if (hasException()) {
        result = result && getException()
            .equals(other.getException());
      }
      result = result && (hasIdentifier() == other.hasIdentifier());
      if (hasIdentifier()) {
        result = result && getIdentifier()
            .equals(other.getIdentifier());
      }
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasName()) {
        hash = (37 * hash) + NAME_FIELD_NUMBER;
        hash = (53 * hash) + getName().hashCode();
      }
      if (hasMessage()) {
        hash = (37 * hash) + MESSAGE_FIELD_NUMBER;
        hash = (53 * hash) + getMessage().hashCode();
      }
      if (hasException()) {
        hash = (37 * hash) + EXCEPTION_FIELD_NUMBER;
        hash = (53 * hash) + getException().hashCode();
      }
      if (hasIdentifier()) {
        hash = (37 * hash) + IDENTIFIER_FIELD_NUMBER;
        hash = (53 * hash) + getIdentifier().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto 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.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto 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.reef.proto.ReefServiceProtos.RuntimeErrorProto 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 RuntimeErrorProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_RuntimeErrorProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_RuntimeErrorProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.class, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.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();
        name_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        message_ = "";
        bitField0_ = (bitField0_ & ~0x00000002);
        exception_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000004);
        identifier_ = "";
        bitField0_ = (bitField0_ & ~0x00000008);
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_RuntimeErrorProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto build() {
        org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto result = new org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.name_ = name_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.message_ = message_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.exception_ = exception_;
        if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
          to_bitField0_ |= 0x00000008;
        }
        result.identifier_ = identifier_;
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance()) return this;
        if (other.hasName()) {
          bitField0_ |= 0x00000001;
          name_ = other.name_;
          onChanged();
        }
        if (other.hasMessage()) {
          bitField0_ |= 0x00000002;
          message_ = other.message_;
          onChanged();
        }
        if (other.hasException()) {
          setException(other.getException());
        }
        if (other.hasIdentifier()) {
          bitField0_ |= 0x00000008;
          identifier_ = other.identifier_;
          onChanged();
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasName()) {
          
          return false;
        }
        if (!hasMessage()) {
          
          return false;
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required string name = 1;
      private java.lang.Object name_ = "";
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public boolean hasName() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public java.lang.String getName() {
        java.lang.Object ref = name_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          name_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public com.google.protobuf.ByteString
          getNameBytes() {
        java.lang.Object ref = name_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          name_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public Builder setName(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        name_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public Builder clearName() {
        bitField0_ = (bitField0_ & ~0x00000001);
        name_ = getDefaultInstance().getName();
        onChanged();
        return this;
      }
      /**
       * <code>required string name = 1;</code>
       *
       * <pre>
       * e.g., local, yarn21
       * </pre>
       */
      public Builder setNameBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        name_ = value;
        onChanged();
        return this;
      }

      // required string message = 2;
      private java.lang.Object message_ = "";
      /**
       * <code>required string message = 2;</code>
       */
      public boolean hasMessage() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required string message = 2;</code>
       */
      public java.lang.String getMessage() {
        java.lang.Object ref = message_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          message_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string message = 2;</code>
       */
      public com.google.protobuf.ByteString
          getMessageBytes() {
        java.lang.Object ref = message_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          message_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string message = 2;</code>
       */
      public Builder setMessage(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        message_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string message = 2;</code>
       */
      public Builder clearMessage() {
        bitField0_ = (bitField0_ & ~0x00000002);
        message_ = getDefaultInstance().getMessage();
        onChanged();
        return this;
      }
      /**
       * <code>required string message = 2;</code>
       */
      public Builder setMessageBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        message_ = value;
        onChanged();
        return this;
      }

      // optional bytes exception = 3;
      private com.google.protobuf.ByteString exception_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes exception = 3;</code>
       */
      public boolean hasException() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>optional bytes exception = 3;</code>
       */
      public com.google.protobuf.ByteString getException() {
        return exception_;
      }
      /**
       * <code>optional bytes exception = 3;</code>
       */
      public Builder setException(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        exception_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes exception = 3;</code>
       */
      public Builder clearException() {
        bitField0_ = (bitField0_ & ~0x00000004);
        exception_ = getDefaultInstance().getException();
        onChanged();
        return this;
      }

      // optional string identifier = 5;
      private java.lang.Object identifier_ = "";
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public boolean hasIdentifier() {
        return ((bitField0_ & 0x00000008) == 0x00000008);
      }
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public java.lang.String getIdentifier() {
        java.lang.Object ref = identifier_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          identifier_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public com.google.protobuf.ByteString
          getIdentifierBytes() {
        java.lang.Object ref = identifier_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          identifier_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public Builder setIdentifier(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000008;
        identifier_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public Builder clearIdentifier() {
        bitField0_ = (bitField0_ & ~0x00000008);
        identifier_ = getDefaultInstance().getIdentifier();
        onChanged();
        return this;
      }
      /**
       * <code>optional string identifier = 5;</code>
       *
       * <pre>
       * e.g., evaluator id
       * </pre>
       */
      public Builder setIdentifierBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000008;
        identifier_ = value;
        onChanged();
        return this;
      }

      // @@protoc_insertion_point(builder_scope:RuntimeErrorProto)
    }

    static {
      defaultInstance = new RuntimeErrorProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:RuntimeErrorProto)
  }

  public interface JobStatusProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required string identifier = 1;
    /**
     * <code>required string identifier = 1;</code>
     */
    boolean hasIdentifier();
    /**
     * <code>required string identifier = 1;</code>
     */
    java.lang.String getIdentifier();
    /**
     * <code>required string identifier = 1;</code>
     */
    com.google.protobuf.ByteString
        getIdentifierBytes();

    // required .State state = 2;
    /**
     * <code>required .State state = 2;</code>
     */
    boolean hasState();
    /**
     * <code>required .State state = 2;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.State getState();

    // optional bytes message = 3;
    /**
     * <code>optional bytes message = 3;</code>
     */
    boolean hasMessage();
    /**
     * <code>optional bytes message = 3;</code>
     */
    com.google.protobuf.ByteString getMessage();

    // optional bytes exception = 4;
    /**
     * <code>optional bytes exception = 4;</code>
     */
    boolean hasException();
    /**
     * <code>optional bytes exception = 4;</code>
     */
    com.google.protobuf.ByteString getException();
  }
  /**
   * Protobuf type {@code JobStatusProto}
   */
  public static final class JobStatusProto extends
      com.google.protobuf.GeneratedMessage
      implements JobStatusProtoOrBuilder {
    // Use JobStatusProto.newBuilder() to construct.
    private JobStatusProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private JobStatusProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final JobStatusProto defaultInstance;
    public static JobStatusProto getDefaultInstance() {
      return defaultInstance;
    }

    public JobStatusProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private JobStatusProto(
        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;
              identifier_ = input.readBytes();
              break;
            }
            case 16: {
              int rawValue = input.readEnum();
              org.apache.reef.proto.ReefServiceProtos.State value = org.apache.reef.proto.ReefServiceProtos.State.valueOf(rawValue);
              if (value == null) {
                unknownFields.mergeVarintField(2, rawValue);
              } else {
                bitField0_ |= 0x00000002;
                state_ = value;
              }
              break;
            }
            case 26: {
              bitField0_ |= 0x00000004;
              message_ = input.readBytes();
              break;
            }
            case 34: {
              bitField0_ |= 0x00000008;
              exception_ = 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.reef.proto.ReefServiceProtos.internal_static_JobStatusProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_JobStatusProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.JobStatusProto.class, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder.class);
    }

    public static com.google.protobuf.Parser<JobStatusProto> PARSER =
        new com.google.protobuf.AbstractParser<JobStatusProto>() {
      public JobStatusProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new JobStatusProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<JobStatusProto> getParserForType() {
      return PARSER;
    }

    private int bitField0_;
    // required string identifier = 1;
    public static final int IDENTIFIER_FIELD_NUMBER = 1;
    private java.lang.Object identifier_;
    /**
     * <code>required string identifier = 1;</code>
     */
    public boolean hasIdentifier() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required string identifier = 1;</code>
     */
    public java.lang.String getIdentifier() {
      java.lang.Object ref = identifier_;
      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()) {
          identifier_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string identifier = 1;</code>
     */
    public com.google.protobuf.ByteString
        getIdentifierBytes() {
      java.lang.Object ref = identifier_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        identifier_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required .State state = 2;
    public static final int STATE_FIELD_NUMBER = 2;
    private org.apache.reef.proto.ReefServiceProtos.State state_;
    /**
     * <code>required .State state = 2;</code>
     */
    public boolean hasState() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required .State state = 2;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.State getState() {
      return state_;
    }

    // optional bytes message = 3;
    public static final int MESSAGE_FIELD_NUMBER = 3;
    private com.google.protobuf.ByteString message_;
    /**
     * <code>optional bytes message = 3;</code>
     */
    public boolean hasMessage() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>optional bytes message = 3;</code>
     */
    public com.google.protobuf.ByteString getMessage() {
      return message_;
    }

    // optional bytes exception = 4;
    public static final int EXCEPTION_FIELD_NUMBER = 4;
    private com.google.protobuf.ByteString exception_;
    /**
     * <code>optional bytes exception = 4;</code>
     */
    public boolean hasException() {
      return ((bitField0_ & 0x00000008) == 0x00000008);
    }
    /**
     * <code>optional bytes exception = 4;</code>
     */
    public com.google.protobuf.ByteString getException() {
      return exception_;
    }

    private void initFields() {
      identifier_ = "";
      state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      message_ = com.google.protobuf.ByteString.EMPTY;
      exception_ = com.google.protobuf.ByteString.EMPTY;
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasIdentifier()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasState()) {
        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, getIdentifierBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeEnum(2, state_.getNumber());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeBytes(3, message_);
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        output.writeBytes(4, exception_);
      }
      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, getIdentifierBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeEnumSize(2, state_.getNumber());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(3, message_);
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(4, exception_);
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.JobStatusProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.JobStatusProto other = (org.apache.reef.proto.ReefServiceProtos.JobStatusProto) obj;

      boolean result = true;
      result = result && (hasIdentifier() == other.hasIdentifier());
      if (hasIdentifier()) {
        result = result && getIdentifier()
            .equals(other.getIdentifier());
      }
      result = result && (hasState() == other.hasState());
      if (hasState()) {
        result = result &&
            (getState() == other.getState());
      }
      result = result && (hasMessage() == other.hasMessage());
      if (hasMessage()) {
        result = result && getMessage()
            .equals(other.getMessage());
      }
      result = result && (hasException() == other.hasException());
      if (hasException()) {
        result = result && getException()
            .equals(other.getException());
      }
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasIdentifier()) {
        hash = (37 * hash) + IDENTIFIER_FIELD_NUMBER;
        hash = (53 * hash) + getIdentifier().hashCode();
      }
      if (hasState()) {
        hash = (37 * hash) + STATE_FIELD_NUMBER;
        hash = (53 * hash) + hashEnum(getState());
      }
      if (hasMessage()) {
        hash = (37 * hash) + MESSAGE_FIELD_NUMBER;
        hash = (53 * hash) + getMessage().hashCode();
      }
      if (hasException()) {
        hash = (37 * hash) + EXCEPTION_FIELD_NUMBER;
        hash = (53 * hash) + getException().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto 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.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.JobStatusProto 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.reef.proto.ReefServiceProtos.JobStatusProto 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 JobStatusProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_JobStatusProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_JobStatusProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.JobStatusProto.class, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.JobStatusProto.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();
        identifier_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        bitField0_ = (bitField0_ & ~0x00000002);
        message_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000004);
        exception_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000008);
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_JobStatusProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.JobStatusProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.JobStatusProto build() {
        org.apache.reef.proto.ReefServiceProtos.JobStatusProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.JobStatusProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.JobStatusProto result = new org.apache.reef.proto.ReefServiceProtos.JobStatusProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.identifier_ = identifier_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.state_ = state_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.message_ = message_;
        if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
          to_bitField0_ |= 0x00000008;
        }
        result.exception_ = exception_;
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.JobStatusProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.JobStatusProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.JobStatusProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance()) return this;
        if (other.hasIdentifier()) {
          bitField0_ |= 0x00000001;
          identifier_ = other.identifier_;
          onChanged();
        }
        if (other.hasState()) {
          setState(other.getState());
        }
        if (other.hasMessage()) {
          setMessage(other.getMessage());
        }
        if (other.hasException()) {
          setException(other.getException());
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasIdentifier()) {
          
          return false;
        }
        if (!hasState()) {
          
          return false;
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.JobStatusProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.JobStatusProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required string identifier = 1;
      private java.lang.Object identifier_ = "";
      /**
       * <code>required string identifier = 1;</code>
       */
      public boolean hasIdentifier() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string identifier = 1;</code>
       */
      public java.lang.String getIdentifier() {
        java.lang.Object ref = identifier_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          identifier_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string identifier = 1;</code>
       */
      public com.google.protobuf.ByteString
          getIdentifierBytes() {
        java.lang.Object ref = identifier_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          identifier_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string identifier = 1;</code>
       */
      public Builder setIdentifier(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        identifier_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string identifier = 1;</code>
       */
      public Builder clearIdentifier() {
        bitField0_ = (bitField0_ & ~0x00000001);
        identifier_ = getDefaultInstance().getIdentifier();
        onChanged();
        return this;
      }
      /**
       * <code>required string identifier = 1;</code>
       */
      public Builder setIdentifierBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        identifier_ = value;
        onChanged();
        return this;
      }

      // required .State state = 2;
      private org.apache.reef.proto.ReefServiceProtos.State state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      /**
       * <code>required .State state = 2;</code>
       */
      public boolean hasState() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.State getState() {
        return state_;
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public Builder setState(org.apache.reef.proto.ReefServiceProtos.State value) {
        if (value == null) {
          throw new NullPointerException();
        }
        bitField0_ |= 0x00000002;
        state_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public Builder clearState() {
        bitField0_ = (bitField0_ & ~0x00000002);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        onChanged();
        return this;
      }

      // optional bytes message = 3;
      private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes message = 3;</code>
       */
      public boolean hasMessage() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>optional bytes message = 3;</code>
       */
      public com.google.protobuf.ByteString getMessage() {
        return message_;
      }
      /**
       * <code>optional bytes message = 3;</code>
       */
      public Builder setMessage(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        message_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes message = 3;</code>
       */
      public Builder clearMessage() {
        bitField0_ = (bitField0_ & ~0x00000004);
        message_ = getDefaultInstance().getMessage();
        onChanged();
        return this;
      }

      // optional bytes exception = 4;
      private com.google.protobuf.ByteString exception_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes exception = 4;</code>
       */
      public boolean hasException() {
        return ((bitField0_ & 0x00000008) == 0x00000008);
      }
      /**
       * <code>optional bytes exception = 4;</code>
       */
      public com.google.protobuf.ByteString getException() {
        return exception_;
      }
      /**
       * <code>optional bytes exception = 4;</code>
       */
      public Builder setException(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000008;
        exception_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes exception = 4;</code>
       */
      public Builder clearException() {
        bitField0_ = (bitField0_ & ~0x00000008);
        exception_ = getDefaultInstance().getException();
        onChanged();
        return this;
      }

      // @@protoc_insertion_point(builder_scope:JobStatusProto)
    }

    static {
      defaultInstance = new JobStatusProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:JobStatusProto)
  }

  public interface ContextStatusProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required .ContextStatusProto.State context_state = 1;
    /**
     * <code>required .ContextStatusProto.State context_state = 1;</code>
     */
    boolean hasContextState();
    /**
     * <code>required .ContextStatusProto.State context_state = 1;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State getContextState();

    // required string context_id = 2;
    /**
     * <code>required string context_id = 2;</code>
     */
    boolean hasContextId();
    /**
     * <code>required string context_id = 2;</code>
     */
    java.lang.String getContextId();
    /**
     * <code>required string context_id = 2;</code>
     */
    com.google.protobuf.ByteString
        getContextIdBytes();

    // optional string parent_id = 3;
    /**
     * <code>optional string parent_id = 3;</code>
     */
    boolean hasParentId();
    /**
     * <code>optional string parent_id = 3;</code>
     */
    java.lang.String getParentId();
    /**
     * <code>optional string parent_id = 3;</code>
     */
    com.google.protobuf.ByteString
        getParentIdBytes();

    // optional bytes error = 5;
    /**
     * <code>optional bytes error = 5;</code>
     *
     * <pre>
     * when creating the context
     * </pre>
     */
    boolean hasError();
    /**
     * <code>optional bytes error = 5;</code>
     *
     * <pre>
     * when creating the context
     * </pre>
     */
    com.google.protobuf.ByteString getError();

    // optional bool recovery = 6;
    /**
     * <code>optional bool recovery = 6;</code>
     */
    boolean hasRecovery();
    /**
     * <code>optional bool recovery = 6;</code>
     */
    boolean getRecovery();

    // repeated .ContextStatusProto.ContextMessageProto context_message = 7;
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> 
        getContextMessageList();
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto getContextMessage(int index);
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    int getContextMessageCount();
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder> 
        getContextMessageOrBuilderList();
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder getContextMessageOrBuilder(
        int index);
  }
  /**
   * Protobuf type {@code ContextStatusProto}
   */
  public static final class ContextStatusProto extends
      com.google.protobuf.GeneratedMessage
      implements ContextStatusProtoOrBuilder {
    // Use ContextStatusProto.newBuilder() to construct.
    private ContextStatusProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private ContextStatusProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final ContextStatusProto defaultInstance;
    public static ContextStatusProto getDefaultInstance() {
      return defaultInstance;
    }

    public ContextStatusProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private ContextStatusProto(
        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 8: {
              int rawValue = input.readEnum();
              org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State value = org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State.valueOf(rawValue);
              if (value == null) {
                unknownFields.mergeVarintField(1, rawValue);
              } else {
                bitField0_ |= 0x00000001;
                contextState_ = value;
              }
              break;
            }
            case 18: {
              bitField0_ |= 0x00000002;
              contextId_ = input.readBytes();
              break;
            }
            case 26: {
              bitField0_ |= 0x00000004;
              parentId_ = input.readBytes();
              break;
            }
            case 42: {
              bitField0_ |= 0x00000008;
              error_ = input.readBytes();
              break;
            }
            case 48: {
              bitField0_ |= 0x00000010;
              recovery_ = input.readBool();
              break;
            }
            case 58: {
              if (!((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
                contextMessage_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto>();
                mutable_bitField0_ |= 0x00000020;
              }
              contextMessage_.add(input.readMessage(org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.PARSER, extensionRegistry));
              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 {
        if (((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
          contextMessage_ = java.util.Collections.unmodifiableList(contextMessage_);
        }
        this.unknownFields = unknownFields.build();
        makeExtensionsImmutable();
      }
    }
    public static final com.google.protobuf.Descriptors.Descriptor
        getDescriptor() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.class, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder.class);
    }

    public static com.google.protobuf.Parser<ContextStatusProto> PARSER =
        new com.google.protobuf.AbstractParser<ContextStatusProto>() {
      public ContextStatusProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new ContextStatusProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<ContextStatusProto> getParserForType() {
      return PARSER;
    }

    /**
     * Protobuf enum {@code ContextStatusProto.State}
     */
    public enum State
        implements com.google.protobuf.ProtocolMessageEnum {
      /**
       * <code>READY = 0;</code>
       */
      READY(0, 0),
      /**
       * <code>DONE = 1;</code>
       */
      DONE(1, 1),
      /**
       * <code>FAIL = 2;</code>
       */
      FAIL(2, 2),
      ;

      /**
       * <code>READY = 0;</code>
       */
      public static final int READY_VALUE = 0;
      /**
       * <code>DONE = 1;</code>
       */
      public static final int DONE_VALUE = 1;
      /**
       * <code>FAIL = 2;</code>
       */
      public static final int FAIL_VALUE = 2;


      public final int getNumber() { return value; }

      public static State valueOf(int value) {
        switch (value) {
          case 0: return READY;
          case 1: return DONE;
          case 2: return FAIL;
          default: return null;
        }
      }

      public static com.google.protobuf.Internal.EnumLiteMap<State>
          internalGetValueMap() {
        return internalValueMap;
      }
      private static com.google.protobuf.Internal.EnumLiteMap<State>
          internalValueMap =
            new com.google.protobuf.Internal.EnumLiteMap<State>() {
              public State findValueByNumber(int number) {
                return State.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.reef.proto.ReefServiceProtos.ContextStatusProto.getDescriptor().getEnumTypes().get(0);
      }

      private static final State[] VALUES = values();

      public static State 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 State(int index, int value) {
        this.index = index;
        this.value = value;
      }

      // @@protoc_insertion_point(enum_scope:ContextStatusProto.State)
    }

    public interface ContextMessageProtoOrBuilder
        extends com.google.protobuf.MessageOrBuilder {

      // required string source_id = 1;
      /**
       * <code>required string source_id = 1;</code>
       */
      boolean hasSourceId();
      /**
       * <code>required string source_id = 1;</code>
       */
      java.lang.String getSourceId();
      /**
       * <code>required string source_id = 1;</code>
       */
      com.google.protobuf.ByteString
          getSourceIdBytes();

      // required bytes message = 2;
      /**
       * <code>required bytes message = 2;</code>
       */
      boolean hasMessage();
      /**
       * <code>required bytes message = 2;</code>
       */
      com.google.protobuf.ByteString getMessage();
    }
    /**
     * Protobuf type {@code ContextStatusProto.ContextMessageProto}
     *
     * <pre>
     * Context messages
     * </pre>
     */
    public static final class ContextMessageProto extends
        com.google.protobuf.GeneratedMessage
        implements ContextMessageProtoOrBuilder {
      // Use ContextMessageProto.newBuilder() to construct.
      private ContextMessageProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
        super(builder);
        this.unknownFields = builder.getUnknownFields();
      }
      private ContextMessageProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

      private static final ContextMessageProto defaultInstance;
      public static ContextMessageProto getDefaultInstance() {
        return defaultInstance;
      }

      public ContextMessageProto getDefaultInstanceForType() {
        return defaultInstance;
      }

      private final com.google.protobuf.UnknownFieldSet unknownFields;
      @java.lang.Override
      public final com.google.protobuf.UnknownFieldSet
          getUnknownFields() {
        return this.unknownFields;
      }
      private ContextMessageProto(
          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;
                sourceId_ = input.readBytes();
                break;
              }
              case 18: {
                bitField0_ |= 0x00000002;
                message_ = 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.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_ContextMessageProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_ContextMessageProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.class, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder.class);
      }

      public static com.google.protobuf.Parser<ContextMessageProto> PARSER =
          new com.google.protobuf.AbstractParser<ContextMessageProto>() {
        public ContextMessageProto parsePartialFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return new ContextMessageProto(input, extensionRegistry);
        }
      };

      @java.lang.Override
      public com.google.protobuf.Parser<ContextMessageProto> getParserForType() {
        return PARSER;
      }

      private int bitField0_;
      // required string source_id = 1;
      public static final int SOURCE_ID_FIELD_NUMBER = 1;
      private java.lang.Object sourceId_;
      /**
       * <code>required string source_id = 1;</code>
       */
      public boolean hasSourceId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string source_id = 1;</code>
       */
      public java.lang.String getSourceId() {
        java.lang.Object ref = sourceId_;
        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()) {
            sourceId_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string source_id = 1;</code>
       */
      public com.google.protobuf.ByteString
          getSourceIdBytes() {
        java.lang.Object ref = sourceId_;
        if (ref instanceof java.lang.String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          sourceId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }

      // required bytes message = 2;
      public static final int MESSAGE_FIELD_NUMBER = 2;
      private com.google.protobuf.ByteString message_;
      /**
       * <code>required bytes message = 2;</code>
       */
      public boolean hasMessage() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required bytes message = 2;</code>
       */
      public com.google.protobuf.ByteString getMessage() {
        return message_;
      }

      private void initFields() {
        sourceId_ = "";
        message_ = com.google.protobuf.ByteString.EMPTY;
      }
      private byte memoizedIsInitialized = -1;
      public final boolean isInitialized() {
        byte isInitialized = memoizedIsInitialized;
        if (isInitialized != -1) return isInitialized == 1;

        if (!hasSourceId()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasMessage()) {
          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, getSourceIdBytes());
        }
        if (((bitField0_ & 0x00000002) == 0x00000002)) {
          output.writeBytes(2, message_);
        }
        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, getSourceIdBytes());
        }
        if (((bitField0_ & 0x00000002) == 0x00000002)) {
          size += com.google.protobuf.CodedOutputStream
            .computeBytesSize(2, message_);
        }
        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();
      }

      @java.lang.Override
      public boolean equals(final java.lang.Object obj) {
        if (obj == this) {
         return true;
        }
        if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto)) {
          return super.equals(obj);
        }
        org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto other = (org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto) obj;

        boolean result = true;
        result = result && (hasSourceId() == other.hasSourceId());
        if (hasSourceId()) {
          result = result && getSourceId()
              .equals(other.getSourceId());
        }
        result = result && (hasMessage() == other.hasMessage());
        if (hasMessage()) {
          result = result && getMessage()
              .equals(other.getMessage());
        }
        result = result &&
            getUnknownFields().equals(other.getUnknownFields());
        return result;
      }

      private int memoizedHashCode = 0;
      @java.lang.Override
      public int hashCode() {
        if (memoizedHashCode != 0) {
          return memoizedHashCode;
        }
        int hash = 41;
        hash = (19 * hash) + getDescriptorForType().hashCode();
        if (hasSourceId()) {
          hash = (37 * hash) + SOURCE_ID_FIELD_NUMBER;
          hash = (53 * hash) + getSourceId().hashCode();
        }
        if (hasMessage()) {
          hash = (37 * hash) + MESSAGE_FIELD_NUMBER;
          hash = (53 * hash) + getMessage().hashCode();
        }
        hash = (29 * hash) + getUnknownFields().hashCode();
        memoizedHashCode = hash;
        return hash;
      }

      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(
          com.google.protobuf.ByteString data)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto 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.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(byte[] data)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(
          byte[] data,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(java.io.InputStream input)
          throws java.io.IOException {
        return PARSER.parseFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(
          java.io.InputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return PARSER.parseFrom(input, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseDelimitedFrom(java.io.InputStream input)
          throws java.io.IOException {
        return PARSER.parseDelimitedFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseDelimitedFrom(
          java.io.InputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return PARSER.parseDelimitedFrom(input, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parseFrom(
          com.google.protobuf.CodedInputStream input)
          throws java.io.IOException {
        return PARSER.parseFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto 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.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto 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 ContextStatusProto.ContextMessageProto}
       *
       * <pre>
       * Context messages
       * </pre>
       */
      public static final class Builder extends
          com.google.protobuf.GeneratedMessage.Builder<Builder>
         implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder {
        public static final com.google.protobuf.Descriptors.Descriptor
            getDescriptor() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_ContextMessageProto_descriptor;
        }

        protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
            internalGetFieldAccessorTable() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_ContextMessageProto_fieldAccessorTable
              .ensureFieldAccessorsInitialized(
                  org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.class, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder.class);
        }

        // Construct using org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.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();
          sourceId_ = "";
          bitField0_ = (bitField0_ & ~0x00000001);
          message_ = com.google.protobuf.ByteString.EMPTY;
          bitField0_ = (bitField0_ & ~0x00000002);
          return this;
        }

        public Builder clone() {
          return create().mergeFrom(buildPartial());
        }

        public com.google.protobuf.Descriptors.Descriptor
            getDescriptorForType() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_ContextMessageProto_descriptor;
        }

        public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto getDefaultInstanceForType() {
          return org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.getDefaultInstance();
        }

        public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto build() {
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto result = buildPartial();
          if (!result.isInitialized()) {
            throw newUninitializedMessageException(result);
          }
          return result;
        }

        public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto buildPartial() {
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto result = new org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto(this);
          int from_bitField0_ = bitField0_;
          int to_bitField0_ = 0;
          if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
            to_bitField0_ |= 0x00000001;
          }
          result.sourceId_ = sourceId_;
          if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
            to_bitField0_ |= 0x00000002;
          }
          result.message_ = message_;
          result.bitField0_ = to_bitField0_;
          onBuilt();
          return result;
        }

        public Builder mergeFrom(com.google.protobuf.Message other) {
          if (other instanceof org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto) {
            return mergeFrom((org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto)other);
          } else {
            super.mergeFrom(other);
            return this;
          }
        }

        public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto other) {
          if (other == org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.getDefaultInstance()) return this;
          if (other.hasSourceId()) {
            bitField0_ |= 0x00000001;
            sourceId_ = other.sourceId_;
            onChanged();
          }
          if (other.hasMessage()) {
            setMessage(other.getMessage());
          }
          this.mergeUnknownFields(other.getUnknownFields());
          return this;
        }

        public final boolean isInitialized() {
          if (!hasSourceId()) {
            
            return false;
          }
          if (!hasMessage()) {
            
            return false;
          }
          return true;
        }

        public Builder mergeFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto parsedMessage = null;
          try {
            parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
          } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            parsedMessage = (org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto) e.getUnfinishedMessage();
            throw e;
          } finally {
            if (parsedMessage != null) {
              mergeFrom(parsedMessage);
            }
          }
          return this;
        }
        private int bitField0_;

        // required string source_id = 1;
        private java.lang.Object sourceId_ = "";
        /**
         * <code>required string source_id = 1;</code>
         */
        public boolean hasSourceId() {
          return ((bitField0_ & 0x00000001) == 0x00000001);
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public java.lang.String getSourceId() {
          java.lang.Object ref = sourceId_;
          if (!(ref instanceof java.lang.String)) {
            java.lang.String s = ((com.google.protobuf.ByteString) ref)
                .toStringUtf8();
            sourceId_ = s;
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public com.google.protobuf.ByteString
            getSourceIdBytes() {
          java.lang.Object ref = sourceId_;
          if (ref instanceof String) {
            com.google.protobuf.ByteString b = 
                com.google.protobuf.ByteString.copyFromUtf8(
                    (java.lang.String) ref);
            sourceId_ = b;
            return b;
          } else {
            return (com.google.protobuf.ByteString) ref;
          }
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder setSourceId(
            java.lang.String value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
          sourceId_ = value;
          onChanged();
          return this;
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder clearSourceId() {
          bitField0_ = (bitField0_ & ~0x00000001);
          sourceId_ = getDefaultInstance().getSourceId();
          onChanged();
          return this;
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder setSourceIdBytes(
            com.google.protobuf.ByteString value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
          sourceId_ = value;
          onChanged();
          return this;
        }

        // required bytes message = 2;
        private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY;
        /**
         * <code>required bytes message = 2;</code>
         */
        public boolean hasMessage() {
          return ((bitField0_ & 0x00000002) == 0x00000002);
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public com.google.protobuf.ByteString getMessage() {
          return message_;
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public Builder setMessage(com.google.protobuf.ByteString value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
          message_ = value;
          onChanged();
          return this;
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public Builder clearMessage() {
          bitField0_ = (bitField0_ & ~0x00000002);
          message_ = getDefaultInstance().getMessage();
          onChanged();
          return this;
        }

        // @@protoc_insertion_point(builder_scope:ContextStatusProto.ContextMessageProto)
      }

      static {
        defaultInstance = new ContextMessageProto(true);
        defaultInstance.initFields();
      }

      // @@protoc_insertion_point(class_scope:ContextStatusProto.ContextMessageProto)
    }

    private int bitField0_;
    // required .ContextStatusProto.State context_state = 1;
    public static final int CONTEXT_STATE_FIELD_NUMBER = 1;
    private org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State contextState_;
    /**
     * <code>required .ContextStatusProto.State context_state = 1;</code>
     */
    public boolean hasContextState() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required .ContextStatusProto.State context_state = 1;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State getContextState() {
      return contextState_;
    }

    // required string context_id = 2;
    public static final int CONTEXT_ID_FIELD_NUMBER = 2;
    private java.lang.Object contextId_;
    /**
     * <code>required string context_id = 2;</code>
     */
    public boolean hasContextId() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required string context_id = 2;</code>
     */
    public java.lang.String getContextId() {
      java.lang.Object ref = contextId_;
      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()) {
          contextId_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string context_id = 2;</code>
     */
    public com.google.protobuf.ByteString
        getContextIdBytes() {
      java.lang.Object ref = contextId_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        contextId_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // optional string parent_id = 3;
    public static final int PARENT_ID_FIELD_NUMBER = 3;
    private java.lang.Object parentId_;
    /**
     * <code>optional string parent_id = 3;</code>
     */
    public boolean hasParentId() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>optional string parent_id = 3;</code>
     */
    public java.lang.String getParentId() {
      java.lang.Object ref = parentId_;
      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()) {
          parentId_ = s;
        }
        return s;
      }
    }
    /**
     * <code>optional string parent_id = 3;</code>
     */
    public com.google.protobuf.ByteString
        getParentIdBytes() {
      java.lang.Object ref = parentId_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        parentId_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // optional bytes error = 5;
    public static final int ERROR_FIELD_NUMBER = 5;
    private com.google.protobuf.ByteString error_;
    /**
     * <code>optional bytes error = 5;</code>
     *
     * <pre>
     * when creating the context
     * </pre>
     */
    public boolean hasError() {
      return ((bitField0_ & 0x00000008) == 0x00000008);
    }
    /**
     * <code>optional bytes error = 5;</code>
     *
     * <pre>
     * when creating the context
     * </pre>
     */
    public com.google.protobuf.ByteString getError() {
      return error_;
    }

    // optional bool recovery = 6;
    public static final int RECOVERY_FIELD_NUMBER = 6;
    private boolean recovery_;
    /**
     * <code>optional bool recovery = 6;</code>
     */
    public boolean hasRecovery() {
      return ((bitField0_ & 0x00000010) == 0x00000010);
    }
    /**
     * <code>optional bool recovery = 6;</code>
     */
    public boolean getRecovery() {
      return recovery_;
    }

    // repeated .ContextStatusProto.ContextMessageProto context_message = 7;
    public static final int CONTEXT_MESSAGE_FIELD_NUMBER = 7;
    private java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> contextMessage_;
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    public java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> getContextMessageList() {
      return contextMessage_;
    }
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder> 
        getContextMessageOrBuilderList() {
      return contextMessage_;
    }
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    public int getContextMessageCount() {
      return contextMessage_.size();
    }
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto getContextMessage(int index) {
      return contextMessage_.get(index);
    }
    /**
     * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder getContextMessageOrBuilder(
        int index) {
      return contextMessage_.get(index);
    }

    private void initFields() {
      contextState_ = org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State.READY;
      contextId_ = "";
      parentId_ = "";
      error_ = com.google.protobuf.ByteString.EMPTY;
      recovery_ = false;
      contextMessage_ = java.util.Collections.emptyList();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasContextState()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasContextId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      for (int i = 0; i < getContextMessageCount(); i++) {
        if (!getContextMessage(i).isInitialized()) {
          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.writeEnum(1, contextState_.getNumber());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeBytes(2, getContextIdBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeBytes(3, getParentIdBytes());
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        output.writeBytes(5, error_);
      }
      if (((bitField0_ & 0x00000010) == 0x00000010)) {
        output.writeBool(6, recovery_);
      }
      for (int i = 0; i < contextMessage_.size(); i++) {
        output.writeMessage(7, contextMessage_.get(i));
      }
      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
          .computeEnumSize(1, contextState_.getNumber());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(2, getContextIdBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(3, getParentIdBytes());
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(5, error_);
      }
      if (((bitField0_ & 0x00000010) == 0x00000010)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBoolSize(6, recovery_);
      }
      for (int i = 0; i < contextMessage_.size(); i++) {
        size += com.google.protobuf.CodedOutputStream
          .computeMessageSize(7, contextMessage_.get(i));
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.ContextStatusProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.ContextStatusProto other = (org.apache.reef.proto.ReefServiceProtos.ContextStatusProto) obj;

      boolean result = true;
      result = result && (hasContextState() == other.hasContextState());
      if (hasContextState()) {
        result = result &&
            (getContextState() == other.getContextState());
      }
      result = result && (hasContextId() == other.hasContextId());
      if (hasContextId()) {
        result = result && getContextId()
            .equals(other.getContextId());
      }
      result = result && (hasParentId() == other.hasParentId());
      if (hasParentId()) {
        result = result && getParentId()
            .equals(other.getParentId());
      }
      result = result && (hasError() == other.hasError());
      if (hasError()) {
        result = result && getError()
            .equals(other.getError());
      }
      result = result && (hasRecovery() == other.hasRecovery());
      if (hasRecovery()) {
        result = result && (getRecovery()
            == other.getRecovery());
      }
      result = result && getContextMessageList()
          .equals(other.getContextMessageList());
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasContextState()) {
        hash = (37 * hash) + CONTEXT_STATE_FIELD_NUMBER;
        hash = (53 * hash) + hashEnum(getContextState());
      }
      if (hasContextId()) {
        hash = (37 * hash) + CONTEXT_ID_FIELD_NUMBER;
        hash = (53 * hash) + getContextId().hashCode();
      }
      if (hasParentId()) {
        hash = (37 * hash) + PARENT_ID_FIELD_NUMBER;
        hash = (53 * hash) + getParentId().hashCode();
      }
      if (hasError()) {
        hash = (37 * hash) + ERROR_FIELD_NUMBER;
        hash = (53 * hash) + getError().hashCode();
      }
      if (hasRecovery()) {
        hash = (37 * hash) + RECOVERY_FIELD_NUMBER;
        hash = (53 * hash) + hashBoolean(getRecovery());
      }
      if (getContextMessageCount() > 0) {
        hash = (37 * hash) + CONTEXT_MESSAGE_FIELD_NUMBER;
        hash = (53 * hash) + getContextMessageList().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto 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.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.ContextStatusProto 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.reef.proto.ReefServiceProtos.ContextStatusProto 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 ContextStatusProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.class, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.newBuilder()
      private Builder() {
        maybeForceBuilderInitialization();
      }

      private Builder(
          com.google.protobuf.GeneratedMessage.BuilderParent parent) {
        super(parent);
        maybeForceBuilderInitialization();
      }
      private void maybeForceBuilderInitialization() {
        if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
          getContextMessageFieldBuilder();
        }
      }
      private static Builder create() {
        return new Builder();
      }

      public Builder clear() {
        super.clear();
        contextState_ = org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State.READY;
        bitField0_ = (bitField0_ & ~0x00000001);
        contextId_ = "";
        bitField0_ = (bitField0_ & ~0x00000002);
        parentId_ = "";
        bitField0_ = (bitField0_ & ~0x00000004);
        error_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000008);
        recovery_ = false;
        bitField0_ = (bitField0_ & ~0x00000010);
        if (contextMessageBuilder_ == null) {
          contextMessage_ = java.util.Collections.emptyList();
          bitField0_ = (bitField0_ & ~0x00000020);
        } else {
          contextMessageBuilder_.clear();
        }
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_ContextStatusProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto build() {
        org.apache.reef.proto.ReefServiceProtos.ContextStatusProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.ContextStatusProto result = new org.apache.reef.proto.ReefServiceProtos.ContextStatusProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.contextState_ = contextState_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.contextId_ = contextId_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.parentId_ = parentId_;
        if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
          to_bitField0_ |= 0x00000008;
        }
        result.error_ = error_;
        if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
          to_bitField0_ |= 0x00000010;
        }
        result.recovery_ = recovery_;
        if (contextMessageBuilder_ == null) {
          if (((bitField0_ & 0x00000020) == 0x00000020)) {
            contextMessage_ = java.util.Collections.unmodifiableList(contextMessage_);
            bitField0_ = (bitField0_ & ~0x00000020);
          }
          result.contextMessage_ = contextMessage_;
        } else {
          result.contextMessage_ = contextMessageBuilder_.build();
        }
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.ContextStatusProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.ContextStatusProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.ContextStatusProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.getDefaultInstance()) return this;
        if (other.hasContextState()) {
          setContextState(other.getContextState());
        }
        if (other.hasContextId()) {
          bitField0_ |= 0x00000002;
          contextId_ = other.contextId_;
          onChanged();
        }
        if (other.hasParentId()) {
          bitField0_ |= 0x00000004;
          parentId_ = other.parentId_;
          onChanged();
        }
        if (other.hasError()) {
          setError(other.getError());
        }
        if (other.hasRecovery()) {
          setRecovery(other.getRecovery());
        }
        if (contextMessageBuilder_ == null) {
          if (!other.contextMessage_.isEmpty()) {
            if (contextMessage_.isEmpty()) {
              contextMessage_ = other.contextMessage_;
              bitField0_ = (bitField0_ & ~0x00000020);
            } else {
              ensureContextMessageIsMutable();
              contextMessage_.addAll(other.contextMessage_);
            }
            onChanged();
          }
        } else {
          if (!other.contextMessage_.isEmpty()) {
            if (contextMessageBuilder_.isEmpty()) {
              contextMessageBuilder_.dispose();
              contextMessageBuilder_ = null;
              contextMessage_ = other.contextMessage_;
              bitField0_ = (bitField0_ & ~0x00000020);
              contextMessageBuilder_ = 
                com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
                   getContextMessageFieldBuilder() : null;
            } else {
              contextMessageBuilder_.addAllMessages(other.contextMessage_);
            }
          }
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasContextState()) {
          
          return false;
        }
        if (!hasContextId()) {
          
          return false;
        }
        for (int i = 0; i < getContextMessageCount(); i++) {
          if (!getContextMessage(i).isInitialized()) {
            
            return false;
          }
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.ContextStatusProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.ContextStatusProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required .ContextStatusProto.State context_state = 1;
      private org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State contextState_ = org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State.READY;
      /**
       * <code>required .ContextStatusProto.State context_state = 1;</code>
       */
      public boolean hasContextState() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required .ContextStatusProto.State context_state = 1;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State getContextState() {
        return contextState_;
      }
      /**
       * <code>required .ContextStatusProto.State context_state = 1;</code>
       */
      public Builder setContextState(org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State value) {
        if (value == null) {
          throw new NullPointerException();
        }
        bitField0_ |= 0x00000001;
        contextState_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required .ContextStatusProto.State context_state = 1;</code>
       */
      public Builder clearContextState() {
        bitField0_ = (bitField0_ & ~0x00000001);
        contextState_ = org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State.READY;
        onChanged();
        return this;
      }

      // required string context_id = 2;
      private java.lang.Object contextId_ = "";
      /**
       * <code>required string context_id = 2;</code>
       */
      public boolean hasContextId() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public java.lang.String getContextId() {
        java.lang.Object ref = contextId_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          contextId_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public com.google.protobuf.ByteString
          getContextIdBytes() {
        java.lang.Object ref = contextId_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          contextId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder setContextId(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        contextId_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder clearContextId() {
        bitField0_ = (bitField0_ & ~0x00000002);
        contextId_ = getDefaultInstance().getContextId();
        onChanged();
        return this;
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder setContextIdBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        contextId_ = value;
        onChanged();
        return this;
      }

      // optional string parent_id = 3;
      private java.lang.Object parentId_ = "";
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public boolean hasParentId() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public java.lang.String getParentId() {
        java.lang.Object ref = parentId_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          parentId_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public com.google.protobuf.ByteString
          getParentIdBytes() {
        java.lang.Object ref = parentId_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          parentId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public Builder setParentId(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        parentId_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public Builder clearParentId() {
        bitField0_ = (bitField0_ & ~0x00000004);
        parentId_ = getDefaultInstance().getParentId();
        onChanged();
        return this;
      }
      /**
       * <code>optional string parent_id = 3;</code>
       */
      public Builder setParentIdBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        parentId_ = value;
        onChanged();
        return this;
      }

      // optional bytes error = 5;
      private com.google.protobuf.ByteString error_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes error = 5;</code>
       *
       * <pre>
       * when creating the context
       * </pre>
       */
      public boolean hasError() {
        return ((bitField0_ & 0x00000008) == 0x00000008);
      }
      /**
       * <code>optional bytes error = 5;</code>
       *
       * <pre>
       * when creating the context
       * </pre>
       */
      public com.google.protobuf.ByteString getError() {
        return error_;
      }
      /**
       * <code>optional bytes error = 5;</code>
       *
       * <pre>
       * when creating the context
       * </pre>
       */
      public Builder setError(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000008;
        error_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes error = 5;</code>
       *
       * <pre>
       * when creating the context
       * </pre>
       */
      public Builder clearError() {
        bitField0_ = (bitField0_ & ~0x00000008);
        error_ = getDefaultInstance().getError();
        onChanged();
        return this;
      }

      // optional bool recovery = 6;
      private boolean recovery_ ;
      /**
       * <code>optional bool recovery = 6;</code>
       */
      public boolean hasRecovery() {
        return ((bitField0_ & 0x00000010) == 0x00000010);
      }
      /**
       * <code>optional bool recovery = 6;</code>
       */
      public boolean getRecovery() {
        return recovery_;
      }
      /**
       * <code>optional bool recovery = 6;</code>
       */
      public Builder setRecovery(boolean value) {
        bitField0_ |= 0x00000010;
        recovery_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bool recovery = 6;</code>
       */
      public Builder clearRecovery() {
        bitField0_ = (bitField0_ & ~0x00000010);
        recovery_ = false;
        onChanged();
        return this;
      }

      // repeated .ContextStatusProto.ContextMessageProto context_message = 7;
      private java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> contextMessage_ =
        java.util.Collections.emptyList();
      private void ensureContextMessageIsMutable() {
        if (!((bitField0_ & 0x00000020) == 0x00000020)) {
          contextMessage_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto>(contextMessage_);
          bitField0_ |= 0x00000020;
         }
      }

      private com.google.protobuf.RepeatedFieldBuilder<
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder> contextMessageBuilder_;

      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> getContextMessageList() {
        if (contextMessageBuilder_ == null) {
          return java.util.Collections.unmodifiableList(contextMessage_);
        } else {
          return contextMessageBuilder_.getMessageList();
        }
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public int getContextMessageCount() {
        if (contextMessageBuilder_ == null) {
          return contextMessage_.size();
        } else {
          return contextMessageBuilder_.getCount();
        }
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto getContextMessage(int index) {
        if (contextMessageBuilder_ == null) {
          return contextMessage_.get(index);
        } else {
          return contextMessageBuilder_.getMessage(index);
        }
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder setContextMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto value) {
        if (contextMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureContextMessageIsMutable();
          contextMessage_.set(index, value);
          onChanged();
        } else {
          contextMessageBuilder_.setMessage(index, value);
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder setContextMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder builderForValue) {
        if (contextMessageBuilder_ == null) {
          ensureContextMessageIsMutable();
          contextMessage_.set(index, builderForValue.build());
          onChanged();
        } else {
          contextMessageBuilder_.setMessage(index, builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder addContextMessage(org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto value) {
        if (contextMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureContextMessageIsMutable();
          contextMessage_.add(value);
          onChanged();
        } else {
          contextMessageBuilder_.addMessage(value);
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder addContextMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto value) {
        if (contextMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureContextMessageIsMutable();
          contextMessage_.add(index, value);
          onChanged();
        } else {
          contextMessageBuilder_.addMessage(index, value);
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder addContextMessage(
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder builderForValue) {
        if (contextMessageBuilder_ == null) {
          ensureContextMessageIsMutable();
          contextMessage_.add(builderForValue.build());
          onChanged();
        } else {
          contextMessageBuilder_.addMessage(builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder addContextMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder builderForValue) {
        if (contextMessageBuilder_ == null) {
          ensureContextMessageIsMutable();
          contextMessage_.add(index, builderForValue.build());
          onChanged();
        } else {
          contextMessageBuilder_.addMessage(index, builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder addAllContextMessage(
          java.lang.Iterable<? extends org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto> values) {
        if (contextMessageBuilder_ == null) {
          ensureContextMessageIsMutable();
          super.addAll(values, contextMessage_);
          onChanged();
        } else {
          contextMessageBuilder_.addAllMessages(values);
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder clearContextMessage() {
        if (contextMessageBuilder_ == null) {
          contextMessage_ = java.util.Collections.emptyList();
          bitField0_ = (bitField0_ & ~0x00000020);
          onChanged();
        } else {
          contextMessageBuilder_.clear();
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public Builder removeContextMessage(int index) {
        if (contextMessageBuilder_ == null) {
          ensureContextMessageIsMutable();
          contextMessage_.remove(index);
          onChanged();
        } else {
          contextMessageBuilder_.remove(index);
        }
        return this;
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder getContextMessageBuilder(
          int index) {
        return getContextMessageFieldBuilder().getBuilder(index);
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder getContextMessageOrBuilder(
          int index) {
        if (contextMessageBuilder_ == null) {
          return contextMessage_.get(index);  } else {
          return contextMessageBuilder_.getMessageOrBuilder(index);
        }
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder> 
           getContextMessageOrBuilderList() {
        if (contextMessageBuilder_ != null) {
          return contextMessageBuilder_.getMessageOrBuilderList();
        } else {
          return java.util.Collections.unmodifiableList(contextMessage_);
        }
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder addContextMessageBuilder() {
        return getContextMessageFieldBuilder().addBuilder(
            org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.getDefaultInstance());
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder addContextMessageBuilder(
          int index) {
        return getContextMessageFieldBuilder().addBuilder(
            index, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.getDefaultInstance());
      }
      /**
       * <code>repeated .ContextStatusProto.ContextMessageProto context_message = 7;</code>
       */
      public java.util.List<org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder> 
           getContextMessageBuilderList() {
        return getContextMessageFieldBuilder().getBuilderList();
      }
      private com.google.protobuf.RepeatedFieldBuilder<
          org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder> 
          getContextMessageFieldBuilder() {
        if (contextMessageBuilder_ == null) {
          contextMessageBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
              org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder>(
                  contextMessage_,
                  ((bitField0_ & 0x00000020) == 0x00000020),
                  getParentForChildren(),
                  isClean());
          contextMessage_ = null;
        }
        return contextMessageBuilder_;
      }

      // @@protoc_insertion_point(builder_scope:ContextStatusProto)
    }

    static {
      defaultInstance = new ContextStatusProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:ContextStatusProto)
  }

  public interface TaskStatusProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required string task_id = 1;
    /**
     * <code>required string task_id = 1;</code>
     */
    boolean hasTaskId();
    /**
     * <code>required string task_id = 1;</code>
     */
    java.lang.String getTaskId();
    /**
     * <code>required string task_id = 1;</code>
     */
    com.google.protobuf.ByteString
        getTaskIdBytes();

    // required string context_id = 2;
    /**
     * <code>required string context_id = 2;</code>
     */
    boolean hasContextId();
    /**
     * <code>required string context_id = 2;</code>
     */
    java.lang.String getContextId();
    /**
     * <code>required string context_id = 2;</code>
     */
    com.google.protobuf.ByteString
        getContextIdBytes();

    // required .State state = 3;
    /**
     * <code>required .State state = 3;</code>
     */
    boolean hasState();
    /**
     * <code>required .State state = 3;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.State getState();

    // optional bytes result = 4;
    /**
     * <code>optional bytes result = 4;</code>
     *
     * <pre>
     * e.g., return value from Task.call()
     * </pre>
     */
    boolean hasResult();
    /**
     * <code>optional bytes result = 4;</code>
     *
     * <pre>
     * e.g., return value from Task.call()
     * </pre>
     */
    com.google.protobuf.ByteString getResult();

    // optional bool recovery = 5;
    /**
     * <code>optional bool recovery = 5;</code>
     */
    boolean hasRecovery();
    /**
     * <code>optional bool recovery = 5;</code>
     */
    boolean getRecovery();

    // repeated .TaskStatusProto.TaskMessageProto task_message = 6;
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> 
        getTaskMessageList();
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto getTaskMessage(int index);
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    int getTaskMessageCount();
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder> 
        getTaskMessageOrBuilderList();
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder getTaskMessageOrBuilder(
        int index);
  }
  /**
   * Protobuf type {@code TaskStatusProto}
   */
  public static final class TaskStatusProto extends
      com.google.protobuf.GeneratedMessage
      implements TaskStatusProtoOrBuilder {
    // Use TaskStatusProto.newBuilder() to construct.
    private TaskStatusProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private TaskStatusProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final TaskStatusProto defaultInstance;
    public static TaskStatusProto getDefaultInstance() {
      return defaultInstance;
    }

    public TaskStatusProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private TaskStatusProto(
        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;
              taskId_ = input.readBytes();
              break;
            }
            case 18: {
              bitField0_ |= 0x00000002;
              contextId_ = input.readBytes();
              break;
            }
            case 24: {
              int rawValue = input.readEnum();
              org.apache.reef.proto.ReefServiceProtos.State value = org.apache.reef.proto.ReefServiceProtos.State.valueOf(rawValue);
              if (value == null) {
                unknownFields.mergeVarintField(3, rawValue);
              } else {
                bitField0_ |= 0x00000004;
                state_ = value;
              }
              break;
            }
            case 34: {
              bitField0_ |= 0x00000008;
              result_ = input.readBytes();
              break;
            }
            case 40: {
              bitField0_ |= 0x00000010;
              recovery_ = input.readBool();
              break;
            }
            case 50: {
              if (!((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
                taskMessage_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto>();
                mutable_bitField0_ |= 0x00000020;
              }
              taskMessage_.add(input.readMessage(org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.PARSER, extensionRegistry));
              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 {
        if (((mutable_bitField0_ & 0x00000020) == 0x00000020)) {
          taskMessage_ = java.util.Collections.unmodifiableList(taskMessage_);
        }
        this.unknownFields = unknownFields.build();
        makeExtensionsImmutable();
      }
    }
    public static final com.google.protobuf.Descriptors.Descriptor
        getDescriptor() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.class, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder.class);
    }

    public static com.google.protobuf.Parser<TaskStatusProto> PARSER =
        new com.google.protobuf.AbstractParser<TaskStatusProto>() {
      public TaskStatusProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new TaskStatusProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<TaskStatusProto> getParserForType() {
      return PARSER;
    }

    public interface TaskMessageProtoOrBuilder
        extends com.google.protobuf.MessageOrBuilder {

      // required string source_id = 1;
      /**
       * <code>required string source_id = 1;</code>
       */
      boolean hasSourceId();
      /**
       * <code>required string source_id = 1;</code>
       */
      java.lang.String getSourceId();
      /**
       * <code>required string source_id = 1;</code>
       */
      com.google.protobuf.ByteString
          getSourceIdBytes();

      // required bytes message = 2;
      /**
       * <code>required bytes message = 2;</code>
       */
      boolean hasMessage();
      /**
       * <code>required bytes message = 2;</code>
       */
      com.google.protobuf.ByteString getMessage();
    }
    /**
     * Protobuf type {@code TaskStatusProto.TaskMessageProto}
     *
     * <pre>
     * TaskMessageSource messages
     * </pre>
     */
    public static final class TaskMessageProto extends
        com.google.protobuf.GeneratedMessage
        implements TaskMessageProtoOrBuilder {
      // Use TaskMessageProto.newBuilder() to construct.
      private TaskMessageProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
        super(builder);
        this.unknownFields = builder.getUnknownFields();
      }
      private TaskMessageProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

      private static final TaskMessageProto defaultInstance;
      public static TaskMessageProto getDefaultInstance() {
        return defaultInstance;
      }

      public TaskMessageProto getDefaultInstanceForType() {
        return defaultInstance;
      }

      private final com.google.protobuf.UnknownFieldSet unknownFields;
      @java.lang.Override
      public final com.google.protobuf.UnknownFieldSet
          getUnknownFields() {
        return this.unknownFields;
      }
      private TaskMessageProto(
          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;
                sourceId_ = input.readBytes();
                break;
              }
              case 18: {
                bitField0_ |= 0x00000002;
                message_ = 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.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_TaskMessageProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_TaskMessageProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.class, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder.class);
      }

      public static com.google.protobuf.Parser<TaskMessageProto> PARSER =
          new com.google.protobuf.AbstractParser<TaskMessageProto>() {
        public TaskMessageProto parsePartialFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
          return new TaskMessageProto(input, extensionRegistry);
        }
      };

      @java.lang.Override
      public com.google.protobuf.Parser<TaskMessageProto> getParserForType() {
        return PARSER;
      }

      private int bitField0_;
      // required string source_id = 1;
      public static final int SOURCE_ID_FIELD_NUMBER = 1;
      private java.lang.Object sourceId_;
      /**
       * <code>required string source_id = 1;</code>
       */
      public boolean hasSourceId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string source_id = 1;</code>
       */
      public java.lang.String getSourceId() {
        java.lang.Object ref = sourceId_;
        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()) {
            sourceId_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string source_id = 1;</code>
       */
      public com.google.protobuf.ByteString
          getSourceIdBytes() {
        java.lang.Object ref = sourceId_;
        if (ref instanceof java.lang.String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          sourceId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }

      // required bytes message = 2;
      public static final int MESSAGE_FIELD_NUMBER = 2;
      private com.google.protobuf.ByteString message_;
      /**
       * <code>required bytes message = 2;</code>
       */
      public boolean hasMessage() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required bytes message = 2;</code>
       */
      public com.google.protobuf.ByteString getMessage() {
        return message_;
      }

      private void initFields() {
        sourceId_ = "";
        message_ = com.google.protobuf.ByteString.EMPTY;
      }
      private byte memoizedIsInitialized = -1;
      public final boolean isInitialized() {
        byte isInitialized = memoizedIsInitialized;
        if (isInitialized != -1) return isInitialized == 1;

        if (!hasSourceId()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasMessage()) {
          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, getSourceIdBytes());
        }
        if (((bitField0_ & 0x00000002) == 0x00000002)) {
          output.writeBytes(2, message_);
        }
        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, getSourceIdBytes());
        }
        if (((bitField0_ & 0x00000002) == 0x00000002)) {
          size += com.google.protobuf.CodedOutputStream
            .computeBytesSize(2, message_);
        }
        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();
      }

      @java.lang.Override
      public boolean equals(final java.lang.Object obj) {
        if (obj == this) {
         return true;
        }
        if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto)) {
          return super.equals(obj);
        }
        org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto other = (org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto) obj;

        boolean result = true;
        result = result && (hasSourceId() == other.hasSourceId());
        if (hasSourceId()) {
          result = result && getSourceId()
              .equals(other.getSourceId());
        }
        result = result && (hasMessage() == other.hasMessage());
        if (hasMessage()) {
          result = result && getMessage()
              .equals(other.getMessage());
        }
        result = result &&
            getUnknownFields().equals(other.getUnknownFields());
        return result;
      }

      private int memoizedHashCode = 0;
      @java.lang.Override
      public int hashCode() {
        if (memoizedHashCode != 0) {
          return memoizedHashCode;
        }
        int hash = 41;
        hash = (19 * hash) + getDescriptorForType().hashCode();
        if (hasSourceId()) {
          hash = (37 * hash) + SOURCE_ID_FIELD_NUMBER;
          hash = (53 * hash) + getSourceId().hashCode();
        }
        if (hasMessage()) {
          hash = (37 * hash) + MESSAGE_FIELD_NUMBER;
          hash = (53 * hash) + getMessage().hashCode();
        }
        hash = (29 * hash) + getUnknownFields().hashCode();
        memoizedHashCode = hash;
        return hash;
      }

      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(
          com.google.protobuf.ByteString data)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto 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.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(byte[] data)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(
          byte[] data,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(java.io.InputStream input)
          throws java.io.IOException {
        return PARSER.parseFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(
          java.io.InputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return PARSER.parseFrom(input, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseDelimitedFrom(java.io.InputStream input)
          throws java.io.IOException {
        return PARSER.parseDelimitedFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseDelimitedFrom(
          java.io.InputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return PARSER.parseDelimitedFrom(input, extensionRegistry);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parseFrom(
          com.google.protobuf.CodedInputStream input)
          throws java.io.IOException {
        return PARSER.parseFrom(input);
      }
      public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto 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.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto 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 TaskStatusProto.TaskMessageProto}
       *
       * <pre>
       * TaskMessageSource messages
       * </pre>
       */
      public static final class Builder extends
          com.google.protobuf.GeneratedMessage.Builder<Builder>
         implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder {
        public static final com.google.protobuf.Descriptors.Descriptor
            getDescriptor() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_TaskMessageProto_descriptor;
        }

        protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
            internalGetFieldAccessorTable() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_TaskMessageProto_fieldAccessorTable
              .ensureFieldAccessorsInitialized(
                  org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.class, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder.class);
        }

        // Construct using org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.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();
          sourceId_ = "";
          bitField0_ = (bitField0_ & ~0x00000001);
          message_ = com.google.protobuf.ByteString.EMPTY;
          bitField0_ = (bitField0_ & ~0x00000002);
          return this;
        }

        public Builder clone() {
          return create().mergeFrom(buildPartial());
        }

        public com.google.protobuf.Descriptors.Descriptor
            getDescriptorForType() {
          return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_TaskMessageProto_descriptor;
        }

        public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto getDefaultInstanceForType() {
          return org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.getDefaultInstance();
        }

        public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto build() {
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto result = buildPartial();
          if (!result.isInitialized()) {
            throw newUninitializedMessageException(result);
          }
          return result;
        }

        public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto buildPartial() {
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto result = new org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto(this);
          int from_bitField0_ = bitField0_;
          int to_bitField0_ = 0;
          if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
            to_bitField0_ |= 0x00000001;
          }
          result.sourceId_ = sourceId_;
          if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
            to_bitField0_ |= 0x00000002;
          }
          result.message_ = message_;
          result.bitField0_ = to_bitField0_;
          onBuilt();
          return result;
        }

        public Builder mergeFrom(com.google.protobuf.Message other) {
          if (other instanceof org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto) {
            return mergeFrom((org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto)other);
          } else {
            super.mergeFrom(other);
            return this;
          }
        }

        public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto other) {
          if (other == org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.getDefaultInstance()) return this;
          if (other.hasSourceId()) {
            bitField0_ |= 0x00000001;
            sourceId_ = other.sourceId_;
            onChanged();
          }
          if (other.hasMessage()) {
            setMessage(other.getMessage());
          }
          this.mergeUnknownFields(other.getUnknownFields());
          return this;
        }

        public final boolean isInitialized() {
          if (!hasSourceId()) {
            
            return false;
          }
          if (!hasMessage()) {
            
            return false;
          }
          return true;
        }

        public Builder mergeFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto parsedMessage = null;
          try {
            parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
          } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            parsedMessage = (org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto) e.getUnfinishedMessage();
            throw e;
          } finally {
            if (parsedMessage != null) {
              mergeFrom(parsedMessage);
            }
          }
          return this;
        }
        private int bitField0_;

        // required string source_id = 1;
        private java.lang.Object sourceId_ = "";
        /**
         * <code>required string source_id = 1;</code>
         */
        public boolean hasSourceId() {
          return ((bitField0_ & 0x00000001) == 0x00000001);
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public java.lang.String getSourceId() {
          java.lang.Object ref = sourceId_;
          if (!(ref instanceof java.lang.String)) {
            java.lang.String s = ((com.google.protobuf.ByteString) ref)
                .toStringUtf8();
            sourceId_ = s;
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public com.google.protobuf.ByteString
            getSourceIdBytes() {
          java.lang.Object ref = sourceId_;
          if (ref instanceof String) {
            com.google.protobuf.ByteString b = 
                com.google.protobuf.ByteString.copyFromUtf8(
                    (java.lang.String) ref);
            sourceId_ = b;
            return b;
          } else {
            return (com.google.protobuf.ByteString) ref;
          }
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder setSourceId(
            java.lang.String value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
          sourceId_ = value;
          onChanged();
          return this;
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder clearSourceId() {
          bitField0_ = (bitField0_ & ~0x00000001);
          sourceId_ = getDefaultInstance().getSourceId();
          onChanged();
          return this;
        }
        /**
         * <code>required string source_id = 1;</code>
         */
        public Builder setSourceIdBytes(
            com.google.protobuf.ByteString value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
          sourceId_ = value;
          onChanged();
          return this;
        }

        // required bytes message = 2;
        private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY;
        /**
         * <code>required bytes message = 2;</code>
         */
        public boolean hasMessage() {
          return ((bitField0_ & 0x00000002) == 0x00000002);
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public com.google.protobuf.ByteString getMessage() {
          return message_;
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public Builder setMessage(com.google.protobuf.ByteString value) {
          if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
          message_ = value;
          onChanged();
          return this;
        }
        /**
         * <code>required bytes message = 2;</code>
         */
        public Builder clearMessage() {
          bitField0_ = (bitField0_ & ~0x00000002);
          message_ = getDefaultInstance().getMessage();
          onChanged();
          return this;
        }

        // @@protoc_insertion_point(builder_scope:TaskStatusProto.TaskMessageProto)
      }

      static {
        defaultInstance = new TaskMessageProto(true);
        defaultInstance.initFields();
      }

      // @@protoc_insertion_point(class_scope:TaskStatusProto.TaskMessageProto)
    }

    private int bitField0_;
    // required string task_id = 1;
    public static final int TASK_ID_FIELD_NUMBER = 1;
    private java.lang.Object taskId_;
    /**
     * <code>required string task_id = 1;</code>
     */
    public boolean hasTaskId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required string task_id = 1;</code>
     */
    public java.lang.String getTaskId() {
      java.lang.Object ref = taskId_;
      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()) {
          taskId_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string task_id = 1;</code>
     */
    public com.google.protobuf.ByteString
        getTaskIdBytes() {
      java.lang.Object ref = taskId_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        taskId_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required string context_id = 2;
    public static final int CONTEXT_ID_FIELD_NUMBER = 2;
    private java.lang.Object contextId_;
    /**
     * <code>required string context_id = 2;</code>
     */
    public boolean hasContextId() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required string context_id = 2;</code>
     */
    public java.lang.String getContextId() {
      java.lang.Object ref = contextId_;
      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()) {
          contextId_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string context_id = 2;</code>
     */
    public com.google.protobuf.ByteString
        getContextIdBytes() {
      java.lang.Object ref = contextId_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        contextId_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required .State state = 3;
    public static final int STATE_FIELD_NUMBER = 3;
    private org.apache.reef.proto.ReefServiceProtos.State state_;
    /**
     * <code>required .State state = 3;</code>
     */
    public boolean hasState() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>required .State state = 3;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.State getState() {
      return state_;
    }

    // optional bytes result = 4;
    public static final int RESULT_FIELD_NUMBER = 4;
    private com.google.protobuf.ByteString result_;
    /**
     * <code>optional bytes result = 4;</code>
     *
     * <pre>
     * e.g., return value from Task.call()
     * </pre>
     */
    public boolean hasResult() {
      return ((bitField0_ & 0x00000008) == 0x00000008);
    }
    /**
     * <code>optional bytes result = 4;</code>
     *
     * <pre>
     * e.g., return value from Task.call()
     * </pre>
     */
    public com.google.protobuf.ByteString getResult() {
      return result_;
    }

    // optional bool recovery = 5;
    public static final int RECOVERY_FIELD_NUMBER = 5;
    private boolean recovery_;
    /**
     * <code>optional bool recovery = 5;</code>
     */
    public boolean hasRecovery() {
      return ((bitField0_ & 0x00000010) == 0x00000010);
    }
    /**
     * <code>optional bool recovery = 5;</code>
     */
    public boolean getRecovery() {
      return recovery_;
    }

    // repeated .TaskStatusProto.TaskMessageProto task_message = 6;
    public static final int TASK_MESSAGE_FIELD_NUMBER = 6;
    private java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> taskMessage_;
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    public java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> getTaskMessageList() {
      return taskMessage_;
    }
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder> 
        getTaskMessageOrBuilderList() {
      return taskMessage_;
    }
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    public int getTaskMessageCount() {
      return taskMessage_.size();
    }
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto getTaskMessage(int index) {
      return taskMessage_.get(index);
    }
    /**
     * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder getTaskMessageOrBuilder(
        int index) {
      return taskMessage_.get(index);
    }

    private void initFields() {
      taskId_ = "";
      contextId_ = "";
      state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      result_ = com.google.protobuf.ByteString.EMPTY;
      recovery_ = false;
      taskMessage_ = java.util.Collections.emptyList();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasTaskId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasContextId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasState()) {
        memoizedIsInitialized = 0;
        return false;
      }
      for (int i = 0; i < getTaskMessageCount(); i++) {
        if (!getTaskMessage(i).isInitialized()) {
          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, getTaskIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeBytes(2, getContextIdBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeEnum(3, state_.getNumber());
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        output.writeBytes(4, result_);
      }
      if (((bitField0_ & 0x00000010) == 0x00000010)) {
        output.writeBool(5, recovery_);
      }
      for (int i = 0; i < taskMessage_.size(); i++) {
        output.writeMessage(6, taskMessage_.get(i));
      }
      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, getTaskIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(2, getContextIdBytes());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeEnumSize(3, state_.getNumber());
      }
      if (((bitField0_ & 0x00000008) == 0x00000008)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(4, result_);
      }
      if (((bitField0_ & 0x00000010) == 0x00000010)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBoolSize(5, recovery_);
      }
      for (int i = 0; i < taskMessage_.size(); i++) {
        size += com.google.protobuf.CodedOutputStream
          .computeMessageSize(6, taskMessage_.get(i));
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.TaskStatusProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.TaskStatusProto other = (org.apache.reef.proto.ReefServiceProtos.TaskStatusProto) obj;

      boolean result = true;
      result = result && (hasTaskId() == other.hasTaskId());
      if (hasTaskId()) {
        result = result && getTaskId()
            .equals(other.getTaskId());
      }
      result = result && (hasContextId() == other.hasContextId());
      if (hasContextId()) {
        result = result && getContextId()
            .equals(other.getContextId());
      }
      result = result && (hasState() == other.hasState());
      if (hasState()) {
        result = result &&
            (getState() == other.getState());
      }
      result = result && (hasResult() == other.hasResult());
      if (hasResult()) {
        result = result && getResult()
            .equals(other.getResult());
      }
      result = result && (hasRecovery() == other.hasRecovery());
      if (hasRecovery()) {
        result = result && (getRecovery()
            == other.getRecovery());
      }
      result = result && getTaskMessageList()
          .equals(other.getTaskMessageList());
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasTaskId()) {
        hash = (37 * hash) + TASK_ID_FIELD_NUMBER;
        hash = (53 * hash) + getTaskId().hashCode();
      }
      if (hasContextId()) {
        hash = (37 * hash) + CONTEXT_ID_FIELD_NUMBER;
        hash = (53 * hash) + getContextId().hashCode();
      }
      if (hasState()) {
        hash = (37 * hash) + STATE_FIELD_NUMBER;
        hash = (53 * hash) + hashEnum(getState());
      }
      if (hasResult()) {
        hash = (37 * hash) + RESULT_FIELD_NUMBER;
        hash = (53 * hash) + getResult().hashCode();
      }
      if (hasRecovery()) {
        hash = (37 * hash) + RECOVERY_FIELD_NUMBER;
        hash = (53 * hash) + hashBoolean(getRecovery());
      }
      if (getTaskMessageCount() > 0) {
        hash = (37 * hash) + TASK_MESSAGE_FIELD_NUMBER;
        hash = (53 * hash) + getTaskMessageList().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto 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.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.TaskStatusProto 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.reef.proto.ReefServiceProtos.TaskStatusProto 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 TaskStatusProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.class, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.newBuilder()
      private Builder() {
        maybeForceBuilderInitialization();
      }

      private Builder(
          com.google.protobuf.GeneratedMessage.BuilderParent parent) {
        super(parent);
        maybeForceBuilderInitialization();
      }
      private void maybeForceBuilderInitialization() {
        if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
          getTaskMessageFieldBuilder();
        }
      }
      private static Builder create() {
        return new Builder();
      }

      public Builder clear() {
        super.clear();
        taskId_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        contextId_ = "";
        bitField0_ = (bitField0_ & ~0x00000002);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        bitField0_ = (bitField0_ & ~0x00000004);
        result_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000008);
        recovery_ = false;
        bitField0_ = (bitField0_ & ~0x00000010);
        if (taskMessageBuilder_ == null) {
          taskMessage_ = java.util.Collections.emptyList();
          bitField0_ = (bitField0_ & ~0x00000020);
        } else {
          taskMessageBuilder_.clear();
        }
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_TaskStatusProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto build() {
        org.apache.reef.proto.ReefServiceProtos.TaskStatusProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.TaskStatusProto result = new org.apache.reef.proto.ReefServiceProtos.TaskStatusProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.taskId_ = taskId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.contextId_ = contextId_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.state_ = state_;
        if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
          to_bitField0_ |= 0x00000008;
        }
        result.result_ = result_;
        if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
          to_bitField0_ |= 0x00000010;
        }
        result.recovery_ = recovery_;
        if (taskMessageBuilder_ == null) {
          if (((bitField0_ & 0x00000020) == 0x00000020)) {
            taskMessage_ = java.util.Collections.unmodifiableList(taskMessage_);
            bitField0_ = (bitField0_ & ~0x00000020);
          }
          result.taskMessage_ = taskMessage_;
        } else {
          result.taskMessage_ = taskMessageBuilder_.build();
        }
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.TaskStatusProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.TaskStatusProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.TaskStatusProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.getDefaultInstance()) return this;
        if (other.hasTaskId()) {
          bitField0_ |= 0x00000001;
          taskId_ = other.taskId_;
          onChanged();
        }
        if (other.hasContextId()) {
          bitField0_ |= 0x00000002;
          contextId_ = other.contextId_;
          onChanged();
        }
        if (other.hasState()) {
          setState(other.getState());
        }
        if (other.hasResult()) {
          setResult(other.getResult());
        }
        if (other.hasRecovery()) {
          setRecovery(other.getRecovery());
        }
        if (taskMessageBuilder_ == null) {
          if (!other.taskMessage_.isEmpty()) {
            if (taskMessage_.isEmpty()) {
              taskMessage_ = other.taskMessage_;
              bitField0_ = (bitField0_ & ~0x00000020);
            } else {
              ensureTaskMessageIsMutable();
              taskMessage_.addAll(other.taskMessage_);
            }
            onChanged();
          }
        } else {
          if (!other.taskMessage_.isEmpty()) {
            if (taskMessageBuilder_.isEmpty()) {
              taskMessageBuilder_.dispose();
              taskMessageBuilder_ = null;
              taskMessage_ = other.taskMessage_;
              bitField0_ = (bitField0_ & ~0x00000020);
              taskMessageBuilder_ = 
                com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ?
                   getTaskMessageFieldBuilder() : null;
            } else {
              taskMessageBuilder_.addAllMessages(other.taskMessage_);
            }
          }
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasTaskId()) {
          
          return false;
        }
        if (!hasContextId()) {
          
          return false;
        }
        if (!hasState()) {
          
          return false;
        }
        for (int i = 0; i < getTaskMessageCount(); i++) {
          if (!getTaskMessage(i).isInitialized()) {
            
            return false;
          }
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.TaskStatusProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.TaskStatusProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required string task_id = 1;
      private java.lang.Object taskId_ = "";
      /**
       * <code>required string task_id = 1;</code>
       */
      public boolean hasTaskId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string task_id = 1;</code>
       */
      public java.lang.String getTaskId() {
        java.lang.Object ref = taskId_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          taskId_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string task_id = 1;</code>
       */
      public com.google.protobuf.ByteString
          getTaskIdBytes() {
        java.lang.Object ref = taskId_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          taskId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string task_id = 1;</code>
       */
      public Builder setTaskId(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        taskId_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string task_id = 1;</code>
       */
      public Builder clearTaskId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        taskId_ = getDefaultInstance().getTaskId();
        onChanged();
        return this;
      }
      /**
       * <code>required string task_id = 1;</code>
       */
      public Builder setTaskIdBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        taskId_ = value;
        onChanged();
        return this;
      }

      // required string context_id = 2;
      private java.lang.Object contextId_ = "";
      /**
       * <code>required string context_id = 2;</code>
       */
      public boolean hasContextId() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public java.lang.String getContextId() {
        java.lang.Object ref = contextId_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          contextId_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public com.google.protobuf.ByteString
          getContextIdBytes() {
        java.lang.Object ref = contextId_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          contextId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder setContextId(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        contextId_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder clearContextId() {
        bitField0_ = (bitField0_ & ~0x00000002);
        contextId_ = getDefaultInstance().getContextId();
        onChanged();
        return this;
      }
      /**
       * <code>required string context_id = 2;</code>
       */
      public Builder setContextIdBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        contextId_ = value;
        onChanged();
        return this;
      }

      // required .State state = 3;
      private org.apache.reef.proto.ReefServiceProtos.State state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      /**
       * <code>required .State state = 3;</code>
       */
      public boolean hasState() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>required .State state = 3;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.State getState() {
        return state_;
      }
      /**
       * <code>required .State state = 3;</code>
       */
      public Builder setState(org.apache.reef.proto.ReefServiceProtos.State value) {
        if (value == null) {
          throw new NullPointerException();
        }
        bitField0_ |= 0x00000004;
        state_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required .State state = 3;</code>
       */
      public Builder clearState() {
        bitField0_ = (bitField0_ & ~0x00000004);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        onChanged();
        return this;
      }

      // optional bytes result = 4;
      private com.google.protobuf.ByteString result_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes result = 4;</code>
       *
       * <pre>
       * e.g., return value from Task.call()
       * </pre>
       */
      public boolean hasResult() {
        return ((bitField0_ & 0x00000008) == 0x00000008);
      }
      /**
       * <code>optional bytes result = 4;</code>
       *
       * <pre>
       * e.g., return value from Task.call()
       * </pre>
       */
      public com.google.protobuf.ByteString getResult() {
        return result_;
      }
      /**
       * <code>optional bytes result = 4;</code>
       *
       * <pre>
       * e.g., return value from Task.call()
       * </pre>
       */
      public Builder setResult(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000008;
        result_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes result = 4;</code>
       *
       * <pre>
       * e.g., return value from Task.call()
       * </pre>
       */
      public Builder clearResult() {
        bitField0_ = (bitField0_ & ~0x00000008);
        result_ = getDefaultInstance().getResult();
        onChanged();
        return this;
      }

      // optional bool recovery = 5;
      private boolean recovery_ ;
      /**
       * <code>optional bool recovery = 5;</code>
       */
      public boolean hasRecovery() {
        return ((bitField0_ & 0x00000010) == 0x00000010);
      }
      /**
       * <code>optional bool recovery = 5;</code>
       */
      public boolean getRecovery() {
        return recovery_;
      }
      /**
       * <code>optional bool recovery = 5;</code>
       */
      public Builder setRecovery(boolean value) {
        bitField0_ |= 0x00000010;
        recovery_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bool recovery = 5;</code>
       */
      public Builder clearRecovery() {
        bitField0_ = (bitField0_ & ~0x00000010);
        recovery_ = false;
        onChanged();
        return this;
      }

      // repeated .TaskStatusProto.TaskMessageProto task_message = 6;
      private java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> taskMessage_ =
        java.util.Collections.emptyList();
      private void ensureTaskMessageIsMutable() {
        if (!((bitField0_ & 0x00000020) == 0x00000020)) {
          taskMessage_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto>(taskMessage_);
          bitField0_ |= 0x00000020;
         }
      }

      private com.google.protobuf.RepeatedFieldBuilder<
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder> taskMessageBuilder_;

      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> getTaskMessageList() {
        if (taskMessageBuilder_ == null) {
          return java.util.Collections.unmodifiableList(taskMessage_);
        } else {
          return taskMessageBuilder_.getMessageList();
        }
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public int getTaskMessageCount() {
        if (taskMessageBuilder_ == null) {
          return taskMessage_.size();
        } else {
          return taskMessageBuilder_.getCount();
        }
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto getTaskMessage(int index) {
        if (taskMessageBuilder_ == null) {
          return taskMessage_.get(index);
        } else {
          return taskMessageBuilder_.getMessage(index);
        }
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder setTaskMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto value) {
        if (taskMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTaskMessageIsMutable();
          taskMessage_.set(index, value);
          onChanged();
        } else {
          taskMessageBuilder_.setMessage(index, value);
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder setTaskMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder builderForValue) {
        if (taskMessageBuilder_ == null) {
          ensureTaskMessageIsMutable();
          taskMessage_.set(index, builderForValue.build());
          onChanged();
        } else {
          taskMessageBuilder_.setMessage(index, builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder addTaskMessage(org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto value) {
        if (taskMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTaskMessageIsMutable();
          taskMessage_.add(value);
          onChanged();
        } else {
          taskMessageBuilder_.addMessage(value);
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder addTaskMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto value) {
        if (taskMessageBuilder_ == null) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTaskMessageIsMutable();
          taskMessage_.add(index, value);
          onChanged();
        } else {
          taskMessageBuilder_.addMessage(index, value);
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder addTaskMessage(
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder builderForValue) {
        if (taskMessageBuilder_ == null) {
          ensureTaskMessageIsMutable();
          taskMessage_.add(builderForValue.build());
          onChanged();
        } else {
          taskMessageBuilder_.addMessage(builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder addTaskMessage(
          int index, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder builderForValue) {
        if (taskMessageBuilder_ == null) {
          ensureTaskMessageIsMutable();
          taskMessage_.add(index, builderForValue.build());
          onChanged();
        } else {
          taskMessageBuilder_.addMessage(index, builderForValue.build());
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder addAllTaskMessage(
          java.lang.Iterable<? extends org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto> values) {
        if (taskMessageBuilder_ == null) {
          ensureTaskMessageIsMutable();
          super.addAll(values, taskMessage_);
          onChanged();
        } else {
          taskMessageBuilder_.addAllMessages(values);
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder clearTaskMessage() {
        if (taskMessageBuilder_ == null) {
          taskMessage_ = java.util.Collections.emptyList();
          bitField0_ = (bitField0_ & ~0x00000020);
          onChanged();
        } else {
          taskMessageBuilder_.clear();
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public Builder removeTaskMessage(int index) {
        if (taskMessageBuilder_ == null) {
          ensureTaskMessageIsMutable();
          taskMessage_.remove(index);
          onChanged();
        } else {
          taskMessageBuilder_.remove(index);
        }
        return this;
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder getTaskMessageBuilder(
          int index) {
        return getTaskMessageFieldBuilder().getBuilder(index);
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder getTaskMessageOrBuilder(
          int index) {
        if (taskMessageBuilder_ == null) {
          return taskMessage_.get(index);  } else {
          return taskMessageBuilder_.getMessageOrBuilder(index);
        }
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder> 
           getTaskMessageOrBuilderList() {
        if (taskMessageBuilder_ != null) {
          return taskMessageBuilder_.getMessageOrBuilderList();
        } else {
          return java.util.Collections.unmodifiableList(taskMessage_);
        }
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder addTaskMessageBuilder() {
        return getTaskMessageFieldBuilder().addBuilder(
            org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.getDefaultInstance());
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder addTaskMessageBuilder(
          int index) {
        return getTaskMessageFieldBuilder().addBuilder(
            index, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.getDefaultInstance());
      }
      /**
       * <code>repeated .TaskStatusProto.TaskMessageProto task_message = 6;</code>
       */
      public java.util.List<org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder> 
           getTaskMessageBuilderList() {
        return getTaskMessageFieldBuilder().getBuilderList();
      }
      private com.google.protobuf.RepeatedFieldBuilder<
          org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder> 
          getTaskMessageFieldBuilder() {
        if (taskMessageBuilder_ == null) {
          taskMessageBuilder_ = new com.google.protobuf.RepeatedFieldBuilder<
              org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder, org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder>(
                  taskMessage_,
                  ((bitField0_ & 0x00000020) == 0x00000020),
                  getParentForChildren(),
                  isClean());
          taskMessage_ = null;
        }
        return taskMessageBuilder_;
      }

      // @@protoc_insertion_point(builder_scope:TaskStatusProto)
    }

    static {
      defaultInstance = new TaskStatusProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:TaskStatusProto)
  }

  public interface EvaluatorStatusProtoOrBuilder
      extends com.google.protobuf.MessageOrBuilder {

    // required string evaluator_id = 1;
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    boolean hasEvaluatorId();
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    java.lang.String getEvaluatorId();
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    com.google.protobuf.ByteString
        getEvaluatorIdBytes();

    // required .State state = 2;
    /**
     * <code>required .State state = 2;</code>
     */
    boolean hasState();
    /**
     * <code>required .State state = 2;</code>
     */
    org.apache.reef.proto.ReefServiceProtos.State getState();

    // optional bytes error = 3;
    /**
     * <code>optional bytes error = 3;</code>
     */
    boolean hasError();
    /**
     * <code>optional bytes error = 3;</code>
     */
    com.google.protobuf.ByteString getError();
  }
  /**
   * Protobuf type {@code EvaluatorStatusProto}
   */
  public static final class EvaluatorStatusProto extends
      com.google.protobuf.GeneratedMessage
      implements EvaluatorStatusProtoOrBuilder {
    // Use EvaluatorStatusProto.newBuilder() to construct.
    private EvaluatorStatusProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
      super(builder);
      this.unknownFields = builder.getUnknownFields();
    }
    private EvaluatorStatusProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }

    private static final EvaluatorStatusProto defaultInstance;
    public static EvaluatorStatusProto getDefaultInstance() {
      return defaultInstance;
    }

    public EvaluatorStatusProto getDefaultInstanceForType() {
      return defaultInstance;
    }

    private final com.google.protobuf.UnknownFieldSet unknownFields;
    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
        getUnknownFields() {
      return this.unknownFields;
    }
    private EvaluatorStatusProto(
        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;
              evaluatorId_ = input.readBytes();
              break;
            }
            case 16: {
              int rawValue = input.readEnum();
              org.apache.reef.proto.ReefServiceProtos.State value = org.apache.reef.proto.ReefServiceProtos.State.valueOf(rawValue);
              if (value == null) {
                unknownFields.mergeVarintField(2, rawValue);
              } else {
                bitField0_ |= 0x00000002;
                state_ = value;
              }
              break;
            }
            case 26: {
              bitField0_ |= 0x00000004;
              error_ = 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.reef.proto.ReefServiceProtos.internal_static_EvaluatorStatusProto_descriptor;
    }

    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
        internalGetFieldAccessorTable() {
      return org.apache.reef.proto.ReefServiceProtos.internal_static_EvaluatorStatusProto_fieldAccessorTable
          .ensureFieldAccessorsInitialized(
              org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.class, org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder.class);
    }

    public static com.google.protobuf.Parser<EvaluatorStatusProto> PARSER =
        new com.google.protobuf.AbstractParser<EvaluatorStatusProto>() {
      public EvaluatorStatusProto parsePartialFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        return new EvaluatorStatusProto(input, extensionRegistry);
      }
    };

    @java.lang.Override
    public com.google.protobuf.Parser<EvaluatorStatusProto> getParserForType() {
      return PARSER;
    }

    private int bitField0_;
    // required string evaluator_id = 1;
    public static final int EVALUATOR_ID_FIELD_NUMBER = 1;
    private java.lang.Object evaluatorId_;
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    public boolean hasEvaluatorId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    public java.lang.String getEvaluatorId() {
      java.lang.Object ref = evaluatorId_;
      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()) {
          evaluatorId_ = s;
        }
        return s;
      }
    }
    /**
     * <code>required string evaluator_id = 1;</code>
     */
    public com.google.protobuf.ByteString
        getEvaluatorIdBytes() {
      java.lang.Object ref = evaluatorId_;
      if (ref instanceof java.lang.String) {
        com.google.protobuf.ByteString b = 
            com.google.protobuf.ByteString.copyFromUtf8(
                (java.lang.String) ref);
        evaluatorId_ = b;
        return b;
      } else {
        return (com.google.protobuf.ByteString) ref;
      }
    }

    // required .State state = 2;
    public static final int STATE_FIELD_NUMBER = 2;
    private org.apache.reef.proto.ReefServiceProtos.State state_;
    /**
     * <code>required .State state = 2;</code>
     */
    public boolean hasState() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    /**
     * <code>required .State state = 2;</code>
     */
    public org.apache.reef.proto.ReefServiceProtos.State getState() {
      return state_;
    }

    // optional bytes error = 3;
    public static final int ERROR_FIELD_NUMBER = 3;
    private com.google.protobuf.ByteString error_;
    /**
     * <code>optional bytes error = 3;</code>
     */
    public boolean hasError() {
      return ((bitField0_ & 0x00000004) == 0x00000004);
    }
    /**
     * <code>optional bytes error = 3;</code>
     */
    public com.google.protobuf.ByteString getError() {
      return error_;
    }

    private void initFields() {
      evaluatorId_ = "";
      state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      error_ = com.google.protobuf.ByteString.EMPTY;
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;

      if (!hasEvaluatorId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasState()) {
        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, getEvaluatorIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeEnum(2, state_.getNumber());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        output.writeBytes(3, error_);
      }
      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, getEvaluatorIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += com.google.protobuf.CodedOutputStream
          .computeEnumSize(2, state_.getNumber());
      }
      if (((bitField0_ & 0x00000004) == 0x00000004)) {
        size += com.google.protobuf.CodedOutputStream
          .computeBytesSize(3, error_);
      }
      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();
    }

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
      if (obj == this) {
       return true;
      }
      if (!(obj instanceof org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto)) {
        return super.equals(obj);
      }
      org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto other = (org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto) obj;

      boolean result = true;
      result = result && (hasEvaluatorId() == other.hasEvaluatorId());
      if (hasEvaluatorId()) {
        result = result && getEvaluatorId()
            .equals(other.getEvaluatorId());
      }
      result = result && (hasState() == other.hasState());
      if (hasState()) {
        result = result &&
            (getState() == other.getState());
      }
      result = result && (hasError() == other.hasError());
      if (hasError()) {
        result = result && getError()
            .equals(other.getError());
      }
      result = result &&
          getUnknownFields().equals(other.getUnknownFields());
      return result;
    }

    private int memoizedHashCode = 0;
    @java.lang.Override
    public int hashCode() {
      if (memoizedHashCode != 0) {
        return memoizedHashCode;
      }
      int hash = 41;
      hash = (19 * hash) + getDescriptorForType().hashCode();
      if (hasEvaluatorId()) {
        hash = (37 * hash) + EVALUATOR_ID_FIELD_NUMBER;
        hash = (53 * hash) + getEvaluatorId().hashCode();
      }
      if (hasState()) {
        hash = (37 * hash) + STATE_FIELD_NUMBER;
        hash = (53 * hash) + hashEnum(getState());
      }
      if (hasError()) {
        hash = (37 * hash) + ERROR_FIELD_NUMBER;
        hash = (53 * hash) + getError().hashCode();
      }
      hash = (29 * hash) + getUnknownFields().hashCode();
      memoizedHashCode = hash;
      return hash;
    }

    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto 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.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
      return PARSER.parseFrom(data, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return PARSER.parseDelimitedFrom(input, extensionRegistry);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
      return PARSER.parseFrom(input);
    }
    public static org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto 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.reef.proto.ReefServiceProtos.EvaluatorStatusProto 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 EvaluatorStatusProto}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessage.Builder<Builder>
       implements org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProtoOrBuilder {
      public static final com.google.protobuf.Descriptors.Descriptor
          getDescriptor() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_EvaluatorStatusProto_descriptor;
      }

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_EvaluatorStatusProto_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.class, org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder.class);
      }

      // Construct using org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.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();
        evaluatorId_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        bitField0_ = (bitField0_ & ~0x00000002);
        error_ = com.google.protobuf.ByteString.EMPTY;
        bitField0_ = (bitField0_ & ~0x00000004);
        return this;
      }

      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }

      public com.google.protobuf.Descriptors.Descriptor
          getDescriptorForType() {
        return org.apache.reef.proto.ReefServiceProtos.internal_static_EvaluatorStatusProto_descriptor;
      }

      public org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto getDefaultInstanceForType() {
        return org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.getDefaultInstance();
      }

      public org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto build() {
        org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }

      public org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto buildPartial() {
        org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto result = new org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto(this);
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.evaluatorId_ = evaluatorId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.state_ = state_;
        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
          to_bitField0_ |= 0x00000004;
        }
        result.error_ = error_;
        result.bitField0_ = to_bitField0_;
        onBuilt();
        return result;
      }

      public Builder mergeFrom(com.google.protobuf.Message other) {
        if (other instanceof org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto) {
          return mergeFrom((org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto)other);
        } else {
          super.mergeFrom(other);
          return this;
        }
      }

      public Builder mergeFrom(org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto other) {
        if (other == org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.getDefaultInstance()) return this;
        if (other.hasEvaluatorId()) {
          bitField0_ |= 0x00000001;
          evaluatorId_ = other.evaluatorId_;
          onChanged();
        }
        if (other.hasState()) {
          setState(other.getState());
        }
        if (other.hasError()) {
          setError(other.getError());
        }
        this.mergeUnknownFields(other.getUnknownFields());
        return this;
      }

      public final boolean isInitialized() {
        if (!hasEvaluatorId()) {
          
          return false;
        }
        if (!hasState()) {
          
          return false;
        }
        return true;
      }

      public Builder mergeFrom(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto parsedMessage = null;
        try {
          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
          parsedMessage = (org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto) e.getUnfinishedMessage();
          throw e;
        } finally {
          if (parsedMessage != null) {
            mergeFrom(parsedMessage);
          }
        }
        return this;
      }
      private int bitField0_;

      // required string evaluator_id = 1;
      private java.lang.Object evaluatorId_ = "";
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public boolean hasEvaluatorId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public java.lang.String getEvaluatorId() {
        java.lang.Object ref = evaluatorId_;
        if (!(ref instanceof java.lang.String)) {
          java.lang.String s = ((com.google.protobuf.ByteString) ref)
              .toStringUtf8();
          evaluatorId_ = s;
          return s;
        } else {
          return (java.lang.String) ref;
        }
      }
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public com.google.protobuf.ByteString
          getEvaluatorIdBytes() {
        java.lang.Object ref = evaluatorId_;
        if (ref instanceof String) {
          com.google.protobuf.ByteString b = 
              com.google.protobuf.ByteString.copyFromUtf8(
                  (java.lang.String) ref);
          evaluatorId_ = b;
          return b;
        } else {
          return (com.google.protobuf.ByteString) ref;
        }
      }
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public Builder setEvaluatorId(
          java.lang.String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        evaluatorId_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public Builder clearEvaluatorId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        evaluatorId_ = getDefaultInstance().getEvaluatorId();
        onChanged();
        return this;
      }
      /**
       * <code>required string evaluator_id = 1;</code>
       */
      public Builder setEvaluatorIdBytes(
          com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        evaluatorId_ = value;
        onChanged();
        return this;
      }

      // required .State state = 2;
      private org.apache.reef.proto.ReefServiceProtos.State state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
      /**
       * <code>required .State state = 2;</code>
       */
      public boolean hasState() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public org.apache.reef.proto.ReefServiceProtos.State getState() {
        return state_;
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public Builder setState(org.apache.reef.proto.ReefServiceProtos.State value) {
        if (value == null) {
          throw new NullPointerException();
        }
        bitField0_ |= 0x00000002;
        state_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>required .State state = 2;</code>
       */
      public Builder clearState() {
        bitField0_ = (bitField0_ & ~0x00000002);
        state_ = org.apache.reef.proto.ReefServiceProtos.State.INIT;
        onChanged();
        return this;
      }

      // optional bytes error = 3;
      private com.google.protobuf.ByteString error_ = com.google.protobuf.ByteString.EMPTY;
      /**
       * <code>optional bytes error = 3;</code>
       */
      public boolean hasError() {
        return ((bitField0_ & 0x00000004) == 0x00000004);
      }
      /**
       * <code>optional bytes error = 3;</code>
       */
      public com.google.protobuf.ByteString getError() {
        return error_;
      }
      /**
       * <code>optional bytes error = 3;</code>
       */
      public Builder setError(com.google.protobuf.ByteString value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000004;
        error_ = value;
        onChanged();
        return this;
      }
      /**
       * <code>optional bytes error = 3;</code>
       */
      public Builder clearError() {
        bitField0_ = (bitField0_ & ~0x00000004);
        error_ = getDefaultInstance().getError();
        onChanged();
        return this;
      }

      // @@protoc_insertion_point(builder_scope:EvaluatorStatusProto)
    }

    static {
      defaultInstance = new EvaluatorStatusProto(true);
      defaultInstance.initFields();
    }

    // @@protoc_insertion_point(class_scope:EvaluatorStatusProto)
  }

  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_FileResourceProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_FileResourceProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_RuntimeErrorProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_RuntimeErrorProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_JobStatusProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_JobStatusProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_ContextStatusProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_ContextStatusProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_ContextStatusProto_ContextMessageProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_ContextStatusProto_ContextMessageProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_TaskStatusProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_TaskStatusProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_TaskStatusProto_TaskMessageProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_TaskStatusProto_TaskMessageProto_fieldAccessorTable;
  private static com.google.protobuf.Descriptors.Descriptor
    internal_static_EvaluatorStatusProto_descriptor;
  private static
    com.google.protobuf.GeneratedMessage.FieldAccessorTable
      internal_static_EvaluatorStatusProto_fieldAccessorTable;

  public static com.google.protobuf.Descriptors.FileDescriptor
      getDescriptor() {
    return descriptor;
  }
  private static com.google.protobuf.Descriptors.FileDescriptor
      descriptor;
  static {
    java.lang.String[] descriptorData = {
      "\n\031reef_service_protos.proto\"H\n\021FileResou" +
      "rceProto\022\027\n\004type\030\001 \002(\0162\t.FileType\022\014\n\004nam" +
      "e\030\002 \002(\t\022\014\n\004path\030\003 \002(\t\"Y\n\021RuntimeErrorPro" +
      "to\022\014\n\004name\030\001 \002(\t\022\017\n\007message\030\002 \002(\t\022\021\n\texc" +
      "eption\030\003 \001(\014\022\022\n\nidentifier\030\005 \001(\t\"_\n\016JobS" +
      "tatusProto\022\022\n\nidentifier\030\001 \002(\t\022\025\n\005state\030" +
      "\002 \002(\0162\006.State\022\017\n\007message\030\003 \001(\014\022\021\n\texcept" +
      "ion\030\004 \001(\014\"\263\002\n\022ContextStatusProto\0220\n\rcont" +
      "ext_state\030\001 \002(\0162\031.ContextStatusProto.Sta" +
      "te\022\022\n\ncontext_id\030\002 \002(\t\022\021\n\tparent_id\030\003 \001(",
      "\t\022\r\n\005error\030\005 \001(\014\022\020\n\010recovery\030\006 \001(\010\022@\n\017co" +
      "ntext_message\030\007 \003(\0132\'.ContextStatusProto" +
      ".ContextMessageProto\0329\n\023ContextMessagePr" +
      "oto\022\021\n\tsource_id\030\001 \002(\t\022\017\n\007message\030\002 \002(\014\"" +
      "&\n\005State\022\t\n\005READY\020\000\022\010\n\004DONE\020\001\022\010\n\004FAIL\020\002\"" +
      "\340\001\n\017TaskStatusProto\022\017\n\007task_id\030\001 \002(\t\022\022\n\n" +
      "context_id\030\002 \002(\t\022\025\n\005state\030\003 \002(\0162\006.State\022" +
      "\016\n\006result\030\004 \001(\014\022\020\n\010recovery\030\005 \001(\010\0227\n\014tas" +
      "k_message\030\006 \003(\0132!.TaskStatusProto.TaskMe" +
      "ssageProto\0326\n\020TaskMessageProto\022\021\n\tsource",
      "_id\030\001 \002(\t\022\017\n\007message\030\002 \002(\014\"R\n\024EvaluatorS" +
      "tatusProto\022\024\n\014evaluator_id\030\001 \002(\t\022\025\n\005stat" +
      "e\030\002 \002(\0162\006.State\022\r\n\005error\030\003 \001(\014*M\n\005State\022" +
      "\010\n\004INIT\020\000\022\013\n\007RUNNING\020\001\022\010\n\004DONE\020\002\022\013\n\007SUSP" +
      "END\020\003\022\n\n\006FAILED\020\004\022\n\n\006KILLED\020\005*+\n\010FileTyp" +
      "e\022\t\n\005PLAIN\020\000\022\007\n\003LIB\020\001\022\013\n\007ARCHIVE\020\002*\037\n\013Pr" +
      "ocessType\022\007\n\003JVM\020\000\022\007\n\003CLR\020\001B0\n\025org.apach" +
      "e.reef.protoB\021ReefServiceProtos\210\001\001\240\001\001"
    };
    com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
      new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
        public com.google.protobuf.ExtensionRegistry assignDescriptors(
            com.google.protobuf.Descriptors.FileDescriptor root) {
          descriptor = root;
          internal_static_FileResourceProto_descriptor =
            getDescriptor().getMessageTypes().get(0);
          internal_static_FileResourceProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_FileResourceProto_descriptor,
              new java.lang.String[] { "Type", "Name", "Path", });
          internal_static_RuntimeErrorProto_descriptor =
            getDescriptor().getMessageTypes().get(1);
          internal_static_RuntimeErrorProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_RuntimeErrorProto_descriptor,
              new java.lang.String[] { "Name", "Message", "Exception", "Identifier", });
          internal_static_JobStatusProto_descriptor =
            getDescriptor().getMessageTypes().get(2);
          internal_static_JobStatusProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_JobStatusProto_descriptor,
              new java.lang.String[] { "Identifier", "State", "Message", "Exception", });
          internal_static_ContextStatusProto_descriptor =
            getDescriptor().getMessageTypes().get(3);
          internal_static_ContextStatusProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_ContextStatusProto_descriptor,
              new java.lang.String[] { "ContextState", "ContextId", "ParentId", "Error", "Recovery", "ContextMessage", });
          internal_static_ContextStatusProto_ContextMessageProto_descriptor =
            internal_static_ContextStatusProto_descriptor.getNestedTypes().get(0);
          internal_static_ContextStatusProto_ContextMessageProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_ContextStatusProto_ContextMessageProto_descriptor,
              new java.lang.String[] { "SourceId", "Message", });
          internal_static_TaskStatusProto_descriptor =
            getDescriptor().getMessageTypes().get(4);
          internal_static_TaskStatusProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_TaskStatusProto_descriptor,
              new java.lang.String[] { "TaskId", "ContextId", "State", "Result", "Recovery", "TaskMessage", });
          internal_static_TaskStatusProto_TaskMessageProto_descriptor =
            internal_static_TaskStatusProto_descriptor.getNestedTypes().get(0);
          internal_static_TaskStatusProto_TaskMessageProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_TaskStatusProto_TaskMessageProto_descriptor,
              new java.lang.String[] { "SourceId", "Message", });
          internal_static_EvaluatorStatusProto_descriptor =
            getDescriptor().getMessageTypes().get(5);
          internal_static_EvaluatorStatusProto_fieldAccessorTable = new
            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
              internal_static_EvaluatorStatusProto_descriptor,
              new java.lang.String[] { "EvaluatorId", "State", "Error", });
          return null;
        }
      };
    com.google.protobuf.Descriptors.FileDescriptor
      .internalBuildGeneratedFileFrom(descriptorData,
        new com.google.protobuf.Descriptors.FileDescriptor[] {
        }, assigner);
  }

  // @@protoc_insertion_point(outer_class_scope)
}