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