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