001// Generated by the protocol buffer compiler. DO NOT EDIT! 002// source: reef_protocol.proto 003 004package org.apache.reef.proto; 005 006public final class REEFProtocol { 007 private REEFProtocol() {} 008 public static void registerAllExtensions( 009 com.google.protobuf.ExtensionRegistry registry) { 010 } 011 public interface REEFMessageOrBuilder 012 extends com.google.protobuf.MessageOrBuilder { 013 014 // optional .JobSubmissionProto jobSubmission = 1; 015 /** 016 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 017 * 018 * <pre> 019 * Messages defined in client_runtime.proto 020 * </pre> 021 */ 022 boolean hasJobSubmission(); 023 /** 024 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 025 * 026 * <pre> 027 * Messages defined in client_runtime.proto 028 * </pre> 029 */ 030 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto getJobSubmission(); 031 /** 032 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 033 * 034 * <pre> 035 * Messages defined in client_runtime.proto 036 * </pre> 037 */ 038 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder getJobSubmissionOrBuilder(); 039 040 // optional .JobControlProto jobControl = 2; 041 /** 042 * <code>optional .JobControlProto jobControl = 2;</code> 043 */ 044 boolean hasJobControl(); 045 /** 046 * <code>optional .JobControlProto jobControl = 2;</code> 047 */ 048 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl(); 049 /** 050 * <code>optional .JobControlProto jobControl = 2;</code> 051 */ 052 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder(); 053 054 // optional .RuntimeErrorProto runtimeError = 3; 055 /** 056 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 057 * 058 * <pre> 059 * Messages defined in reef_service_protos.proto 060 * </pre> 061 */ 062 boolean hasRuntimeError(); 063 /** 064 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 065 * 066 * <pre> 067 * Messages defined in reef_service_protos.proto 068 * </pre> 069 */ 070 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError(); 071 /** 072 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 073 * 074 * <pre> 075 * Messages defined in reef_service_protos.proto 076 * </pre> 077 */ 078 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder(); 079 080 // optional .JobStatusProto jobStatus = 4; 081 /** 082 * <code>optional .JobStatusProto jobStatus = 4;</code> 083 */ 084 boolean hasJobStatus(); 085 /** 086 * <code>optional .JobStatusProto jobStatus = 4;</code> 087 */ 088 org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus(); 089 /** 090 * <code>optional .JobStatusProto jobStatus = 4;</code> 091 */ 092 org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder(); 093 094 // optional .EvaluatorControlProto evaluatorControl = 5; 095 /** 096 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 097 * 098 * <pre> 099 * Messages from evaluator_runtime.proto 100 * </pre> 101 */ 102 boolean hasEvaluatorControl(); 103 /** 104 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 105 * 106 * <pre> 107 * Messages from evaluator_runtime.proto 108 * </pre> 109 */ 110 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl(); 111 /** 112 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 113 * 114 * <pre> 115 * Messages from evaluator_runtime.proto 116 * </pre> 117 */ 118 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder(); 119 120 // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6; 121 /** 122 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 123 */ 124 boolean hasEvaluatorHeartBeat(); 125 /** 126 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 127 */ 128 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat(); 129 /** 130 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 131 */ 132 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder(); 133 } 134 /** 135 * Protobuf type {@code REEFMessage} 136 */ 137 public static final class REEFMessage extends 138 com.google.protobuf.GeneratedMessage 139 implements REEFMessageOrBuilder { 140 // Use REEFMessage.newBuilder() to construct. 141 private REEFMessage(com.google.protobuf.GeneratedMessage.Builder<?> builder) { 142 super(builder); 143 this.unknownFields = builder.getUnknownFields(); 144 } 145 private REEFMessage(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } 146 147 private static final REEFMessage defaultInstance; 148 public static REEFMessage getDefaultInstance() { 149 return defaultInstance; 150 } 151 152 public REEFMessage getDefaultInstanceForType() { 153 return defaultInstance; 154 } 155 156 private final com.google.protobuf.UnknownFieldSet unknownFields; 157 @java.lang.Override 158 public final com.google.protobuf.UnknownFieldSet 159 getUnknownFields() { 160 return this.unknownFields; 161 } 162 private REEFMessage( 163 com.google.protobuf.CodedInputStream input, 164 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 165 throws com.google.protobuf.InvalidProtocolBufferException { 166 initFields(); 167 int mutable_bitField0_ = 0; 168 com.google.protobuf.UnknownFieldSet.Builder unknownFields = 169 com.google.protobuf.UnknownFieldSet.newBuilder(); 170 try { 171 boolean done = false; 172 while (!done) { 173 int tag = input.readTag(); 174 switch (tag) { 175 case 0: 176 done = true; 177 break; 178 default: { 179 if (!parseUnknownField(input, unknownFields, 180 extensionRegistry, tag)) { 181 done = true; 182 } 183 break; 184 } 185 case 10: { 186 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder subBuilder = null; 187 if (((bitField0_ & 0x00000001) == 0x00000001)) { 188 subBuilder = jobSubmission_.toBuilder(); 189 } 190 jobSubmission_ = input.readMessage(org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.PARSER, extensionRegistry); 191 if (subBuilder != null) { 192 subBuilder.mergeFrom(jobSubmission_); 193 jobSubmission_ = subBuilder.buildPartial(); 194 } 195 bitField0_ |= 0x00000001; 196 break; 197 } 198 case 18: { 199 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder subBuilder = null; 200 if (((bitField0_ & 0x00000002) == 0x00000002)) { 201 subBuilder = jobControl_.toBuilder(); 202 } 203 jobControl_ = input.readMessage(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.PARSER, extensionRegistry); 204 if (subBuilder != null) { 205 subBuilder.mergeFrom(jobControl_); 206 jobControl_ = subBuilder.buildPartial(); 207 } 208 bitField0_ |= 0x00000002; 209 break; 210 } 211 case 26: { 212 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder subBuilder = null; 213 if (((bitField0_ & 0x00000004) == 0x00000004)) { 214 subBuilder = runtimeError_.toBuilder(); 215 } 216 runtimeError_ = input.readMessage(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.PARSER, extensionRegistry); 217 if (subBuilder != null) { 218 subBuilder.mergeFrom(runtimeError_); 219 runtimeError_ = subBuilder.buildPartial(); 220 } 221 bitField0_ |= 0x00000004; 222 break; 223 } 224 case 34: { 225 org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder subBuilder = null; 226 if (((bitField0_ & 0x00000008) == 0x00000008)) { 227 subBuilder = jobStatus_.toBuilder(); 228 } 229 jobStatus_ = input.readMessage(org.apache.reef.proto.ReefServiceProtos.JobStatusProto.PARSER, extensionRegistry); 230 if (subBuilder != null) { 231 subBuilder.mergeFrom(jobStatus_); 232 jobStatus_ = subBuilder.buildPartial(); 233 } 234 bitField0_ |= 0x00000008; 235 break; 236 } 237 case 42: { 238 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder subBuilder = null; 239 if (((bitField0_ & 0x00000010) == 0x00000010)) { 240 subBuilder = evaluatorControl_.toBuilder(); 241 } 242 evaluatorControl_ = input.readMessage(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.PARSER, extensionRegistry); 243 if (subBuilder != null) { 244 subBuilder.mergeFrom(evaluatorControl_); 245 evaluatorControl_ = subBuilder.buildPartial(); 246 } 247 bitField0_ |= 0x00000010; 248 break; 249 } 250 case 50: { 251 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder subBuilder = null; 252 if (((bitField0_ & 0x00000020) == 0x00000020)) { 253 subBuilder = evaluatorHeartBeat_.toBuilder(); 254 } 255 evaluatorHeartBeat_ = input.readMessage(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.PARSER, extensionRegistry); 256 if (subBuilder != null) { 257 subBuilder.mergeFrom(evaluatorHeartBeat_); 258 evaluatorHeartBeat_ = subBuilder.buildPartial(); 259 } 260 bitField0_ |= 0x00000020; 261 break; 262 } 263 } 264 } 265 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 266 throw e.setUnfinishedMessage(this); 267 } catch (java.io.IOException e) { 268 throw new com.google.protobuf.InvalidProtocolBufferException( 269 e.getMessage()).setUnfinishedMessage(this); 270 } finally { 271 this.unknownFields = unknownFields.build(); 272 makeExtensionsImmutable(); 273 } 274 } 275 public static final com.google.protobuf.Descriptors.Descriptor 276 getDescriptor() { 277 return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor; 278 } 279 280 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 281 internalGetFieldAccessorTable() { 282 return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_fieldAccessorTable 283 .ensureFieldAccessorsInitialized( 284 org.apache.reef.proto.REEFProtocol.REEFMessage.class, org.apache.reef.proto.REEFProtocol.REEFMessage.Builder.class); 285 } 286 287 public static com.google.protobuf.Parser<REEFMessage> PARSER = 288 new com.google.protobuf.AbstractParser<REEFMessage>() { 289 public REEFMessage parsePartialFrom( 290 com.google.protobuf.CodedInputStream input, 291 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 292 throws com.google.protobuf.InvalidProtocolBufferException { 293 return new REEFMessage(input, extensionRegistry); 294 } 295 }; 296 297 @java.lang.Override 298 public com.google.protobuf.Parser<REEFMessage> getParserForType() { 299 return PARSER; 300 } 301 302 private int bitField0_; 303 // optional .JobSubmissionProto jobSubmission = 1; 304 public static final int JOBSUBMISSION_FIELD_NUMBER = 1; 305 private org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto jobSubmission_; 306 /** 307 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 308 * 309 * <pre> 310 * Messages defined in client_runtime.proto 311 * </pre> 312 */ 313 public boolean hasJobSubmission() { 314 return ((bitField0_ & 0x00000001) == 0x00000001); 315 } 316 /** 317 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 318 * 319 * <pre> 320 * Messages defined in client_runtime.proto 321 * </pre> 322 */ 323 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto getJobSubmission() { 324 return jobSubmission_; 325 } 326 /** 327 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 328 * 329 * <pre> 330 * Messages defined in client_runtime.proto 331 * </pre> 332 */ 333 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder getJobSubmissionOrBuilder() { 334 return jobSubmission_; 335 } 336 337 // optional .JobControlProto jobControl = 2; 338 public static final int JOBCONTROL_FIELD_NUMBER = 2; 339 private org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto jobControl_; 340 /** 341 * <code>optional .JobControlProto jobControl = 2;</code> 342 */ 343 public boolean hasJobControl() { 344 return ((bitField0_ & 0x00000002) == 0x00000002); 345 } 346 /** 347 * <code>optional .JobControlProto jobControl = 2;</code> 348 */ 349 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl() { 350 return jobControl_; 351 } 352 /** 353 * <code>optional .JobControlProto jobControl = 2;</code> 354 */ 355 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder() { 356 return jobControl_; 357 } 358 359 // optional .RuntimeErrorProto runtimeError = 3; 360 public static final int RUNTIMEERROR_FIELD_NUMBER = 3; 361 private org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto runtimeError_; 362 /** 363 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 364 * 365 * <pre> 366 * Messages defined in reef_service_protos.proto 367 * </pre> 368 */ 369 public boolean hasRuntimeError() { 370 return ((bitField0_ & 0x00000004) == 0x00000004); 371 } 372 /** 373 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 374 * 375 * <pre> 376 * Messages defined in reef_service_protos.proto 377 * </pre> 378 */ 379 public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError() { 380 return runtimeError_; 381 } 382 /** 383 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 384 * 385 * <pre> 386 * Messages defined in reef_service_protos.proto 387 * </pre> 388 */ 389 public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder() { 390 return runtimeError_; 391 } 392 393 // optional .JobStatusProto jobStatus = 4; 394 public static final int JOBSTATUS_FIELD_NUMBER = 4; 395 private org.apache.reef.proto.ReefServiceProtos.JobStatusProto jobStatus_; 396 /** 397 * <code>optional .JobStatusProto jobStatus = 4;</code> 398 */ 399 public boolean hasJobStatus() { 400 return ((bitField0_ & 0x00000008) == 0x00000008); 401 } 402 /** 403 * <code>optional .JobStatusProto jobStatus = 4;</code> 404 */ 405 public org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus() { 406 return jobStatus_; 407 } 408 /** 409 * <code>optional .JobStatusProto jobStatus = 4;</code> 410 */ 411 public org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder() { 412 return jobStatus_; 413 } 414 415 // optional .EvaluatorControlProto evaluatorControl = 5; 416 public static final int EVALUATORCONTROL_FIELD_NUMBER = 5; 417 private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControl_; 418 /** 419 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 420 * 421 * <pre> 422 * Messages from evaluator_runtime.proto 423 * </pre> 424 */ 425 public boolean hasEvaluatorControl() { 426 return ((bitField0_ & 0x00000010) == 0x00000010); 427 } 428 /** 429 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 430 * 431 * <pre> 432 * Messages from evaluator_runtime.proto 433 * </pre> 434 */ 435 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl() { 436 return evaluatorControl_; 437 } 438 /** 439 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 440 * 441 * <pre> 442 * Messages from evaluator_runtime.proto 443 * </pre> 444 */ 445 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder() { 446 return evaluatorControl_; 447 } 448 449 // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6; 450 public static final int EVALUATORHEARTBEAT_FIELD_NUMBER = 6; 451 private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto evaluatorHeartBeat_; 452 /** 453 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 454 */ 455 public boolean hasEvaluatorHeartBeat() { 456 return ((bitField0_ & 0x00000020) == 0x00000020); 457 } 458 /** 459 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 460 */ 461 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat() { 462 return evaluatorHeartBeat_; 463 } 464 /** 465 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 466 */ 467 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder() { 468 return evaluatorHeartBeat_; 469 } 470 471 private void initFields() { 472 jobSubmission_ = org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance(); 473 jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 474 runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance(); 475 jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance(); 476 evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance(); 477 evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance(); 478 } 479 private byte memoizedIsInitialized = -1; 480 public final boolean isInitialized() { 481 byte isInitialized = memoizedIsInitialized; 482 if (isInitialized != -1) return isInitialized == 1; 483 484 if (hasJobSubmission()) { 485 if (!getJobSubmission().isInitialized()) { 486 memoizedIsInitialized = 0; 487 return false; 488 } 489 } 490 if (hasJobControl()) { 491 if (!getJobControl().isInitialized()) { 492 memoizedIsInitialized = 0; 493 return false; 494 } 495 } 496 if (hasRuntimeError()) { 497 if (!getRuntimeError().isInitialized()) { 498 memoizedIsInitialized = 0; 499 return false; 500 } 501 } 502 if (hasJobStatus()) { 503 if (!getJobStatus().isInitialized()) { 504 memoizedIsInitialized = 0; 505 return false; 506 } 507 } 508 if (hasEvaluatorControl()) { 509 if (!getEvaluatorControl().isInitialized()) { 510 memoizedIsInitialized = 0; 511 return false; 512 } 513 } 514 if (hasEvaluatorHeartBeat()) { 515 if (!getEvaluatorHeartBeat().isInitialized()) { 516 memoizedIsInitialized = 0; 517 return false; 518 } 519 } 520 memoizedIsInitialized = 1; 521 return true; 522 } 523 524 public void writeTo(com.google.protobuf.CodedOutputStream output) 525 throws java.io.IOException { 526 getSerializedSize(); 527 if (((bitField0_ & 0x00000001) == 0x00000001)) { 528 output.writeMessage(1, jobSubmission_); 529 } 530 if (((bitField0_ & 0x00000002) == 0x00000002)) { 531 output.writeMessage(2, jobControl_); 532 } 533 if (((bitField0_ & 0x00000004) == 0x00000004)) { 534 output.writeMessage(3, runtimeError_); 535 } 536 if (((bitField0_ & 0x00000008) == 0x00000008)) { 537 output.writeMessage(4, jobStatus_); 538 } 539 if (((bitField0_ & 0x00000010) == 0x00000010)) { 540 output.writeMessage(5, evaluatorControl_); 541 } 542 if (((bitField0_ & 0x00000020) == 0x00000020)) { 543 output.writeMessage(6, evaluatorHeartBeat_); 544 } 545 getUnknownFields().writeTo(output); 546 } 547 548 private int memoizedSerializedSize = -1; 549 public int getSerializedSize() { 550 int size = memoizedSerializedSize; 551 if (size != -1) return size; 552 553 size = 0; 554 if (((bitField0_ & 0x00000001) == 0x00000001)) { 555 size += com.google.protobuf.CodedOutputStream 556 .computeMessageSize(1, jobSubmission_); 557 } 558 if (((bitField0_ & 0x00000002) == 0x00000002)) { 559 size += com.google.protobuf.CodedOutputStream 560 .computeMessageSize(2, jobControl_); 561 } 562 if (((bitField0_ & 0x00000004) == 0x00000004)) { 563 size += com.google.protobuf.CodedOutputStream 564 .computeMessageSize(3, runtimeError_); 565 } 566 if (((bitField0_ & 0x00000008) == 0x00000008)) { 567 size += com.google.protobuf.CodedOutputStream 568 .computeMessageSize(4, jobStatus_); 569 } 570 if (((bitField0_ & 0x00000010) == 0x00000010)) { 571 size += com.google.protobuf.CodedOutputStream 572 .computeMessageSize(5, evaluatorControl_); 573 } 574 if (((bitField0_ & 0x00000020) == 0x00000020)) { 575 size += com.google.protobuf.CodedOutputStream 576 .computeMessageSize(6, evaluatorHeartBeat_); 577 } 578 size += getUnknownFields().getSerializedSize(); 579 memoizedSerializedSize = size; 580 return size; 581 } 582 583 private static final long serialVersionUID = 0L; 584 @java.lang.Override 585 protected java.lang.Object writeReplace() 586 throws java.io.ObjectStreamException { 587 return super.writeReplace(); 588 } 589 590 @java.lang.Override 591 public boolean equals(final java.lang.Object obj) { 592 if (obj == this) { 593 return true; 594 } 595 if (!(obj instanceof org.apache.reef.proto.REEFProtocol.REEFMessage)) { 596 return super.equals(obj); 597 } 598 org.apache.reef.proto.REEFProtocol.REEFMessage other = (org.apache.reef.proto.REEFProtocol.REEFMessage) obj; 599 600 boolean result = true; 601 result = result && (hasJobSubmission() == other.hasJobSubmission()); 602 if (hasJobSubmission()) { 603 result = result && getJobSubmission() 604 .equals(other.getJobSubmission()); 605 } 606 result = result && (hasJobControl() == other.hasJobControl()); 607 if (hasJobControl()) { 608 result = result && getJobControl() 609 .equals(other.getJobControl()); 610 } 611 result = result && (hasRuntimeError() == other.hasRuntimeError()); 612 if (hasRuntimeError()) { 613 result = result && getRuntimeError() 614 .equals(other.getRuntimeError()); 615 } 616 result = result && (hasJobStatus() == other.hasJobStatus()); 617 if (hasJobStatus()) { 618 result = result && getJobStatus() 619 .equals(other.getJobStatus()); 620 } 621 result = result && (hasEvaluatorControl() == other.hasEvaluatorControl()); 622 if (hasEvaluatorControl()) { 623 result = result && getEvaluatorControl() 624 .equals(other.getEvaluatorControl()); 625 } 626 result = result && (hasEvaluatorHeartBeat() == other.hasEvaluatorHeartBeat()); 627 if (hasEvaluatorHeartBeat()) { 628 result = result && getEvaluatorHeartBeat() 629 .equals(other.getEvaluatorHeartBeat()); 630 } 631 result = result && 632 getUnknownFields().equals(other.getUnknownFields()); 633 return result; 634 } 635 636 private int memoizedHashCode = 0; 637 @java.lang.Override 638 public int hashCode() { 639 if (memoizedHashCode != 0) { 640 return memoizedHashCode; 641 } 642 int hash = 41; 643 hash = (19 * hash) + getDescriptorForType().hashCode(); 644 if (hasJobSubmission()) { 645 hash = (37 * hash) + JOBSUBMISSION_FIELD_NUMBER; 646 hash = (53 * hash) + getJobSubmission().hashCode(); 647 } 648 if (hasJobControl()) { 649 hash = (37 * hash) + JOBCONTROL_FIELD_NUMBER; 650 hash = (53 * hash) + getJobControl().hashCode(); 651 } 652 if (hasRuntimeError()) { 653 hash = (37 * hash) + RUNTIMEERROR_FIELD_NUMBER; 654 hash = (53 * hash) + getRuntimeError().hashCode(); 655 } 656 if (hasJobStatus()) { 657 hash = (37 * hash) + JOBSTATUS_FIELD_NUMBER; 658 hash = (53 * hash) + getJobStatus().hashCode(); 659 } 660 if (hasEvaluatorControl()) { 661 hash = (37 * hash) + EVALUATORCONTROL_FIELD_NUMBER; 662 hash = (53 * hash) + getEvaluatorControl().hashCode(); 663 } 664 if (hasEvaluatorHeartBeat()) { 665 hash = (37 * hash) + EVALUATORHEARTBEAT_FIELD_NUMBER; 666 hash = (53 * hash) + getEvaluatorHeartBeat().hashCode(); 667 } 668 hash = (29 * hash) + getUnknownFields().hashCode(); 669 memoizedHashCode = hash; 670 return hash; 671 } 672 673 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 674 com.google.protobuf.ByteString data) 675 throws com.google.protobuf.InvalidProtocolBufferException { 676 return PARSER.parseFrom(data); 677 } 678 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 679 com.google.protobuf.ByteString data, 680 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 681 throws com.google.protobuf.InvalidProtocolBufferException { 682 return PARSER.parseFrom(data, extensionRegistry); 683 } 684 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(byte[] data) 685 throws com.google.protobuf.InvalidProtocolBufferException { 686 return PARSER.parseFrom(data); 687 } 688 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 689 byte[] data, 690 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 691 throws com.google.protobuf.InvalidProtocolBufferException { 692 return PARSER.parseFrom(data, extensionRegistry); 693 } 694 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom(java.io.InputStream input) 695 throws java.io.IOException { 696 return PARSER.parseFrom(input); 697 } 698 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 699 java.io.InputStream input, 700 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 701 throws java.io.IOException { 702 return PARSER.parseFrom(input, extensionRegistry); 703 } 704 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseDelimitedFrom(java.io.InputStream input) 705 throws java.io.IOException { 706 return PARSER.parseDelimitedFrom(input); 707 } 708 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseDelimitedFrom( 709 java.io.InputStream input, 710 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 711 throws java.io.IOException { 712 return PARSER.parseDelimitedFrom(input, extensionRegistry); 713 } 714 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 715 com.google.protobuf.CodedInputStream input) 716 throws java.io.IOException { 717 return PARSER.parseFrom(input); 718 } 719 public static org.apache.reef.proto.REEFProtocol.REEFMessage parseFrom( 720 com.google.protobuf.CodedInputStream input, 721 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 722 throws java.io.IOException { 723 return PARSER.parseFrom(input, extensionRegistry); 724 } 725 726 public static Builder newBuilder() { return Builder.create(); } 727 public Builder newBuilderForType() { return newBuilder(); } 728 public static Builder newBuilder(org.apache.reef.proto.REEFProtocol.REEFMessage prototype) { 729 return newBuilder().mergeFrom(prototype); 730 } 731 public Builder toBuilder() { return newBuilder(this); } 732 733 @java.lang.Override 734 protected Builder newBuilderForType( 735 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 736 Builder builder = new Builder(parent); 737 return builder; 738 } 739 /** 740 * Protobuf type {@code REEFMessage} 741 */ 742 public static final class Builder extends 743 com.google.protobuf.GeneratedMessage.Builder<Builder> 744 implements org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder { 745 public static final com.google.protobuf.Descriptors.Descriptor 746 getDescriptor() { 747 return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor; 748 } 749 750 protected com.google.protobuf.GeneratedMessage.FieldAccessorTable 751 internalGetFieldAccessorTable() { 752 return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_fieldAccessorTable 753 .ensureFieldAccessorsInitialized( 754 org.apache.reef.proto.REEFProtocol.REEFMessage.class, org.apache.reef.proto.REEFProtocol.REEFMessage.Builder.class); 755 } 756 757 // Construct using org.apache.reef.proto.REEFProtocol.REEFMessage.newBuilder() 758 private Builder() { 759 maybeForceBuilderInitialization(); 760 } 761 762 private Builder( 763 com.google.protobuf.GeneratedMessage.BuilderParent parent) { 764 super(parent); 765 maybeForceBuilderInitialization(); 766 } 767 private void maybeForceBuilderInitialization() { 768 if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { 769 getJobSubmissionFieldBuilder(); 770 getJobControlFieldBuilder(); 771 getRuntimeErrorFieldBuilder(); 772 getJobStatusFieldBuilder(); 773 getEvaluatorControlFieldBuilder(); 774 getEvaluatorHeartBeatFieldBuilder(); 775 } 776 } 777 private static Builder create() { 778 return new Builder(); 779 } 780 781 public Builder clear() { 782 super.clear(); 783 if (jobSubmissionBuilder_ == null) { 784 jobSubmission_ = org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance(); 785 } else { 786 jobSubmissionBuilder_.clear(); 787 } 788 bitField0_ = (bitField0_ & ~0x00000001); 789 if (jobControlBuilder_ == null) { 790 jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 791 } else { 792 jobControlBuilder_.clear(); 793 } 794 bitField0_ = (bitField0_ & ~0x00000002); 795 if (runtimeErrorBuilder_ == null) { 796 runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance(); 797 } else { 798 runtimeErrorBuilder_.clear(); 799 } 800 bitField0_ = (bitField0_ & ~0x00000004); 801 if (jobStatusBuilder_ == null) { 802 jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance(); 803 } else { 804 jobStatusBuilder_.clear(); 805 } 806 bitField0_ = (bitField0_ & ~0x00000008); 807 if (evaluatorControlBuilder_ == null) { 808 evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance(); 809 } else { 810 evaluatorControlBuilder_.clear(); 811 } 812 bitField0_ = (bitField0_ & ~0x00000010); 813 if (evaluatorHeartBeatBuilder_ == null) { 814 evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance(); 815 } else { 816 evaluatorHeartBeatBuilder_.clear(); 817 } 818 bitField0_ = (bitField0_ & ~0x00000020); 819 return this; 820 } 821 822 public Builder clone() { 823 return create().mergeFrom(buildPartial()); 824 } 825 826 public com.google.protobuf.Descriptors.Descriptor 827 getDescriptorForType() { 828 return org.apache.reef.proto.REEFProtocol.internal_static_REEFMessage_descriptor; 829 } 830 831 public org.apache.reef.proto.REEFProtocol.REEFMessage getDefaultInstanceForType() { 832 return org.apache.reef.proto.REEFProtocol.REEFMessage.getDefaultInstance(); 833 } 834 835 public org.apache.reef.proto.REEFProtocol.REEFMessage build() { 836 org.apache.reef.proto.REEFProtocol.REEFMessage result = buildPartial(); 837 if (!result.isInitialized()) { 838 throw newUninitializedMessageException(result); 839 } 840 return result; 841 } 842 843 public org.apache.reef.proto.REEFProtocol.REEFMessage buildPartial() { 844 org.apache.reef.proto.REEFProtocol.REEFMessage result = new org.apache.reef.proto.REEFProtocol.REEFMessage(this); 845 int from_bitField0_ = bitField0_; 846 int to_bitField0_ = 0; 847 if (((from_bitField0_ & 0x00000001) == 0x00000001)) { 848 to_bitField0_ |= 0x00000001; 849 } 850 if (jobSubmissionBuilder_ == null) { 851 result.jobSubmission_ = jobSubmission_; 852 } else { 853 result.jobSubmission_ = jobSubmissionBuilder_.build(); 854 } 855 if (((from_bitField0_ & 0x00000002) == 0x00000002)) { 856 to_bitField0_ |= 0x00000002; 857 } 858 if (jobControlBuilder_ == null) { 859 result.jobControl_ = jobControl_; 860 } else { 861 result.jobControl_ = jobControlBuilder_.build(); 862 } 863 if (((from_bitField0_ & 0x00000004) == 0x00000004)) { 864 to_bitField0_ |= 0x00000004; 865 } 866 if (runtimeErrorBuilder_ == null) { 867 result.runtimeError_ = runtimeError_; 868 } else { 869 result.runtimeError_ = runtimeErrorBuilder_.build(); 870 } 871 if (((from_bitField0_ & 0x00000008) == 0x00000008)) { 872 to_bitField0_ |= 0x00000008; 873 } 874 if (jobStatusBuilder_ == null) { 875 result.jobStatus_ = jobStatus_; 876 } else { 877 result.jobStatus_ = jobStatusBuilder_.build(); 878 } 879 if (((from_bitField0_ & 0x00000010) == 0x00000010)) { 880 to_bitField0_ |= 0x00000010; 881 } 882 if (evaluatorControlBuilder_ == null) { 883 result.evaluatorControl_ = evaluatorControl_; 884 } else { 885 result.evaluatorControl_ = evaluatorControlBuilder_.build(); 886 } 887 if (((from_bitField0_ & 0x00000020) == 0x00000020)) { 888 to_bitField0_ |= 0x00000020; 889 } 890 if (evaluatorHeartBeatBuilder_ == null) { 891 result.evaluatorHeartBeat_ = evaluatorHeartBeat_; 892 } else { 893 result.evaluatorHeartBeat_ = evaluatorHeartBeatBuilder_.build(); 894 } 895 result.bitField0_ = to_bitField0_; 896 onBuilt(); 897 return result; 898 } 899 900 public Builder mergeFrom(com.google.protobuf.Message other) { 901 if (other instanceof org.apache.reef.proto.REEFProtocol.REEFMessage) { 902 return mergeFrom((org.apache.reef.proto.REEFProtocol.REEFMessage)other); 903 } else { 904 super.mergeFrom(other); 905 return this; 906 } 907 } 908 909 public Builder mergeFrom(org.apache.reef.proto.REEFProtocol.REEFMessage other) { 910 if (other == org.apache.reef.proto.REEFProtocol.REEFMessage.getDefaultInstance()) return this; 911 if (other.hasJobSubmission()) { 912 mergeJobSubmission(other.getJobSubmission()); 913 } 914 if (other.hasJobControl()) { 915 mergeJobControl(other.getJobControl()); 916 } 917 if (other.hasRuntimeError()) { 918 mergeRuntimeError(other.getRuntimeError()); 919 } 920 if (other.hasJobStatus()) { 921 mergeJobStatus(other.getJobStatus()); 922 } 923 if (other.hasEvaluatorControl()) { 924 mergeEvaluatorControl(other.getEvaluatorControl()); 925 } 926 if (other.hasEvaluatorHeartBeat()) { 927 mergeEvaluatorHeartBeat(other.getEvaluatorHeartBeat()); 928 } 929 this.mergeUnknownFields(other.getUnknownFields()); 930 return this; 931 } 932 933 public final boolean isInitialized() { 934 if (hasJobSubmission()) { 935 if (!getJobSubmission().isInitialized()) { 936 937 return false; 938 } 939 } 940 if (hasJobControl()) { 941 if (!getJobControl().isInitialized()) { 942 943 return false; 944 } 945 } 946 if (hasRuntimeError()) { 947 if (!getRuntimeError().isInitialized()) { 948 949 return false; 950 } 951 } 952 if (hasJobStatus()) { 953 if (!getJobStatus().isInitialized()) { 954 955 return false; 956 } 957 } 958 if (hasEvaluatorControl()) { 959 if (!getEvaluatorControl().isInitialized()) { 960 961 return false; 962 } 963 } 964 if (hasEvaluatorHeartBeat()) { 965 if (!getEvaluatorHeartBeat().isInitialized()) { 966 967 return false; 968 } 969 } 970 return true; 971 } 972 973 public Builder mergeFrom( 974 com.google.protobuf.CodedInputStream input, 975 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 976 throws java.io.IOException { 977 org.apache.reef.proto.REEFProtocol.REEFMessage parsedMessage = null; 978 try { 979 parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); 980 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 981 parsedMessage = (org.apache.reef.proto.REEFProtocol.REEFMessage) e.getUnfinishedMessage(); 982 throw e; 983 } finally { 984 if (parsedMessage != null) { 985 mergeFrom(parsedMessage); 986 } 987 } 988 return this; 989 } 990 private int bitField0_; 991 992 // optional .JobSubmissionProto jobSubmission = 1; 993 private org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto jobSubmission_ = org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance(); 994 private com.google.protobuf.SingleFieldBuilder< 995 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder> jobSubmissionBuilder_; 996 /** 997 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 998 * 999 * <pre> 1000 * Messages defined in client_runtime.proto 1001 * </pre> 1002 */ 1003 public boolean hasJobSubmission() { 1004 return ((bitField0_ & 0x00000001) == 0x00000001); 1005 } 1006 /** 1007 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1008 * 1009 * <pre> 1010 * Messages defined in client_runtime.proto 1011 * </pre> 1012 */ 1013 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto getJobSubmission() { 1014 if (jobSubmissionBuilder_ == null) { 1015 return jobSubmission_; 1016 } else { 1017 return jobSubmissionBuilder_.getMessage(); 1018 } 1019 } 1020 /** 1021 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1022 * 1023 * <pre> 1024 * Messages defined in client_runtime.proto 1025 * </pre> 1026 */ 1027 public Builder setJobSubmission(org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto value) { 1028 if (jobSubmissionBuilder_ == null) { 1029 if (value == null) { 1030 throw new NullPointerException(); 1031 } 1032 jobSubmission_ = value; 1033 onChanged(); 1034 } else { 1035 jobSubmissionBuilder_.setMessage(value); 1036 } 1037 bitField0_ |= 0x00000001; 1038 return this; 1039 } 1040 /** 1041 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1042 * 1043 * <pre> 1044 * Messages defined in client_runtime.proto 1045 * </pre> 1046 */ 1047 public Builder setJobSubmission( 1048 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder builderForValue) { 1049 if (jobSubmissionBuilder_ == null) { 1050 jobSubmission_ = builderForValue.build(); 1051 onChanged(); 1052 } else { 1053 jobSubmissionBuilder_.setMessage(builderForValue.build()); 1054 } 1055 bitField0_ |= 0x00000001; 1056 return this; 1057 } 1058 /** 1059 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1060 * 1061 * <pre> 1062 * Messages defined in client_runtime.proto 1063 * </pre> 1064 */ 1065 public Builder mergeJobSubmission(org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto value) { 1066 if (jobSubmissionBuilder_ == null) { 1067 if (((bitField0_ & 0x00000001) == 0x00000001) && 1068 jobSubmission_ != org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance()) { 1069 jobSubmission_ = 1070 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.newBuilder(jobSubmission_).mergeFrom(value).buildPartial(); 1071 } else { 1072 jobSubmission_ = value; 1073 } 1074 onChanged(); 1075 } else { 1076 jobSubmissionBuilder_.mergeFrom(value); 1077 } 1078 bitField0_ |= 0x00000001; 1079 return this; 1080 } 1081 /** 1082 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1083 * 1084 * <pre> 1085 * Messages defined in client_runtime.proto 1086 * </pre> 1087 */ 1088 public Builder clearJobSubmission() { 1089 if (jobSubmissionBuilder_ == null) { 1090 jobSubmission_ = org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.getDefaultInstance(); 1091 onChanged(); 1092 } else { 1093 jobSubmissionBuilder_.clear(); 1094 } 1095 bitField0_ = (bitField0_ & ~0x00000001); 1096 return this; 1097 } 1098 /** 1099 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1100 * 1101 * <pre> 1102 * Messages defined in client_runtime.proto 1103 * </pre> 1104 */ 1105 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder getJobSubmissionBuilder() { 1106 bitField0_ |= 0x00000001; 1107 onChanged(); 1108 return getJobSubmissionFieldBuilder().getBuilder(); 1109 } 1110 /** 1111 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1112 * 1113 * <pre> 1114 * Messages defined in client_runtime.proto 1115 * </pre> 1116 */ 1117 public org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder getJobSubmissionOrBuilder() { 1118 if (jobSubmissionBuilder_ != null) { 1119 return jobSubmissionBuilder_.getMessageOrBuilder(); 1120 } else { 1121 return jobSubmission_; 1122 } 1123 } 1124 /** 1125 * <code>optional .JobSubmissionProto jobSubmission = 1;</code> 1126 * 1127 * <pre> 1128 * Messages defined in client_runtime.proto 1129 * </pre> 1130 */ 1131 private com.google.protobuf.SingleFieldBuilder< 1132 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder> 1133 getJobSubmissionFieldBuilder() { 1134 if (jobSubmissionBuilder_ == null) { 1135 jobSubmissionBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1136 org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder>( 1137 jobSubmission_, 1138 getParentForChildren(), 1139 isClean()); 1140 jobSubmission_ = null; 1141 } 1142 return jobSubmissionBuilder_; 1143 } 1144 1145 // optional .JobControlProto jobControl = 2; 1146 private org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 1147 private com.google.protobuf.SingleFieldBuilder< 1148 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder> jobControlBuilder_; 1149 /** 1150 * <code>optional .JobControlProto jobControl = 2;</code> 1151 */ 1152 public boolean hasJobControl() { 1153 return ((bitField0_ & 0x00000002) == 0x00000002); 1154 } 1155 /** 1156 * <code>optional .JobControlProto jobControl = 2;</code> 1157 */ 1158 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto getJobControl() { 1159 if (jobControlBuilder_ == null) { 1160 return jobControl_; 1161 } else { 1162 return jobControlBuilder_.getMessage(); 1163 } 1164 } 1165 /** 1166 * <code>optional .JobControlProto jobControl = 2;</code> 1167 */ 1168 public Builder setJobControl(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto value) { 1169 if (jobControlBuilder_ == null) { 1170 if (value == null) { 1171 throw new NullPointerException(); 1172 } 1173 jobControl_ = value; 1174 onChanged(); 1175 } else { 1176 jobControlBuilder_.setMessage(value); 1177 } 1178 bitField0_ |= 0x00000002; 1179 return this; 1180 } 1181 /** 1182 * <code>optional .JobControlProto jobControl = 2;</code> 1183 */ 1184 public Builder setJobControl( 1185 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder builderForValue) { 1186 if (jobControlBuilder_ == null) { 1187 jobControl_ = builderForValue.build(); 1188 onChanged(); 1189 } else { 1190 jobControlBuilder_.setMessage(builderForValue.build()); 1191 } 1192 bitField0_ |= 0x00000002; 1193 return this; 1194 } 1195 /** 1196 * <code>optional .JobControlProto jobControl = 2;</code> 1197 */ 1198 public Builder mergeJobControl(org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto value) { 1199 if (jobControlBuilder_ == null) { 1200 if (((bitField0_ & 0x00000002) == 0x00000002) && 1201 jobControl_ != org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance()) { 1202 jobControl_ = 1203 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.newBuilder(jobControl_).mergeFrom(value).buildPartial(); 1204 } else { 1205 jobControl_ = value; 1206 } 1207 onChanged(); 1208 } else { 1209 jobControlBuilder_.mergeFrom(value); 1210 } 1211 bitField0_ |= 0x00000002; 1212 return this; 1213 } 1214 /** 1215 * <code>optional .JobControlProto jobControl = 2;</code> 1216 */ 1217 public Builder clearJobControl() { 1218 if (jobControlBuilder_ == null) { 1219 jobControl_ = org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.getDefaultInstance(); 1220 onChanged(); 1221 } else { 1222 jobControlBuilder_.clear(); 1223 } 1224 bitField0_ = (bitField0_ & ~0x00000002); 1225 return this; 1226 } 1227 /** 1228 * <code>optional .JobControlProto jobControl = 2;</code> 1229 */ 1230 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder getJobControlBuilder() { 1231 bitField0_ |= 0x00000002; 1232 onChanged(); 1233 return getJobControlFieldBuilder().getBuilder(); 1234 } 1235 /** 1236 * <code>optional .JobControlProto jobControl = 2;</code> 1237 */ 1238 public org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder getJobControlOrBuilder() { 1239 if (jobControlBuilder_ != null) { 1240 return jobControlBuilder_.getMessageOrBuilder(); 1241 } else { 1242 return jobControl_; 1243 } 1244 } 1245 /** 1246 * <code>optional .JobControlProto jobControl = 2;</code> 1247 */ 1248 private com.google.protobuf.SingleFieldBuilder< 1249 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder> 1250 getJobControlFieldBuilder() { 1251 if (jobControlBuilder_ == null) { 1252 jobControlBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1253 org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder, org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder>( 1254 jobControl_, 1255 getParentForChildren(), 1256 isClean()); 1257 jobControl_ = null; 1258 } 1259 return jobControlBuilder_; 1260 } 1261 1262 // optional .RuntimeErrorProto runtimeError = 3; 1263 private org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance(); 1264 private com.google.protobuf.SingleFieldBuilder< 1265 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder> runtimeErrorBuilder_; 1266 /** 1267 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1268 * 1269 * <pre> 1270 * Messages defined in reef_service_protos.proto 1271 * </pre> 1272 */ 1273 public boolean hasRuntimeError() { 1274 return ((bitField0_ & 0x00000004) == 0x00000004); 1275 } 1276 /** 1277 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1278 * 1279 * <pre> 1280 * Messages defined in reef_service_protos.proto 1281 * </pre> 1282 */ 1283 public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto getRuntimeError() { 1284 if (runtimeErrorBuilder_ == null) { 1285 return runtimeError_; 1286 } else { 1287 return runtimeErrorBuilder_.getMessage(); 1288 } 1289 } 1290 /** 1291 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1292 * 1293 * <pre> 1294 * Messages defined in reef_service_protos.proto 1295 * </pre> 1296 */ 1297 public Builder setRuntimeError(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto value) { 1298 if (runtimeErrorBuilder_ == null) { 1299 if (value == null) { 1300 throw new NullPointerException(); 1301 } 1302 runtimeError_ = value; 1303 onChanged(); 1304 } else { 1305 runtimeErrorBuilder_.setMessage(value); 1306 } 1307 bitField0_ |= 0x00000004; 1308 return this; 1309 } 1310 /** 1311 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1312 * 1313 * <pre> 1314 * Messages defined in reef_service_protos.proto 1315 * </pre> 1316 */ 1317 public Builder setRuntimeError( 1318 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder builderForValue) { 1319 if (runtimeErrorBuilder_ == null) { 1320 runtimeError_ = builderForValue.build(); 1321 onChanged(); 1322 } else { 1323 runtimeErrorBuilder_.setMessage(builderForValue.build()); 1324 } 1325 bitField0_ |= 0x00000004; 1326 return this; 1327 } 1328 /** 1329 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1330 * 1331 * <pre> 1332 * Messages defined in reef_service_protos.proto 1333 * </pre> 1334 */ 1335 public Builder mergeRuntimeError(org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto value) { 1336 if (runtimeErrorBuilder_ == null) { 1337 if (((bitField0_ & 0x00000004) == 0x00000004) && 1338 runtimeError_ != org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance()) { 1339 runtimeError_ = 1340 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.newBuilder(runtimeError_).mergeFrom(value).buildPartial(); 1341 } else { 1342 runtimeError_ = value; 1343 } 1344 onChanged(); 1345 } else { 1346 runtimeErrorBuilder_.mergeFrom(value); 1347 } 1348 bitField0_ |= 0x00000004; 1349 return this; 1350 } 1351 /** 1352 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1353 * 1354 * <pre> 1355 * Messages defined in reef_service_protos.proto 1356 * </pre> 1357 */ 1358 public Builder clearRuntimeError() { 1359 if (runtimeErrorBuilder_ == null) { 1360 runtimeError_ = org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.getDefaultInstance(); 1361 onChanged(); 1362 } else { 1363 runtimeErrorBuilder_.clear(); 1364 } 1365 bitField0_ = (bitField0_ & ~0x00000004); 1366 return this; 1367 } 1368 /** 1369 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1370 * 1371 * <pre> 1372 * Messages defined in reef_service_protos.proto 1373 * </pre> 1374 */ 1375 public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder getRuntimeErrorBuilder() { 1376 bitField0_ |= 0x00000004; 1377 onChanged(); 1378 return getRuntimeErrorFieldBuilder().getBuilder(); 1379 } 1380 /** 1381 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1382 * 1383 * <pre> 1384 * Messages defined in reef_service_protos.proto 1385 * </pre> 1386 */ 1387 public org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder getRuntimeErrorOrBuilder() { 1388 if (runtimeErrorBuilder_ != null) { 1389 return runtimeErrorBuilder_.getMessageOrBuilder(); 1390 } else { 1391 return runtimeError_; 1392 } 1393 } 1394 /** 1395 * <code>optional .RuntimeErrorProto runtimeError = 3;</code> 1396 * 1397 * <pre> 1398 * Messages defined in reef_service_protos.proto 1399 * </pre> 1400 */ 1401 private com.google.protobuf.SingleFieldBuilder< 1402 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder> 1403 getRuntimeErrorFieldBuilder() { 1404 if (runtimeErrorBuilder_ == null) { 1405 runtimeErrorBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1406 org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder, org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder>( 1407 runtimeError_, 1408 getParentForChildren(), 1409 isClean()); 1410 runtimeError_ = null; 1411 } 1412 return runtimeErrorBuilder_; 1413 } 1414 1415 // optional .JobStatusProto jobStatus = 4; 1416 private org.apache.reef.proto.ReefServiceProtos.JobStatusProto jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance(); 1417 private com.google.protobuf.SingleFieldBuilder< 1418 org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder> jobStatusBuilder_; 1419 /** 1420 * <code>optional .JobStatusProto jobStatus = 4;</code> 1421 */ 1422 public boolean hasJobStatus() { 1423 return ((bitField0_ & 0x00000008) == 0x00000008); 1424 } 1425 /** 1426 * <code>optional .JobStatusProto jobStatus = 4;</code> 1427 */ 1428 public org.apache.reef.proto.ReefServiceProtos.JobStatusProto getJobStatus() { 1429 if (jobStatusBuilder_ == null) { 1430 return jobStatus_; 1431 } else { 1432 return jobStatusBuilder_.getMessage(); 1433 } 1434 } 1435 /** 1436 * <code>optional .JobStatusProto jobStatus = 4;</code> 1437 */ 1438 public Builder setJobStatus(org.apache.reef.proto.ReefServiceProtos.JobStatusProto value) { 1439 if (jobStatusBuilder_ == null) { 1440 if (value == null) { 1441 throw new NullPointerException(); 1442 } 1443 jobStatus_ = value; 1444 onChanged(); 1445 } else { 1446 jobStatusBuilder_.setMessage(value); 1447 } 1448 bitField0_ |= 0x00000008; 1449 return this; 1450 } 1451 /** 1452 * <code>optional .JobStatusProto jobStatus = 4;</code> 1453 */ 1454 public Builder setJobStatus( 1455 org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder builderForValue) { 1456 if (jobStatusBuilder_ == null) { 1457 jobStatus_ = builderForValue.build(); 1458 onChanged(); 1459 } else { 1460 jobStatusBuilder_.setMessage(builderForValue.build()); 1461 } 1462 bitField0_ |= 0x00000008; 1463 return this; 1464 } 1465 /** 1466 * <code>optional .JobStatusProto jobStatus = 4;</code> 1467 */ 1468 public Builder mergeJobStatus(org.apache.reef.proto.ReefServiceProtos.JobStatusProto value) { 1469 if (jobStatusBuilder_ == null) { 1470 if (((bitField0_ & 0x00000008) == 0x00000008) && 1471 jobStatus_ != org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance()) { 1472 jobStatus_ = 1473 org.apache.reef.proto.ReefServiceProtos.JobStatusProto.newBuilder(jobStatus_).mergeFrom(value).buildPartial(); 1474 } else { 1475 jobStatus_ = value; 1476 } 1477 onChanged(); 1478 } else { 1479 jobStatusBuilder_.mergeFrom(value); 1480 } 1481 bitField0_ |= 0x00000008; 1482 return this; 1483 } 1484 /** 1485 * <code>optional .JobStatusProto jobStatus = 4;</code> 1486 */ 1487 public Builder clearJobStatus() { 1488 if (jobStatusBuilder_ == null) { 1489 jobStatus_ = org.apache.reef.proto.ReefServiceProtos.JobStatusProto.getDefaultInstance(); 1490 onChanged(); 1491 } else { 1492 jobStatusBuilder_.clear(); 1493 } 1494 bitField0_ = (bitField0_ & ~0x00000008); 1495 return this; 1496 } 1497 /** 1498 * <code>optional .JobStatusProto jobStatus = 4;</code> 1499 */ 1500 public org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder getJobStatusBuilder() { 1501 bitField0_ |= 0x00000008; 1502 onChanged(); 1503 return getJobStatusFieldBuilder().getBuilder(); 1504 } 1505 /** 1506 * <code>optional .JobStatusProto jobStatus = 4;</code> 1507 */ 1508 public org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder getJobStatusOrBuilder() { 1509 if (jobStatusBuilder_ != null) { 1510 return jobStatusBuilder_.getMessageOrBuilder(); 1511 } else { 1512 return jobStatus_; 1513 } 1514 } 1515 /** 1516 * <code>optional .JobStatusProto jobStatus = 4;</code> 1517 */ 1518 private com.google.protobuf.SingleFieldBuilder< 1519 org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder> 1520 getJobStatusFieldBuilder() { 1521 if (jobStatusBuilder_ == null) { 1522 jobStatusBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1523 org.apache.reef.proto.ReefServiceProtos.JobStatusProto, org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder, org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder>( 1524 jobStatus_, 1525 getParentForChildren(), 1526 isClean()); 1527 jobStatus_ = null; 1528 } 1529 return jobStatusBuilder_; 1530 } 1531 1532 // optional .EvaluatorControlProto evaluatorControl = 5; 1533 private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance(); 1534 private com.google.protobuf.SingleFieldBuilder< 1535 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder> evaluatorControlBuilder_; 1536 /** 1537 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1538 * 1539 * <pre> 1540 * Messages from evaluator_runtime.proto 1541 * </pre> 1542 */ 1543 public boolean hasEvaluatorControl() { 1544 return ((bitField0_ & 0x00000010) == 0x00000010); 1545 } 1546 /** 1547 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1548 * 1549 * <pre> 1550 * Messages from evaluator_runtime.proto 1551 * </pre> 1552 */ 1553 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto getEvaluatorControl() { 1554 if (evaluatorControlBuilder_ == null) { 1555 return evaluatorControl_; 1556 } else { 1557 return evaluatorControlBuilder_.getMessage(); 1558 } 1559 } 1560 /** 1561 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1562 * 1563 * <pre> 1564 * Messages from evaluator_runtime.proto 1565 * </pre> 1566 */ 1567 public Builder setEvaluatorControl(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto value) { 1568 if (evaluatorControlBuilder_ == null) { 1569 if (value == null) { 1570 throw new NullPointerException(); 1571 } 1572 evaluatorControl_ = value; 1573 onChanged(); 1574 } else { 1575 evaluatorControlBuilder_.setMessage(value); 1576 } 1577 bitField0_ |= 0x00000010; 1578 return this; 1579 } 1580 /** 1581 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1582 * 1583 * <pre> 1584 * Messages from evaluator_runtime.proto 1585 * </pre> 1586 */ 1587 public Builder setEvaluatorControl( 1588 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder builderForValue) { 1589 if (evaluatorControlBuilder_ == null) { 1590 evaluatorControl_ = builderForValue.build(); 1591 onChanged(); 1592 } else { 1593 evaluatorControlBuilder_.setMessage(builderForValue.build()); 1594 } 1595 bitField0_ |= 0x00000010; 1596 return this; 1597 } 1598 /** 1599 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1600 * 1601 * <pre> 1602 * Messages from evaluator_runtime.proto 1603 * </pre> 1604 */ 1605 public Builder mergeEvaluatorControl(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto value) { 1606 if (evaluatorControlBuilder_ == null) { 1607 if (((bitField0_ & 0x00000010) == 0x00000010) && 1608 evaluatorControl_ != org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance()) { 1609 evaluatorControl_ = 1610 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.newBuilder(evaluatorControl_).mergeFrom(value).buildPartial(); 1611 } else { 1612 evaluatorControl_ = value; 1613 } 1614 onChanged(); 1615 } else { 1616 evaluatorControlBuilder_.mergeFrom(value); 1617 } 1618 bitField0_ |= 0x00000010; 1619 return this; 1620 } 1621 /** 1622 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1623 * 1624 * <pre> 1625 * Messages from evaluator_runtime.proto 1626 * </pre> 1627 */ 1628 public Builder clearEvaluatorControl() { 1629 if (evaluatorControlBuilder_ == null) { 1630 evaluatorControl_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.getDefaultInstance(); 1631 onChanged(); 1632 } else { 1633 evaluatorControlBuilder_.clear(); 1634 } 1635 bitField0_ = (bitField0_ & ~0x00000010); 1636 return this; 1637 } 1638 /** 1639 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1640 * 1641 * <pre> 1642 * Messages from evaluator_runtime.proto 1643 * </pre> 1644 */ 1645 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder getEvaluatorControlBuilder() { 1646 bitField0_ |= 0x00000010; 1647 onChanged(); 1648 return getEvaluatorControlFieldBuilder().getBuilder(); 1649 } 1650 /** 1651 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1652 * 1653 * <pre> 1654 * Messages from evaluator_runtime.proto 1655 * </pre> 1656 */ 1657 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder getEvaluatorControlOrBuilder() { 1658 if (evaluatorControlBuilder_ != null) { 1659 return evaluatorControlBuilder_.getMessageOrBuilder(); 1660 } else { 1661 return evaluatorControl_; 1662 } 1663 } 1664 /** 1665 * <code>optional .EvaluatorControlProto evaluatorControl = 5;</code> 1666 * 1667 * <pre> 1668 * Messages from evaluator_runtime.proto 1669 * </pre> 1670 */ 1671 private com.google.protobuf.SingleFieldBuilder< 1672 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder> 1673 getEvaluatorControlFieldBuilder() { 1674 if (evaluatorControlBuilder_ == null) { 1675 evaluatorControlBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1676 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder>( 1677 evaluatorControl_, 1678 getParentForChildren(), 1679 isClean()); 1680 evaluatorControl_ = null; 1681 } 1682 return evaluatorControlBuilder_; 1683 } 1684 1685 // optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6; 1686 private org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance(); 1687 private com.google.protobuf.SingleFieldBuilder< 1688 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder> evaluatorHeartBeatBuilder_; 1689 /** 1690 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1691 */ 1692 public boolean hasEvaluatorHeartBeat() { 1693 return ((bitField0_ & 0x00000020) == 0x00000020); 1694 } 1695 /** 1696 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1697 */ 1698 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto getEvaluatorHeartBeat() { 1699 if (evaluatorHeartBeatBuilder_ == null) { 1700 return evaluatorHeartBeat_; 1701 } else { 1702 return evaluatorHeartBeatBuilder_.getMessage(); 1703 } 1704 } 1705 /** 1706 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1707 */ 1708 public Builder setEvaluatorHeartBeat(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto value) { 1709 if (evaluatorHeartBeatBuilder_ == null) { 1710 if (value == null) { 1711 throw new NullPointerException(); 1712 } 1713 evaluatorHeartBeat_ = value; 1714 onChanged(); 1715 } else { 1716 evaluatorHeartBeatBuilder_.setMessage(value); 1717 } 1718 bitField0_ |= 0x00000020; 1719 return this; 1720 } 1721 /** 1722 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1723 */ 1724 public Builder setEvaluatorHeartBeat( 1725 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder builderForValue) { 1726 if (evaluatorHeartBeatBuilder_ == null) { 1727 evaluatorHeartBeat_ = builderForValue.build(); 1728 onChanged(); 1729 } else { 1730 evaluatorHeartBeatBuilder_.setMessage(builderForValue.build()); 1731 } 1732 bitField0_ |= 0x00000020; 1733 return this; 1734 } 1735 /** 1736 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1737 */ 1738 public Builder mergeEvaluatorHeartBeat(org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto value) { 1739 if (evaluatorHeartBeatBuilder_ == null) { 1740 if (((bitField0_ & 0x00000020) == 0x00000020) && 1741 evaluatorHeartBeat_ != org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance()) { 1742 evaluatorHeartBeat_ = 1743 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.newBuilder(evaluatorHeartBeat_).mergeFrom(value).buildPartial(); 1744 } else { 1745 evaluatorHeartBeat_ = value; 1746 } 1747 onChanged(); 1748 } else { 1749 evaluatorHeartBeatBuilder_.mergeFrom(value); 1750 } 1751 bitField0_ |= 0x00000020; 1752 return this; 1753 } 1754 /** 1755 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1756 */ 1757 public Builder clearEvaluatorHeartBeat() { 1758 if (evaluatorHeartBeatBuilder_ == null) { 1759 evaluatorHeartBeat_ = org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getDefaultInstance(); 1760 onChanged(); 1761 } else { 1762 evaluatorHeartBeatBuilder_.clear(); 1763 } 1764 bitField0_ = (bitField0_ & ~0x00000020); 1765 return this; 1766 } 1767 /** 1768 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1769 */ 1770 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder getEvaluatorHeartBeatBuilder() { 1771 bitField0_ |= 0x00000020; 1772 onChanged(); 1773 return getEvaluatorHeartBeatFieldBuilder().getBuilder(); 1774 } 1775 /** 1776 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1777 */ 1778 public org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder getEvaluatorHeartBeatOrBuilder() { 1779 if (evaluatorHeartBeatBuilder_ != null) { 1780 return evaluatorHeartBeatBuilder_.getMessageOrBuilder(); 1781 } else { 1782 return evaluatorHeartBeat_; 1783 } 1784 } 1785 /** 1786 * <code>optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;</code> 1787 */ 1788 private com.google.protobuf.SingleFieldBuilder< 1789 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder> 1790 getEvaluatorHeartBeatFieldBuilder() { 1791 if (evaluatorHeartBeatBuilder_ == null) { 1792 evaluatorHeartBeatBuilder_ = new com.google.protobuf.SingleFieldBuilder< 1793 org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder, org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder>( 1794 evaluatorHeartBeat_, 1795 getParentForChildren(), 1796 isClean()); 1797 evaluatorHeartBeat_ = null; 1798 } 1799 return evaluatorHeartBeatBuilder_; 1800 } 1801 1802 // @@protoc_insertion_point(builder_scope:REEFMessage) 1803 } 1804 1805 static { 1806 defaultInstance = new REEFMessage(true); 1807 defaultInstance.initFields(); 1808 } 1809 1810 // @@protoc_insertion_point(class_scope:REEFMessage) 1811 } 1812 1813 private static com.google.protobuf.Descriptors.Descriptor 1814 internal_static_REEFMessage_descriptor; 1815 private static 1816 com.google.protobuf.GeneratedMessage.FieldAccessorTable 1817 internal_static_REEFMessage_fieldAccessorTable; 1818 1819 public static com.google.protobuf.Descriptors.FileDescriptor 1820 getDescriptor() { 1821 return descriptor; 1822 } 1823 private static com.google.protobuf.Descriptors.FileDescriptor 1824 descriptor; 1825 static { 1826 java.lang.String[] descriptorData = { 1827 "\n\023reef_protocol.proto\032\024client_runtime.pr" + 1828 "oto\032\027evaluator_runtime.proto\032\031reef_servi" + 1829 "ce_protos.proto\"\225\002\n\013REEFMessage\022*\n\rjobSu" + 1830 "bmission\030\001 \001(\0132\023.JobSubmissionProto\022$\n\nj" + 1831 "obControl\030\002 \001(\0132\020.JobControlProto\022(\n\014run" + 1832 "timeError\030\003 \001(\0132\022.RuntimeErrorProto\022\"\n\tj" + 1833 "obStatus\030\004 \001(\0132\017.JobStatusProto\0220\n\020evalu" + 1834 "atorControl\030\005 \001(\0132\026.EvaluatorControlProt" + 1835 "o\0224\n\022evaluatorHeartBeat\030\006 \001(\0132\030.Evaluato" + 1836 "rHeartbeatProtoB+\n\025org.apache.reef.proto", 1837 "B\014REEFProtocol\210\001\001\240\001\001" 1838 }; 1839 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 1840 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 1841 public com.google.protobuf.ExtensionRegistry assignDescriptors( 1842 com.google.protobuf.Descriptors.FileDescriptor root) { 1843 descriptor = root; 1844 internal_static_REEFMessage_descriptor = 1845 getDescriptor().getMessageTypes().get(0); 1846 internal_static_REEFMessage_fieldAccessorTable = new 1847 com.google.protobuf.GeneratedMessage.FieldAccessorTable( 1848 internal_static_REEFMessage_descriptor, 1849 new java.lang.String[] { "JobSubmission", "JobControl", "RuntimeError", "JobStatus", "EvaluatorControl", "EvaluatorHeartBeat", }); 1850 return null; 1851 } 1852 }; 1853 com.google.protobuf.Descriptors.FileDescriptor 1854 .internalBuildGeneratedFileFrom(descriptorData, 1855 new com.google.protobuf.Descriptors.FileDescriptor[] { 1856 org.apache.reef.proto.ClientRuntimeProtocol.getDescriptor(), 1857 org.apache.reef.proto.EvaluatorRuntimeProtocol.getDescriptor(), 1858 org.apache.reef.proto.ReefServiceProtos.getDescriptor(), 1859 }, assigner); 1860 } 1861 1862 // @@protoc_insertion_point(outer_class_scope) 1863}