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}