001// Generated by the protocol buffer compiler. DO NOT EDIT! 002// source: client_runtime.proto 003 004package org.apache.reef.proto; 005 006public final class ClientRuntimeProtocol { 007 private ClientRuntimeProtocol() {} 008 public static void registerAllExtensions( 009 com.google.protobuf.ExtensionRegistry registry) { 010 } 011 /** 012 * Protobuf enum {@code Signal} 013 */ 014 public enum Signal 015 implements com.google.protobuf.ProtocolMessageEnum { 016 /** 017 * <code>SIG_TERMINATE = 1;</code> 018 */ 019 SIG_TERMINATE(0, 1), 020 /** 021 * <code>SIG_SUSPEND = 2;</code> 022 */ 023 SIG_SUSPEND(1, 2), 024 /** 025 * <code>SIG_RESUME = 3;</code> 026 */ 027 SIG_RESUME(2, 3), 028 ; 029 030 /** 031 * <code>SIG_TERMINATE = 1;</code> 032 */ 033 public static final int SIG_TERMINATE_VALUE = 1; 034 /** 035 * <code>SIG_SUSPEND = 2;</code> 036 */ 037 public static final int SIG_SUSPEND_VALUE = 2; 038 /** 039 * <code>SIG_RESUME = 3;</code> 040 */ 041 public static final int SIG_RESUME_VALUE = 3; 042 043 044 public final int getNumber() { return value; } 045 046 public static Signal valueOf(int value) { 047 switch (value) { 048 case 1: return SIG_TERMINATE; 049 case 2: return SIG_SUSPEND; 050 case 3: return SIG_RESUME; 051 default: return null; 052 } 053 } 054 055 public static com.google.protobuf.Internal.EnumLiteMap<Signal> 056 internalGetValueMap() { 057 return internalValueMap; 058 } 059 private static com.google.protobuf.Internal.EnumLiteMap<Signal> 060 internalValueMap = 061 new com.google.protobuf.Internal.EnumLiteMap<Signal>() { 062 public Signal findValueByNumber(int number) { 063 return Signal.valueOf(number); 064 } 065 }; 066 067 public final com.google.protobuf.Descriptors.EnumValueDescriptor 068 getValueDescriptor() { 069 return getDescriptor().getValues().get(index); 070 } 071 public final com.google.protobuf.Descriptors.EnumDescriptor 072 getDescriptorForType() { 073 return getDescriptor(); 074 } 075 public static final com.google.protobuf.Descriptors.EnumDescriptor 076 getDescriptor() { 077 return org.apache.reef.proto.ClientRuntimeProtocol.getDescriptor().getEnumTypes().get(0); 078 } 079 080 private static final Signal[] VALUES = values(); 081 082 public static Signal valueOf( 083 com.google.protobuf.Descriptors.EnumValueDescriptor desc) { 084 if (desc.getType() != getDescriptor()) { 085 throw new java.lang.IllegalArgumentException( 086 "EnumValueDescriptor is not for this type."); 087 } 088 return VALUES[desc.getIndex()]; 089 } 090 091 private final int index; 092 private final int value; 093 094 private Signal(int index, int value) { 095 this.index = index; 096 this.value = value; 097 } 098 099 // @@protoc_insertion_point(enum_scope:Signal) 100 } 101 102 public interface JobSubmissionProtoOrBuilder 103 extends com.google.protobuf.MessageOrBuilder { 104 105 // required string identifier = 1; 106 /** 107 * <code>required string identifier = 1;</code> 108 * 109 * <pre> 110 * the job identifier 111 * </pre> 112 */ 113 boolean hasIdentifier(); 114 /** 115 * <code>required string identifier = 1;</code> 116 * 117 * <pre> 118 * the job identifier 119 * </pre> 120 */ 121 java.lang.String getIdentifier(); 122 /** 123 * <code>required string identifier = 1;</code> 124 * 125 * <pre> 126 * the job identifier 127 * </pre> 128 */ 129 com.google.protobuf.ByteString 130 getIdentifierBytes(); 131 132 // required string remote_id = 2; 133 /** 134 * <code>required string remote_id = 2;</code> 135 * 136 * <pre> 137 * the remote identifier 138 * </pre> 139 */ 140 boolean hasRemoteId(); 141 /** 142 * <code>required string remote_id = 2;</code> 143 * 144 * <pre> 145 * the remote identifier 146 * </pre> 147 */ 148 java.lang.String getRemoteId(); 149 /** 150 * <code>required string remote_id = 2;</code> 151 * 152 * <pre> 153 * the remote identifier 154 * </pre> 155 */ 156 com.google.protobuf.ByteString 157 getRemoteIdBytes(); 158 159 // required string configuration = 5; 160 /** 161 * <code>required string configuration = 5;</code> 162 * 163 * <pre> 164 * the runtime configuration 165 * </pre> 166 */ 167 boolean hasConfiguration(); 168 /** 169 * <code>required string configuration = 5;</code> 170 * 171 * <pre> 172 * the runtime configuration 173 * </pre> 174 */ 175 java.lang.String getConfiguration(); 176 /** 177 * <code>required string configuration = 5;</code> 178 * 179 * <pre> 180 * the runtime configuration 181 * </pre> 182 */ 183 com.google.protobuf.ByteString 184 getConfigurationBytes(); 185 186 // required string user_name = 6; 187 /** 188 * <code>required string user_name = 6;</code> 189 * 190 * <pre> 191 * the user name 192 * </pre> 193 */ 194 boolean hasUserName(); 195 /** 196 * <code>required string user_name = 6;</code> 197 * 198 * <pre> 199 * the user name 200 * </pre> 201 */ 202 java.lang.String getUserName(); 203 /** 204 * <code>required string user_name = 6;</code> 205 * 206 * <pre> 207 * the user name 208 * </pre> 209 */ 210 com.google.protobuf.ByteString 211 getUserNameBytes(); 212 213 // optional int32 driver_memory = 8; 214 /** 215 * <code>optional int32 driver_memory = 8;</code> 216 * 217 * <pre> 218 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 219 * </pre> 220 */ 221 boolean hasDriverMemory(); 222 /** 223 * <code>optional int32 driver_memory = 8;</code> 224 * 225 * <pre> 226 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 227 * </pre> 228 */ 229 int getDriverMemory(); 230 231 // optional int32 priority = 9; 232 /** 233 * <code>optional int32 priority = 9;</code> 234 */ 235 boolean hasPriority(); 236 /** 237 * <code>optional int32 priority = 9;</code> 238 */ 239 int getPriority(); 240 241 // optional string queue = 10; 242 /** 243 * <code>optional string queue = 10;</code> 244 */ 245 boolean hasQueue(); 246 /** 247 * <code>optional string queue = 10;</code> 248 */ 249 java.lang.String getQueue(); 250 /** 251 * <code>optional string queue = 10;</code> 252 */ 253 com.google.protobuf.ByteString 254 getQueueBytes(); 255 256 // repeated .FileResourceProto global_file = 11; 257 /** 258 * <code>repeated .FileResourceProto global_file = 11;</code> 259 * 260 * <pre> 261 * files that should be placed on the driver and all subsequent evaluators 262 * </pre> 263 */ 264 java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> 265 getGlobalFileList(); 266 /** 267 * <code>repeated .FileResourceProto global_file = 11;</code> 268 * 269 * <pre> 270 * files that should be placed on the driver and all subsequent evaluators 271 * </pre> 272 */ 273 org.apache.reef.proto.ReefServiceProtos.FileResourceProto getGlobalFile(int index); 274 /** 275 * <code>repeated .FileResourceProto global_file = 11;</code> 276 * 277 * <pre> 278 * files that should be placed on the driver and all subsequent evaluators 279 * </pre> 280 */ 281 int getGlobalFileCount(); 282 /** 283 * <code>repeated .FileResourceProto global_file = 11;</code> 284 * 285 * <pre> 286 * files that should be placed on the driver and all subsequent evaluators 287 * </pre> 288 */ 289 java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 290 getGlobalFileOrBuilderList(); 291 /** 292 * <code>repeated .FileResourceProto global_file = 11;</code> 293 * 294 * <pre> 295 * files that should be placed on the driver and all subsequent evaluators 296 * </pre> 297 */ 298 org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getGlobalFileOrBuilder( 299 int index); 300 301 // repeated .FileResourceProto local_File = 12; 302 /** 303 * <code>repeated .FileResourceProto local_File = 12;</code> 304 * 305 * <pre> 306 * files that should be placed on the driver only 307 * </pre> 308 */ 309 java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> 310 getLocalFileList(); 311 /** 312 * <code>repeated .FileResourceProto local_File = 12;</code> 313 * 314 * <pre> 315 * files that should be placed on the driver only 316 * </pre> 317 */ 318 org.apache.reef.proto.ReefServiceProtos.FileResourceProto getLocalFile(int index); 319 /** 320 * <code>repeated .FileResourceProto local_File = 12;</code> 321 * 322 * <pre> 323 * files that should be placed on the driver only 324 * </pre> 325 */ 326 int getLocalFileCount(); 327 /** 328 * <code>repeated .FileResourceProto local_File = 12;</code> 329 * 330 * <pre> 331 * files that should be placed on the driver only 332 * </pre> 333 */ 334 java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 335 getLocalFileOrBuilderList(); 336 /** 337 * <code>repeated .FileResourceProto local_File = 12;</code> 338 * 339 * <pre> 340 * files that should be placed on the driver only 341 * </pre> 342 */ 343 org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getLocalFileOrBuilder( 344 int index); 345 } 346 /** 347 * Protobuf type {@code JobSubmissionProto} 348 */ 349 public static final class JobSubmissionProto extends 350 com.google.protobuf.GeneratedMessage 351 implements JobSubmissionProtoOrBuilder { 352 // Use JobSubmissionProto.newBuilder() to construct. 353 private JobSubmissionProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 354 super(builder); 355 this.unknownFields = builder.getUnknownFields(); 356 } 357 private JobSubmissionProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 358 359 private static final JobSubmissionProto defaultInstance; 360 public static JobSubmissionProto getDefaultInstance() { 361 return defaultInstance; 362 } 363 364 public JobSubmissionProto getDefaultInstanceForType() { 365 return defaultInstance; 366 } 367 368 private final com.google.protobuf.UnknownFieldSet unknownFields; 369 @java.lang.Override 370 public final com.google.protobuf.UnknownFieldSet 371 getUnknownFields() { 372 return this.unknownFields; 373 } 374 private JobSubmissionProto( 375 com.google.protobuf.CodedInputStream input, 376 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 377 throws com.google.protobuf.InvalidProtocolBufferException { 378 initFields(); 379 int mutable_bitField0_ = 0; 380 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 381 com.google.protobuf.UnknownFieldSet.newBuilder(); 382 try { 383 boolean done = false; 384 while (!done) { 385 int tag = input.readTag(); 386 switch (tag) { 387 case 0: 388 done = true; 389 break; 390 default: { 391 if (!parseUnknownField(input, unknownFields, 392 extensionRegistry, tag)) { 393 done = true; 394 } 395 break; 396 } 397 case 10: { 398 bitField0_ |= 0x00000001; 399 identifier_ = input.readBytes(); 400 break; 401 } 402 case 18: { 403 bitField0_ |= 0x00000002; 404 remoteId_ = input.readBytes(); 405 break; 406 } 407 case 42: { 408 bitField0_ |= 0x00000004; 409 configuration_ = input.readBytes(); 410 break; 411 } 412 case 50: { 413 bitField0_ |= 0x00000008; 414 userName_ = input.readBytes(); 415 break; 416 } 417 case 64: { 418 bitField0_ |= 0x00000010; 419 driverMemory_ = input.readInt32(); 420 break; 421 } 422 case 72: { 423 bitField0_ |= 0x00000020; 424 priority_ = input.readInt32(); 425 break; 426 } 427 case 82: { 428 bitField0_ |= 0x00000040; 429 queue_ = input.readBytes(); 430 break; 431 } 432 case 90: { 433 if (!((mutable_bitField0_ & 0x00000080) == 0x00000080)) { 434 globalFile_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.FileResourceProto>(); 435 mutable_bitField0_ |= 0x00000080; 436 } 437 globalFile_.add(input.readMessage(org.apache.reef.proto.ReefServiceProtos.FileResourceProto.PARSER, extensionRegistry)); 438 break; 439 } 440 case 98: { 441 if (!((mutable_bitField0_ & 0x00000100) == 0x00000100)) { 442 localFile_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.FileResourceProto>(); 443 mutable_bitField0_ |= 0x00000100; 444 } 445 localFile_.add(input.readMessage(org.apache.reef.proto.ReefServiceProtos.FileResourceProto.PARSER, extensionRegistry)); 446 break; 447 } 448 } 449 } 450 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 451 throw e.setUnfinishedMessage(this); 452 } catch (java.io.IOException e) { 453 throw new com.google.protobuf.InvalidProtocolBufferException( 454 e.getMessage()).setUnfinishedMessage(this); 455 } finally { 456 if (((mutable_bitField0_ & 0x00000080) == 0x00000080)) { 457 globalFile_ = java.util.Collections.unmodifiableList(globalFile_); 458 } 459 if (((mutable_bitField0_ & 0x00000100) == 0x00000100)) { 460 localFile_ = java.util.Collections.unmodifiableList(localFile_); 461 } 462 this.unknownFields = unknownFields.build(); 463 makeExtensionsImmutable(); 464 } 465 } 466 public static final com.google.protobuf.Descriptors.Descriptor 467 getDescriptor() { 468 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobSubmissionProto_descriptor; 469 } 470 471 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 472 internalGetFieldAccessorTable() { 473 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobSubmissionProto_fieldAccessorTable 474 .ensureFieldAccessorsInitialized( 475 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder.class); 476 } 477 478 public static com.google.protobuf.Parser<JobSubmissionProto> PARSER = 479 new com.google.protobuf.AbstractParser<JobSubmissionProto>() { 480 public JobSubmissionProto parsePartialFrom( 481 com.google.protobuf.CodedInputStream input, 482 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 483 throws com.google.protobuf.InvalidProtocolBufferException { 484 return new JobSubmissionProto(input, extensionRegistry); 485 } 486 }; 487 488 @java.lang.Override 489 public com.google.protobuf.Parser<JobSubmissionProto> getParserForType() { 490 return PARSER; 491 } 492 493 private int bitField0_; 494 // required string identifier = 1; 495 public static final int IDENTIFIER_FIELD_NUMBER = 1; 496 private java.lang.Object identifier_; 497 /** 498 * <code>required string identifier = 1;</code> 499 * 500 * <pre> 501 * the job identifier 502 * </pre> 503 */ 504 public boolean hasIdentifier() { 505 return ((bitField0_ & 0x00000001) == 0x00000001); 506 } 507 /** 508 * <code>required string identifier = 1;</code> 509 * 510 * <pre> 511 * the job identifier 512 * </pre> 513 */ 514 public java.lang.String getIdentifier() { 515 java.lang.Object ref = identifier_; 516 if (ref instanceof java.lang.String) { 517 return (java.lang.String) ref; 518 } else { 519 com.google.protobuf.ByteString bs = 520 (com.google.protobuf.ByteString) ref; 521 java.lang.String s = bs.toStringUtf8(); 522 if (bs.isValidUtf8()) { 523 identifier_ = s; 524 } 525 return s; 526 } 527 } 528 /** 529 * <code>required string identifier = 1;</code> 530 * 531 * <pre> 532 * the job identifier 533 * </pre> 534 */ 535 public com.google.protobuf.ByteString 536 getIdentifierBytes() { 537 java.lang.Object ref = identifier_; 538 if (ref instanceof java.lang.String) { 539 com.google.protobuf.ByteString b = 540 com.google.protobuf.ByteString.copyFromUtf8( 541 (java.lang.String) ref); 542 identifier_ = b; 543 return b; 544 } else { 545 return (com.google.protobuf.ByteString) ref; 546 } 547 } 548 549 // required string remote_id = 2; 550 public static final int REMOTE_ID_FIELD_NUMBER = 2; 551 private java.lang.Object remoteId_; 552 /** 553 * <code>required string remote_id = 2;</code> 554 * 555 * <pre> 556 * the remote identifier 557 * </pre> 558 */ 559 public boolean hasRemoteId() { 560 return ((bitField0_ & 0x00000002) == 0x00000002); 561 } 562 /** 563 * <code>required string remote_id = 2;</code> 564 * 565 * <pre> 566 * the remote identifier 567 * </pre> 568 */ 569 public java.lang.String getRemoteId() { 570 java.lang.Object ref = remoteId_; 571 if (ref instanceof java.lang.String) { 572 return (java.lang.String) ref; 573 } else { 574 com.google.protobuf.ByteString bs = 575 (com.google.protobuf.ByteString) ref; 576 java.lang.String s = bs.toStringUtf8(); 577 if (bs.isValidUtf8()) { 578 remoteId_ = s; 579 } 580 return s; 581 } 582 } 583 /** 584 * <code>required string remote_id = 2;</code> 585 * 586 * <pre> 587 * the remote identifier 588 * </pre> 589 */ 590 public com.google.protobuf.ByteString 591 getRemoteIdBytes() { 592 java.lang.Object ref = remoteId_; 593 if (ref instanceof java.lang.String) { 594 com.google.protobuf.ByteString b = 595 com.google.protobuf.ByteString.copyFromUtf8( 596 (java.lang.String) ref); 597 remoteId_ = b; 598 return b; 599 } else { 600 return (com.google.protobuf.ByteString) ref; 601 } 602 } 603 604 // required string configuration = 5; 605 public static final int CONFIGURATION_FIELD_NUMBER = 5; 606 private java.lang.Object configuration_; 607 /** 608 * <code>required string configuration = 5;</code> 609 * 610 * <pre> 611 * the runtime configuration 612 * </pre> 613 */ 614 public boolean hasConfiguration() { 615 return ((bitField0_ & 0x00000004) == 0x00000004); 616 } 617 /** 618 * <code>required string configuration = 5;</code> 619 * 620 * <pre> 621 * the runtime configuration 622 * </pre> 623 */ 624 public java.lang.String getConfiguration() { 625 java.lang.Object ref = configuration_; 626 if (ref instanceof java.lang.String) { 627 return (java.lang.String) ref; 628 } else { 629 com.google.protobuf.ByteString bs = 630 (com.google.protobuf.ByteString) ref; 631 java.lang.String s = bs.toStringUtf8(); 632 if (bs.isValidUtf8()) { 633 configuration_ = s; 634 } 635 return s; 636 } 637 } 638 /** 639 * <code>required string configuration = 5;</code> 640 * 641 * <pre> 642 * the runtime configuration 643 * </pre> 644 */ 645 public com.google.protobuf.ByteString 646 getConfigurationBytes() { 647 java.lang.Object ref = configuration_; 648 if (ref instanceof java.lang.String) { 649 com.google.protobuf.ByteString b = 650 com.google.protobuf.ByteString.copyFromUtf8( 651 (java.lang.String) ref); 652 configuration_ = b; 653 return b; 654 } else { 655 return (com.google.protobuf.ByteString) ref; 656 } 657 } 658 659 // required string user_name = 6; 660 public static final int USER_NAME_FIELD_NUMBER = 6; 661 private java.lang.Object userName_; 662 /** 663 * <code>required string user_name = 6;</code> 664 * 665 * <pre> 666 * the user name 667 * </pre> 668 */ 669 public boolean hasUserName() { 670 return ((bitField0_ & 0x00000008) == 0x00000008); 671 } 672 /** 673 * <code>required string user_name = 6;</code> 674 * 675 * <pre> 676 * the user name 677 * </pre> 678 */ 679 public java.lang.String getUserName() { 680 java.lang.Object ref = userName_; 681 if (ref instanceof java.lang.String) { 682 return (java.lang.String) ref; 683 } else { 684 com.google.protobuf.ByteString bs = 685 (com.google.protobuf.ByteString) ref; 686 java.lang.String s = bs.toStringUtf8(); 687 if (bs.isValidUtf8()) { 688 userName_ = s; 689 } 690 return s; 691 } 692 } 693 /** 694 * <code>required string user_name = 6;</code> 695 * 696 * <pre> 697 * the user name 698 * </pre> 699 */ 700 public com.google.protobuf.ByteString 701 getUserNameBytes() { 702 java.lang.Object ref = userName_; 703 if (ref instanceof java.lang.String) { 704 com.google.protobuf.ByteString b = 705 com.google.protobuf.ByteString.copyFromUtf8( 706 (java.lang.String) ref); 707 userName_ = b; 708 return b; 709 } else { 710 return (com.google.protobuf.ByteString) ref; 711 } 712 } 713 714 // optional int32 driver_memory = 8; 715 public static final int DRIVER_MEMORY_FIELD_NUMBER = 8; 716 private int driverMemory_; 717 /** 718 * <code>optional int32 driver_memory = 8;</code> 719 * 720 * <pre> 721 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 722 * </pre> 723 */ 724 public boolean hasDriverMemory() { 725 return ((bitField0_ & 0x00000010) == 0x00000010); 726 } 727 /** 728 * <code>optional int32 driver_memory = 8;</code> 729 * 730 * <pre> 731 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 732 * </pre> 733 */ 734 public int getDriverMemory() { 735 return driverMemory_; 736 } 737 738 // optional int32 priority = 9; 739 public static final int PRIORITY_FIELD_NUMBER = 9; 740 private int priority_; 741 /** 742 * <code>optional int32 priority = 9;</code> 743 */ 744 public boolean hasPriority() { 745 return ((bitField0_ & 0x00000020) == 0x00000020); 746 } 747 /** 748 * <code>optional int32 priority = 9;</code> 749 */ 750 public int getPriority() { 751 return priority_; 752 } 753 754 // optional string queue = 10; 755 public static final int QUEUE_FIELD_NUMBER = 10; 756 private java.lang.Object queue_; 757 /** 758 * <code>optional string queue = 10;</code> 759 */ 760 public boolean hasQueue() { 761 return ((bitField0_ & 0x00000040) == 0x00000040); 762 } 763 /** 764 * <code>optional string queue = 10;</code> 765 */ 766 public java.lang.String getQueue() { 767 java.lang.Object ref = queue_; 768 if (ref instanceof java.lang.String) { 769 return (java.lang.String) ref; 770 } else { 771 com.google.protobuf.ByteString bs = 772 (com.google.protobuf.ByteString) ref; 773 java.lang.String s = bs.toStringUtf8(); 774 if (bs.isValidUtf8()) { 775 queue_ = s; 776 } 777 return s; 778 } 779 } 780 /** 781 * <code>optional string queue = 10;</code> 782 */ 783 public com.google.protobuf.ByteString 784 getQueueBytes() { 785 java.lang.Object ref = queue_; 786 if (ref instanceof java.lang.String) { 787 com.google.protobuf.ByteString b = 788 com.google.protobuf.ByteString.copyFromUtf8( 789 (java.lang.String) ref); 790 queue_ = b; 791 return b; 792 } else { 793 return (com.google.protobuf.ByteString) ref; 794 } 795 } 796 797 // repeated .FileResourceProto global_file = 11; 798 public static final int GLOBAL_FILE_FIELD_NUMBER = 11; 799 private java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> globalFile_; 800 /** 801 * <code>repeated .FileResourceProto global_file = 11;</code> 802 * 803 * <pre> 804 * files that should be placed on the driver and all subsequent evaluators 805 * </pre> 806 */ 807 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> getGlobalFileList() { 808 return globalFile_; 809 } 810 /** 811 * <code>repeated .FileResourceProto global_file = 11;</code> 812 * 813 * <pre> 814 * files that should be placed on the driver and all subsequent evaluators 815 * </pre> 816 */ 817 public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 818 getGlobalFileOrBuilderList() { 819 return globalFile_; 820 } 821 /** 822 * <code>repeated .FileResourceProto global_file = 11;</code> 823 * 824 * <pre> 825 * files that should be placed on the driver and all subsequent evaluators 826 * </pre> 827 */ 828 public int getGlobalFileCount() { 829 return globalFile_.size(); 830 } 831 /** 832 * <code>repeated .FileResourceProto global_file = 11;</code> 833 * 834 * <pre> 835 * files that should be placed on the driver and all subsequent evaluators 836 * </pre> 837 */ 838 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto getGlobalFile(int index) { 839 return globalFile_.get(index); 840 } 841 /** 842 * <code>repeated .FileResourceProto global_file = 11;</code> 843 * 844 * <pre> 845 * files that should be placed on the driver and all subsequent evaluators 846 * </pre> 847 */ 848 public org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getGlobalFileOrBuilder( 849 int index) { 850 return globalFile_.get(index); 851 } 852 853 // repeated .FileResourceProto local_File = 12; 854 public static final int LOCAL_FILE_FIELD_NUMBER = 12; 855 private java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> localFile_; 856 /** 857 * <code>repeated .FileResourceProto local_File = 12;</code> 858 * 859 * <pre> 860 * files that should be placed on the driver only 861 * </pre> 862 */ 863 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> getLocalFileList() { 864 return localFile_; 865 } 866 /** 867 * <code>repeated .FileResourceProto local_File = 12;</code> 868 * 869 * <pre> 870 * files that should be placed on the driver only 871 * </pre> 872 */ 873 public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 874 getLocalFileOrBuilderList() { 875 return localFile_; 876 } 877 /** 878 * <code>repeated .FileResourceProto local_File = 12;</code> 879 * 880 * <pre> 881 * files that should be placed on the driver only 882 * </pre> 883 */ 884 public int getLocalFileCount() { 885 return localFile_.size(); 886 } 887 /** 888 * <code>repeated .FileResourceProto local_File = 12;</code> 889 * 890 * <pre> 891 * files that should be placed on the driver only 892 * </pre> 893 */ 894 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto getLocalFile(int index) { 895 return localFile_.get(index); 896 } 897 /** 898 * <code>repeated .FileResourceProto local_File = 12;</code> 899 * 900 * <pre> 901 * files that should be placed on the driver only 902 * </pre> 903 */ 904 public org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getLocalFileOrBuilder( 905 int index) { 906 return localFile_.get(index); 907 } 908 909 private void initFields() { 910 identifier_ = ""; 911 remoteId_ = ""; 912 configuration_ = ""; 913 userName_ = ""; 914 driverMemory_ = 0; 915 priority_ = 0; 916 queue_ = ""; 917 globalFile_ = java.util.Collections.emptyList(); 918 localFile_ = java.util.Collections.emptyList(); 919 } 920 private byte memoizedIsInitialized = -1; 921 public final boolean isInitialized() { 922 byte isInitialized = memoizedIsInitialized; 923 if (isInitialized != -1) return isInitialized == 1; 924 925 if (!hasIdentifier()) { 926 memoizedIsInitialized = 0; 927 return false; 928 } 929 if (!hasRemoteId()) { 930 memoizedIsInitialized = 0; 931 return false; 932 } 933 if (!hasConfiguration()) { 934 memoizedIsInitialized = 0; 935 return false; 936 } 937 if (!hasUserName()) { 938 memoizedIsInitialized = 0; 939 return false; 940 } 941 for (int i = 0; i < getGlobalFileCount(); i++) { 942 if (!getGlobalFile(i).isInitialized()) { 943 memoizedIsInitialized = 0; 944 return false; 945 } 946 } 947 for (int i = 0; i < getLocalFileCount(); i++) { 948 if (!getLocalFile(i).isInitialized()) { 949 memoizedIsInitialized = 0; 950 return false; 951 } 952 } 953 memoizedIsInitialized = 1; 954 return true; 955 } 956 957 public void writeTo(com.google.protobuf.CodedOutputStream output) 958 throws java.io.IOException { 959 getSerializedSize(); 960 if (((bitField0_ & 0x00000001) == 0x00000001)) { 961 output.writeBytes(1, getIdentifierBytes()); 962 } 963 if (((bitField0_ & 0x00000002) == 0x00000002)) { 964 output.writeBytes(2, getRemoteIdBytes()); 965 } 966 if (((bitField0_ & 0x00000004) == 0x00000004)) { 967 output.writeBytes(5, getConfigurationBytes()); 968 } 969 if (((bitField0_ & 0x00000008) == 0x00000008)) { 970 output.writeBytes(6, getUserNameBytes()); 971 } 972 if (((bitField0_ & 0x00000010) == 0x00000010)) { 973 output.writeInt32(8, driverMemory_); 974 } 975 if (((bitField0_ & 0x00000020) == 0x00000020)) { 976 output.writeInt32(9, priority_); 977 } 978 if (((bitField0_ & 0x00000040) == 0x00000040)) { 979 output.writeBytes(10, getQueueBytes()); 980 } 981 for (int i = 0; i < globalFile_.size(); i++) { 982 output.writeMessage(11, globalFile_.get(i)); 983 } 984 for (int i = 0; i < localFile_.size(); i++) { 985 output.writeMessage(12, localFile_.get(i)); 986 } 987 getUnknownFields().writeTo(output); 988 } 989 990 private int memoizedSerializedSize = -1; 991 public int getSerializedSize() { 992 int size = memoizedSerializedSize; 993 if (size != -1) return size; 994 995 size = 0; 996 if (((bitField0_ & 0x00000001) == 0x00000001)) { 997 size += com.google.protobuf.CodedOutputStream 998 .computeBytesSize(1, getIdentifierBytes()); 999 } 1000 if (((bitField0_ & 0x00000002) == 0x00000002)) { 1001 size += com.google.protobuf.CodedOutputStream 1002 .computeBytesSize(2, getRemoteIdBytes()); 1003 } 1004 if (((bitField0_ & 0x00000004) == 0x00000004)) { 1005 size += com.google.protobuf.CodedOutputStream 1006 .computeBytesSize(5, getConfigurationBytes()); 1007 } 1008 if (((bitField0_ & 0x00000008) == 0x00000008)) { 1009 size += com.google.protobuf.CodedOutputStream 1010 .computeBytesSize(6, getUserNameBytes()); 1011 } 1012 if (((bitField0_ & 0x00000010) == 0x00000010)) { 1013 size += com.google.protobuf.CodedOutputStream 1014 .computeInt32Size(8, driverMemory_); 1015 } 1016 if (((bitField0_ & 0x00000020) == 0x00000020)) { 1017 size += com.google.protobuf.CodedOutputStream 1018 .computeInt32Size(9, priority_); 1019 } 1020 if (((bitField0_ & 0x00000040) == 0x00000040)) { 1021 size += com.google.protobuf.CodedOutputStream 1022 .computeBytesSize(10, getQueueBytes()); 1023 } 1024 for (int i = 0; i < globalFile_.size(); i++) { 1025 size += com.google.protobuf.CodedOutputStream 1026 .computeMessageSize(11, globalFile_.get(i)); 1027 } 1028 for (int i = 0; i < localFile_.size(); i++) { 1029 size += com.google.protobuf.CodedOutputStream 1030 .computeMessageSize(12, localFile_.get(i)); 1031 } 1032 size += getUnknownFields().getSerializedSize(); 1033 memoizedSerializedSize = size; 1034 return size; 1035 } 1036 1037 private static final long serialVersionUID = 0L; 1038 @java.lang.Override 1039 protected java.lang.Object writeReplace() 1040 throws java.io.ObjectStreamException { 1041 return super.writeReplace(); 1042 } 1043 1044 @java.lang.Override 1045 public boolean equals(final java.lang.Object obj) { 1046 if (obj == this) { 1047 return true; 1048 } 1049 if (!(obj instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto)) { 1050 return super.equals(obj); 1051 } 1052 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto other = (org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto) obj; 1053 1054 boolean result = true; 1055 result = result && (hasIdentifier() == other.hasIdentifier()); 1056 if (hasIdentifier()) { 1057 result = result && getIdentifier() 1058 .equals(other.getIdentifier()); 1059 } 1060 result = result && (hasRemoteId() == other.hasRemoteId()); 1061 if (hasRemoteId()) { 1062 result = result && getRemoteId() 1063 .equals(other.getRemoteId()); 1064 } 1065 result = result && (hasConfiguration() == other.hasConfiguration()); 1066 if (hasConfiguration()) { 1067 result = result && getConfiguration() 1068 .equals(other.getConfiguration()); 1069 } 1070 result = result && (hasUserName() == other.hasUserName()); 1071 if (hasUserName()) { 1072 result = result && getUserName() 1073 .equals(other.getUserName()); 1074 } 1075 result = result && (hasDriverMemory() == other.hasDriverMemory()); 1076 if (hasDriverMemory()) { 1077 result = result && (getDriverMemory() 1078 == other.getDriverMemory()); 1079 } 1080 result = result && (hasPriority() == other.hasPriority()); 1081 if (hasPriority()) { 1082 result = result && (getPriority() 1083 == other.getPriority()); 1084 } 1085 result = result && (hasQueue() == other.hasQueue()); 1086 if (hasQueue()) { 1087 result = result && getQueue() 1088 .equals(other.getQueue()); 1089 } 1090 result = result && getGlobalFileList() 1091 .equals(other.getGlobalFileList()); 1092 result = result && getLocalFileList() 1093 .equals(other.getLocalFileList()); 1094 result = result && 1095 getUnknownFields().equals(other.getUnknownFields()); 1096 return result; 1097 } 1098 1099 private int memoizedHashCode = 0; 1100 @java.lang.Override 1101 public int hashCode() { 1102 if (memoizedHashCode != 0) { 1103 return memoizedHashCode; 1104 } 1105 int hash = 41; 1106 hash = (19 * hash) + getDescriptorForType().hashCode(); 1107 if (hasIdentifier()) { 1108 hash = (37 * hash) + IDENTIFIER_FIELD_NUMBER; 1109 hash = (53 * hash) + getIdentifier().hashCode(); 1110 } 1111 if (hasRemoteId()) { 1112 hash = (37 * hash) + REMOTE_ID_FIELD_NUMBER; 1113 hash = (53 * hash) + getRemoteId().hashCode(); 1114 } 1115 if (hasConfiguration()) { 1116 hash = (37 * hash) + CONFIGURATION_FIELD_NUMBER; 1117 hash = (53 * hash) + getConfiguration().hashCode(); 1118 } 1119 if (hasUserName()) { 1120 hash = (37 * hash) + USER_NAME_FIELD_NUMBER; 1121 hash = (53 * hash) + getUserName().hashCode(); 1122 } 1123 if (hasDriverMemory()) { 1124 hash = (37 * hash) + DRIVER_MEMORY_FIELD_NUMBER; 1125 hash = (53 * hash) + getDriverMemory(); 1126 } 1127 if (hasPriority()) { 1128 hash = (37 * hash) + PRIORITY_FIELD_NUMBER; 1129 hash = (53 * hash) + getPriority(); 1130 } 1131 if (hasQueue()) { 1132 hash = (37 * hash) + QUEUE_FIELD_NUMBER; 1133 hash = (53 * hash) + getQueue().hashCode(); 1134 } 1135 if (getGlobalFileCount() > 0) { 1136 hash = (37 * hash) + GLOBAL_FILE_FIELD_NUMBER; 1137 hash = (53 * hash) + getGlobalFileList().hashCode(); 1138 } 1139 if (getLocalFileCount() > 0) { 1140 hash = (37 * hash) + LOCAL_FILE_FIELD_NUMBER; 1141 hash = (53 * hash) + getLocalFileList().hashCode(); 1142 } 1143 hash = (29 * hash) + getUnknownFields().hashCode(); 1144 memoizedHashCode = hash; 1145 return hash; 1146 } 1147 1148 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1149 com.google.protobuf.ByteString data) 1150 throws com.google.protobuf.InvalidProtocolBufferException { 1151 return PARSER.parseFrom(data); 1152 } 1153 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1154 com.google.protobuf.ByteString data, 1155 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1156 throws com.google.protobuf.InvalidProtocolBufferException { 1157 return PARSER.parseFrom(data, extensionRegistry); 1158 } 1159 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom(byte[] data) 1160 throws com.google.protobuf.InvalidProtocolBufferException { 1161 return PARSER.parseFrom(data); 1162 } 1163 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1164 byte[] data, 1165 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1166 throws com.google.protobuf.InvalidProtocolBufferException { 1167 return PARSER.parseFrom(data, extensionRegistry); 1168 } 1169 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom(java.io.InputStream input) 1170 throws java.io.IOException { 1171 return PARSER.parseFrom(input); 1172 } 1173 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1174 java.io.InputStream input, 1175 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1176 throws java.io.IOException { 1177 return PARSER.parseFrom(input, extensionRegistry); 1178 } 1179 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseDelimitedFrom(java.io.InputStream input) 1180 throws java.io.IOException { 1181 return PARSER.parseDelimitedFrom(input); 1182 } 1183 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseDelimitedFrom( 1184 java.io.InputStream input, 1185 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1186 throws java.io.IOException { 1187 return PARSER.parseDelimitedFrom(input, extensionRegistry); 1188 } 1189 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1190 com.google.protobuf.CodedInputStream input) 1191 throws java.io.IOException { 1192 return PARSER.parseFrom(input); 1193 } 1194 public static org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parseFrom( 1195 com.google.protobuf.CodedInputStream input, 1196 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1197 throws java.io.IOException { 1198 return PARSER.parseFrom(input, extensionRegistry); 1199 } 1200 1201 public static Builder newBuilder() { return Builder.create(); } 1202 public Builder newBuilderForType() { return newBuilder(); } 1203 public static Builder newBuilder(org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto prototype) { 1204 return newBuilder().mergeFrom(prototype); 1205 } 1206 public Builder toBuilder() { return newBuilder(this); } 1207 1208 @java.lang.Override 1209 protected Builder newBuilderForType( 1210 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 1211 Builder builder = new Builder(parent); 1212 return builder; 1213 } 1214 /** 1215 * Protobuf type {@code JobSubmissionProto} 1216 */ 1217 public static final class Builder extends 1218 com.google.protobuf.GeneratedMessage.Builder<Builder> 1219 implements org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder { 1220 public static final com.google.protobuf.Descriptors.Descriptor 1221 getDescriptor() { 1222 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobSubmissionProto_descriptor; 1223 } 1224 1225 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 1226 internalGetFieldAccessorTable() { 1227 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobSubmissionProto_fieldAccessorTable 1228 .ensureFieldAccessorsInitialized( 1229 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder.class); 1230 } 1231 1232 // Construct using org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.newBuilder() 1233 private Builder() { 1234 maybeForceBuilderInitialization(); 1235 } 1236 1237 private Builder( 1238 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 1239 super(parent); 1240 maybeForceBuilderInitialization(); 1241 } 1242 private void maybeForceBuilderInitialization() { 1243 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 1244 getGlobalFileFieldBuilder(); 1245 getLocalFileFieldBuilder(); 1246 } 1247 } 1248 private static Builder create() { 1249 return new Builder(); 1250 } 1251 1252 public Builder clear() { 1253 super.clear(); 1254 identifier_ = ""; 1255 bitField0_ = (bitField0_ & ~0x00000001); 1256 remoteId_ = ""; 1257 bitField0_ = (bitField0_ & ~0x00000002); 1258 configuration_ = ""; 1259 bitField0_ = (bitField0_ & ~0x00000004); 1260 userName_ = ""; 1261 bitField0_ = (bitField0_ & ~0x00000008); 1262 driverMemory_ = 0; 1263 bitField0_ = (bitField0_ & ~0x00000010); 1264 priority_ = 0; 1265 bitField0_ = (bitField0_ & ~0x00000020); 1266 queue_ = ""; 1267 bitField0_ = (bitField0_ & ~0x00000040); 1268 if (globalFileBuilder_ == null) { 1269 globalFile_ = java.util.Collections.emptyList(); 1270 bitField0_ = (bitField0_ & ~0x00000080); 1271 } else { 1272 globalFileBuilder_.clear(); 1273 } 1274 if (localFileBuilder_ == null) { 1275 localFile_ = java.util.Collections.emptyList(); 1276 bitField0_ = (bitField0_ & ~0x00000100); 1277 } else { 1278 localFileBuilder_.clear(); 1279 } 1280 return this; 1281 } 1282 1283 public Builder clone() { 1284 return create().mergeFrom(buildPartial()); 1285 } 1286 1287 public com.google.protobuf.Descriptors.Descriptor 1288 getDescriptorForType() { 1289 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobSubmissionProto_descriptor; 1290 } 1291 1292 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto getDefaultInstanceForType() { 1293 return org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance(); 1294 } 1295 1296 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto build() { 1297 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto result = buildPartial(); 1298 if (!result.isInitialized()) { 1299 throw newUninitializedMessageException(result); 1300 } 1301 return result; 1302 } 1303 1304 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto buildPartial() { 1305 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto result = new org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto(this); 1306 int from_bitField0_ = bitField0_; 1307 int to_bitField0_ = 0; 1308 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 1309 to_bitField0_ |= 0x00000001; 1310 } 1311 result.identifier_ = identifier_; 1312 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 1313 to_bitField0_ |= 0x00000002; 1314 } 1315 result.remoteId_ = remoteId_; 1316 if (((from_bitField0_ & 0x00000004) == 0x00000004)) { 1317 to_bitField0_ |= 0x00000004; 1318 } 1319 result.configuration_ = configuration_; 1320 if (((from_bitField0_ & 0x00000008) == 0x00000008)) { 1321 to_bitField0_ |= 0x00000008; 1322 } 1323 result.userName_ = userName_; 1324 if (((from_bitField0_ & 0x00000010) == 0x00000010)) { 1325 to_bitField0_ |= 0x00000010; 1326 } 1327 result.driverMemory_ = driverMemory_; 1328 if (((from_bitField0_ & 0x00000020) == 0x00000020)) { 1329 to_bitField0_ |= 0x00000020; 1330 } 1331 result.priority_ = priority_; 1332 if (((from_bitField0_ & 0x00000040) == 0x00000040)) { 1333 to_bitField0_ |= 0x00000040; 1334 } 1335 result.queue_ = queue_; 1336 if (globalFileBuilder_ == null) { 1337 if (((bitField0_ & 0x00000080) == 0x00000080)) { 1338 globalFile_ = java.util.Collections.unmodifiableList(globalFile_); 1339 bitField0_ = (bitField0_ & ~0x00000080); 1340 } 1341 result.globalFile_ = globalFile_; 1342 } else { 1343 result.globalFile_ = globalFileBuilder_.build(); 1344 } 1345 if (localFileBuilder_ == null) { 1346 if (((bitField0_ & 0x00000100) == 0x00000100)) { 1347 localFile_ = java.util.Collections.unmodifiableList(localFile_); 1348 bitField0_ = (bitField0_ & ~0x00000100); 1349 } 1350 result.localFile_ = localFile_; 1351 } else { 1352 result.localFile_ = localFileBuilder_.build(); 1353 } 1354 result.bitField0_ = to_bitField0_; 1355 onBuilt(); 1356 return result; 1357 } 1358 1359 public Builder mergeFrom(com.google.protobuf.Message other) { 1360 if (other instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto) { 1361 return mergeFrom((org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto)other); 1362 } else { 1363 super.mergeFrom(other); 1364 return this; 1365 } 1366 } 1367 1368 public Builder mergeFrom(org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto other) { 1369 if (other == org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance()) return this; 1370 if (other.hasIdentifier()) { 1371 bitField0_ |= 0x00000001; 1372 identifier_ = other.identifier_; 1373 onChanged(); 1374 } 1375 if (other.hasRemoteId()) { 1376 bitField0_ |= 0x00000002; 1377 remoteId_ = other.remoteId_; 1378 onChanged(); 1379 } 1380 if (other.hasConfiguration()) { 1381 bitField0_ |= 0x00000004; 1382 configuration_ = other.configuration_; 1383 onChanged(); 1384 } 1385 if (other.hasUserName()) { 1386 bitField0_ |= 0x00000008; 1387 userName_ = other.userName_; 1388 onChanged(); 1389 } 1390 if (other.hasDriverMemory()) { 1391 setDriverMemory(other.getDriverMemory()); 1392 } 1393 if (other.hasPriority()) { 1394 setPriority(other.getPriority()); 1395 } 1396 if (other.hasQueue()) { 1397 bitField0_ |= 0x00000040; 1398 queue_ = other.queue_; 1399 onChanged(); 1400 } 1401 if (globalFileBuilder_ == null) { 1402 if (!other.globalFile_.isEmpty()) { 1403 if (globalFile_.isEmpty()) { 1404 globalFile_ = other.globalFile_; 1405 bitField0_ = (bitField0_ & ~0x00000080); 1406 } else { 1407 ensureGlobalFileIsMutable(); 1408 globalFile_.addAll(other.globalFile_); 1409 } 1410 onChanged(); 1411 } 1412 } else { 1413 if (!other.globalFile_.isEmpty()) { 1414 if (globalFileBuilder_.isEmpty()) { 1415 globalFileBuilder_.dispose(); 1416 globalFileBuilder_ = null; 1417 globalFile_ = other.globalFile_; 1418 bitField0_ = (bitField0_ & ~0x00000080); 1419 globalFileBuilder_ = 1420 com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? 1421 getGlobalFileFieldBuilder() : null; 1422 } else { 1423 globalFileBuilder_.addAllMessages(other.globalFile_); 1424 } 1425 } 1426 } 1427 if (localFileBuilder_ == null) { 1428 if (!other.localFile_.isEmpty()) { 1429 if (localFile_.isEmpty()) { 1430 localFile_ = other.localFile_; 1431 bitField0_ = (bitField0_ & ~0x00000100); 1432 } else { 1433 ensureLocalFileIsMutable(); 1434 localFile_.addAll(other.localFile_); 1435 } 1436 onChanged(); 1437 } 1438 } else { 1439 if (!other.localFile_.isEmpty()) { 1440 if (localFileBuilder_.isEmpty()) { 1441 localFileBuilder_.dispose(); 1442 localFileBuilder_ = null; 1443 localFile_ = other.localFile_; 1444 bitField0_ = (bitField0_ & ~0x00000100); 1445 localFileBuilder_ = 1446 com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? 1447 getLocalFileFieldBuilder() : null; 1448 } else { 1449 localFileBuilder_.addAllMessages(other.localFile_); 1450 } 1451 } 1452 } 1453 this.mergeUnknownFields(other.getUnknownFields()); 1454 return this; 1455 } 1456 1457 public final boolean isInitialized() { 1458 if (!hasIdentifier()) { 1459 1460 return false; 1461 } 1462 if (!hasRemoteId()) { 1463 1464 return false; 1465 } 1466 if (!hasConfiguration()) { 1467 1468 return false; 1469 } 1470 if (!hasUserName()) { 1471 1472 return false; 1473 } 1474 for (int i = 0; i < getGlobalFileCount(); i++) { 1475 if (!getGlobalFile(i).isInitialized()) { 1476 1477 return false; 1478 } 1479 } 1480 for (int i = 0; i < getLocalFileCount(); i++) { 1481 if (!getLocalFile(i).isInitialized()) { 1482 1483 return false; 1484 } 1485 } 1486 return true; 1487 } 1488 1489 public Builder mergeFrom( 1490 com.google.protobuf.CodedInputStream input, 1491 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1492 throws java.io.IOException { 1493 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto parsedMessage = null; 1494 try { 1495 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 1496 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1497 parsedMessage = (org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto) e.getUnfinishedMessage(); 1498 throw e; 1499 } finally { 1500 if (parsedMessage != null) { 1501 mergeFrom(parsedMessage); 1502 } 1503 } 1504 return this; 1505 } 1506 private int bitField0_; 1507 1508 // required string identifier = 1; 1509 private java.lang.Object identifier_ = ""; 1510 /** 1511 * <code>required string identifier = 1;</code> 1512 * 1513 * <pre> 1514 * the job identifier 1515 * </pre> 1516 */ 1517 public boolean hasIdentifier() { 1518 return ((bitField0_ & 0x00000001) == 0x00000001); 1519 } 1520 /** 1521 * <code>required string identifier = 1;</code> 1522 * 1523 * <pre> 1524 * the job identifier 1525 * </pre> 1526 */ 1527 public java.lang.String getIdentifier() { 1528 java.lang.Object ref = identifier_; 1529 if (!(ref instanceof java.lang.String)) { 1530 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1531 .toStringUtf8(); 1532 identifier_ = s; 1533 return s; 1534 } else { 1535 return (java.lang.String) ref; 1536 } 1537 } 1538 /** 1539 * <code>required string identifier = 1;</code> 1540 * 1541 * <pre> 1542 * the job identifier 1543 * </pre> 1544 */ 1545 public com.google.protobuf.ByteString 1546 getIdentifierBytes() { 1547 java.lang.Object ref = identifier_; 1548 if (ref instanceof String) { 1549 com.google.protobuf.ByteString b = 1550 com.google.protobuf.ByteString.copyFromUtf8( 1551 (java.lang.String) ref); 1552 identifier_ = b; 1553 return b; 1554 } else { 1555 return (com.google.protobuf.ByteString) ref; 1556 } 1557 } 1558 /** 1559 * <code>required string identifier = 1;</code> 1560 * 1561 * <pre> 1562 * the job identifier 1563 * </pre> 1564 */ 1565 public Builder setIdentifier( 1566 java.lang.String value) { 1567 if (value == null) { 1568 throw new NullPointerException(); 1569 } 1570 bitField0_ |= 0x00000001; 1571 identifier_ = value; 1572 onChanged(); 1573 return this; 1574 } 1575 /** 1576 * <code>required string identifier = 1;</code> 1577 * 1578 * <pre> 1579 * the job identifier 1580 * </pre> 1581 */ 1582 public Builder clearIdentifier() { 1583 bitField0_ = (bitField0_ & ~0x00000001); 1584 identifier_ = getDefaultInstance().getIdentifier(); 1585 onChanged(); 1586 return this; 1587 } 1588 /** 1589 * <code>required string identifier = 1;</code> 1590 * 1591 * <pre> 1592 * the job identifier 1593 * </pre> 1594 */ 1595 public Builder setIdentifierBytes( 1596 com.google.protobuf.ByteString value) { 1597 if (value == null) { 1598 throw new NullPointerException(); 1599 } 1600 bitField0_ |= 0x00000001; 1601 identifier_ = value; 1602 onChanged(); 1603 return this; 1604 } 1605 1606 // required string remote_id = 2; 1607 private java.lang.Object remoteId_ = ""; 1608 /** 1609 * <code>required string remote_id = 2;</code> 1610 * 1611 * <pre> 1612 * the remote identifier 1613 * </pre> 1614 */ 1615 public boolean hasRemoteId() { 1616 return ((bitField0_ & 0x00000002) == 0x00000002); 1617 } 1618 /** 1619 * <code>required string remote_id = 2;</code> 1620 * 1621 * <pre> 1622 * the remote identifier 1623 * </pre> 1624 */ 1625 public java.lang.String getRemoteId() { 1626 java.lang.Object ref = remoteId_; 1627 if (!(ref instanceof java.lang.String)) { 1628 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1629 .toStringUtf8(); 1630 remoteId_ = s; 1631 return s; 1632 } else { 1633 return (java.lang.String) ref; 1634 } 1635 } 1636 /** 1637 * <code>required string remote_id = 2;</code> 1638 * 1639 * <pre> 1640 * the remote identifier 1641 * </pre> 1642 */ 1643 public com.google.protobuf.ByteString 1644 getRemoteIdBytes() { 1645 java.lang.Object ref = remoteId_; 1646 if (ref instanceof String) { 1647 com.google.protobuf.ByteString b = 1648 com.google.protobuf.ByteString.copyFromUtf8( 1649 (java.lang.String) ref); 1650 remoteId_ = b; 1651 return b; 1652 } else { 1653 return (com.google.protobuf.ByteString) ref; 1654 } 1655 } 1656 /** 1657 * <code>required string remote_id = 2;</code> 1658 * 1659 * <pre> 1660 * the remote identifier 1661 * </pre> 1662 */ 1663 public Builder setRemoteId( 1664 java.lang.String value) { 1665 if (value == null) { 1666 throw new NullPointerException(); 1667 } 1668 bitField0_ |= 0x00000002; 1669 remoteId_ = value; 1670 onChanged(); 1671 return this; 1672 } 1673 /** 1674 * <code>required string remote_id = 2;</code> 1675 * 1676 * <pre> 1677 * the remote identifier 1678 * </pre> 1679 */ 1680 public Builder clearRemoteId() { 1681 bitField0_ = (bitField0_ & ~0x00000002); 1682 remoteId_ = getDefaultInstance().getRemoteId(); 1683 onChanged(); 1684 return this; 1685 } 1686 /** 1687 * <code>required string remote_id = 2;</code> 1688 * 1689 * <pre> 1690 * the remote identifier 1691 * </pre> 1692 */ 1693 public Builder setRemoteIdBytes( 1694 com.google.protobuf.ByteString value) { 1695 if (value == null) { 1696 throw new NullPointerException(); 1697 } 1698 bitField0_ |= 0x00000002; 1699 remoteId_ = value; 1700 onChanged(); 1701 return this; 1702 } 1703 1704 // required string configuration = 5; 1705 private java.lang.Object configuration_ = ""; 1706 /** 1707 * <code>required string configuration = 5;</code> 1708 * 1709 * <pre> 1710 * the runtime configuration 1711 * </pre> 1712 */ 1713 public boolean hasConfiguration() { 1714 return ((bitField0_ & 0x00000004) == 0x00000004); 1715 } 1716 /** 1717 * <code>required string configuration = 5;</code> 1718 * 1719 * <pre> 1720 * the runtime configuration 1721 * </pre> 1722 */ 1723 public java.lang.String getConfiguration() { 1724 java.lang.Object ref = configuration_; 1725 if (!(ref instanceof java.lang.String)) { 1726 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1727 .toStringUtf8(); 1728 configuration_ = s; 1729 return s; 1730 } else { 1731 return (java.lang.String) ref; 1732 } 1733 } 1734 /** 1735 * <code>required string configuration = 5;</code> 1736 * 1737 * <pre> 1738 * the runtime configuration 1739 * </pre> 1740 */ 1741 public com.google.protobuf.ByteString 1742 getConfigurationBytes() { 1743 java.lang.Object ref = configuration_; 1744 if (ref instanceof String) { 1745 com.google.protobuf.ByteString b = 1746 com.google.protobuf.ByteString.copyFromUtf8( 1747 (java.lang.String) ref); 1748 configuration_ = b; 1749 return b; 1750 } else { 1751 return (com.google.protobuf.ByteString) ref; 1752 } 1753 } 1754 /** 1755 * <code>required string configuration = 5;</code> 1756 * 1757 * <pre> 1758 * the runtime configuration 1759 * </pre> 1760 */ 1761 public Builder setConfiguration( 1762 java.lang.String value) { 1763 if (value == null) { 1764 throw new NullPointerException(); 1765 } 1766 bitField0_ |= 0x00000004; 1767 configuration_ = value; 1768 onChanged(); 1769 return this; 1770 } 1771 /** 1772 * <code>required string configuration = 5;</code> 1773 * 1774 * <pre> 1775 * the runtime configuration 1776 * </pre> 1777 */ 1778 public Builder clearConfiguration() { 1779 bitField0_ = (bitField0_ & ~0x00000004); 1780 configuration_ = getDefaultInstance().getConfiguration(); 1781 onChanged(); 1782 return this; 1783 } 1784 /** 1785 * <code>required string configuration = 5;</code> 1786 * 1787 * <pre> 1788 * the runtime configuration 1789 * </pre> 1790 */ 1791 public Builder setConfigurationBytes( 1792 com.google.protobuf.ByteString value) { 1793 if (value == null) { 1794 throw new NullPointerException(); 1795 } 1796 bitField0_ |= 0x00000004; 1797 configuration_ = value; 1798 onChanged(); 1799 return this; 1800 } 1801 1802 // required string user_name = 6; 1803 private java.lang.Object userName_ = ""; 1804 /** 1805 * <code>required string user_name = 6;</code> 1806 * 1807 * <pre> 1808 * the user name 1809 * </pre> 1810 */ 1811 public boolean hasUserName() { 1812 return ((bitField0_ & 0x00000008) == 0x00000008); 1813 } 1814 /** 1815 * <code>required string user_name = 6;</code> 1816 * 1817 * <pre> 1818 * the user name 1819 * </pre> 1820 */ 1821 public java.lang.String getUserName() { 1822 java.lang.Object ref = userName_; 1823 if (!(ref instanceof java.lang.String)) { 1824 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1825 .toStringUtf8(); 1826 userName_ = s; 1827 return s; 1828 } else { 1829 return (java.lang.String) ref; 1830 } 1831 } 1832 /** 1833 * <code>required string user_name = 6;</code> 1834 * 1835 * <pre> 1836 * the user name 1837 * </pre> 1838 */ 1839 public com.google.protobuf.ByteString 1840 getUserNameBytes() { 1841 java.lang.Object ref = userName_; 1842 if (ref instanceof String) { 1843 com.google.protobuf.ByteString b = 1844 com.google.protobuf.ByteString.copyFromUtf8( 1845 (java.lang.String) ref); 1846 userName_ = b; 1847 return b; 1848 } else { 1849 return (com.google.protobuf.ByteString) ref; 1850 } 1851 } 1852 /** 1853 * <code>required string user_name = 6;</code> 1854 * 1855 * <pre> 1856 * the user name 1857 * </pre> 1858 */ 1859 public Builder setUserName( 1860 java.lang.String value) { 1861 if (value == null) { 1862 throw new NullPointerException(); 1863 } 1864 bitField0_ |= 0x00000008; 1865 userName_ = value; 1866 onChanged(); 1867 return this; 1868 } 1869 /** 1870 * <code>required string user_name = 6;</code> 1871 * 1872 * <pre> 1873 * the user name 1874 * </pre> 1875 */ 1876 public Builder clearUserName() { 1877 bitField0_ = (bitField0_ & ~0x00000008); 1878 userName_ = getDefaultInstance().getUserName(); 1879 onChanged(); 1880 return this; 1881 } 1882 /** 1883 * <code>required string user_name = 6;</code> 1884 * 1885 * <pre> 1886 * the user name 1887 * </pre> 1888 */ 1889 public Builder setUserNameBytes( 1890 com.google.protobuf.ByteString value) { 1891 if (value == null) { 1892 throw new NullPointerException(); 1893 } 1894 bitField0_ |= 0x00000008; 1895 userName_ = value; 1896 onChanged(); 1897 return this; 1898 } 1899 1900 // optional int32 driver_memory = 8; 1901 private int driverMemory_ ; 1902 /** 1903 * <code>optional int32 driver_memory = 8;</code> 1904 * 1905 * <pre> 1906 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 1907 * </pre> 1908 */ 1909 public boolean hasDriverMemory() { 1910 return ((bitField0_ & 0x00000010) == 0x00000010); 1911 } 1912 /** 1913 * <code>optional int32 driver_memory = 8;</code> 1914 * 1915 * <pre> 1916 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 1917 * </pre> 1918 */ 1919 public int getDriverMemory() { 1920 return driverMemory_; 1921 } 1922 /** 1923 * <code>optional int32 driver_memory = 8;</code> 1924 * 1925 * <pre> 1926 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 1927 * </pre> 1928 */ 1929 public Builder setDriverMemory(int value) { 1930 bitField0_ |= 0x00000010; 1931 driverMemory_ = value; 1932 onChanged(); 1933 return this; 1934 } 1935 /** 1936 * <code>optional int32 driver_memory = 8;</code> 1937 * 1938 * <pre> 1939 *optional SIZE driver_size = 7; // Removed in REEF 0.3 in favor of driver_memory below. 1940 * </pre> 1941 */ 1942 public Builder clearDriverMemory() { 1943 bitField0_ = (bitField0_ & ~0x00000010); 1944 driverMemory_ = 0; 1945 onChanged(); 1946 return this; 1947 } 1948 1949 // optional int32 priority = 9; 1950 private int priority_ ; 1951 /** 1952 * <code>optional int32 priority = 9;</code> 1953 */ 1954 public boolean hasPriority() { 1955 return ((bitField0_ & 0x00000020) == 0x00000020); 1956 } 1957 /** 1958 * <code>optional int32 priority = 9;</code> 1959 */ 1960 public int getPriority() { 1961 return priority_; 1962 } 1963 /** 1964 * <code>optional int32 priority = 9;</code> 1965 */ 1966 public Builder setPriority(int value) { 1967 bitField0_ |= 0x00000020; 1968 priority_ = value; 1969 onChanged(); 1970 return this; 1971 } 1972 /** 1973 * <code>optional int32 priority = 9;</code> 1974 */ 1975 public Builder clearPriority() { 1976 bitField0_ = (bitField0_ & ~0x00000020); 1977 priority_ = 0; 1978 onChanged(); 1979 return this; 1980 } 1981 1982 // optional string queue = 10; 1983 private java.lang.Object queue_ = ""; 1984 /** 1985 * <code>optional string queue = 10;</code> 1986 */ 1987 public boolean hasQueue() { 1988 return ((bitField0_ & 0x00000040) == 0x00000040); 1989 } 1990 /** 1991 * <code>optional string queue = 10;</code> 1992 */ 1993 public java.lang.String getQueue() { 1994 java.lang.Object ref = queue_; 1995 if (!(ref instanceof java.lang.String)) { 1996 java.lang.String s = ((com.google.protobuf.ByteString) ref) 1997 .toStringUtf8(); 1998 queue_ = s; 1999 return s; 2000 } else { 2001 return (java.lang.String) ref; 2002 } 2003 } 2004 /** 2005 * <code>optional string queue = 10;</code> 2006 */ 2007 public com.google.protobuf.ByteString 2008 getQueueBytes() { 2009 java.lang.Object ref = queue_; 2010 if (ref instanceof String) { 2011 com.google.protobuf.ByteString b = 2012 com.google.protobuf.ByteString.copyFromUtf8( 2013 (java.lang.String) ref); 2014 queue_ = b; 2015 return b; 2016 } else { 2017 return (com.google.protobuf.ByteString) ref; 2018 } 2019 } 2020 /** 2021 * <code>optional string queue = 10;</code> 2022 */ 2023 public Builder setQueue( 2024 java.lang.String value) { 2025 if (value == null) { 2026 throw new NullPointerException(); 2027 } 2028 bitField0_ |= 0x00000040; 2029 queue_ = value; 2030 onChanged(); 2031 return this; 2032 } 2033 /** 2034 * <code>optional string queue = 10;</code> 2035 */ 2036 public Builder clearQueue() { 2037 bitField0_ = (bitField0_ & ~0x00000040); 2038 queue_ = getDefaultInstance().getQueue(); 2039 onChanged(); 2040 return this; 2041 } 2042 /** 2043 * <code>optional string queue = 10;</code> 2044 */ 2045 public Builder setQueueBytes( 2046 com.google.protobuf.ByteString value) { 2047 if (value == null) { 2048 throw new NullPointerException(); 2049 } 2050 bitField0_ |= 0x00000040; 2051 queue_ = value; 2052 onChanged(); 2053 return this; 2054 } 2055 2056 // repeated .FileResourceProto global_file = 11; 2057 private java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> globalFile_ = 2058 java.util.Collections.emptyList(); 2059 private void ensureGlobalFileIsMutable() { 2060 if (!((bitField0_ & 0x00000080) == 0x00000080)) { 2061 globalFile_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.FileResourceProto>(globalFile_); 2062 bitField0_ |= 0x00000080; 2063 } 2064 } 2065 2066 private com.google.protobuf.RepeatedFieldBuilder< 2067 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> globalFileBuilder_; 2068 2069 /** 2070 * <code>repeated .FileResourceProto global_file = 11;</code> 2071 * 2072 * <pre> 2073 * files that should be placed on the driver and all subsequent evaluators 2074 * </pre> 2075 */ 2076 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> getGlobalFileList() { 2077 if (globalFileBuilder_ == null) { 2078 return java.util.Collections.unmodifiableList(globalFile_); 2079 } else { 2080 return globalFileBuilder_.getMessageList(); 2081 } 2082 } 2083 /** 2084 * <code>repeated .FileResourceProto global_file = 11;</code> 2085 * 2086 * <pre> 2087 * files that should be placed on the driver and all subsequent evaluators 2088 * </pre> 2089 */ 2090 public int getGlobalFileCount() { 2091 if (globalFileBuilder_ == null) { 2092 return globalFile_.size(); 2093 } else { 2094 return globalFileBuilder_.getCount(); 2095 } 2096 } 2097 /** 2098 * <code>repeated .FileResourceProto global_file = 11;</code> 2099 * 2100 * <pre> 2101 * files that should be placed on the driver and all subsequent evaluators 2102 * </pre> 2103 */ 2104 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto getGlobalFile(int index) { 2105 if (globalFileBuilder_ == null) { 2106 return globalFile_.get(index); 2107 } else { 2108 return globalFileBuilder_.getMessage(index); 2109 } 2110 } 2111 /** 2112 * <code>repeated .FileResourceProto global_file = 11;</code> 2113 * 2114 * <pre> 2115 * files that should be placed on the driver and all subsequent evaluators 2116 * </pre> 2117 */ 2118 public Builder setGlobalFile( 2119 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2120 if (globalFileBuilder_ == null) { 2121 if (value == null) { 2122 throw new NullPointerException(); 2123 } 2124 ensureGlobalFileIsMutable(); 2125 globalFile_.set(index, value); 2126 onChanged(); 2127 } else { 2128 globalFileBuilder_.setMessage(index, value); 2129 } 2130 return this; 2131 } 2132 /** 2133 * <code>repeated .FileResourceProto global_file = 11;</code> 2134 * 2135 * <pre> 2136 * files that should be placed on the driver and all subsequent evaluators 2137 * </pre> 2138 */ 2139 public Builder setGlobalFile( 2140 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2141 if (globalFileBuilder_ == null) { 2142 ensureGlobalFileIsMutable(); 2143 globalFile_.set(index, builderForValue.build()); 2144 onChanged(); 2145 } else { 2146 globalFileBuilder_.setMessage(index, builderForValue.build()); 2147 } 2148 return this; 2149 } 2150 /** 2151 * <code>repeated .FileResourceProto global_file = 11;</code> 2152 * 2153 * <pre> 2154 * files that should be placed on the driver and all subsequent evaluators 2155 * </pre> 2156 */ 2157 public Builder addGlobalFile(org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2158 if (globalFileBuilder_ == null) { 2159 if (value == null) { 2160 throw new NullPointerException(); 2161 } 2162 ensureGlobalFileIsMutable(); 2163 globalFile_.add(value); 2164 onChanged(); 2165 } else { 2166 globalFileBuilder_.addMessage(value); 2167 } 2168 return this; 2169 } 2170 /** 2171 * <code>repeated .FileResourceProto global_file = 11;</code> 2172 * 2173 * <pre> 2174 * files that should be placed on the driver and all subsequent evaluators 2175 * </pre> 2176 */ 2177 public Builder addGlobalFile( 2178 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2179 if (globalFileBuilder_ == null) { 2180 if (value == null) { 2181 throw new NullPointerException(); 2182 } 2183 ensureGlobalFileIsMutable(); 2184 globalFile_.add(index, value); 2185 onChanged(); 2186 } else { 2187 globalFileBuilder_.addMessage(index, value); 2188 } 2189 return this; 2190 } 2191 /** 2192 * <code>repeated .FileResourceProto global_file = 11;</code> 2193 * 2194 * <pre> 2195 * files that should be placed on the driver and all subsequent evaluators 2196 * </pre> 2197 */ 2198 public Builder addGlobalFile( 2199 org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2200 if (globalFileBuilder_ == null) { 2201 ensureGlobalFileIsMutable(); 2202 globalFile_.add(builderForValue.build()); 2203 onChanged(); 2204 } else { 2205 globalFileBuilder_.addMessage(builderForValue.build()); 2206 } 2207 return this; 2208 } 2209 /** 2210 * <code>repeated .FileResourceProto global_file = 11;</code> 2211 * 2212 * <pre> 2213 * files that should be placed on the driver and all subsequent evaluators 2214 * </pre> 2215 */ 2216 public Builder addGlobalFile( 2217 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2218 if (globalFileBuilder_ == null) { 2219 ensureGlobalFileIsMutable(); 2220 globalFile_.add(index, builderForValue.build()); 2221 onChanged(); 2222 } else { 2223 globalFileBuilder_.addMessage(index, builderForValue.build()); 2224 } 2225 return this; 2226 } 2227 /** 2228 * <code>repeated .FileResourceProto global_file = 11;</code> 2229 * 2230 * <pre> 2231 * files that should be placed on the driver and all subsequent evaluators 2232 * </pre> 2233 */ 2234 public Builder addAllGlobalFile( 2235 java.lang.Iterable<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProto> values) { 2236 if (globalFileBuilder_ == null) { 2237 ensureGlobalFileIsMutable(); 2238 super.addAll(values, globalFile_); 2239 onChanged(); 2240 } else { 2241 globalFileBuilder_.addAllMessages(values); 2242 } 2243 return this; 2244 } 2245 /** 2246 * <code>repeated .FileResourceProto global_file = 11;</code> 2247 * 2248 * <pre> 2249 * files that should be placed on the driver and all subsequent evaluators 2250 * </pre> 2251 */ 2252 public Builder clearGlobalFile() { 2253 if (globalFileBuilder_ == null) { 2254 globalFile_ = java.util.Collections.emptyList(); 2255 bitField0_ = (bitField0_ & ~0x00000080); 2256 onChanged(); 2257 } else { 2258 globalFileBuilder_.clear(); 2259 } 2260 return this; 2261 } 2262 /** 2263 * <code>repeated .FileResourceProto global_file = 11;</code> 2264 * 2265 * <pre> 2266 * files that should be placed on the driver and all subsequent evaluators 2267 * </pre> 2268 */ 2269 public Builder removeGlobalFile(int index) { 2270 if (globalFileBuilder_ == null) { 2271 ensureGlobalFileIsMutable(); 2272 globalFile_.remove(index); 2273 onChanged(); 2274 } else { 2275 globalFileBuilder_.remove(index); 2276 } 2277 return this; 2278 } 2279 /** 2280 * <code>repeated .FileResourceProto global_file = 11;</code> 2281 * 2282 * <pre> 2283 * files that should be placed on the driver and all subsequent evaluators 2284 * </pre> 2285 */ 2286 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder getGlobalFileBuilder( 2287 int index) { 2288 return getGlobalFileFieldBuilder().getBuilder(index); 2289 } 2290 /** 2291 * <code>repeated .FileResourceProto global_file = 11;</code> 2292 * 2293 * <pre> 2294 * files that should be placed on the driver and all subsequent evaluators 2295 * </pre> 2296 */ 2297 public org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getGlobalFileOrBuilder( 2298 int index) { 2299 if (globalFileBuilder_ == null) { 2300 return globalFile_.get(index); } else { 2301 return globalFileBuilder_.getMessageOrBuilder(index); 2302 } 2303 } 2304 /** 2305 * <code>repeated .FileResourceProto global_file = 11;</code> 2306 * 2307 * <pre> 2308 * files that should be placed on the driver and all subsequent evaluators 2309 * </pre> 2310 */ 2311 public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 2312 getGlobalFileOrBuilderList() { 2313 if (globalFileBuilder_ != null) { 2314 return globalFileBuilder_.getMessageOrBuilderList(); 2315 } else { 2316 return java.util.Collections.unmodifiableList(globalFile_); 2317 } 2318 } 2319 /** 2320 * <code>repeated .FileResourceProto global_file = 11;</code> 2321 * 2322 * <pre> 2323 * files that should be placed on the driver and all subsequent evaluators 2324 * </pre> 2325 */ 2326 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder addGlobalFileBuilder() { 2327 return getGlobalFileFieldBuilder().addBuilder( 2328 org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance()); 2329 } 2330 /** 2331 * <code>repeated .FileResourceProto global_file = 11;</code> 2332 * 2333 * <pre> 2334 * files that should be placed on the driver and all subsequent evaluators 2335 * </pre> 2336 */ 2337 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder addGlobalFileBuilder( 2338 int index) { 2339 return getGlobalFileFieldBuilder().addBuilder( 2340 index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance()); 2341 } 2342 /** 2343 * <code>repeated .FileResourceProto global_file = 11;</code> 2344 * 2345 * <pre> 2346 * files that should be placed on the driver and all subsequent evaluators 2347 * </pre> 2348 */ 2349 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder> 2350 getGlobalFileBuilderList() { 2351 return getGlobalFileFieldBuilder().getBuilderList(); 2352 } 2353 private com.google.protobuf.RepeatedFieldBuilder< 2354 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 2355 getGlobalFileFieldBuilder() { 2356 if (globalFileBuilder_ == null) { 2357 globalFileBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< 2358 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder>( 2359 globalFile_, 2360 ((bitField0_ & 0x00000080) == 0x00000080), 2361 getParentForChildren(), 2362 isClean()); 2363 globalFile_ = null; 2364 } 2365 return globalFileBuilder_; 2366 } 2367 2368 // repeated .FileResourceProto local_File = 12; 2369 private java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> localFile_ = 2370 java.util.Collections.emptyList(); 2371 private void ensureLocalFileIsMutable() { 2372 if (!((bitField0_ & 0x00000100) == 0x00000100)) { 2373 localFile_ = new java.util.ArrayList<org.apache.reef.proto.ReefServiceProtos.FileResourceProto>(localFile_); 2374 bitField0_ |= 0x00000100; 2375 } 2376 } 2377 2378 private com.google.protobuf.RepeatedFieldBuilder< 2379 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> localFileBuilder_; 2380 2381 /** 2382 * <code>repeated .FileResourceProto local_File = 12;</code> 2383 * 2384 * <pre> 2385 * files that should be placed on the driver only 2386 * </pre> 2387 */ 2388 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto> getLocalFileList() { 2389 if (localFileBuilder_ == null) { 2390 return java.util.Collections.unmodifiableList(localFile_); 2391 } else { 2392 return localFileBuilder_.getMessageList(); 2393 } 2394 } 2395 /** 2396 * <code>repeated .FileResourceProto local_File = 12;</code> 2397 * 2398 * <pre> 2399 * files that should be placed on the driver only 2400 * </pre> 2401 */ 2402 public int getLocalFileCount() { 2403 if (localFileBuilder_ == null) { 2404 return localFile_.size(); 2405 } else { 2406 return localFileBuilder_.getCount(); 2407 } 2408 } 2409 /** 2410 * <code>repeated .FileResourceProto local_File = 12;</code> 2411 * 2412 * <pre> 2413 * files that should be placed on the driver only 2414 * </pre> 2415 */ 2416 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto getLocalFile(int index) { 2417 if (localFileBuilder_ == null) { 2418 return localFile_.get(index); 2419 } else { 2420 return localFileBuilder_.getMessage(index); 2421 } 2422 } 2423 /** 2424 * <code>repeated .FileResourceProto local_File = 12;</code> 2425 * 2426 * <pre> 2427 * files that should be placed on the driver only 2428 * </pre> 2429 */ 2430 public Builder setLocalFile( 2431 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2432 if (localFileBuilder_ == null) { 2433 if (value == null) { 2434 throw new NullPointerException(); 2435 } 2436 ensureLocalFileIsMutable(); 2437 localFile_.set(index, value); 2438 onChanged(); 2439 } else { 2440 localFileBuilder_.setMessage(index, value); 2441 } 2442 return this; 2443 } 2444 /** 2445 * <code>repeated .FileResourceProto local_File = 12;</code> 2446 * 2447 * <pre> 2448 * files that should be placed on the driver only 2449 * </pre> 2450 */ 2451 public Builder setLocalFile( 2452 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2453 if (localFileBuilder_ == null) { 2454 ensureLocalFileIsMutable(); 2455 localFile_.set(index, builderForValue.build()); 2456 onChanged(); 2457 } else { 2458 localFileBuilder_.setMessage(index, builderForValue.build()); 2459 } 2460 return this; 2461 } 2462 /** 2463 * <code>repeated .FileResourceProto local_File = 12;</code> 2464 * 2465 * <pre> 2466 * files that should be placed on the driver only 2467 * </pre> 2468 */ 2469 public Builder addLocalFile(org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2470 if (localFileBuilder_ == null) { 2471 if (value == null) { 2472 throw new NullPointerException(); 2473 } 2474 ensureLocalFileIsMutable(); 2475 localFile_.add(value); 2476 onChanged(); 2477 } else { 2478 localFileBuilder_.addMessage(value); 2479 } 2480 return this; 2481 } 2482 /** 2483 * <code>repeated .FileResourceProto local_File = 12;</code> 2484 * 2485 * <pre> 2486 * files that should be placed on the driver only 2487 * </pre> 2488 */ 2489 public Builder addLocalFile( 2490 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto value) { 2491 if (localFileBuilder_ == null) { 2492 if (value == null) { 2493 throw new NullPointerException(); 2494 } 2495 ensureLocalFileIsMutable(); 2496 localFile_.add(index, value); 2497 onChanged(); 2498 } else { 2499 localFileBuilder_.addMessage(index, value); 2500 } 2501 return this; 2502 } 2503 /** 2504 * <code>repeated .FileResourceProto local_File = 12;</code> 2505 * 2506 * <pre> 2507 * files that should be placed on the driver only 2508 * </pre> 2509 */ 2510 public Builder addLocalFile( 2511 org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2512 if (localFileBuilder_ == null) { 2513 ensureLocalFileIsMutable(); 2514 localFile_.add(builderForValue.build()); 2515 onChanged(); 2516 } else { 2517 localFileBuilder_.addMessage(builderForValue.build()); 2518 } 2519 return this; 2520 } 2521 /** 2522 * <code>repeated .FileResourceProto local_File = 12;</code> 2523 * 2524 * <pre> 2525 * files that should be placed on the driver only 2526 * </pre> 2527 */ 2528 public Builder addLocalFile( 2529 int index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder builderForValue) { 2530 if (localFileBuilder_ == null) { 2531 ensureLocalFileIsMutable(); 2532 localFile_.add(index, builderForValue.build()); 2533 onChanged(); 2534 } else { 2535 localFileBuilder_.addMessage(index, builderForValue.build()); 2536 } 2537 return this; 2538 } 2539 /** 2540 * <code>repeated .FileResourceProto local_File = 12;</code> 2541 * 2542 * <pre> 2543 * files that should be placed on the driver only 2544 * </pre> 2545 */ 2546 public Builder addAllLocalFile( 2547 java.lang.Iterable<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProto> values) { 2548 if (localFileBuilder_ == null) { 2549 ensureLocalFileIsMutable(); 2550 super.addAll(values, localFile_); 2551 onChanged(); 2552 } else { 2553 localFileBuilder_.addAllMessages(values); 2554 } 2555 return this; 2556 } 2557 /** 2558 * <code>repeated .FileResourceProto local_File = 12;</code> 2559 * 2560 * <pre> 2561 * files that should be placed on the driver only 2562 * </pre> 2563 */ 2564 public Builder clearLocalFile() { 2565 if (localFileBuilder_ == null) { 2566 localFile_ = java.util.Collections.emptyList(); 2567 bitField0_ = (bitField0_ & ~0x00000100); 2568 onChanged(); 2569 } else { 2570 localFileBuilder_.clear(); 2571 } 2572 return this; 2573 } 2574 /** 2575 * <code>repeated .FileResourceProto local_File = 12;</code> 2576 * 2577 * <pre> 2578 * files that should be placed on the driver only 2579 * </pre> 2580 */ 2581 public Builder removeLocalFile(int index) { 2582 if (localFileBuilder_ == null) { 2583 ensureLocalFileIsMutable(); 2584 localFile_.remove(index); 2585 onChanged(); 2586 } else { 2587 localFileBuilder_.remove(index); 2588 } 2589 return this; 2590 } 2591 /** 2592 * <code>repeated .FileResourceProto local_File = 12;</code> 2593 * 2594 * <pre> 2595 * files that should be placed on the driver only 2596 * </pre> 2597 */ 2598 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder getLocalFileBuilder( 2599 int index) { 2600 return getLocalFileFieldBuilder().getBuilder(index); 2601 } 2602 /** 2603 * <code>repeated .FileResourceProto local_File = 12;</code> 2604 * 2605 * <pre> 2606 * files that should be placed on the driver only 2607 * </pre> 2608 */ 2609 public org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder getLocalFileOrBuilder( 2610 int index) { 2611 if (localFileBuilder_ == null) { 2612 return localFile_.get(index); } else { 2613 return localFileBuilder_.getMessageOrBuilder(index); 2614 } 2615 } 2616 /** 2617 * <code>repeated .FileResourceProto local_File = 12;</code> 2618 * 2619 * <pre> 2620 * files that should be placed on the driver only 2621 * </pre> 2622 */ 2623 public java.util.List<? extends org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 2624 getLocalFileOrBuilderList() { 2625 if (localFileBuilder_ != null) { 2626 return localFileBuilder_.getMessageOrBuilderList(); 2627 } else { 2628 return java.util.Collections.unmodifiableList(localFile_); 2629 } 2630 } 2631 /** 2632 * <code>repeated .FileResourceProto local_File = 12;</code> 2633 * 2634 * <pre> 2635 * files that should be placed on the driver only 2636 * </pre> 2637 */ 2638 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder addLocalFileBuilder() { 2639 return getLocalFileFieldBuilder().addBuilder( 2640 org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance()); 2641 } 2642 /** 2643 * <code>repeated .FileResourceProto local_File = 12;</code> 2644 * 2645 * <pre> 2646 * files that should be placed on the driver only 2647 * </pre> 2648 */ 2649 public org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder addLocalFileBuilder( 2650 int index) { 2651 return getLocalFileFieldBuilder().addBuilder( 2652 index, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.getDefaultInstance()); 2653 } 2654 /** 2655 * <code>repeated .FileResourceProto local_File = 12;</code> 2656 * 2657 * <pre> 2658 * files that should be placed on the driver only 2659 * </pre> 2660 */ 2661 public java.util.List<org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder> 2662 getLocalFileBuilderList() { 2663 return getLocalFileFieldBuilder().getBuilderList(); 2664 } 2665 private com.google.protobuf.RepeatedFieldBuilder< 2666 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder> 2667 getLocalFileFieldBuilder() { 2668 if (localFileBuilder_ == null) { 2669 localFileBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< 2670 org.apache.reef.proto.ReefServiceProtos.FileResourceProto, org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder, org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder>( 2671 localFile_, 2672 ((bitField0_ & 0x00000100) == 0x00000100), 2673 getParentForChildren(), 2674 isClean()); 2675 localFile_ = null; 2676 } 2677 return localFileBuilder_; 2678 } 2679 2680 // @@protoc_insertion_point(builder_scope:JobSubmissionProto) 2681 } 2682 2683 static { 2684 defaultInstance = new JobSubmissionProto(true); 2685 defaultInstance.initFields(); 2686 } 2687 2688 // @@protoc_insertion_point(class_scope:JobSubmissionProto) 2689 } 2690 2691 public interface JobControlProtoOrBuilder 2692 extends com.google.protobuf.MessageOrBuilder { 2693 2694 // required string identifier = 1; 2695 /** 2696 * <code>required string identifier = 1;</code> 2697 */ 2698 boolean hasIdentifier(); 2699 /** 2700 * <code>required string identifier = 1;</code> 2701 */ 2702 java.lang.String getIdentifier(); 2703 /** 2704 * <code>required string identifier = 1;</code> 2705 */ 2706 com.google.protobuf.ByteString 2707 getIdentifierBytes(); 2708 2709 // optional .Signal signal = 2; 2710 /** 2711 * <code>optional .Signal signal = 2;</code> 2712 */ 2713 boolean hasSignal(); 2714 /** 2715 * <code>optional .Signal signal = 2;</code> 2716 */ 2717 org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal(); 2718 2719 // optional bytes message = 3; 2720 /** 2721 * <code>optional bytes message = 3;</code> 2722 */ 2723 boolean hasMessage(); 2724 /** 2725 * <code>optional bytes message = 3;</code> 2726 */ 2727 com.google.protobuf.ByteString getMessage(); 2728 } 2729 /** 2730 * Protobuf type {@code JobControlProto} 2731 */ 2732 public static final class JobControlProto extends 2733 com.google.protobuf.GeneratedMessage 2734 implements JobControlProtoOrBuilder { 2735 // Use JobControlProto.newBuilder() to construct. 2736 private JobControlProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 2737 super(builder); 2738 this.unknownFields = builder.getUnknownFields(); 2739 } 2740 private JobControlProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 2741 2742 private static final JobControlProto defaultInstance; 2743 public static JobControlProto getDefaultInstance() { 2744 return defaultInstance; 2745 } 2746 2747 public JobControlProto getDefaultInstanceForType() { 2748 return defaultInstance; 2749 } 2750 2751 private final com.google.protobuf.UnknownFieldSet unknownFields; 2752 @java.lang.Override 2753 public final com.google.protobuf.UnknownFieldSet 2754 getUnknownFields() { 2755 return this.unknownFields; 2756 } 2757 private JobControlProto( 2758 com.google.protobuf.CodedInputStream input, 2759 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 2760 throws com.google.protobuf.InvalidProtocolBufferException { 2761 initFields(); 2762 int mutable_bitField0_ = 0; 2763 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 2764 com.google.protobuf.UnknownFieldSet.newBuilder(); 2765 try { 2766 boolean done = false; 2767 while (!done) { 2768 int tag = input.readTag(); 2769 switch (tag) { 2770 case 0: 2771 done = true; 2772 break; 2773 default: { 2774 if (!parseUnknownField(input, unknownFields, 2775 extensionRegistry, tag)) { 2776 done = true; 2777 } 2778 break; 2779 } 2780 case 10: { 2781 bitField0_ |= 0x00000001; 2782 identifier_ = input.readBytes(); 2783 break; 2784 } 2785 case 16: { 2786 int rawValue = input.readEnum(); 2787 org.apache.reef.proto.ClientRuntimeProtocol.Signal value = org.apache.reef.proto.ClientRuntimeProtocol.Signal.valueOf(rawValue); 2788 if (value == null) { 2789 unknownFields.mergeVarintField(2, rawValue); 2790 } else { 2791 bitField0_ |= 0x00000002; 2792 signal_ = value; 2793 } 2794 break; 2795 } 2796 case 26: { 2797 bitField0_ |= 0x00000004; 2798 message_ = input.readBytes(); 2799 break; 2800 } 2801 } 2802 } 2803 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 2804 throw e.setUnfinishedMessage(this); 2805 } catch (java.io.IOException e) { 2806 throw new com.google.protobuf.InvalidProtocolBufferException( 2807 e.getMessage()).setUnfinishedMessage(this); 2808 } finally { 2809 this.unknownFields = unknownFields.build(); 2810 makeExtensionsImmutable(); 2811 } 2812 } 2813 public static final com.google.protobuf.Descriptors.Descriptor 2814 getDescriptor() { 2815 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 2816 } 2817 2818 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 2819 internalGetFieldAccessorTable() { 2820 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_fieldAccessorTable 2821 .ensureFieldAccessorsInitialized( 2822 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder.class); 2823 } 2824 2825 public static com.google.protobuf.Parser<JobControlProto> PARSER = 2826 new com.google.protobuf.AbstractParser<JobControlProto>() { 2827 public JobControlProto parsePartialFrom( 2828 com.google.protobuf.CodedInputStream input, 2829 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 2830 throws com.google.protobuf.InvalidProtocolBufferException { 2831 return new JobControlProto(input, extensionRegistry); 2832 } 2833 }; 2834 2835 @java.lang.Override 2836 public com.google.protobuf.Parser<JobControlProto> getParserForType() { 2837 return PARSER; 2838 } 2839 2840 private int bitField0_; 2841 // required string identifier = 1; 2842 public static final int IDENTIFIER_FIELD_NUMBER = 1; 2843 private java.lang.Object identifier_; 2844 /** 2845 * <code>required string identifier = 1;</code> 2846 */ 2847 public boolean hasIdentifier() { 2848 return ((bitField0_ & 0x00000001) == 0x00000001); 2849 } 2850 /** 2851 * <code>required string identifier = 1;</code> 2852 */ 2853 public java.lang.String getIdentifier() { 2854 java.lang.Object ref = identifier_; 2855 if (ref instanceof java.lang.String) { 2856 return (java.lang.String) ref; 2857 } else { 2858 com.google.protobuf.ByteString bs = 2859 (com.google.protobuf.ByteString) ref; 2860 java.lang.String s = bs.toStringUtf8(); 2861 if (bs.isValidUtf8()) { 2862 identifier_ = s; 2863 } 2864 return s; 2865 } 2866 } 2867 /** 2868 * <code>required string identifier = 1;</code> 2869 */ 2870 public com.google.protobuf.ByteString 2871 getIdentifierBytes() { 2872 java.lang.Object ref = identifier_; 2873 if (ref instanceof java.lang.String) { 2874 com.google.protobuf.ByteString b = 2875 com.google.protobuf.ByteString.copyFromUtf8( 2876 (java.lang.String) ref); 2877 identifier_ = b; 2878 return b; 2879 } else { 2880 return (com.google.protobuf.ByteString) ref; 2881 } 2882 } 2883 2884 // optional .Signal signal = 2; 2885 public static final int SIGNAL_FIELD_NUMBER = 2; 2886 private org.apache.reef.proto.ClientRuntimeProtocol.Signal signal_; 2887 /** 2888 * <code>optional .Signal signal = 2;</code> 2889 */ 2890 public boolean hasSignal() { 2891 return ((bitField0_ & 0x00000002) == 0x00000002); 2892 } 2893 /** 2894 * <code>optional .Signal signal = 2;</code> 2895 */ 2896 public org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal() { 2897 return signal_; 2898 } 2899 2900 // optional bytes message = 3; 2901 public static final int MESSAGE_FIELD_NUMBER = 3; 2902 private com.google.protobuf.ByteString message_; 2903 /** 2904 * <code>optional bytes message = 3;</code> 2905 */ 2906 public boolean hasMessage() { 2907 return ((bitField0_ & 0x00000004) == 0x00000004); 2908 } 2909 /** 2910 * <code>optional bytes message = 3;</code> 2911 */ 2912 public com.google.protobuf.ByteString getMessage() { 2913 return message_; 2914 } 2915 2916 private void initFields() { 2917 identifier_ = ""; 2918 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 2919 message_ = com.google.protobuf.ByteString.EMPTY; 2920 } 2921 private byte memoizedIsInitialized = -1; 2922 public final boolean isInitialized() { 2923 byte isInitialized = memoizedIsInitialized; 2924 if (isInitialized != -1) return isInitialized == 1; 2925 2926 if (!hasIdentifier()) { 2927 memoizedIsInitialized = 0; 2928 return false; 2929 } 2930 memoizedIsInitialized = 1; 2931 return true; 2932 } 2933 2934 public void writeTo(com.google.protobuf.CodedOutputStream output) 2935 throws java.io.IOException { 2936 getSerializedSize(); 2937 if (((bitField0_ & 0x00000001) == 0x00000001)) { 2938 output.writeBytes(1, getIdentifierBytes()); 2939 } 2940 if (((bitField0_ & 0x00000002) == 0x00000002)) { 2941 output.writeEnum(2, signal_.getNumber()); 2942 } 2943 if (((bitField0_ & 0x00000004) == 0x00000004)) { 2944 output.writeBytes(3, message_); 2945 } 2946 getUnknownFields().writeTo(output); 2947 } 2948 2949 private int memoizedSerializedSize = -1; 2950 public int getSerializedSize() { 2951 int size = memoizedSerializedSize; 2952 if (size != -1) return size; 2953 2954 size = 0; 2955 if (((bitField0_ & 0x00000001) == 0x00000001)) { 2956 size += com.google.protobuf.CodedOutputStream 2957 .computeBytesSize(1, getIdentifierBytes()); 2958 } 2959 if (((bitField0_ & 0x00000002) == 0x00000002)) { 2960 size += com.google.protobuf.CodedOutputStream 2961 .computeEnumSize(2, signal_.getNumber()); 2962 } 2963 if (((bitField0_ & 0x00000004) == 0x00000004)) { 2964 size += com.google.protobuf.CodedOutputStream 2965 .computeBytesSize(3, message_); 2966 } 2967 size += getUnknownFields().getSerializedSize(); 2968 memoizedSerializedSize = size; 2969 return size; 2970 } 2971 2972 private static final long serialVersionUID = 0L; 2973 @java.lang.Override 2974 protected java.lang.Object writeReplace() 2975 throws java.io.ObjectStreamException { 2976 return super.writeReplace(); 2977 } 2978 2979 @java.lang.Override 2980 public boolean equals(final java.lang.Object obj) { 2981 if (obj == this) { 2982 return true; 2983 } 2984 if (!(obj instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto)) { 2985 return super.equals(obj); 2986 } 2987 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto other = (org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) obj; 2988 2989 boolean result = true; 2990 result = result && (hasIdentifier() == other.hasIdentifier()); 2991 if (hasIdentifier()) { 2992 result = result && getIdentifier() 2993 .equals(other.getIdentifier()); 2994 } 2995 result = result && (hasSignal() == other.hasSignal()); 2996 if (hasSignal()) { 2997 result = result && 2998 (getSignal() == other.getSignal()); 2999 } 3000 result = result && (hasMessage() == other.hasMessage()); 3001 if (hasMessage()) { 3002 result = result && getMessage() 3003 .equals(other.getMessage()); 3004 } 3005 result = result && 3006 getUnknownFields().equals(other.getUnknownFields()); 3007 return result; 3008 } 3009 3010 private int memoizedHashCode = 0; 3011 @java.lang.Override 3012 public int hashCode() { 3013 if (memoizedHashCode != 0) { 3014 return memoizedHashCode; 3015 } 3016 int hash = 41; 3017 hash = (19 * hash) + getDescriptorForType().hashCode(); 3018 if (hasIdentifier()) { 3019 hash = (37 * hash) + IDENTIFIER_FIELD_NUMBER; 3020 hash = (53 * hash) + getIdentifier().hashCode(); 3021 } 3022 if (hasSignal()) { 3023 hash = (37 * hash) + SIGNAL_FIELD_NUMBER; 3024 hash = (53 * hash) + hashEnum(getSignal()); 3025 } 3026 if (hasMessage()) { 3027 hash = (37 * hash) + MESSAGE_FIELD_NUMBER; 3028 hash = (53 * hash) + getMessage().hashCode(); 3029 } 3030 hash = (29 * hash) + getUnknownFields().hashCode(); 3031 memoizedHashCode = hash; 3032 return hash; 3033 } 3034 3035 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3036 com.google.protobuf.ByteString data) 3037 throws com.google.protobuf.InvalidProtocolBufferException { 3038 return PARSER.parseFrom(data); 3039 } 3040 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3041 com.google.protobuf.ByteString data, 3042 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3043 throws com.google.protobuf.InvalidProtocolBufferException { 3044 return PARSER.parseFrom(data, extensionRegistry); 3045 } 3046 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom(byte[] data) 3047 throws com.google.protobuf.InvalidProtocolBufferException { 3048 return PARSER.parseFrom(data); 3049 } 3050 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3051 byte[] data, 3052 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3053 throws com.google.protobuf.InvalidProtocolBufferException { 3054 return PARSER.parseFrom(data, extensionRegistry); 3055 } 3056 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom(java.io.InputStream input) 3057 throws java.io.IOException { 3058 return PARSER.parseFrom(input); 3059 } 3060 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3061 java.io.InputStream input, 3062 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3063 throws java.io.IOException { 3064 return PARSER.parseFrom(input, extensionRegistry); 3065 } 3066 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseDelimitedFrom(java.io.InputStream input) 3067 throws java.io.IOException { 3068 return PARSER.parseDelimitedFrom(input); 3069 } 3070 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseDelimitedFrom( 3071 java.io.InputStream input, 3072 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3073 throws java.io.IOException { 3074 return PARSER.parseDelimitedFrom(input, extensionRegistry); 3075 } 3076 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3077 com.google.protobuf.CodedInputStream input) 3078 throws java.io.IOException { 3079 return PARSER.parseFrom(input); 3080 } 3081 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 3082 com.google.protobuf.CodedInputStream input, 3083 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3084 throws java.io.IOException { 3085 return PARSER.parseFrom(input, extensionRegistry); 3086 } 3087 3088 public static Builder newBuilder() { return Builder.create(); } 3089 public Builder newBuilderForType() { return newBuilder(); } 3090 public static Builder newBuilder(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto prototype) { 3091 return newBuilder().mergeFrom(prototype); 3092 } 3093 public Builder toBuilder() { return newBuilder(this); } 3094 3095 @java.lang.Override 3096 protected Builder newBuilderForType( 3097 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 3098 Builder builder = new Builder(parent); 3099 return builder; 3100 } 3101 /** 3102 * Protobuf type {@code JobControlProto} 3103 */ 3104 public static final class Builder extends 3105 com.google.protobuf.GeneratedMessage.Builder<Builder> 3106 implements org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder { 3107 public static final com.google.protobuf.Descriptors.Descriptor 3108 getDescriptor() { 3109 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 3110 } 3111 3112 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 3113 internalGetFieldAccessorTable() { 3114 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_fieldAccessorTable 3115 .ensureFieldAccessorsInitialized( 3116 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder.class); 3117 } 3118 3119 // Construct using org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.newBuilder() 3120 private Builder() { 3121 maybeForceBuilderInitialization(); 3122 } 3123 3124 private Builder( 3125 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 3126 super(parent); 3127 maybeForceBuilderInitialization(); 3128 } 3129 private void maybeForceBuilderInitialization() { 3130 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 3131 } 3132 } 3133 private static Builder create() { 3134 return new Builder(); 3135 } 3136 3137 public Builder clear() { 3138 super.clear(); 3139 identifier_ = ""; 3140 bitField0_ = (bitField0_ & ~0x00000001); 3141 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 3142 bitField0_ = (bitField0_ & ~0x00000002); 3143 message_ = com.google.protobuf.ByteString.EMPTY; 3144 bitField0_ = (bitField0_ & ~0x00000004); 3145 return this; 3146 } 3147 3148 public Builder clone() { 3149 return create().mergeFrom(buildPartial()); 3150 } 3151 3152 public com.google.protobuf.Descriptors.Descriptor 3153 getDescriptorForType() { 3154 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 3155 } 3156 3157 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getDefaultInstanceForType() { 3158 return org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 3159 } 3160 3161 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto build() { 3162 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto result = buildPartial(); 3163 if (!result.isInitialized()) { 3164 throw newUninitializedMessageException(result); 3165 } 3166 return result; 3167 } 3168 3169 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto buildPartial() { 3170 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto result = new org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto(this); 3171 int from_bitField0_ = bitField0_; 3172 int to_bitField0_ = 0; 3173 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 3174 to_bitField0_ |= 0x00000001; 3175 } 3176 result.identifier_ = identifier_; 3177 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 3178 to_bitField0_ |= 0x00000002; 3179 } 3180 result.signal_ = signal_; 3181 if (((from_bitField0_ & 0x00000004) == 0x00000004)) { 3182 to_bitField0_ |= 0x00000004; 3183 } 3184 result.message_ = message_; 3185 result.bitField0_ = to_bitField0_; 3186 onBuilt(); 3187 return result; 3188 } 3189 3190 public Builder mergeFrom(com.google.protobuf.Message other) { 3191 if (other instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) { 3192 return mergeFrom((org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto)other); 3193 } else { 3194 super.mergeFrom(other); 3195 return this; 3196 } 3197 } 3198 3199 public Builder mergeFrom(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto other) { 3200 if (other == org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance()) return this; 3201 if (other.hasIdentifier()) { 3202 bitField0_ |= 0x00000001; 3203 identifier_ = other.identifier_; 3204 onChanged(); 3205 } 3206 if (other.hasSignal()) { 3207 setSignal(other.getSignal()); 3208 } 3209 if (other.hasMessage()) { 3210 setMessage(other.getMessage()); 3211 } 3212 this.mergeUnknownFields(other.getUnknownFields()); 3213 return this; 3214 } 3215 3216 public final boolean isInitialized() { 3217 if (!hasIdentifier()) { 3218 3219 return false; 3220 } 3221 return true; 3222 } 3223 3224 public Builder mergeFrom( 3225 com.google.protobuf.CodedInputStream input, 3226 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 3227 throws java.io.IOException { 3228 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parsedMessage = null; 3229 try { 3230 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 3231 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 3232 parsedMessage = (org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) e.getUnfinishedMessage(); 3233 throw e; 3234 } finally { 3235 if (parsedMessage != null) { 3236 mergeFrom(parsedMessage); 3237 } 3238 } 3239 return this; 3240 } 3241 private int bitField0_; 3242 3243 // required string identifier = 1; 3244 private java.lang.Object identifier_ = ""; 3245 /** 3246 * <code>required string identifier = 1;</code> 3247 */ 3248 public boolean hasIdentifier() { 3249 return ((bitField0_ & 0x00000001) == 0x00000001); 3250 } 3251 /** 3252 * <code>required string identifier = 1;</code> 3253 */ 3254 public java.lang.String getIdentifier() { 3255 java.lang.Object ref = identifier_; 3256 if (!(ref instanceof java.lang.String)) { 3257 java.lang.String s = ((com.google.protobuf.ByteString) ref) 3258 .toStringUtf8(); 3259 identifier_ = s; 3260 return s; 3261 } else { 3262 return (java.lang.String) ref; 3263 } 3264 } 3265 /** 3266 * <code>required string identifier = 1;</code> 3267 */ 3268 public com.google.protobuf.ByteString 3269 getIdentifierBytes() { 3270 java.lang.Object ref = identifier_; 3271 if (ref instanceof String) { 3272 com.google.protobuf.ByteString b = 3273 com.google.protobuf.ByteString.copyFromUtf8( 3274 (java.lang.String) ref); 3275 identifier_ = b; 3276 return b; 3277 } else { 3278 return (com.google.protobuf.ByteString) ref; 3279 } 3280 } 3281 /** 3282 * <code>required string identifier = 1;</code> 3283 */ 3284 public Builder setIdentifier( 3285 java.lang.String value) { 3286 if (value == null) { 3287 throw new NullPointerException(); 3288 } 3289 bitField0_ |= 0x00000001; 3290 identifier_ = value; 3291 onChanged(); 3292 return this; 3293 } 3294 /** 3295 * <code>required string identifier = 1;</code> 3296 */ 3297 public Builder clearIdentifier() { 3298 bitField0_ = (bitField0_ & ~0x00000001); 3299 identifier_ = getDefaultInstance().getIdentifier(); 3300 onChanged(); 3301 return this; 3302 } 3303 /** 3304 * <code>required string identifier = 1;</code> 3305 */ 3306 public Builder setIdentifierBytes( 3307 com.google.protobuf.ByteString value) { 3308 if (value == null) { 3309 throw new NullPointerException(); 3310 } 3311 bitField0_ |= 0x00000001; 3312 identifier_ = value; 3313 onChanged(); 3314 return this; 3315 } 3316 3317 // optional .Signal signal = 2; 3318 private org.apache.reef.proto.ClientRuntimeProtocol.Signal signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 3319 /** 3320 * <code>optional .Signal signal = 2;</code> 3321 */ 3322 public boolean hasSignal() { 3323 return ((bitField0_ & 0x00000002) == 0x00000002); 3324 } 3325 /** 3326 * <code>optional .Signal signal = 2;</code> 3327 */ 3328 public org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal() { 3329 return signal_; 3330 } 3331 /** 3332 * <code>optional .Signal signal = 2;</code> 3333 */ 3334 public Builder setSignal(org.apache.reef.proto.ClientRuntimeProtocol.Signal value) { 3335 if (value == null) { 3336 throw new NullPointerException(); 3337 } 3338 bitField0_ |= 0x00000002; 3339 signal_ = value; 3340 onChanged(); 3341 return this; 3342 } 3343 /** 3344 * <code>optional .Signal signal = 2;</code> 3345 */ 3346 public Builder clearSignal() { 3347 bitField0_ = (bitField0_ & ~0x00000002); 3348 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 3349 onChanged(); 3350 return this; 3351 } 3352 3353 // optional bytes message = 3; 3354 private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY; 3355 /** 3356 * <code>optional bytes message = 3;</code> 3357 */ 3358 public boolean hasMessage() { 3359 return ((bitField0_ & 0x00000004) == 0x00000004); 3360 } 3361 /** 3362 * <code>optional bytes message = 3;</code> 3363 */ 3364 public com.google.protobuf.ByteString getMessage() { 3365 return message_; 3366 } 3367 /** 3368 * <code>optional bytes message = 3;</code> 3369 */ 3370 public Builder setMessage(com.google.protobuf.ByteString value) { 3371 if (value == null) { 3372 throw new NullPointerException(); 3373 } 3374 bitField0_ |= 0x00000004; 3375 message_ = value; 3376 onChanged(); 3377 return this; 3378 } 3379 /** 3380 * <code>optional bytes message = 3;</code> 3381 */ 3382 public Builder clearMessage() { 3383 bitField0_ = (bitField0_ & ~0x00000004); 3384 message_ = getDefaultInstance().getMessage(); 3385 onChanged(); 3386 return this; 3387 } 3388 3389 // @@protoc_insertion_point(builder_scope:JobControlProto) 3390 } 3391 3392 static { 3393 defaultInstance = new JobControlProto(true); 3394 defaultInstance.initFields(); 3395 } 3396 3397 // @@protoc_insertion_point(class_scope:JobControlProto) 3398 } 3399 3400 private static com.google.protobuf.Descriptors.Descriptor 3401 internal_static_JobSubmissionProto_descriptor; 3402 private static 3403 com.google.protobuf.GeneratedMessage.FieldAccessorTable 3404 internal_static_JobSubmissionProto_fieldAccessorTable; 3405 private static com.google.protobuf.Descriptors.Descriptor 3406 internal_static_JobControlProto_descriptor; 3407 private static 3408 com.google.protobuf.GeneratedMessage.FieldAccessorTable 3409 internal_static_JobControlProto_fieldAccessorTable; 3410 3411 public static com.google.protobuf.Descriptors.FileDescriptor 3412 getDescriptor() { 3413 return descriptor; 3414 } 3415 private static com.google.protobuf.Descriptors.FileDescriptor 3416 descriptor; 3417 static { 3418 java.lang.String[] descriptorData = { 3419 "\n\024client_runtime.proto\032\031reef_service_pro" + 3420 "tos.proto\"\356\001\n\022JobSubmissionProto\022\022\n\niden" + 3421 "tifier\030\001 \002(\t\022\021\n\tremote_id\030\002 \002(\t\022\025\n\rconfi" + 3422 "guration\030\005 \002(\t\022\021\n\tuser_name\030\006 \002(\t\022\025\n\rdri" + 3423 "ver_memory\030\010 \001(\005\022\020\n\010priority\030\t \001(\005\022\r\n\005qu" + 3424 "eue\030\n \001(\t\022\'\n\013global_file\030\013 \003(\0132\022.FileRes" + 3425 "ourceProto\022&\n\nlocal_File\030\014 \003(\0132\022.FileRes" + 3426 "ourceProto\"O\n\017JobControlProto\022\022\n\nidentif" + 3427 "ier\030\001 \002(\t\022\027\n\006signal\030\002 \001(\0162\007.Signal\022\017\n\007me" + 3428 "ssage\030\003 \001(\014*<\n\006Signal\022\021\n\rSIG_TERMINATE\020\001", 3429 "\022\017\n\013SIG_SUSPEND\020\002\022\016\n\nSIG_RESUME\020\003B4\n\025org" + 3430 ".apache.reef.protoB\025ClientRuntimeProtoco" + 3431 "l\210\001\001\240\001\001" 3432 }; 3433 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 3434 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 3435 public com.google.protobuf.ExtensionRegistry assignDescriptors( 3436 com.google.protobuf.Descriptors.FileDescriptor root) { 3437 descriptor = root; 3438 internal_static_JobSubmissionProto_descriptor = 3439 getDescriptor().getMessageTypes().get(0); 3440 internal_static_JobSubmissionProto_fieldAccessorTable = new 3441 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 3442 internal_static_JobSubmissionProto_descriptor, 3443 new java.lang.String[] { "Identifier", "RemoteId", "Configuration", "UserName", "DriverMemory", "Priority", "Queue", "GlobalFile", "LocalFile", }); 3444 internal_static_JobControlProto_descriptor = 3445 getDescriptor().getMessageTypes().get(1); 3446 internal_static_JobControlProto_fieldAccessorTable = new 3447 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 3448 internal_static_JobControlProto_descriptor, 3449 new java.lang.String[] { "Identifier", "Signal", "Message", }); 3450 return null; 3451 } 3452 }; 3453 com.google.protobuf.Descriptors.FileDescriptor 3454 .internalBuildGeneratedFileFrom(descriptorData, 3455 new com.google.protobuf.Descriptors.FileDescriptor[] { 3456 org.apache.reef.proto.ReefServiceProtos.getDescriptor(), 3457 }, assigner); 3458 } 3459 3460 // @@protoc_insertion_point(outer_class_scope) 3461}