This project has retired. For details please refer to its Attic page.
Source code
001// Generated by the protocol buffer compiler.  DO NOT EDIT!
002// source: reef_protocol.proto
003
004package org.apache.reef.proto;
005
006public final class REEFProtocol {
007  private REEFProtocol() {}
008  public static void registerAllExtensions(
009      com.google.protobuf.ExtensionRegistry registry) {
010  }
011  public interface REEFMessageOrBuilder
012      extends com.google.protobuf.MessageOrBuilder {
013
014    // optional .JobControlProto jobControl = 2;
015    /**
016     * <code>optional .JobControlProto jobControl = 2;</code>
017     *
018     * <pre>
019     * Messages defined in client_runtime.proto
020     * </pre>
021     */
022    boolean hasJobControl();
023    /**
024     * <code>optional .JobControlProto jobControl = 2;</code>
025     *
026     * <pre>
027     * Messages defined in client_runtime.proto
028     * </pre>
029     */
030    org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl();
031    /**
032     * <code>optional .JobControlProto jobControl = 2;</code>
033     *
034     * <pre>
035     * Messages defined in client_runtime.proto
036     * </pre>
037     */
038    org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder();
039
040    // optional .RuntimeErrorProto runtimeError = 3;
041    /**
042     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
043     *
044     * <pre>
045     * Messages defined in reef_service_protos.proto
046     * </pre>
047     */
048    boolean hasRuntimeError();
049    /**
050     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
051     *
052     * <pre>
053     * Messages defined in reef_service_protos.proto
054     * </pre>
055     */
056    org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError();
057    /**
058     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
059     *
060     * <pre>
061     * Messages defined in reef_service_protos.proto
062     * </pre>
063     */
064    org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder();
065
066    // optional .JobStatusProto jobStatus = 4;
067    /**
068     * <code>optional .JobStatusProto jobStatus = 4;</code>
069     */
070    boolean hasJobStatus();
071    /**
072     * <code>optional .JobStatusProto jobStatus = 4;</code>
073     */
074    org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus();
075    /**
076     * <code>optional .JobStatusProto jobStatus = 4;</code>
077     */
078    org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder();
079
080    // optional .EvaluatorControlProto evaluatorControl = 5;
081    /**
082     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
083     *
084     * <pre>
085     * Messages from evaluator_runtime.proto
086     * </pre>
087     */
088    boolean hasEvaluatorControl();
089    /**
090     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
091     *
092     * <pre>
093     * Messages from evaluator_runtime.proto
094     * </pre>
095     */
096    org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl();
097    /**
098     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
099     *
100     * <pre>
101     * Messages from evaluator_runtime.proto
102     * </pre>
103     */
104    org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder();
105
106    // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;
107    /**
108     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
109     */
110    boolean hasEvaluatorHeartBeat();
111    /**
112     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
113     */
114    org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat();
115    /**
116     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
117     */
118    org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder();
119  }
120  /**
121   * Protobuf type {@code REEFMessage}
122   *
123   * <pre>
124   * Field 1 removed
125   * </pre>
126   */
127  public static final class REEFMessage extends
128      com.google.protobuf.GeneratedMessage
129      implements REEFMessageOrBuilder {
130    // Use REEFMessage.newBuilder() to construct.
131    private REEFMessage(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
132      super(builder);
133      this.unknownFields = builder.getUnknownFields();
134    }
135    private REEFMessage(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
136
137    private static final REEFMessage defaultInstance;
138    public static REEFMessage getDefaultInstance() {
139      return defaultInstance;
140    }
141
142    public REEFMessage getDefaultInstanceForType() {
143      return defaultInstance;
144    }
145
146    private final com.google.protobuf.UnknownFieldSet unknownFields;
147    @java.lang.Override
148    public final com.google.protobuf.UnknownFieldSet
149        getUnknownFields() {
150      return this.unknownFields;
151    }
152    private REEFMessage(
153        com.google.protobuf.CodedInputStream input,
154        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
155        throws com.google.protobuf.InvalidProtocolBufferException {
156      initFields();
157      int mutable_bitField0_ = 0;
158      com.google.protobuf.UnknownFieldSet.Builder unknownFields =
159          com.google.protobuf.UnknownFieldSet.newBuilder();
160      try {
161        boolean done = false;
162        while (!done) {
163          int tag = input.readTag();
164          switch (tag) {
165            case 0:
166              done = true;
167              break;
168            default: {
169              if (!parseUnknownField(input, unknownFields,
170                                     extensionRegistry, tag)) {
171                done = true;
172              }
173              break;
174            }
175            case 18: {
176              org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder subBuilder = null;
177              if (((bitField0_ & 0x00000001) == 0x00000001)) {
178                subBuilder = jobControl_.toBuilder();
179              }
180              jobControl_ = input.readMessage(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.PARSER, extensionRegistry);
181              if (subBuilder != null) {
182                subBuilder.mergeFrom(jobControl_);
183                jobControl_ = subBuilder.buildPartial();
184              }
185              bitField0_ |= 0x00000001;
186              break;
187            }
188            case 26: {
189              org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder subBuilder = null;
190              if (((bitField0_ & 0x00000002) == 0x00000002)) {
191                subBuilder = runtimeError_.toBuilder();
192              }
193              runtimeError_ = input.readMessage(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.PARSER, extensionRegistry);
194              if (subBuilder != null) {
195                subBuilder.mergeFrom(runtimeError_);
196                runtimeError_ = subBuilder.buildPartial();
197              }
198              bitField0_ |= 0x00000002;
199              break;
200            }
201            case 34: {
202              org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder subBuilder = null;
203              if (((bitField0_ & 0x00000004) == 0x00000004)) {
204                subBuilder = jobStatus_.toBuilder();
205              }
206              jobStatus_ = input.readMessage(org.apache.reef.proto.ReefServiceProtos.JobStatusProto.PARSER, extensionRegistry);
207              if (subBuilder != null) {
208                subBuilder.mergeFrom(jobStatus_);
209                jobStatus_ = subBuilder.buildPartial();
210              }
211              bitField0_ |= 0x00000004;
212              break;
213            }
214            case 42: {
215              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder subBuilder = null;
216              if (((bitField0_ & 0x00000008) == 0x00000008)) {
217                subBuilder = evaluatorControl_.toBuilder();
218              }
219              evaluatorControl_ = input.readMessage(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.PARSER, extensionRegistry);
220              if (subBuilder != null) {
221                subBuilder.mergeFrom(evaluatorControl_);
222                evaluatorControl_ = subBuilder.buildPartial();
223              }
224              bitField0_ |= 0x00000008;
225              break;
226            }
227            case 50: {
228              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder subBuilder = null;
229              if (((bitField0_ & 0x00000010) == 0x00000010)) {
230                subBuilder = evaluatorHeartBeat_.toBuilder();
231              }
232              evaluatorHeartBeat_ = input.readMessage(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.PARSER, extensionRegistry);
233              if (subBuilder != null) {
234                subBuilder.mergeFrom(evaluatorHeartBeat_);
235                evaluatorHeartBeat_ = subBuilder.buildPartial();
236              }
237              bitField0_ |= 0x00000010;
238              break;
239            }
240          }
241        }
242      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
243        throw e.setUnfinishedMessage(this);
244      } catch (java.io.IOException e) {
245        throw new com.google.protobuf.InvalidProtocolBufferException(
246            e.getMessage()).setUnfinishedMessage(this);
247      } finally {
248        this.unknownFields = unknownFields.build();
249        makeExtensionsImmutable();
250      }
251    }
252    public static final com.google.protobuf.Descriptors.Descriptor
253        getDescriptor() {
254      return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor;
255    }
256
257    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
258        internalGetFieldAccessorTable() {
259      return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_fieldAccessorTable
260          .ensureFieldAccessorsInitialized(
261              org.apache.reef.proto.REEFProtocol.REEFMessage.class, org.apache.reef.proto.REEFProtocol.REEFMessage.Builder.class);
262    }
263
264    public static com.google.protobuf.Parser<REEFMessage> PARSER =
265        new com.google.protobuf.AbstractParser<REEFMessage>() {
266      public REEFMessage parsePartialFrom(
267          com.google.protobuf.CodedInputStream input,
268          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
269          throws com.google.protobuf.InvalidProtocolBufferException {
270        return new REEFMessage(input, extensionRegistry);
271      }
272    };
273
274    @java.lang.Override
275    public com.google.protobuf.Parser<REEFMessage> getParserForType() {
276      return PARSER;
277    }
278
279    private int bitField0_;
280    // optional .JobControlProto jobControl = 2;
281    public static final int JOBCONTROL_FIELD_NUMBER = 2;
282    private org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto jobControl_;
283    /**
284     * <code>optional .JobControlProto jobControl = 2;</code>
285     *
286     * <pre>
287     * Messages defined in client_runtime.proto
288     * </pre>
289     */
290    public boolean hasJobControl() {
291      return ((bitField0_ & 0x00000001) == 0x00000001);
292    }
293    /**
294     * <code>optional .JobControlProto jobControl = 2;</code>
295     *
296     * <pre>
297     * Messages defined in client_runtime.proto
298     * </pre>
299     */
300    public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl() {
301      return jobControl_;
302    }
303    /**
304     * <code>optional .JobControlProto jobControl = 2;</code>
305     *
306     * <pre>
307     * Messages defined in client_runtime.proto
308     * </pre>
309     */
310    public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder() {
311      return jobControl_;
312    }
313
314    // optional .RuntimeErrorProto runtimeError = 3;
315    public static final int RUNTIMEERROR_FIELD_NUMBER = 3;
316    private org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto runtimeError_;
317    /**
318     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
319     *
320     * <pre>
321     * Messages defined in reef_service_protos.proto
322     * </pre>
323     */
324    public boolean hasRuntimeError() {
325      return ((bitField0_ & 0x00000002) == 0x00000002);
326    }
327    /**
328     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
329     *
330     * <pre>
331     * Messages defined in reef_service_protos.proto
332     * </pre>
333     */
334    public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError() {
335      return runtimeError_;
336    }
337    /**
338     * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
339     *
340     * <pre>
341     * Messages defined in reef_service_protos.proto
342     * </pre>
343     */
344    public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder() {
345      return runtimeError_;
346    }
347
348    // optional .JobStatusProto jobStatus = 4;
349    public static final int JOBSTATUS_FIELD_NUMBER = 4;
350    private org.apache.reef.proto.ReefServiceProtos.JobStatusProto jobStatus_;
351    /**
352     * <code>optional .JobStatusProto jobStatus = 4;</code>
353     */
354    public boolean hasJobStatus() {
355      return ((bitField0_ & 0x00000004) == 0x00000004);
356    }
357    /**
358     * <code>optional .JobStatusProto jobStatus = 4;</code>
359     */
360    public org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus() {
361      return jobStatus_;
362    }
363    /**
364     * <code>optional .JobStatusProto jobStatus = 4;</code>
365     */
366    public org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder() {
367      return jobStatus_;
368    }
369
370    // optional .EvaluatorControlProto evaluatorControl = 5;
371    public static final int EVALUATORCONTROL_FIELD_NUMBER = 5;
372    private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControl_;
373    /**
374     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
375     *
376     * <pre>
377     * Messages from evaluator_runtime.proto
378     * </pre>
379     */
380    public boolean hasEvaluatorControl() {
381      return ((bitField0_ & 0x00000008) == 0x00000008);
382    }
383    /**
384     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
385     *
386     * <pre>
387     * Messages from evaluator_runtime.proto
388     * </pre>
389     */
390    public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl() {
391      return evaluatorControl_;
392    }
393    /**
394     * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
395     *
396     * <pre>
397     * Messages from evaluator_runtime.proto
398     * </pre>
399     */
400    public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder() {
401      return evaluatorControl_;
402    }
403
404    // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;
405    public static final int EVALUATORHEARTBEAT_FIELD_NUMBER = 6;
406    private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto evaluatorHeartBeat_;
407    /**
408     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
409     */
410    public boolean hasEvaluatorHeartBeat() {
411      return ((bitField0_ & 0x00000010) == 0x00000010);
412    }
413    /**
414     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
415     */
416    public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat() {
417      return evaluatorHeartBeat_;
418    }
419    /**
420     * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
421     */
422    public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder() {
423      return evaluatorHeartBeat_;
424    }
425
426    private void initFields() {
427      jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance();
428      runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance();
429      jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance();
430      evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance();
431      evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance();
432    }
433    private byte memoizedIsInitialized = -1;
434    public final boolean isInitialized() {
435      byte isInitialized = memoizedIsInitialized;
436      if (isInitialized != -1) return isInitialized == 1;
437
438      if (hasJobControl()) {
439        if (!getJobControl().isInitialized()) {
440          memoizedIsInitialized = 0;
441          return false;
442        }
443      }
444      if (hasRuntimeError()) {
445        if (!getRuntimeError().isInitialized()) {
446          memoizedIsInitialized = 0;
447          return false;
448        }
449      }
450      if (hasJobStatus()) {
451        if (!getJobStatus().isInitialized()) {
452          memoizedIsInitialized = 0;
453          return false;
454        }
455      }
456      if (hasEvaluatorControl()) {
457        if (!getEvaluatorControl().isInitialized()) {
458          memoizedIsInitialized = 0;
459          return false;
460        }
461      }
462      if (hasEvaluatorHeartBeat()) {
463        if (!getEvaluatorHeartBeat().isInitialized()) {
464          memoizedIsInitialized = 0;
465          return false;
466        }
467      }
468      memoizedIsInitialized = 1;
469      return true;
470    }
471
472    public void writeTo(com.google.protobuf.CodedOutputStream output)
473                        throws java.io.IOException {
474      getSerializedSize();
475      if (((bitField0_ & 0x00000001) == 0x00000001)) {
476        output.writeMessage(2, jobControl_);
477      }
478      if (((bitField0_ & 0x00000002) == 0x00000002)) {
479        output.writeMessage(3, runtimeError_);
480      }
481      if (((bitField0_ & 0x00000004) == 0x00000004)) {
482        output.writeMessage(4, jobStatus_);
483      }
484      if (((bitField0_ & 0x00000008) == 0x00000008)) {
485        output.writeMessage(5, evaluatorControl_);
486      }
487      if (((bitField0_ & 0x00000010) == 0x00000010)) {
488        output.writeMessage(6, evaluatorHeartBeat_);
489      }
490      getUnknownFields().writeTo(output);
491    }
492
493    private int memoizedSerializedSize = -1;
494    public int getSerializedSize() {
495      int size = memoizedSerializedSize;
496      if (size != -1) return size;
497
498      size = 0;
499      if (((bitField0_ & 0x00000001) == 0x00000001)) {
500        size += com.google.protobuf.CodedOutputStream
501          .computeMessageSize(2, jobControl_);
502      }
503      if (((bitField0_ & 0x00000002) == 0x00000002)) {
504        size += com.google.protobuf.CodedOutputStream
505          .computeMessageSize(3, runtimeError_);
506      }
507      if (((bitField0_ & 0x00000004) == 0x00000004)) {
508        size += com.google.protobuf.CodedOutputStream
509          .computeMessageSize(4, jobStatus_);
510      }
511      if (((bitField0_ & 0x00000008) == 0x00000008)) {
512        size += com.google.protobuf.CodedOutputStream
513          .computeMessageSize(5, evaluatorControl_);
514      }
515      if (((bitField0_ & 0x00000010) == 0x00000010)) {
516        size += com.google.protobuf.CodedOutputStream
517          .computeMessageSize(6, evaluatorHeartBeat_);
518      }
519      size += getUnknownFields().getSerializedSize();
520      memoizedSerializedSize = size;
521      return size;
522    }
523
524    private static final long serialVersionUID = 0L;
525    @java.lang.Override
526    protected java.lang.Object writeReplace()
527        throws java.io.ObjectStreamException {
528      return super.writeReplace();
529    }
530
531    @java.lang.Override
532    public boolean equals(final java.lang.Object obj) {
533      if (obj == this) {
534       return true;
535      }
536      if (!(obj instanceof org.apache.reef.proto.REEFProtocol.REEFMessage)) {
537        return super.equals(obj);
538      }
539      org.apache.reef.proto.REEFProtocol.REEFMessage other = (org.apache.reef.proto.REEFProtocol.REEFMessage) obj;
540
541      boolean result = true;
542      result = result && (hasJobControl() == other.hasJobControl());
543      if (hasJobControl()) {
544        result = result && getJobControl()
545            .equals(other.getJobControl());
546      }
547      result = result && (hasRuntimeError() == other.hasRuntimeError());
548      if (hasRuntimeError()) {
549        result = result && getRuntimeError()
550            .equals(other.getRuntimeError());
551      }
552      result = result && (hasJobStatus() == other.hasJobStatus());
553      if (hasJobStatus()) {
554        result = result && getJobStatus()
555            .equals(other.getJobStatus());
556      }
557      result = result && (hasEvaluatorControl() == other.hasEvaluatorControl());
558      if (hasEvaluatorControl()) {
559        result = result && getEvaluatorControl()
560            .equals(other.getEvaluatorControl());
561      }
562      result = result && (hasEvaluatorHeartBeat() == other.hasEvaluatorHeartBeat());
563      if (hasEvaluatorHeartBeat()) {
564        result = result && getEvaluatorHeartBeat()
565            .equals(other.getEvaluatorHeartBeat());
566      }
567      result = result &&
568          getUnknownFields().equals(other.getUnknownFields());
569      return result;
570    }
571
572    private int memoizedHashCode = 0;
573    @java.lang.Override
574    public int hashCode() {
575      if (memoizedHashCode != 0) {
576        return memoizedHashCode;
577      }
578      int hash = 41;
579      hash = (19 * hash) + getDescriptorForType().hashCode();
580      if (hasJobControl()) {
581        hash = (37 * hash) + JOBCONTROL_FIELD_NUMBER;
582        hash = (53 * hash) + getJobControl().hashCode();
583      }
584      if (hasRuntimeError()) {
585        hash = (37 * hash) + RUNTIMEERROR_FIELD_NUMBER;
586        hash = (53 * hash) + getRuntimeError().hashCode();
587      }
588      if (hasJobStatus()) {
589        hash = (37 * hash) + JOBSTATUS_FIELD_NUMBER;
590        hash = (53 * hash) + getJobStatus().hashCode();
591      }
592      if (hasEvaluatorControl()) {
593        hash = (37 * hash) + EVALUATORCONTROL_FIELD_NUMBER;
594        hash = (53 * hash) + getEvaluatorControl().hashCode();
595      }
596      if (hasEvaluatorHeartBeat()) {
597        hash = (37 * hash) + EVALUATORHEARTBEAT_FIELD_NUMBER;
598        hash = (53 * hash) + getEvaluatorHeartBeat().hashCode();
599      }
600      hash = (29 * hash) + getUnknownFields().hashCode();
601      memoizedHashCode = hash;
602      return hash;
603    }
604
605    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
606        com.google.protobuf.ByteString data)
607        throws com.google.protobuf.InvalidProtocolBufferException {
608      return PARSER.parseFrom(data);
609    }
610    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
611        com.google.protobuf.ByteString data,
612        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
613        throws com.google.protobuf.InvalidProtocolBufferException {
614      return PARSER.parseFrom(data, extensionRegistry);
615    }
616    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(byte[] data)
617        throws com.google.protobuf.InvalidProtocolBufferException {
618      return PARSER.parseFrom(data);
619    }
620    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
621        byte[] data,
622        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
623        throws com.google.protobuf.InvalidProtocolBufferException {
624      return PARSER.parseFrom(data, extensionRegistry);
625    }
626    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(java.io.InputStream input)
627        throws java.io.IOException {
628      return PARSER.parseFrom(input);
629    }
630    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
631        java.io.InputStream input,
632        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
633        throws java.io.IOException {
634      return PARSER.parseFrom(input, extensionRegistry);
635    }
636    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseDelimitedFrom(java.io.InputStream input)
637        throws java.io.IOException {
638      return PARSER.parseDelimitedFrom(input);
639    }
640    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseDelimitedFrom(
641        java.io.InputStream input,
642        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
643        throws java.io.IOException {
644      return PARSER.parseDelimitedFrom(input, extensionRegistry);
645    }
646    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
647        com.google.protobuf.CodedInputStream input)
648        throws java.io.IOException {
649      return PARSER.parseFrom(input);
650    }
651    public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(
652        com.google.protobuf.CodedInputStream input,
653        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
654        throws java.io.IOException {
655      return PARSER.parseFrom(input, extensionRegistry);
656    }
657
658    public static Builder newBuilder() { return Builder.create(); }
659    public Builder newBuilderForType() { return newBuilder(); }
660    public static Builder newBuilder(org.apache.reef.proto.REEFProtocol.REEFMessage prototype) {
661      return newBuilder().mergeFrom(prototype);
662    }
663    public Builder toBuilder() { return newBuilder(this); }
664
665    @java.lang.Override
666    protected Builder newBuilderForType(
667        com.google.protobuf.GeneratedMessage.BuilderParent parent) {
668      Builder builder = new Builder(parent);
669      return builder;
670    }
671    /**
672     * Protobuf type {@code REEFMessage}
673     *
674     * <pre>
675     * Field 1 removed
676     * </pre>
677     */
678    public static final class Builder extends
679        com.google.protobuf.GeneratedMessage.Builder<Builder>
680       implements org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder {
681      public static final com.google.protobuf.Descriptors.Descriptor
682          getDescriptor() {
683        return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor;
684      }
685
686      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
687          internalGetFieldAccessorTable() {
688        return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_fieldAccessorTable
689            .ensureFieldAccessorsInitialized(
690                org.apache.reef.proto.REEFProtocol.REEFMessage.class, org.apache.reef.proto.REEFProtocol.REEFMessage.Builder.class);
691      }
692
693      // Construct using org.apache.reef.proto.REEFProtocol.REEFMessage.newBuilder()
694      private Builder() {
695        maybeForceBuilderInitialization();
696      }
697
698      private Builder(
699          com.google.protobuf.GeneratedMessage.BuilderParent parent) {
700        super(parent);
701        maybeForceBuilderInitialization();
702      }
703      private void maybeForceBuilderInitialization() {
704        if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
705          getJobControlFieldBuilder();
706          getRuntimeErrorFieldBuilder();
707          getJobStatusFieldBuilder();
708          getEvaluatorControlFieldBuilder();
709          getEvaluatorHeartBeatFieldBuilder();
710        }
711      }
712      private static Builder create() {
713        return new Builder();
714      }
715
716      public Builder clear() {
717        super.clear();
718        if (jobControlBuilder_ == null) {
719          jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance();
720        } else {
721          jobControlBuilder_.clear();
722        }
723        bitField0_ = (bitField0_ & ~0x00000001);
724        if (runtimeErrorBuilder_ == null) {
725          runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance();
726        } else {
727          runtimeErrorBuilder_.clear();
728        }
729        bitField0_ = (bitField0_ & ~0x00000002);
730        if (jobStatusBuilder_ == null) {
731          jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance();
732        } else {
733          jobStatusBuilder_.clear();
734        }
735        bitField0_ = (bitField0_ & ~0x00000004);
736        if (evaluatorControlBuilder_ == null) {
737          evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance();
738        } else {
739          evaluatorControlBuilder_.clear();
740        }
741        bitField0_ = (bitField0_ & ~0x00000008);
742        if (evaluatorHeartBeatBuilder_ == null) {
743          evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance();
744        } else {
745          evaluatorHeartBeatBuilder_.clear();
746        }
747        bitField0_ = (bitField0_ & ~0x00000010);
748        return this;
749      }
750
751      public Builder clone() {
752        return create().mergeFrom(buildPartial());
753      }
754
755      public com.google.protobuf.Descriptors.Descriptor
756          getDescriptorForType() {
757        return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor;
758      }
759
760      public org.apache.reef.proto.REEFProtocol.REEFMessage getDefaultInstanceForType() {
761        return org.apache.reef.proto.REEFProtocol.REEFMessage.getDefaultInstance();
762      }
763
764      public org.apache.reef.proto.REEFProtocol.REEFMessage build() {
765        org.apache.reef.proto.REEFProtocol.REEFMessage result = buildPartial();
766        if (!result.isInitialized()) {
767          throw newUninitializedMessageException(result);
768        }
769        return result;
770      }
771
772      public org.apache.reef.proto.REEFProtocol.REEFMessage buildPartial() {
773        org.apache.reef.proto.REEFProtocol.REEFMessage result = new org.apache.reef.proto.REEFProtocol.REEFMessage(this);
774        int from_bitField0_ = bitField0_;
775        int to_bitField0_ = 0;
776        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
777          to_bitField0_ |= 0x00000001;
778        }
779        if (jobControlBuilder_ == null) {
780          result.jobControl_ = jobControl_;
781        } else {
782          result.jobControl_ = jobControlBuilder_.build();
783        }
784        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
785          to_bitField0_ |= 0x00000002;
786        }
787        if (runtimeErrorBuilder_ == null) {
788          result.runtimeError_ = runtimeError_;
789        } else {
790          result.runtimeError_ = runtimeErrorBuilder_.build();
791        }
792        if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
793          to_bitField0_ |= 0x00000004;
794        }
795        if (jobStatusBuilder_ == null) {
796          result.jobStatus_ = jobStatus_;
797        } else {
798          result.jobStatus_ = jobStatusBuilder_.build();
799        }
800        if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
801          to_bitField0_ |= 0x00000008;
802        }
803        if (evaluatorControlBuilder_ == null) {
804          result.evaluatorControl_ = evaluatorControl_;
805        } else {
806          result.evaluatorControl_ = evaluatorControlBuilder_.build();
807        }
808        if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
809          to_bitField0_ |= 0x00000010;
810        }
811        if (evaluatorHeartBeatBuilder_ == null) {
812          result.evaluatorHeartBeat_ = evaluatorHeartBeat_;
813        } else {
814          result.evaluatorHeartBeat_ = evaluatorHeartBeatBuilder_.build();
815        }
816        result.bitField0_ = to_bitField0_;
817        onBuilt();
818        return result;
819      }
820
821      public Builder mergeFrom(com.google.protobuf.Message other) {
822        if (other instanceof org.apache.reef.proto.REEFProtocol.REEFMessage) {
823          return mergeFrom((org.apache.reef.proto.REEFProtocol.REEFMessage)other);
824        } else {
825          super.mergeFrom(other);
826          return this;
827        }
828      }
829
830      public Builder mergeFrom(org.apache.reef.proto.REEFProtocol.REEFMessage other) {
831        if (other == org.apache.reef.proto.REEFProtocol.REEFMessage.getDefaultInstance()) return this;
832        if (other.hasJobControl()) {
833          mergeJobControl(other.getJobControl());
834        }
835        if (other.hasRuntimeError()) {
836          mergeRuntimeError(other.getRuntimeError());
837        }
838        if (other.hasJobStatus()) {
839          mergeJobStatus(other.getJobStatus());
840        }
841        if (other.hasEvaluatorControl()) {
842          mergeEvaluatorControl(other.getEvaluatorControl());
843        }
844        if (other.hasEvaluatorHeartBeat()) {
845          mergeEvaluatorHeartBeat(other.getEvaluatorHeartBeat());
846        }
847        this.mergeUnknownFields(other.getUnknownFields());
848        return this;
849      }
850
851      public final boolean isInitialized() {
852        if (hasJobControl()) {
853          if (!getJobControl().isInitialized()) {
854            
855            return false;
856          }
857        }
858        if (hasRuntimeError()) {
859          if (!getRuntimeError().isInitialized()) {
860            
861            return false;
862          }
863        }
864        if (hasJobStatus()) {
865          if (!getJobStatus().isInitialized()) {
866            
867            return false;
868          }
869        }
870        if (hasEvaluatorControl()) {
871          if (!getEvaluatorControl().isInitialized()) {
872            
873            return false;
874          }
875        }
876        if (hasEvaluatorHeartBeat()) {
877          if (!getEvaluatorHeartBeat().isInitialized()) {
878            
879            return false;
880          }
881        }
882        return true;
883      }
884
885      public Builder mergeFrom(
886          com.google.protobuf.CodedInputStream input,
887          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
888          throws java.io.IOException {
889        org.apache.reef.proto.REEFProtocol.REEFMessage parsedMessage = null;
890        try {
891          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
892        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
893          parsedMessage = (org.apache.reef.proto.REEFProtocol.REEFMessage) e.getUnfinishedMessage();
894          throw e;
895        } finally {
896          if (parsedMessage != null) {
897            mergeFrom(parsedMessage);
898          }
899        }
900        return this;
901      }
902      private int bitField0_;
903
904      // optional .JobControlProto jobControl = 2;
905      private org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance();
906      private com.google.protobuf.SingleFieldBuilder<
907          org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder> jobControlBuilder_;
908      /**
909       * <code>optional .JobControlProto jobControl = 2;</code>
910       *
911       * <pre>
912       * Messages defined in client_runtime.proto
913       * </pre>
914       */
915      public boolean hasJobControl() {
916        return ((bitField0_ & 0x00000001) == 0x00000001);
917      }
918      /**
919       * <code>optional .JobControlProto jobControl = 2;</code>
920       *
921       * <pre>
922       * Messages defined in client_runtime.proto
923       * </pre>
924       */
925      public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl() {
926        if (jobControlBuilder_ == null) {
927          return jobControl_;
928        } else {
929          return jobControlBuilder_.getMessage();
930        }
931      }
932      /**
933       * <code>optional .JobControlProto jobControl = 2;</code>
934       *
935       * <pre>
936       * Messages defined in client_runtime.proto
937       * </pre>
938       */
939      public Builder setJobControl(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto value) {
940        if (jobControlBuilder_ == null) {
941          if (value == null) {
942            throw new NullPointerException();
943          }
944          jobControl_ = value;
945          onChanged();
946        } else {
947          jobControlBuilder_.setMessage(value);
948        }
949        bitField0_ |= 0x00000001;
950        return this;
951      }
952      /**
953       * <code>optional .JobControlProto jobControl = 2;</code>
954       *
955       * <pre>
956       * Messages defined in client_runtime.proto
957       * </pre>
958       */
959      public Builder setJobControl(
960          org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder builderForValue) {
961        if (jobControlBuilder_ == null) {
962          jobControl_ = builderForValue.build();
963          onChanged();
964        } else {
965          jobControlBuilder_.setMessage(builderForValue.build());
966        }
967        bitField0_ |= 0x00000001;
968        return this;
969      }
970      /**
971       * <code>optional .JobControlProto jobControl = 2;</code>
972       *
973       * <pre>
974       * Messages defined in client_runtime.proto
975       * </pre>
976       */
977      public Builder mergeJobControl(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto value) {
978        if (jobControlBuilder_ == null) {
979          if (((bitField0_ & 0x00000001) == 0x00000001) &&
980              jobControl_ != org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance()) {
981            jobControl_ =
982              org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.newBuilder(jobControl_).mergeFrom(value).buildPartial();
983          } else {
984            jobControl_ = value;
985          }
986          onChanged();
987        } else {
988          jobControlBuilder_.mergeFrom(value);
989        }
990        bitField0_ |= 0x00000001;
991        return this;
992      }
993      /**
994       * <code>optional .JobControlProto jobControl = 2;</code>
995       *
996       * <pre>
997       * Messages defined in client_runtime.proto
998       * </pre>
999       */
1000      public Builder clearJobControl() {
1001        if (jobControlBuilder_ == null) {
1002          jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance();
1003          onChanged();
1004        } else {
1005          jobControlBuilder_.clear();
1006        }
1007        bitField0_ = (bitField0_ & ~0x00000001);
1008        return this;
1009      }
1010      /**
1011       * <code>optional .JobControlProto jobControl = 2;</code>
1012       *
1013       * <pre>
1014       * Messages defined in client_runtime.proto
1015       * </pre>
1016       */
1017      public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder getJobControlBuilder() {
1018        bitField0_ |= 0x00000001;
1019        onChanged();
1020        return getJobControlFieldBuilder().getBuilder();
1021      }
1022      /**
1023       * <code>optional .JobControlProto jobControl = 2;</code>
1024       *
1025       * <pre>
1026       * Messages defined in client_runtime.proto
1027       * </pre>
1028       */
1029      public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder() {
1030        if (jobControlBuilder_ != null) {
1031          return jobControlBuilder_.getMessageOrBuilder();
1032        } else {
1033          return jobControl_;
1034        }
1035      }
1036      /**
1037       * <code>optional .JobControlProto jobControl = 2;</code>
1038       *
1039       * <pre>
1040       * Messages defined in client_runtime.proto
1041       * </pre>
1042       */
1043      private com.google.protobuf.SingleFieldBuilder<
1044          org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder> 
1045          getJobControlFieldBuilder() {
1046        if (jobControlBuilder_ == null) {
1047          jobControlBuilder_ = new com.google.protobuf.SingleFieldBuilder<
1048              org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder>(
1049                  jobControl_,
1050                  getParentForChildren(),
1051                  isClean());
1052          jobControl_ = null;
1053        }
1054        return jobControlBuilder_;
1055      }
1056
1057      // optional .RuntimeErrorProto runtimeError = 3;
1058      private org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance();
1059      private com.google.protobuf.SingleFieldBuilder<
1060          org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder> runtimeErrorBuilder_;
1061      /**
1062       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1063       *
1064       * <pre>
1065       * Messages defined in reef_service_protos.proto
1066       * </pre>
1067       */
1068      public boolean hasRuntimeError() {
1069        return ((bitField0_ & 0x00000002) == 0x00000002);
1070      }
1071      /**
1072       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1073       *
1074       * <pre>
1075       * Messages defined in reef_service_protos.proto
1076       * </pre>
1077       */
1078      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError() {
1079        if (runtimeErrorBuilder_ == null) {
1080          return runtimeError_;
1081        } else {
1082          return runtimeErrorBuilder_.getMessage();
1083        }
1084      }
1085      /**
1086       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1087       *
1088       * <pre>
1089       * Messages defined in reef_service_protos.proto
1090       * </pre>
1091       */
1092      public Builder setRuntimeError(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto value) {
1093        if (runtimeErrorBuilder_ == null) {
1094          if (value == null) {
1095            throw new NullPointerException();
1096          }
1097          runtimeError_ = value;
1098          onChanged();
1099        } else {
1100          runtimeErrorBuilder_.setMessage(value);
1101        }
1102        bitField0_ |= 0x00000002;
1103        return this;
1104      }
1105      /**
1106       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1107       *
1108       * <pre>
1109       * Messages defined in reef_service_protos.proto
1110       * </pre>
1111       */
1112      public Builder setRuntimeError(
1113          org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder builderForValue) {
1114        if (runtimeErrorBuilder_ == null) {
1115          runtimeError_ = builderForValue.build();
1116          onChanged();
1117        } else {
1118          runtimeErrorBuilder_.setMessage(builderForValue.build());
1119        }
1120        bitField0_ |= 0x00000002;
1121        return this;
1122      }
1123      /**
1124       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1125       *
1126       * <pre>
1127       * Messages defined in reef_service_protos.proto
1128       * </pre>
1129       */
1130      public Builder mergeRuntimeError(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto value) {
1131        if (runtimeErrorBuilder_ == null) {
1132          if (((bitField0_ & 0x00000002) == 0x00000002) &&
1133              runtimeError_ != org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance()) {
1134            runtimeError_ =
1135              org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.newBuilder(runtimeError_).mergeFrom(value).buildPartial();
1136          } else {
1137            runtimeError_ = value;
1138          }
1139          onChanged();
1140        } else {
1141          runtimeErrorBuilder_.mergeFrom(value);
1142        }
1143        bitField0_ |= 0x00000002;
1144        return this;
1145      }
1146      /**
1147       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1148       *
1149       * <pre>
1150       * Messages defined in reef_service_protos.proto
1151       * </pre>
1152       */
1153      public Builder clearRuntimeError() {
1154        if (runtimeErrorBuilder_ == null) {
1155          runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance();
1156          onChanged();
1157        } else {
1158          runtimeErrorBuilder_.clear();
1159        }
1160        bitField0_ = (bitField0_ & ~0x00000002);
1161        return this;
1162      }
1163      /**
1164       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1165       *
1166       * <pre>
1167       * Messages defined in reef_service_protos.proto
1168       * </pre>
1169       */
1170      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder getRuntimeErrorBuilder() {
1171        bitField0_ |= 0x00000002;
1172        onChanged();
1173        return getRuntimeErrorFieldBuilder().getBuilder();
1174      }
1175      /**
1176       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1177       *
1178       * <pre>
1179       * Messages defined in reef_service_protos.proto
1180       * </pre>
1181       */
1182      public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder() {
1183        if (runtimeErrorBuilder_ != null) {
1184          return runtimeErrorBuilder_.getMessageOrBuilder();
1185        } else {
1186          return runtimeError_;
1187        }
1188      }
1189      /**
1190       * <code>optional .RuntimeErrorProto runtimeError = 3;</code>
1191       *
1192       * <pre>
1193       * Messages defined in reef_service_protos.proto
1194       * </pre>
1195       */
1196      private com.google.protobuf.SingleFieldBuilder<
1197          org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder> 
1198          getRuntimeErrorFieldBuilder() {
1199        if (runtimeErrorBuilder_ == null) {
1200          runtimeErrorBuilder_ = new com.google.protobuf.SingleFieldBuilder<
1201              org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder>(
1202                  runtimeError_,
1203                  getParentForChildren(),
1204                  isClean());
1205          runtimeError_ = null;
1206        }
1207        return runtimeErrorBuilder_;
1208      }
1209
1210      // optional .JobStatusProto jobStatus = 4;
1211      private org.apache.reef.proto.ReefServiceProtos.JobStatusProto jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance();
1212      private com.google.protobuf.SingleFieldBuilder<
1213          org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder> jobStatusBuilder_;
1214      /**
1215       * <code>optional .JobStatusProto jobStatus = 4;</code>
1216       */
1217      public boolean hasJobStatus() {
1218        return ((bitField0_ & 0x00000004) == 0x00000004);
1219      }
1220      /**
1221       * <code>optional .JobStatusProto jobStatus = 4;</code>
1222       */
1223      public org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus() {
1224        if (jobStatusBuilder_ == null) {
1225          return jobStatus_;
1226        } else {
1227          return jobStatusBuilder_.getMessage();
1228        }
1229      }
1230      /**
1231       * <code>optional .JobStatusProto jobStatus = 4;</code>
1232       */
1233      public Builder setJobStatus(org.apache.reef.proto.ReefServiceProtos.JobStatusProto value) {
1234        if (jobStatusBuilder_ == null) {
1235          if (value == null) {
1236            throw new NullPointerException();
1237          }
1238          jobStatus_ = value;
1239          onChanged();
1240        } else {
1241          jobStatusBuilder_.setMessage(value);
1242        }
1243        bitField0_ |= 0x00000004;
1244        return this;
1245      }
1246      /**
1247       * <code>optional .JobStatusProto jobStatus = 4;</code>
1248       */
1249      public Builder setJobStatus(
1250          org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder builderForValue) {
1251        if (jobStatusBuilder_ == null) {
1252          jobStatus_ = builderForValue.build();
1253          onChanged();
1254        } else {
1255          jobStatusBuilder_.setMessage(builderForValue.build());
1256        }
1257        bitField0_ |= 0x00000004;
1258        return this;
1259      }
1260      /**
1261       * <code>optional .JobStatusProto jobStatus = 4;</code>
1262       */
1263      public Builder mergeJobStatus(org.apache.reef.proto.ReefServiceProtos.JobStatusProto value) {
1264        if (jobStatusBuilder_ == null) {
1265          if (((bitField0_ & 0x00000004) == 0x00000004) &&
1266              jobStatus_ != org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance()) {
1267            jobStatus_ =
1268              org.apache.reef.proto.ReefServiceProtos.JobStatusProto.newBuilder(jobStatus_).mergeFrom(value).buildPartial();
1269          } else {
1270            jobStatus_ = value;
1271          }
1272          onChanged();
1273        } else {
1274          jobStatusBuilder_.mergeFrom(value);
1275        }
1276        bitField0_ |= 0x00000004;
1277        return this;
1278      }
1279      /**
1280       * <code>optional .JobStatusProto jobStatus = 4;</code>
1281       */
1282      public Builder clearJobStatus() {
1283        if (jobStatusBuilder_ == null) {
1284          jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance();
1285          onChanged();
1286        } else {
1287          jobStatusBuilder_.clear();
1288        }
1289        bitField0_ = (bitField0_ & ~0x00000004);
1290        return this;
1291      }
1292      /**
1293       * <code>optional .JobStatusProto jobStatus = 4;</code>
1294       */
1295      public org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder getJobStatusBuilder() {
1296        bitField0_ |= 0x00000004;
1297        onChanged();
1298        return getJobStatusFieldBuilder().getBuilder();
1299      }
1300      /**
1301       * <code>optional .JobStatusProto jobStatus = 4;</code>
1302       */
1303      public org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder() {
1304        if (jobStatusBuilder_ != null) {
1305          return jobStatusBuilder_.getMessageOrBuilder();
1306        } else {
1307          return jobStatus_;
1308        }
1309      }
1310      /**
1311       * <code>optional .JobStatusProto jobStatus = 4;</code>
1312       */
1313      private com.google.protobuf.SingleFieldBuilder<
1314          org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder> 
1315          getJobStatusFieldBuilder() {
1316        if (jobStatusBuilder_ == null) {
1317          jobStatusBuilder_ = new com.google.protobuf.SingleFieldBuilder<
1318              org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder>(
1319                  jobStatus_,
1320                  getParentForChildren(),
1321                  isClean());
1322          jobStatus_ = null;
1323        }
1324        return jobStatusBuilder_;
1325      }
1326
1327      // optional .EvaluatorControlProto evaluatorControl = 5;
1328      private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance();
1329      private com.google.protobuf.SingleFieldBuilder<
1330          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder> evaluatorControlBuilder_;
1331      /**
1332       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1333       *
1334       * <pre>
1335       * Messages from evaluator_runtime.proto
1336       * </pre>
1337       */
1338      public boolean hasEvaluatorControl() {
1339        return ((bitField0_ & 0x00000008) == 0x00000008);
1340      }
1341      /**
1342       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1343       *
1344       * <pre>
1345       * Messages from evaluator_runtime.proto
1346       * </pre>
1347       */
1348      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl() {
1349        if (evaluatorControlBuilder_ == null) {
1350          return evaluatorControl_;
1351        } else {
1352          return evaluatorControlBuilder_.getMessage();
1353        }
1354      }
1355      /**
1356       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1357       *
1358       * <pre>
1359       * Messages from evaluator_runtime.proto
1360       * </pre>
1361       */
1362      public Builder setEvaluatorControl(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto value) {
1363        if (evaluatorControlBuilder_ == null) {
1364          if (value == null) {
1365            throw new NullPointerException();
1366          }
1367          evaluatorControl_ = value;
1368          onChanged();
1369        } else {
1370          evaluatorControlBuilder_.setMessage(value);
1371        }
1372        bitField0_ |= 0x00000008;
1373        return this;
1374      }
1375      /**
1376       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1377       *
1378       * <pre>
1379       * Messages from evaluator_runtime.proto
1380       * </pre>
1381       */
1382      public Builder setEvaluatorControl(
1383          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder builderForValue) {
1384        if (evaluatorControlBuilder_ == null) {
1385          evaluatorControl_ = builderForValue.build();
1386          onChanged();
1387        } else {
1388          evaluatorControlBuilder_.setMessage(builderForValue.build());
1389        }
1390        bitField0_ |= 0x00000008;
1391        return this;
1392      }
1393      /**
1394       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1395       *
1396       * <pre>
1397       * Messages from evaluator_runtime.proto
1398       * </pre>
1399       */
1400      public Builder mergeEvaluatorControl(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto value) {
1401        if (evaluatorControlBuilder_ == null) {
1402          if (((bitField0_ & 0x00000008) == 0x00000008) &&
1403              evaluatorControl_ != org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance()) {
1404            evaluatorControl_ =
1405              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.newBuilder(evaluatorControl_).mergeFrom(value).buildPartial();
1406          } else {
1407            evaluatorControl_ = value;
1408          }
1409          onChanged();
1410        } else {
1411          evaluatorControlBuilder_.mergeFrom(value);
1412        }
1413        bitField0_ |= 0x00000008;
1414        return this;
1415      }
1416      /**
1417       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1418       *
1419       * <pre>
1420       * Messages from evaluator_runtime.proto
1421       * </pre>
1422       */
1423      public Builder clearEvaluatorControl() {
1424        if (evaluatorControlBuilder_ == null) {
1425          evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance();
1426          onChanged();
1427        } else {
1428          evaluatorControlBuilder_.clear();
1429        }
1430        bitField0_ = (bitField0_ & ~0x00000008);
1431        return this;
1432      }
1433      /**
1434       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1435       *
1436       * <pre>
1437       * Messages from evaluator_runtime.proto
1438       * </pre>
1439       */
1440      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder getEvaluatorControlBuilder() {
1441        bitField0_ |= 0x00000008;
1442        onChanged();
1443        return getEvaluatorControlFieldBuilder().getBuilder();
1444      }
1445      /**
1446       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1447       *
1448       * <pre>
1449       * Messages from evaluator_runtime.proto
1450       * </pre>
1451       */
1452      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder() {
1453        if (evaluatorControlBuilder_ != null) {
1454          return evaluatorControlBuilder_.getMessageOrBuilder();
1455        } else {
1456          return evaluatorControl_;
1457        }
1458      }
1459      /**
1460       * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code>
1461       *
1462       * <pre>
1463       * Messages from evaluator_runtime.proto
1464       * </pre>
1465       */
1466      private com.google.protobuf.SingleFieldBuilder<
1467          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder> 
1468          getEvaluatorControlFieldBuilder() {
1469        if (evaluatorControlBuilder_ == null) {
1470          evaluatorControlBuilder_ = new com.google.protobuf.SingleFieldBuilder<
1471              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder>(
1472                  evaluatorControl_,
1473                  getParentForChildren(),
1474                  isClean());
1475          evaluatorControl_ = null;
1476        }
1477        return evaluatorControlBuilder_;
1478      }
1479
1480      // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;
1481      private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance();
1482      private com.google.protobuf.SingleFieldBuilder<
1483          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder> evaluatorHeartBeatBuilder_;
1484      /**
1485       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1486       */
1487      public boolean hasEvaluatorHeartBeat() {
1488        return ((bitField0_ & 0x00000010) == 0x00000010);
1489      }
1490      /**
1491       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1492       */
1493      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat() {
1494        if (evaluatorHeartBeatBuilder_ == null) {
1495          return evaluatorHeartBeat_;
1496        } else {
1497          return evaluatorHeartBeatBuilder_.getMessage();
1498        }
1499      }
1500      /**
1501       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1502       */
1503      public Builder setEvaluatorHeartBeat(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto value) {
1504        if (evaluatorHeartBeatBuilder_ == null) {
1505          if (value == null) {
1506            throw new NullPointerException();
1507          }
1508          evaluatorHeartBeat_ = value;
1509          onChanged();
1510        } else {
1511          evaluatorHeartBeatBuilder_.setMessage(value);
1512        }
1513        bitField0_ |= 0x00000010;
1514        return this;
1515      }
1516      /**
1517       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1518       */
1519      public Builder setEvaluatorHeartBeat(
1520          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder builderForValue) {
1521        if (evaluatorHeartBeatBuilder_ == null) {
1522          evaluatorHeartBeat_ = builderForValue.build();
1523          onChanged();
1524        } else {
1525          evaluatorHeartBeatBuilder_.setMessage(builderForValue.build());
1526        }
1527        bitField0_ |= 0x00000010;
1528        return this;
1529      }
1530      /**
1531       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1532       */
1533      public Builder mergeEvaluatorHeartBeat(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto value) {
1534        if (evaluatorHeartBeatBuilder_ == null) {
1535          if (((bitField0_ & 0x00000010) == 0x00000010) &&
1536              evaluatorHeartBeat_ != org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance()) {
1537            evaluatorHeartBeat_ =
1538              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.newBuilder(evaluatorHeartBeat_).mergeFrom(value).buildPartial();
1539          } else {
1540            evaluatorHeartBeat_ = value;
1541          }
1542          onChanged();
1543        } else {
1544          evaluatorHeartBeatBuilder_.mergeFrom(value);
1545        }
1546        bitField0_ |= 0x00000010;
1547        return this;
1548      }
1549      /**
1550       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1551       */
1552      public Builder clearEvaluatorHeartBeat() {
1553        if (evaluatorHeartBeatBuilder_ == null) {
1554          evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance();
1555          onChanged();
1556        } else {
1557          evaluatorHeartBeatBuilder_.clear();
1558        }
1559        bitField0_ = (bitField0_ & ~0x00000010);
1560        return this;
1561      }
1562      /**
1563       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1564       */
1565      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder getEvaluatorHeartBeatBuilder() {
1566        bitField0_ |= 0x00000010;
1567        onChanged();
1568        return getEvaluatorHeartBeatFieldBuilder().getBuilder();
1569      }
1570      /**
1571       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1572       */
1573      public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder() {
1574        if (evaluatorHeartBeatBuilder_ != null) {
1575          return evaluatorHeartBeatBuilder_.getMessageOrBuilder();
1576        } else {
1577          return evaluatorHeartBeat_;
1578        }
1579      }
1580      /**
1581       * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code>
1582       */
1583      private com.google.protobuf.SingleFieldBuilder<
1584          org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder> 
1585          getEvaluatorHeartBeatFieldBuilder() {
1586        if (evaluatorHeartBeatBuilder_ == null) {
1587          evaluatorHeartBeatBuilder_ = new com.google.protobuf.SingleFieldBuilder<
1588              org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder>(
1589                  evaluatorHeartBeat_,
1590                  getParentForChildren(),
1591                  isClean());
1592          evaluatorHeartBeat_ = null;
1593        }
1594        return evaluatorHeartBeatBuilder_;
1595      }
1596
1597      // @@protoc_insertion_point(builder_scope:REEFMessage)
1598    }
1599
1600    static {
1601      defaultInstance = new REEFMessage(true);
1602      defaultInstance.initFields();
1603    }
1604
1605    // @@protoc_insertion_point(class_scope:REEFMessage)
1606  }
1607
1608  private static com.google.protobuf.Descriptors.Descriptor
1609    internal_static_REEFMessage_descriptor;
1610  private static
1611    com.google.protobuf.GeneratedMessage.FieldAccessorTable
1612      internal_static_REEFMessage_fieldAccessorTable;
1613
1614  public static com.google.protobuf.Descriptors.FileDescriptor
1615      getDescriptor() {
1616    return descriptor;
1617  }
1618  private static com.google.protobuf.Descriptors.FileDescriptor
1619      descriptor;
1620  static {
1621    java.lang.String[] descriptorData = {
1622      "\n\023reef_protocol.proto\032\024client_runtime.pr" +
1623      "oto\032\027evaluator_runtime.proto\032\031reef_servi" +
1624      "ce_protos.proto\"\351\001\n\013REEFMessage\022$\n\njobCo" +
1625      "ntrol\030\002 \001(\0132\020.JobControlProto\022(\n\014runtime" +
1626      "Error\030\003 \001(\0132\022.RuntimeErrorProto\022\"\n\tjobSt" +
1627      "atus\030\004 \001(\0132\017.JobStatusProto\0220\n\020evaluator" +
1628      "Control\030\005 \001(\0132\026.EvaluatorControlProto\0224\n" +
1629      "\022evaluatorHeartBeat\030\006 \001(\0132\030.EvaluatorHea" +
1630      "rtbeatProtoB+\n\025org.apache.reef.protoB\014RE" +
1631      "EFProtocol\210\001\001\240\001\001"
1632    };
1633    com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
1634      new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
1635        public com.google.protobuf.ExtensionRegistry assignDescriptors(
1636            com.google.protobuf.Descriptors.FileDescriptor root) {
1637          descriptor = root;
1638          internal_static_REEFMessage_descriptor =
1639            getDescriptor().getMessageTypes().get(0);
1640          internal_static_REEFMessage_fieldAccessorTable = new
1641            com.google.protobuf.GeneratedMessage.FieldAccessorTable(
1642              internal_static_REEFMessage_descriptor,
1643              new java.lang.String[] { "JobControl", "RuntimeError", "JobStatus", "EvaluatorControl", "EvaluatorHeartBeat", });
1644          return null;
1645        }
1646      };
1647    com.google.protobuf.Descriptors.FileDescriptor
1648      .internalBuildGeneratedFileFrom(descriptorData,
1649        new com.google.protobuf.Descriptors.FileDescriptor[] {
1650          org.apache.reef.proto.ClientRuntimeProtocol.getDescriptor(),
1651          org.apache.reef.proto.EvaluatorRuntimeProtocol.getDescriptor(),
1652          org.apache.reef.proto.ReefServiceProtos.getDescriptor(),
1653        }, assigner);
1654  }
1655
1656  // @@protoc_insertion_point(outer_class_scope)
1657}