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 JobControlProtoOrBuilder 103 extends com.google.protobuf.MessageOrBuilder { 104 105 // required string identifier = 1; 106 /** 107 * <code>required string identifier = 1;</code> 108 */ 109 boolean hasIdentifier(); 110 /** 111 * <code>required string identifier = 1;</code> 112 */ 113 java.lang.String getIdentifier(); 114 /** 115 * <code>required string identifier = 1;</code> 116 */ 117 com.google.protobuf.ByteString 118 getIdentifierBytes(); 119 120 // optional .Signal signal = 2; 121 /** 122 * <code>optional .Signal signal = 2;</code> 123 */ 124 boolean hasSignal(); 125 /** 126 * <code>optional .Signal signal = 2;</code> 127 */ 128 org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal(); 129 130 // optional bytes message = 3; 131 /** 132 * <code>optional bytes message = 3;</code> 133 */ 134 boolean hasMessage(); 135 /** 136 * <code>optional bytes message = 3;</code> 137 */ 138 com.google.protobuf.ByteString getMessage(); 139 } 140 /** 141 * Protobuf type {@code JobControlProto} 142 */ 143 public static final class JobControlProto extends 144 com.google.protobuf.GeneratedMessage 145 implements JobControlProtoOrBuilder { 146 // Use JobControlProto.newBuilder() to construct. 147 private JobControlProto(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 148 super(builder); 149 this.unknownFields = builder.getUnknownFields(); 150 } 151 private JobControlProto(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 152 153 private static final JobControlProto defaultInstance; 154 public static JobControlProto getDefaultInstance() { 155 return defaultInstance; 156 } 157 158 public JobControlProto getDefaultInstanceForType() { 159 return defaultInstance; 160 } 161 162 private final com.google.protobuf.UnknownFieldSet unknownFields; 163 @java.lang.Override 164 public final com.google.protobuf.UnknownFieldSet 165 getUnknownFields() { 166 return this.unknownFields; 167 } 168 private JobControlProto( 169 com.google.protobuf.CodedInputStream input, 170 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 171 throws com.google.protobuf.InvalidProtocolBufferException { 172 initFields(); 173 int mutable_bitField0_ = 0; 174 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 175 com.google.protobuf.UnknownFieldSet.newBuilder(); 176 try { 177 boolean done = false; 178 while (!done) { 179 int tag = input.readTag(); 180 switch (tag) { 181 case 0: 182 done = true; 183 break; 184 default: { 185 if (!parseUnknownField(input, unknownFields, 186 extensionRegistry, tag)) { 187 done = true; 188 } 189 break; 190 } 191 case 10: { 192 bitField0_ |= 0x00000001; 193 identifier_ = input.readBytes(); 194 break; 195 } 196 case 16: { 197 int rawValue = input.readEnum(); 198 org.apache.reef.proto.ClientRuntimeProtocol.Signal value = org.apache.reef.proto.ClientRuntimeProtocol.Signal.valueOf(rawValue); 199 if (value == null) { 200 unknownFields.mergeVarintField(2, rawValue); 201 } else { 202 bitField0_ |= 0x00000002; 203 signal_ = value; 204 } 205 break; 206 } 207 case 26: { 208 bitField0_ |= 0x00000004; 209 message_ = input.readBytes(); 210 break; 211 } 212 } 213 } 214 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 215 throw e.setUnfinishedMessage(this); 216 } catch (java.io.IOException e) { 217 throw new com.google.protobuf.InvalidProtocolBufferException( 218 e.getMessage()).setUnfinishedMessage(this); 219 } finally { 220 this.unknownFields = unknownFields.build(); 221 makeExtensionsImmutable(); 222 } 223 } 224 public static final com.google.protobuf.Descriptors.Descriptor 225 getDescriptor() { 226 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 227 } 228 229 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 230 internalGetFieldAccessorTable() { 231 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_fieldAccessorTable 232 .ensureFieldAccessorsInitialized( 233 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder.class); 234 } 235 236 public static com.google.protobuf.Parser<JobControlProto> PARSER = 237 new com.google.protobuf.AbstractParser<JobControlProto>() { 238 public JobControlProto parsePartialFrom( 239 com.google.protobuf.CodedInputStream input, 240 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 241 throws com.google.protobuf.InvalidProtocolBufferException { 242 return new JobControlProto(input, extensionRegistry); 243 } 244 }; 245 246 @java.lang.Override 247 public com.google.protobuf.Parser<JobControlProto> getParserForType() { 248 return PARSER; 249 } 250 251 private int bitField0_; 252 // required string identifier = 1; 253 public static final int IDENTIFIER_FIELD_NUMBER = 1; 254 private java.lang.Object identifier_; 255 /** 256 * <code>required string identifier = 1;</code> 257 */ 258 public boolean hasIdentifier() { 259 return ((bitField0_ & 0x00000001) == 0x00000001); 260 } 261 /** 262 * <code>required string identifier = 1;</code> 263 */ 264 public java.lang.String getIdentifier() { 265 java.lang.Object ref = identifier_; 266 if (ref instanceof java.lang.String) { 267 return (java.lang.String) ref; 268 } else { 269 com.google.protobuf.ByteString bs = 270 (com.google.protobuf.ByteString) ref; 271 java.lang.String s = bs.toStringUtf8(); 272 if (bs.isValidUtf8()) { 273 identifier_ = s; 274 } 275 return s; 276 } 277 } 278 /** 279 * <code>required string identifier = 1;</code> 280 */ 281 public com.google.protobuf.ByteString 282 getIdentifierBytes() { 283 java.lang.Object ref = identifier_; 284 if (ref instanceof java.lang.String) { 285 com.google.protobuf.ByteString b = 286 com.google.protobuf.ByteString.copyFromUtf8( 287 (java.lang.String) ref); 288 identifier_ = b; 289 return b; 290 } else { 291 return (com.google.protobuf.ByteString) ref; 292 } 293 } 294 295 // optional .Signal signal = 2; 296 public static final int SIGNAL_FIELD_NUMBER = 2; 297 private org.apache.reef.proto.ClientRuntimeProtocol.Signal signal_; 298 /** 299 * <code>optional .Signal signal = 2;</code> 300 */ 301 public boolean hasSignal() { 302 return ((bitField0_ & 0x00000002) == 0x00000002); 303 } 304 /** 305 * <code>optional .Signal signal = 2;</code> 306 */ 307 public org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal() { 308 return signal_; 309 } 310 311 // optional bytes message = 3; 312 public static final int MESSAGE_FIELD_NUMBER = 3; 313 private com.google.protobuf.ByteString message_; 314 /** 315 * <code>optional bytes message = 3;</code> 316 */ 317 public boolean hasMessage() { 318 return ((bitField0_ & 0x00000004) == 0x00000004); 319 } 320 /** 321 * <code>optional bytes message = 3;</code> 322 */ 323 public com.google.protobuf.ByteString getMessage() { 324 return message_; 325 } 326 327 private void initFields() { 328 identifier_ = ""; 329 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 330 message_ = com.google.protobuf.ByteString.EMPTY; 331 } 332 private byte memoizedIsInitialized = -1; 333 public final boolean isInitialized() { 334 byte isInitialized = memoizedIsInitialized; 335 if (isInitialized != -1) return isInitialized == 1; 336 337 if (!hasIdentifier()) { 338 memoizedIsInitialized = 0; 339 return false; 340 } 341 memoizedIsInitialized = 1; 342 return true; 343 } 344 345 public void writeTo(com.google.protobuf.CodedOutputStream output) 346 throws java.io.IOException { 347 getSerializedSize(); 348 if (((bitField0_ & 0x00000001) == 0x00000001)) { 349 output.writeBytes(1, getIdentifierBytes()); 350 } 351 if (((bitField0_ & 0x00000002) == 0x00000002)) { 352 output.writeEnum(2, signal_.getNumber()); 353 } 354 if (((bitField0_ & 0x00000004) == 0x00000004)) { 355 output.writeBytes(3, message_); 356 } 357 getUnknownFields().writeTo(output); 358 } 359 360 private int memoizedSerializedSize = -1; 361 public int getSerializedSize() { 362 int size = memoizedSerializedSize; 363 if (size != -1) return size; 364 365 size = 0; 366 if (((bitField0_ & 0x00000001) == 0x00000001)) { 367 size += com.google.protobuf.CodedOutputStream 368 .computeBytesSize(1, getIdentifierBytes()); 369 } 370 if (((bitField0_ & 0x00000002) == 0x00000002)) { 371 size += com.google.protobuf.CodedOutputStream 372 .computeEnumSize(2, signal_.getNumber()); 373 } 374 if (((bitField0_ & 0x00000004) == 0x00000004)) { 375 size += com.google.protobuf.CodedOutputStream 376 .computeBytesSize(3, message_); 377 } 378 size += getUnknownFields().getSerializedSize(); 379 memoizedSerializedSize = size; 380 return size; 381 } 382 383 private static final long serialVersionUID = 0L; 384 @java.lang.Override 385 protected java.lang.Object writeReplace() 386 throws java.io.ObjectStreamException { 387 return super.writeReplace(); 388 } 389 390 @java.lang.Override 391 public boolean equals(final java.lang.Object obj) { 392 if (obj == this) { 393 return true; 394 } 395 if (!(obj instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto)) { 396 return super.equals(obj); 397 } 398 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto other = (org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) obj; 399 400 boolean result = true; 401 result = result && (hasIdentifier() == other.hasIdentifier()); 402 if (hasIdentifier()) { 403 result = result && getIdentifier() 404 .equals(other.getIdentifier()); 405 } 406 result = result && (hasSignal() == other.hasSignal()); 407 if (hasSignal()) { 408 result = result && 409 (getSignal() == other.getSignal()); 410 } 411 result = result && (hasMessage() == other.hasMessage()); 412 if (hasMessage()) { 413 result = result && getMessage() 414 .equals(other.getMessage()); 415 } 416 result = result && 417 getUnknownFields().equals(other.getUnknownFields()); 418 return result; 419 } 420 421 private int memoizedHashCode = 0; 422 @java.lang.Override 423 public int hashCode() { 424 if (memoizedHashCode != 0) { 425 return memoizedHashCode; 426 } 427 int hash = 41; 428 hash = (19 * hash) + getDescriptorForType().hashCode(); 429 if (hasIdentifier()) { 430 hash = (37 * hash) + IDENTIFIER_FIELD_NUMBER; 431 hash = (53 * hash) + getIdentifier().hashCode(); 432 } 433 if (hasSignal()) { 434 hash = (37 * hash) + SIGNAL_FIELD_NUMBER; 435 hash = (53 * hash) + hashEnum(getSignal()); 436 } 437 if (hasMessage()) { 438 hash = (37 * hash) + MESSAGE_FIELD_NUMBER; 439 hash = (53 * hash) + getMessage().hashCode(); 440 } 441 hash = (29 * hash) + getUnknownFields().hashCode(); 442 memoizedHashCode = hash; 443 return hash; 444 } 445 446 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 447 com.google.protobuf.ByteString data) 448 throws com.google.protobuf.InvalidProtocolBufferException { 449 return PARSER.parseFrom(data); 450 } 451 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 452 com.google.protobuf.ByteString data, 453 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 454 throws com.google.protobuf.InvalidProtocolBufferException { 455 return PARSER.parseFrom(data, extensionRegistry); 456 } 457 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom(byte[] data) 458 throws com.google.protobuf.InvalidProtocolBufferException { 459 return PARSER.parseFrom(data); 460 } 461 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 462 byte[] data, 463 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 464 throws com.google.protobuf.InvalidProtocolBufferException { 465 return PARSER.parseFrom(data, extensionRegistry); 466 } 467 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom(java.io.InputStream input) 468 throws java.io.IOException { 469 return PARSER.parseFrom(input); 470 } 471 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 472 java.io.InputStream input, 473 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 474 throws java.io.IOException { 475 return PARSER.parseFrom(input, extensionRegistry); 476 } 477 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseDelimitedFrom(java.io.InputStream input) 478 throws java.io.IOException { 479 return PARSER.parseDelimitedFrom(input); 480 } 481 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseDelimitedFrom( 482 java.io.InputStream input, 483 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 484 throws java.io.IOException { 485 return PARSER.parseDelimitedFrom(input, extensionRegistry); 486 } 487 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 488 com.google.protobuf.CodedInputStream input) 489 throws java.io.IOException { 490 return PARSER.parseFrom(input); 491 } 492 public static org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parseFrom( 493 com.google.protobuf.CodedInputStream input, 494 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 495 throws java.io.IOException { 496 return PARSER.parseFrom(input, extensionRegistry); 497 } 498 499 public static Builder newBuilder() { return Builder.create(); } 500 public Builder newBuilderForType() { return newBuilder(); } 501 public static Builder newBuilder(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto prototype) { 502 return newBuilder().mergeFrom(prototype); 503 } 504 public Builder toBuilder() { return newBuilder(this); } 505 506 @java.lang.Override 507 protected Builder newBuilderForType( 508 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 509 Builder builder = new Builder(parent); 510 return builder; 511 } 512 /** 513 * Protobuf type {@code JobControlProto} 514 */ 515 public static final class Builder extends 516 com.google.protobuf.GeneratedMessage.Builder<Builder> 517 implements org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder { 518 public static final com.google.protobuf.Descriptors.Descriptor 519 getDescriptor() { 520 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 521 } 522 523 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 524 internalGetFieldAccessorTable() { 525 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_fieldAccessorTable 526 .ensureFieldAccessorsInitialized( 527 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.class, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder.class); 528 } 529 530 // Construct using org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.newBuilder() 531 private Builder() { 532 maybeForceBuilderInitialization(); 533 } 534 535 private Builder( 536 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 537 super(parent); 538 maybeForceBuilderInitialization(); 539 } 540 private void maybeForceBuilderInitialization() { 541 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 542 } 543 } 544 private static Builder create() { 545 return new Builder(); 546 } 547 548 public Builder clear() { 549 super.clear(); 550 identifier_ = ""; 551 bitField0_ = (bitField0_ & ~0x00000001); 552 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 553 bitField0_ = (bitField0_ & ~0x00000002); 554 message_ = com.google.protobuf.ByteString.EMPTY; 555 bitField0_ = (bitField0_ & ~0x00000004); 556 return this; 557 } 558 559 public Builder clone() { 560 return create().mergeFrom(buildPartial()); 561 } 562 563 public com.google.protobuf.Descriptors.Descriptor 564 getDescriptorForType() { 565 return org.apache.reef.proto.ClientRuntimeProtocol.internal_static_JobControlProto_descriptor; 566 } 567 568 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getDefaultInstanceForType() { 569 return org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 570 } 571 572 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto build() { 573 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto result = buildPartial(); 574 if (!result.isInitialized()) { 575 throw newUninitializedMessageException(result); 576 } 577 return result; 578 } 579 580 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto buildPartial() { 581 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto result = new org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto(this); 582 int from_bitField0_ = bitField0_; 583 int to_bitField0_ = 0; 584 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 585 to_bitField0_ |= 0x00000001; 586 } 587 result.identifier_ = identifier_; 588 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 589 to_bitField0_ |= 0x00000002; 590 } 591 result.signal_ = signal_; 592 if (((from_bitField0_ & 0x00000004) == 0x00000004)) { 593 to_bitField0_ |= 0x00000004; 594 } 595 result.message_ = message_; 596 result.bitField0_ = to_bitField0_; 597 onBuilt(); 598 return result; 599 } 600 601 public Builder mergeFrom(com.google.protobuf.Message other) { 602 if (other instanceof org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) { 603 return mergeFrom((org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto)other); 604 } else { 605 super.mergeFrom(other); 606 return this; 607 } 608 } 609 610 public Builder mergeFrom(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto other) { 611 if (other == org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance()) return this; 612 if (other.hasIdentifier()) { 613 bitField0_ |= 0x00000001; 614 identifier_ = other.identifier_; 615 onChanged(); 616 } 617 if (other.hasSignal()) { 618 setSignal(other.getSignal()); 619 } 620 if (other.hasMessage()) { 621 setMessage(other.getMessage()); 622 } 623 this.mergeUnknownFields(other.getUnknownFields()); 624 return this; 625 } 626 627 public final boolean isInitialized() { 628 if (!hasIdentifier()) { 629 630 return false; 631 } 632 return true; 633 } 634 635 public Builder mergeFrom( 636 com.google.protobuf.CodedInputStream input, 637 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 638 throws java.io.IOException { 639 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto parsedMessage = null; 640 try { 641 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 642 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 643 parsedMessage = (org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto) e.getUnfinishedMessage(); 644 throw e; 645 } finally { 646 if (parsedMessage != null) { 647 mergeFrom(parsedMessage); 648 } 649 } 650 return this; 651 } 652 private int bitField0_; 653 654 // required string identifier = 1; 655 private java.lang.Object identifier_ = ""; 656 /** 657 * <code>required string identifier = 1;</code> 658 */ 659 public boolean hasIdentifier() { 660 return ((bitField0_ & 0x00000001) == 0x00000001); 661 } 662 /** 663 * <code>required string identifier = 1;</code> 664 */ 665 public java.lang.String getIdentifier() { 666 java.lang.Object ref = identifier_; 667 if (!(ref instanceof java.lang.String)) { 668 java.lang.String s = ((com.google.protobuf.ByteString) ref) 669 .toStringUtf8(); 670 identifier_ = s; 671 return s; 672 } else { 673 return (java.lang.String) ref; 674 } 675 } 676 /** 677 * <code>required string identifier = 1;</code> 678 */ 679 public com.google.protobuf.ByteString 680 getIdentifierBytes() { 681 java.lang.Object ref = identifier_; 682 if (ref instanceof String) { 683 com.google.protobuf.ByteString b = 684 com.google.protobuf.ByteString.copyFromUtf8( 685 (java.lang.String) ref); 686 identifier_ = b; 687 return b; 688 } else { 689 return (com.google.protobuf.ByteString) ref; 690 } 691 } 692 /** 693 * <code>required string identifier = 1;</code> 694 */ 695 public Builder setIdentifier( 696 java.lang.String value) { 697 if (value == null) { 698 throw new NullPointerException(); 699 } 700 bitField0_ |= 0x00000001; 701 identifier_ = value; 702 onChanged(); 703 return this; 704 } 705 /** 706 * <code>required string identifier = 1;</code> 707 */ 708 public Builder clearIdentifier() { 709 bitField0_ = (bitField0_ & ~0x00000001); 710 identifier_ = getDefaultInstance().getIdentifier(); 711 onChanged(); 712 return this; 713 } 714 /** 715 * <code>required string identifier = 1;</code> 716 */ 717 public Builder setIdentifierBytes( 718 com.google.protobuf.ByteString value) { 719 if (value == null) { 720 throw new NullPointerException(); 721 } 722 bitField0_ |= 0x00000001; 723 identifier_ = value; 724 onChanged(); 725 return this; 726 } 727 728 // optional .Signal signal = 2; 729 private org.apache.reef.proto.ClientRuntimeProtocol.Signal signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 730 /** 731 * <code>optional .Signal signal = 2;</code> 732 */ 733 public boolean hasSignal() { 734 return ((bitField0_ & 0x00000002) == 0x00000002); 735 } 736 /** 737 * <code>optional .Signal signal = 2;</code> 738 */ 739 public org.apache.reef.proto.ClientRuntimeProtocol.Signal getSignal() { 740 return signal_; 741 } 742 /** 743 * <code>optional .Signal signal = 2;</code> 744 */ 745 public Builder setSignal(org.apache.reef.proto.ClientRuntimeProtocol.Signal value) { 746 if (value == null) { 747 throw new NullPointerException(); 748 } 749 bitField0_ |= 0x00000002; 750 signal_ = value; 751 onChanged(); 752 return this; 753 } 754 /** 755 * <code>optional .Signal signal = 2;</code> 756 */ 757 public Builder clearSignal() { 758 bitField0_ = (bitField0_ & ~0x00000002); 759 signal_ = org.apache.reef.proto.ClientRuntimeProtocol.Signal.SIG_TERMINATE; 760 onChanged(); 761 return this; 762 } 763 764 // optional bytes message = 3; 765 private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY; 766 /** 767 * <code>optional bytes message = 3;</code> 768 */ 769 public boolean hasMessage() { 770 return ((bitField0_ & 0x00000004) == 0x00000004); 771 } 772 /** 773 * <code>optional bytes message = 3;</code> 774 */ 775 public com.google.protobuf.ByteString getMessage() { 776 return message_; 777 } 778 /** 779 * <code>optional bytes message = 3;</code> 780 */ 781 public Builder setMessage(com.google.protobuf.ByteString value) { 782 if (value == null) { 783 throw new NullPointerException(); 784 } 785 bitField0_ |= 0x00000004; 786 message_ = value; 787 onChanged(); 788 return this; 789 } 790 /** 791 * <code>optional bytes message = 3;</code> 792 */ 793 public Builder clearMessage() { 794 bitField0_ = (bitField0_ & ~0x00000004); 795 message_ = getDefaultInstance().getMessage(); 796 onChanged(); 797 return this; 798 } 799 800 // @@protoc_insertion_point(builder_scope:JobControlProto) 801 } 802 803 static { 804 defaultInstance = new JobControlProto(true); 805 defaultInstance.initFields(); 806 } 807 808 // @@protoc_insertion_point(class_scope:JobControlProto) 809 } 810 811 private static com.google.protobuf.Descriptors.Descriptor 812 internal_static_JobControlProto_descriptor; 813 private static 814 com.google.protobuf.GeneratedMessage.FieldAccessorTable 815 internal_static_JobControlProto_fieldAccessorTable; 816 817 public static com.google.protobuf.Descriptors.FileDescriptor 818 getDescriptor() { 819 return descriptor; 820 } 821 private static com.google.protobuf.Descriptors.FileDescriptor 822 descriptor; 823 static { 824 java.lang.String[] descriptorData = { 825 "\n\024client_runtime.proto\032\031reef_service_pro" + 826 "tos.proto\"O\n\017JobControlProto\022\022\n\nidentifi" + 827 "er\030\001 \002(\t\022\027\n\006signal\030\002 \001(\0162\007.Signal\022\017\n\007mes" + 828 "sage\030\003 \001(\014*<\n\006Signal\022\021\n\rSIG_TERMINATE\020\001\022" + 829 "\017\n\013SIG_SUSPEND\020\002\022\016\n\nSIG_RESUME\020\003B4\n\025org." + 830 "apache.reef.protoB\025ClientRuntimeProtocol" + 831 "\210\001\001\240\001\001" 832 }; 833 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 834 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 835 public com.google.protobuf.ExtensionRegistry assignDescriptors( 836 com.google.protobuf.Descriptors.FileDescriptor root) { 837 descriptor = root; 838 internal_static_JobControlProto_descriptor = 839 getDescriptor().getMessageTypes().get(0); 840 internal_static_JobControlProto_fieldAccessorTable = new 841 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 842 internal_static_JobControlProto_descriptor, 843 new java.lang.String[] { "Identifier", "Signal", "Message", }); 844 return null; 845 } 846 }; 847 com.google.protobuf.Descriptors.FileDescriptor 848 .internalBuildGeneratedFileFrom(descriptorData, 849 new com.google.protobuf.Descriptors.FileDescriptor[] { 850 org.apache.reef.proto.ReefServiceProtos.getDescriptor(), 851 }, assigner); 852 } 853 854 // @@protoc_insertion_point(outer_class_scope) 855}