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 /** 035 * Protobuf type {@code WakeMessagePBuf} 036 */ 037 public static final class WakeMessagePBuf extends 038 com.google.protobuf.GeneratedMessage 039 implements WakeMessagePBufOrBuilder { 040 // Use WakeMessagePBuf.newBuilder() to construct. 041 private WakeMessagePBuf(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 042 super(builder); 043 this.unknownFields = builder.getUnknownFields(); 044 } 045 private WakeMessagePBuf(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 046 047 private static final WakeMessagePBuf defaultInstance; 048 public static WakeMessagePBuf getDefaultInstance() { 049 return defaultInstance; 050 } 051 052 public WakeMessagePBuf getDefaultInstanceForType() { 053 return defaultInstance; 054 } 055 056 private final com.google.protobuf.UnknownFieldSet unknownFields; 057 @java.lang.Override 058 public final com.google.protobuf.UnknownFieldSet 059 getUnknownFields() { 060 return this.unknownFields; 061 } 062 private WakeMessagePBuf( 063 com.google.protobuf.CodedInputStream input, 064 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 065 throws com.google.protobuf.InvalidProtocolBufferException { 066 initFields(); 067 int mutable_bitField0_ = 0; 068 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 069 com.google.protobuf.UnknownFieldSet.newBuilder(); 070 try { 071 boolean done = false; 072 while (!done) { 073 int tag = input.readTag(); 074 switch (tag) { 075 case 0: 076 done = true; 077 break; 078 default: { 079 if (!parseUnknownField(input, unknownFields, 080 extensionRegistry, tag)) { 081 done = true; 082 } 083 break; 084 } 085 case 10: { 086 bitField0_ |= 0x00000001; 087 data_ = input.readBytes(); 088 break; 089 } 090 case 16: { 091 bitField0_ |= 0x00000002; 092 seq_ = input.readInt64(); 093 break; 094 } 095 } 096 } 097 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 098 throw e.setUnfinishedMessage(this); 099 } catch (java.io.IOException e) { 100 throw new com.google.protobuf.InvalidProtocolBufferException( 101 e.getMessage()).setUnfinishedMessage(this); 102 } finally { 103 this.unknownFields = unknownFields.build(); 104 makeExtensionsImmutable(); 105 } 106 } 107 public static final com.google.protobuf.Descriptors.Descriptor 108 getDescriptor() { 109 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeMessagePBuf_descriptor; 110 } 111 112 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 113 internalGetFieldAccessorTable() { 114 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeMessagePBuf_fieldAccessorTable 115 .ensureFieldAccessorsInitialized( 116 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.class, org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder.class); 117 } 118 119 public static com.google.protobuf.Parser<WakeMessagePBuf> PARSER = 120 new com.google.protobuf.AbstractParser<WakeMessagePBuf>() { 121 public WakeMessagePBuf parsePartialFrom( 122 com.google.protobuf.CodedInputStream input, 123 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 124 throws com.google.protobuf.InvalidProtocolBufferException { 125 return new WakeMessagePBuf(input, extensionRegistry); 126 } 127 }; 128 129 @java.lang.Override 130 public com.google.protobuf.Parser<WakeMessagePBuf> getParserForType() { 131 return PARSER; 132 } 133 134 private int bitField0_; 135 // required bytes data = 1; 136 public static final int DATA_FIELD_NUMBER = 1; 137 private com.google.protobuf.ByteString data_; 138 /** 139 * <code>required bytes data = 1;</code> 140 */ 141 public boolean hasData() { 142 return ((bitField0_ & 0x00000001) == 0x00000001); 143 } 144 /** 145 * <code>required bytes data = 1;</code> 146 */ 147 public com.google.protobuf.ByteString getData() { 148 return data_; 149 } 150 151 // required int64 seq = 2; 152 public static final int SEQ_FIELD_NUMBER = 2; 153 private long seq_; 154 /** 155 * <code>required int64 seq = 2;</code> 156 */ 157 public boolean hasSeq() { 158 return ((bitField0_ & 0x00000002) == 0x00000002); 159 } 160 /** 161 * <code>required int64 seq = 2;</code> 162 */ 163 public long getSeq() { 164 return seq_; 165 } 166 167 private void initFields() { 168 data_ = com.google.protobuf.ByteString.EMPTY; 169 seq_ = 0L; 170 } 171 private byte memoizedIsInitialized = -1; 172 public final boolean isInitialized() { 173 byte isInitialized = memoizedIsInitialized; 174 if (isInitialized != -1) return isInitialized == 1; 175 176 if (!hasData()) { 177 memoizedIsInitialized = 0; 178 return false; 179 } 180 if (!hasSeq()) { 181 memoizedIsInitialized = 0; 182 return false; 183 } 184 memoizedIsInitialized = 1; 185 return true; 186 } 187 188 public void writeTo(com.google.protobuf.CodedOutputStream output) 189 throws java.io.IOException { 190 getSerializedSize(); 191 if (((bitField0_ & 0x00000001) == 0x00000001)) { 192 output.writeBytes(1, data_); 193 } 194 if (((bitField0_ & 0x00000002) == 0x00000002)) { 195 output.writeInt64(2, seq_); 196 } 197 getUnknownFields().writeTo(output); 198 } 199 200 private int memoizedSerializedSize = -1; 201 public int getSerializedSize() { 202 int size = memoizedSerializedSize; 203 if (size != -1) return size; 204 205 size = 0; 206 if (((bitField0_ & 0x00000001) == 0x00000001)) { 207 size += com.google.protobuf.CodedOutputStream 208 .computeBytesSize(1, data_); 209 } 210 if (((bitField0_ & 0x00000002) == 0x00000002)) { 211 size += com.google.protobuf.CodedOutputStream 212 .computeInt64Size(2, seq_); 213 } 214 size += getUnknownFields().getSerializedSize(); 215 memoizedSerializedSize = size; 216 return size; 217 } 218 219 private static final long serialVersionUID = 0L; 220 @java.lang.Override 221 protected java.lang.Object writeReplace() 222 throws java.io.ObjectStreamException { 223 return super.writeReplace(); 224 } 225 226 @java.lang.Override 227 public boolean equals(final java.lang.Object obj) { 228 if (obj == this) { 229 return true; 230 } 231 if (!(obj instanceof org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf)) { 232 return super.equals(obj); 233 } 234 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf other = (org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf) obj; 235 236 boolean result = true; 237 result = result && (hasData() == other.hasData()); 238 if (hasData()) { 239 result = result && getData() 240 .equals(other.getData()); 241 } 242 result = result && (hasSeq() == other.hasSeq()); 243 if (hasSeq()) { 244 result = result && (getSeq() 245 == other.getSeq()); 246 } 247 result = result && 248 getUnknownFields().equals(other.getUnknownFields()); 249 return result; 250 } 251 252 private int memoizedHashCode = 0; 253 @java.lang.Override 254 public int hashCode() { 255 if (memoizedHashCode != 0) { 256 return memoizedHashCode; 257 } 258 int hash = 41; 259 hash = (19 * hash) + getDescriptorForType().hashCode(); 260 if (hasData()) { 261 hash = (37 * hash) + DATA_FIELD_NUMBER; 262 hash = (53 * hash) + getData().hashCode(); 263 } 264 if (hasSeq()) { 265 hash = (37 * hash) + SEQ_FIELD_NUMBER; 266 hash = (53 * hash) + hashLong(getSeq()); 267 } 268 hash = (29 * hash) + getUnknownFields().hashCode(); 269 memoizedHashCode = hash; 270 return hash; 271 } 272 273 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 274 com.google.protobuf.ByteString data) 275 throws com.google.protobuf.InvalidProtocolBufferException { 276 return PARSER.parseFrom(data); 277 } 278 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 279 com.google.protobuf.ByteString data, 280 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 281 throws com.google.protobuf.InvalidProtocolBufferException { 282 return PARSER.parseFrom(data, extensionRegistry); 283 } 284 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom(byte[] data) 285 throws com.google.protobuf.InvalidProtocolBufferException { 286 return PARSER.parseFrom(data); 287 } 288 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 289 byte[] data, 290 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 291 throws com.google.protobuf.InvalidProtocolBufferException { 292 return PARSER.parseFrom(data, extensionRegistry); 293 } 294 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom(java.io.InputStream input) 295 throws java.io.IOException { 296 return PARSER.parseFrom(input); 297 } 298 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 299 java.io.InputStream input, 300 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 301 throws java.io.IOException { 302 return PARSER.parseFrom(input, extensionRegistry); 303 } 304 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseDelimitedFrom(java.io.InputStream input) 305 throws java.io.IOException { 306 return PARSER.parseDelimitedFrom(input); 307 } 308 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseDelimitedFrom( 309 java.io.InputStream input, 310 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 311 throws java.io.IOException { 312 return PARSER.parseDelimitedFrom(input, extensionRegistry); 313 } 314 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 315 com.google.protobuf.CodedInputStream input) 316 throws java.io.IOException { 317 return PARSER.parseFrom(input); 318 } 319 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parseFrom( 320 com.google.protobuf.CodedInputStream input, 321 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 322 throws java.io.IOException { 323 return PARSER.parseFrom(input, extensionRegistry); 324 } 325 326 public static Builder newBuilder() { return Builder.create(); } 327 public Builder newBuilderForType() { return newBuilder(); } 328 public static Builder newBuilder(org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf prototype) { 329 return newBuilder().mergeFrom(prototype); 330 } 331 public Builder toBuilder() { return newBuilder(this); } 332 333 @java.lang.Override 334 protected Builder newBuilderForType( 335 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 336 Builder builder = new Builder(parent); 337 return builder; 338 } 339 /** 340 * Protobuf type {@code WakeMessagePBuf} 341 */ 342 public static final class Builder extends 343 com.google.protobuf.GeneratedMessage.Builder<Builder> 344 implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBufOrBuilder { 345 public static final com.google.protobuf.Descriptors.Descriptor 346 getDescriptor() { 347 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeMessagePBuf_descriptor; 348 } 349 350 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 351 internalGetFieldAccessorTable() { 352 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeMessagePBuf_fieldAccessorTable 353 .ensureFieldAccessorsInitialized( 354 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.class, org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder.class); 355 } 356 357 // Construct using org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.newBuilder() 358 private Builder() { 359 maybeForceBuilderInitialization(); 360 } 361 362 private Builder( 363 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 364 super(parent); 365 maybeForceBuilderInitialization(); 366 } 367 private void maybeForceBuilderInitialization() { 368 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 369 } 370 } 371 private static Builder create() { 372 return new Builder(); 373 } 374 375 public Builder clear() { 376 super.clear(); 377 data_ = com.google.protobuf.ByteString.EMPTY; 378 bitField0_ = (bitField0_ & ~0x00000001); 379 seq_ = 0L; 380 bitField0_ = (bitField0_ & ~0x00000002); 381 return this; 382 } 383 384 public Builder clone() { 385 return create().mergeFrom(buildPartial()); 386 } 387 388 public com.google.protobuf.Descriptors.Descriptor 389 getDescriptorForType() { 390 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeMessagePBuf_descriptor; 391 } 392 393 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf getDefaultInstanceForType() { 394 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.getDefaultInstance(); 395 } 396 397 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf build() { 398 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf result = buildPartial(); 399 if (!result.isInitialized()) { 400 throw newUninitializedMessageException(result); 401 } 402 return result; 403 } 404 405 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf buildPartial() { 406 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf result = new org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf(this); 407 int from_bitField0_ = bitField0_; 408 int to_bitField0_ = 0; 409 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 410 to_bitField0_ |= 0x00000001; 411 } 412 result.data_ = data_; 413 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 414 to_bitField0_ |= 0x00000002; 415 } 416 result.seq_ = seq_; 417 result.bitField0_ = to_bitField0_; 418 onBuilt(); 419 return result; 420 } 421 422 public Builder mergeFrom(com.google.protobuf.Message other) { 423 if (other instanceof org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf) { 424 return mergeFrom((org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf)other); 425 } else { 426 super.mergeFrom(other); 427 return this; 428 } 429 } 430 431 public Builder mergeFrom(org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf other) { 432 if (other == org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.getDefaultInstance()) return this; 433 if (other.hasData()) { 434 setData(other.getData()); 435 } 436 if (other.hasSeq()) { 437 setSeq(other.getSeq()); 438 } 439 this.mergeUnknownFields(other.getUnknownFields()); 440 return this; 441 } 442 443 public final boolean isInitialized() { 444 if (!hasData()) { 445 446 return false; 447 } 448 if (!hasSeq()) { 449 450 return false; 451 } 452 return true; 453 } 454 455 public Builder mergeFrom( 456 com.google.protobuf.CodedInputStream input, 457 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 458 throws java.io.IOException { 459 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf parsedMessage = null; 460 try { 461 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 462 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 463 parsedMessage = (org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf) e.getUnfinishedMessage(); 464 throw e; 465 } finally { 466 if (parsedMessage != null) { 467 mergeFrom(parsedMessage); 468 } 469 } 470 return this; 471 } 472 private int bitField0_; 473 474 // required bytes data = 1; 475 private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; 476 /** 477 * <code>required bytes data = 1;</code> 478 */ 479 public boolean hasData() { 480 return ((bitField0_ & 0x00000001) == 0x00000001); 481 } 482 /** 483 * <code>required bytes data = 1;</code> 484 */ 485 public com.google.protobuf.ByteString getData() { 486 return data_; 487 } 488 /** 489 * <code>required bytes data = 1;</code> 490 */ 491 public Builder setData(com.google.protobuf.ByteString value) { 492 if (value == null) { 493 throw new NullPointerException(); 494 } 495 bitField0_ |= 0x00000001; 496 data_ = value; 497 onChanged(); 498 return this; 499 } 500 /** 501 * <code>required bytes data = 1;</code> 502 */ 503 public Builder clearData() { 504 bitField0_ = (bitField0_ & ~0x00000001); 505 data_ = getDefaultInstance().getData(); 506 onChanged(); 507 return this; 508 } 509 510 // required int64 seq = 2; 511 private long seq_ ; 512 /** 513 * <code>required int64 seq = 2;</code> 514 */ 515 public boolean hasSeq() { 516 return ((bitField0_ & 0x00000002) == 0x00000002); 517 } 518 /** 519 * <code>required int64 seq = 2;</code> 520 */ 521 public long getSeq() { 522 return seq_; 523 } 524 /** 525 * <code>required int64 seq = 2;</code> 526 */ 527 public Builder setSeq(long value) { 528 bitField0_ |= 0x00000002; 529 seq_ = value; 530 onChanged(); 531 return this; 532 } 533 /** 534 * <code>required int64 seq = 2;</code> 535 */ 536 public Builder clearSeq() { 537 bitField0_ = (bitField0_ & ~0x00000002); 538 seq_ = 0L; 539 onChanged(); 540 return this; 541 } 542 543 // @@protoc_insertion_point(builder_scope:WakeMessagePBuf) 544 } 545 546 static { 547 defaultInstance = new WakeMessagePBuf(true); 548 defaultInstance.initFields(); 549 } 550 551 // @@protoc_insertion_point(class_scope:WakeMessagePBuf) 552 } 553 554 public interface WakeTuplePBufOrBuilder 555 extends com.google.protobuf.MessageOrBuilder { 556 557 // required string className = 1; 558 /** 559 * <code>required string className = 1;</code> 560 */ 561 boolean hasClassName(); 562 /** 563 * <code>required string className = 1;</code> 564 */ 565 java.lang.String getClassName(); 566 /** 567 * <code>required string className = 1;</code> 568 */ 569 com.google.protobuf.ByteString 570 getClassNameBytes(); 571 572 // required bytes data = 2; 573 /** 574 * <code>required bytes data = 2;</code> 575 */ 576 boolean hasData(); 577 /** 578 * <code>required bytes data = 2;</code> 579 */ 580 com.google.protobuf.ByteString getData(); 581 } 582 /** 583 * Protobuf type {@code WakeTuplePBuf} 584 */ 585 public static final class WakeTuplePBuf extends 586 com.google.protobuf.GeneratedMessage 587 implements WakeTuplePBufOrBuilder { 588 // Use WakeTuplePBuf.newBuilder() to construct. 589 private WakeTuplePBuf(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 590 super(builder); 591 this.unknownFields = builder.getUnknownFields(); 592 } 593 private WakeTuplePBuf(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 594 595 private static final WakeTuplePBuf defaultInstance; 596 public static WakeTuplePBuf getDefaultInstance() { 597 return defaultInstance; 598 } 599 600 public WakeTuplePBuf getDefaultInstanceForType() { 601 return defaultInstance; 602 } 603 604 private final com.google.protobuf.UnknownFieldSet unknownFields; 605 @java.lang.Override 606 public final com.google.protobuf.UnknownFieldSet 607 getUnknownFields() { 608 return this.unknownFields; 609 } 610 private WakeTuplePBuf( 611 com.google.protobuf.CodedInputStream input, 612 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 613 throws com.google.protobuf.InvalidProtocolBufferException { 614 initFields(); 615 int mutable_bitField0_ = 0; 616 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 617 com.google.protobuf.UnknownFieldSet.newBuilder(); 618 try { 619 boolean done = false; 620 while (!done) { 621 int tag = input.readTag(); 622 switch (tag) { 623 case 0: 624 done = true; 625 break; 626 default: { 627 if (!parseUnknownField(input, unknownFields, 628 extensionRegistry, tag)) { 629 done = true; 630 } 631 break; 632 } 633 case 10: { 634 bitField0_ |= 0x00000001; 635 className_ = input.readBytes(); 636 break; 637 } 638 case 18: { 639 bitField0_ |= 0x00000002; 640 data_ = input.readBytes(); 641 break; 642 } 643 } 644 } 645 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 646 throw e.setUnfinishedMessage(this); 647 } catch (java.io.IOException e) { 648 throw new com.google.protobuf.InvalidProtocolBufferException( 649 e.getMessage()).setUnfinishedMessage(this); 650 } finally { 651 this.unknownFields = unknownFields.build(); 652 makeExtensionsImmutable(); 653 } 654 } 655 public static final com.google.protobuf.Descriptors.Descriptor 656 getDescriptor() { 657 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeTuplePBuf_descriptor; 658 } 659 660 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 661 internalGetFieldAccessorTable() { 662 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeTuplePBuf_fieldAccessorTable 663 .ensureFieldAccessorsInitialized( 664 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.class, org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder.class); 665 } 666 667 public static com.google.protobuf.Parser<WakeTuplePBuf> PARSER = 668 new com.google.protobuf.AbstractParser<WakeTuplePBuf>() { 669 public WakeTuplePBuf parsePartialFrom( 670 com.google.protobuf.CodedInputStream input, 671 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 672 throws com.google.protobuf.InvalidProtocolBufferException { 673 return new WakeTuplePBuf(input, extensionRegistry); 674 } 675 }; 676 677 @java.lang.Override 678 public com.google.protobuf.Parser<WakeTuplePBuf> getParserForType() { 679 return PARSER; 680 } 681 682 private int bitField0_; 683 // required string className = 1; 684 public static final int CLASSNAME_FIELD_NUMBER = 1; 685 private java.lang.Object className_; 686 /** 687 * <code>required string className = 1;</code> 688 */ 689 public boolean hasClassName() { 690 return ((bitField0_ & 0x00000001) == 0x00000001); 691 } 692 /** 693 * <code>required string className = 1;</code> 694 */ 695 public java.lang.String getClassName() { 696 java.lang.Object ref = className_; 697 if (ref instanceof java.lang.String) { 698 return (java.lang.String) ref; 699 } else { 700 com.google.protobuf.ByteString bs = 701 (com.google.protobuf.ByteString) ref; 702 java.lang.String s = bs.toStringUtf8(); 703 if (bs.isValidUtf8()) { 704 className_ = s; 705 } 706 return s; 707 } 708 } 709 /** 710 * <code>required string className = 1;</code> 711 */ 712 public com.google.protobuf.ByteString 713 getClassNameBytes() { 714 java.lang.Object ref = className_; 715 if (ref instanceof java.lang.String) { 716 com.google.protobuf.ByteString b = 717 com.google.protobuf.ByteString.copyFromUtf8( 718 (java.lang.String) ref); 719 className_ = b; 720 return b; 721 } else { 722 return (com.google.protobuf.ByteString) ref; 723 } 724 } 725 726 // required bytes data = 2; 727 public static final int DATA_FIELD_NUMBER = 2; 728 private com.google.protobuf.ByteString data_; 729 /** 730 * <code>required bytes data = 2;</code> 731 */ 732 public boolean hasData() { 733 return ((bitField0_ & 0x00000002) == 0x00000002); 734 } 735 /** 736 * <code>required bytes data = 2;</code> 737 */ 738 public com.google.protobuf.ByteString getData() { 739 return data_; 740 } 741 742 private void initFields() { 743 className_ = ""; 744 data_ = com.google.protobuf.ByteString.EMPTY; 745 } 746 private byte memoizedIsInitialized = -1; 747 public final boolean isInitialized() { 748 byte isInitialized = memoizedIsInitialized; 749 if (isInitialized != -1) return isInitialized == 1; 750 751 if (!hasClassName()) { 752 memoizedIsInitialized = 0; 753 return false; 754 } 755 if (!hasData()) { 756 memoizedIsInitialized = 0; 757 return false; 758 } 759 memoizedIsInitialized = 1; 760 return true; 761 } 762 763 public void writeTo(com.google.protobuf.CodedOutputStream output) 764 throws java.io.IOException { 765 getSerializedSize(); 766 if (((bitField0_ & 0x00000001) == 0x00000001)) { 767 output.writeBytes(1, getClassNameBytes()); 768 } 769 if (((bitField0_ & 0x00000002) == 0x00000002)) { 770 output.writeBytes(2, data_); 771 } 772 getUnknownFields().writeTo(output); 773 } 774 775 private int memoizedSerializedSize = -1; 776 public int getSerializedSize() { 777 int size = memoizedSerializedSize; 778 if (size != -1) return size; 779 780 size = 0; 781 if (((bitField0_ & 0x00000001) == 0x00000001)) { 782 size += com.google.protobuf.CodedOutputStream 783 .computeBytesSize(1, getClassNameBytes()); 784 } 785 if (((bitField0_ & 0x00000002) == 0x00000002)) { 786 size += com.google.protobuf.CodedOutputStream 787 .computeBytesSize(2, data_); 788 } 789 size += getUnknownFields().getSerializedSize(); 790 memoizedSerializedSize = size; 791 return size; 792 } 793 794 private static final long serialVersionUID = 0L; 795 @java.lang.Override 796 protected java.lang.Object writeReplace() 797 throws java.io.ObjectStreamException { 798 return super.writeReplace(); 799 } 800 801 @java.lang.Override 802 public boolean equals(final java.lang.Object obj) { 803 if (obj == this) { 804 return true; 805 } 806 if (!(obj instanceof org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf)) { 807 return super.equals(obj); 808 } 809 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf other = (org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf) obj; 810 811 boolean result = true; 812 result = result && (hasClassName() == other.hasClassName()); 813 if (hasClassName()) { 814 result = result && getClassName() 815 .equals(other.getClassName()); 816 } 817 result = result && (hasData() == other.hasData()); 818 if (hasData()) { 819 result = result && getData() 820 .equals(other.getData()); 821 } 822 result = result && 823 getUnknownFields().equals(other.getUnknownFields()); 824 return result; 825 } 826 827 private int memoizedHashCode = 0; 828 @java.lang.Override 829 public int hashCode() { 830 if (memoizedHashCode != 0) { 831 return memoizedHashCode; 832 } 833 int hash = 41; 834 hash = (19 * hash) + getDescriptorForType().hashCode(); 835 if (hasClassName()) { 836 hash = (37 * hash) + CLASSNAME_FIELD_NUMBER; 837 hash = (53 * hash) + getClassName().hashCode(); 838 } 839 if (hasData()) { 840 hash = (37 * hash) + DATA_FIELD_NUMBER; 841 hash = (53 * hash) + getData().hashCode(); 842 } 843 hash = (29 * hash) + getUnknownFields().hashCode(); 844 memoizedHashCode = hash; 845 return hash; 846 } 847 848 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 849 com.google.protobuf.ByteString data) 850 throws com.google.protobuf.InvalidProtocolBufferException { 851 return PARSER.parseFrom(data); 852 } 853 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 854 com.google.protobuf.ByteString data, 855 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 856 throws com.google.protobuf.InvalidProtocolBufferException { 857 return PARSER.parseFrom(data, extensionRegistry); 858 } 859 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom(byte[] data) 860 throws com.google.protobuf.InvalidProtocolBufferException { 861 return PARSER.parseFrom(data); 862 } 863 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 864 byte[] data, 865 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 866 throws com.google.protobuf.InvalidProtocolBufferException { 867 return PARSER.parseFrom(data, extensionRegistry); 868 } 869 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom(java.io.InputStream input) 870 throws java.io.IOException { 871 return PARSER.parseFrom(input); 872 } 873 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 874 java.io.InputStream input, 875 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 876 throws java.io.IOException { 877 return PARSER.parseFrom(input, extensionRegistry); 878 } 879 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseDelimitedFrom(java.io.InputStream input) 880 throws java.io.IOException { 881 return PARSER.parseDelimitedFrom(input); 882 } 883 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseDelimitedFrom( 884 java.io.InputStream input, 885 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 886 throws java.io.IOException { 887 return PARSER.parseDelimitedFrom(input, extensionRegistry); 888 } 889 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 890 com.google.protobuf.CodedInputStream input) 891 throws java.io.IOException { 892 return PARSER.parseFrom(input); 893 } 894 public static org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parseFrom( 895 com.google.protobuf.CodedInputStream input, 896 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 897 throws java.io.IOException { 898 return PARSER.parseFrom(input, extensionRegistry); 899 } 900 901 public static Builder newBuilder() { return Builder.create(); } 902 public Builder newBuilderForType() { return newBuilder(); } 903 public static Builder newBuilder(org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf prototype) { 904 return newBuilder().mergeFrom(prototype); 905 } 906 public Builder toBuilder() { return newBuilder(this); } 907 908 @java.lang.Override 909 protected Builder newBuilderForType( 910 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 911 Builder builder = new Builder(parent); 912 return builder; 913 } 914 /** 915 * Protobuf type {@code WakeTuplePBuf} 916 */ 917 public static final class Builder extends 918 com.google.protobuf.GeneratedMessage.Builder<Builder> 919 implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBufOrBuilder { 920 public static final com.google.protobuf.Descriptors.Descriptor 921 getDescriptor() { 922 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeTuplePBuf_descriptor; 923 } 924 925 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 926 internalGetFieldAccessorTable() { 927 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeTuplePBuf_fieldAccessorTable 928 .ensureFieldAccessorsInitialized( 929 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.class, org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder.class); 930 } 931 932 // Construct using org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.newBuilder() 933 private Builder() { 934 maybeForceBuilderInitialization(); 935 } 936 937 private Builder( 938 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 939 super(parent); 940 maybeForceBuilderInitialization(); 941 } 942 private void maybeForceBuilderInitialization() { 943 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 944 } 945 } 946 private static Builder create() { 947 return new Builder(); 948 } 949 950 public Builder clear() { 951 super.clear(); 952 className_ = ""; 953 bitField0_ = (bitField0_ & ~0x00000001); 954 data_ = com.google.protobuf.ByteString.EMPTY; 955 bitField0_ = (bitField0_ & ~0x00000002); 956 return this; 957 } 958 959 public Builder clone() { 960 return create().mergeFrom(buildPartial()); 961 } 962 963 public com.google.protobuf.Descriptors.Descriptor 964 getDescriptorForType() { 965 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.internal_static_WakeTuplePBuf_descriptor; 966 } 967 968 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf getDefaultInstanceForType() { 969 return org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.getDefaultInstance(); 970 } 971 972 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf build() { 973 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf result = buildPartial(); 974 if (!result.isInitialized()) { 975 throw newUninitializedMessageException(result); 976 } 977 return result; 978 } 979 980 public org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf buildPartial() { 981 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf result = new org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf(this); 982 int from_bitField0_ = bitField0_; 983 int to_bitField0_ = 0; 984 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 985 to_bitField0_ |= 0x00000001; 986 } 987 result.className_ = className_; 988 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 989 to_bitField0_ |= 0x00000002; 990 } 991 result.data_ = data_; 992 result.bitField0_ = to_bitField0_; 993 onBuilt(); 994 return result; 995 } 996 997 public Builder mergeFrom(com.google.protobuf.Message other) { 998 if (other instanceof org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf) { 999 return mergeFrom((org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf)other); 1000 } else { 1001 super.mergeFrom(other); 1002 return this; 1003 } 1004 } 1005 1006 public Builder mergeFrom(org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf other) { 1007 if (other == org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.getDefaultInstance()) return this; 1008 if (other.hasClassName()) { 1009 bitField0_ |= 0x00000001; 1010 className_ = other.className_; 1011 onChanged(); 1012 } 1013 if (other.hasData()) { 1014 setData(other.getData()); 1015 } 1016 this.mergeUnknownFields(other.getUnknownFields()); 1017 return this; 1018 } 1019 1020 public final boolean isInitialized() { 1021 if (!hasClassName()) { 1022 1023 return false; 1024 } 1025 if (!hasData()) { 1026 1027 return false; 1028 } 1029 return true; 1030 } 1031 1032 public Builder mergeFrom( 1033 com.google.protobuf.CodedInputStream input, 1034 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1035 throws java.io.IOException { 1036 org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf parsedMessage = null; 1037 try { 1038 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 1039 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1040 parsedMessage = (org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf) e.getUnfinishedMessage(); 1041 throw e; 1042 } finally { 1043 if (parsedMessage != null) { 1044 mergeFrom(parsedMessage); 1045 } 1046 } 1047 return this; 1048 } 1049 private int bitField0_; 1050 1051 // required string className = 1; 1052 private java.lang.Object className_ = ""; 1053 /** 1054 * <code>required string className = 1;</code> 1055 */ 1056 public boolean hasClassName() { 1057 return ((bitField0_ & 0x00000001) == 0x00000001); 1058 } 1059 /** 1060 * <code>required string className = 1;</code> 1061 */ 1062 public java.lang.String getClassName() { 1063 java.lang.Object ref = className_; 1064 if (!(ref instanceof java.lang.String)) { 1065 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1066 .toStringUtf8(); 1067 className_ = s; 1068 return s; 1069 } else { 1070 return (java.lang.String) ref; 1071 } 1072 } 1073 /** 1074 * <code>required string className = 1;</code> 1075 */ 1076 public com.google.protobuf.ByteString 1077 getClassNameBytes() { 1078 java.lang.Object ref = className_; 1079 if (ref instanceof String) { 1080 com.google.protobuf.ByteString b = 1081 com.google.protobuf.ByteString.copyFromUtf8( 1082 (java.lang.String) ref); 1083 className_ = b; 1084 return b; 1085 } else { 1086 return (com.google.protobuf.ByteString) ref; 1087 } 1088 } 1089 /** 1090 * <code>required string className = 1;</code> 1091 */ 1092 public Builder setClassName( 1093 java.lang.String value) { 1094 if (value == null) { 1095 throw new NullPointerException(); 1096 } 1097 bitField0_ |= 0x00000001; 1098 className_ = value; 1099 onChanged(); 1100 return this; 1101 } 1102 /** 1103 * <code>required string className = 1;</code> 1104 */ 1105 public Builder clearClassName() { 1106 bitField0_ = (bitField0_ & ~0x00000001); 1107 className_ = getDefaultInstance().getClassName(); 1108 onChanged(); 1109 return this; 1110 } 1111 /** 1112 * <code>required string className = 1;</code> 1113 */ 1114 public Builder setClassNameBytes( 1115 com.google.protobuf.ByteString value) { 1116 if (value == null) { 1117 throw new NullPointerException(); 1118 } 1119 bitField0_ |= 0x00000001; 1120 className_ = value; 1121 onChanged(); 1122 return this; 1123 } 1124 1125 // required bytes data = 2; 1126 private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; 1127 /** 1128 * <code>required bytes data = 2;</code> 1129 */ 1130 public boolean hasData() { 1131 return ((bitField0_ & 0x00000002) == 0x00000002); 1132 } 1133 /** 1134 * <code>required bytes data = 2;</code> 1135 */ 1136 public com.google.protobuf.ByteString getData() { 1137 return data_; 1138 } 1139 /** 1140 * <code>required bytes data = 2;</code> 1141 */ 1142 public Builder setData(com.google.protobuf.ByteString value) { 1143 if (value == null) { 1144 throw new NullPointerException(); 1145 } 1146 bitField0_ |= 0x00000002; 1147 data_ = value; 1148 onChanged(); 1149 return this; 1150 } 1151 /** 1152 * <code>required bytes data = 2;</code> 1153 */ 1154 public Builder clearData() { 1155 bitField0_ = (bitField0_ & ~0x00000002); 1156 data_ = getDefaultInstance().getData(); 1157 onChanged(); 1158 return this; 1159 } 1160 1161 // @@protoc_insertion_point(builder_scope:WakeTuplePBuf) 1162 } 1163 1164 static { 1165 defaultInstance = new WakeTuplePBuf(true); 1166 defaultInstance.initFields(); 1167 } 1168 1169 // @@protoc_insertion_point(class_scope:WakeTuplePBuf) 1170 } 1171 1172 private static com.google.protobuf.Descriptors.Descriptor 1173 internal_static_WakeMessagePBuf_descriptor; 1174 private static 1175 com.google.protobuf.GeneratedMessage.FieldAccessorTable 1176 internal_static_WakeMessagePBuf_fieldAccessorTable; 1177 private static com.google.protobuf.Descriptors.Descriptor 1178 internal_static_WakeTuplePBuf_descriptor; 1179 private static 1180 com.google.protobuf.GeneratedMessage.FieldAccessorTable 1181 internal_static_WakeTuplePBuf_fieldAccessorTable; 1182 1183 public static com.google.protobuf.Descriptors.FileDescriptor 1184 getDescriptor() { 1185 return descriptor; 1186 } 1187 private static com.google.protobuf.Descriptors.FileDescriptor 1188 descriptor; 1189 static { 1190 java.lang.String[] descriptorData = { 1191 "\n\024RemoteProtocol.proto\",\n\017WakeMessagePBu" + 1192 "f\022\014\n\004data\030\001 \002(\014\022\013\n\003seq\030\002 \002(\003\"0\n\rWakeTupl" + 1193 "ePBuf\022\021\n\tclassName\030\001 \002(\t\022\014\n\004data\030\002 \002(\014B;" + 1194 "\n!org.apache.reef.wake.remote.protoB\020Wak" + 1195 "eRemoteProtos\210\001\001\240\001\001" 1196 }; 1197 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 1198 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 1199 public com.google.protobuf.ExtensionRegistry assignDescriptors( 1200 com.google.protobuf.Descriptors.FileDescriptor root) { 1201 descriptor = root; 1202 internal_static_WakeMessagePBuf_descriptor = 1203 getDescriptor().getMessageTypes().get(0); 1204 internal_static_WakeMessagePBuf_fieldAccessorTable = new 1205 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 1206 internal_static_WakeMessagePBuf_descriptor, 1207 new java.lang.String[] { "Data", "Seq", }); 1208 internal_static_WakeTuplePBuf_descriptor = 1209 getDescriptor().getMessageTypes().get(1); 1210 internal_static_WakeTuplePBuf_fieldAccessorTable = new 1211 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 1212 internal_static_WakeTuplePBuf_descriptor, 1213 new java.lang.String[] { "ClassName", "Data", }); 1214 return null; 1215 } 1216 }; 1217 com.google.protobuf.Descriptors.FileDescriptor 1218 .internalBuildGeneratedFileFrom(descriptorData, 1219 new com.google.protobuf.Descriptors.FileDescriptor[] { 1220 }, assigner); 1221 } 1222 1223 // @@protoc_insertion_point(outer_class_scope) 1224}