1 /* 2 * Copyright 2020 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 // Generated by the protocol buffer compiler. DO NOT EDIT! 17 // source: google/cloud/dataproc/v1/jobs.proto 18 19 package com.google.cloud.dataproc.v1; 20 21 /** 22 * 23 * 24 * <pre> 25 * A Dataproc job for running [Apache Spark](https://spark.apache.org/) 26 * applications on YARN. 27 * </pre> 28 * 29 * Protobuf type {@code google.cloud.dataproc.v1.SparkJob} 30 */ 31 public final class SparkJob extends com.google.protobuf.GeneratedMessageV3 32 implements 33 // @@protoc_insertion_point(message_implements:google.cloud.dataproc.v1.SparkJob) 34 SparkJobOrBuilder { 35 private static final long serialVersionUID = 0L; 36 // Use SparkJob.newBuilder() to construct. SparkJob(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)37 private SparkJob(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { 38 super(builder); 39 } 40 SparkJob()41 private SparkJob() { 42 args_ = com.google.protobuf.LazyStringArrayList.EMPTY; 43 jarFileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 44 fileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 45 archiveUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 46 } 47 48 @java.lang.Override 49 @SuppressWarnings({"unused"}) newInstance(UnusedPrivateParameter unused)50 protected java.lang.Object newInstance(UnusedPrivateParameter unused) { 51 return new SparkJob(); 52 } 53 54 @java.lang.Override getUnknownFields()55 public final com.google.protobuf.UnknownFieldSet getUnknownFields() { 56 return this.unknownFields; 57 } 58 getDescriptor()59 public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { 60 return com.google.cloud.dataproc.v1.JobsProto 61 .internal_static_google_cloud_dataproc_v1_SparkJob_descriptor; 62 } 63 64 @SuppressWarnings({"rawtypes"}) 65 @java.lang.Override internalGetMapField(int number)66 protected com.google.protobuf.MapField internalGetMapField(int number) { 67 switch (number) { 68 case 7: 69 return internalGetProperties(); 70 default: 71 throw new RuntimeException("Invalid map field number: " + number); 72 } 73 } 74 75 @java.lang.Override 76 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()77 internalGetFieldAccessorTable() { 78 return com.google.cloud.dataproc.v1.JobsProto 79 .internal_static_google_cloud_dataproc_v1_SparkJob_fieldAccessorTable 80 .ensureFieldAccessorsInitialized( 81 com.google.cloud.dataproc.v1.SparkJob.class, 82 com.google.cloud.dataproc.v1.SparkJob.Builder.class); 83 } 84 85 private int driverCase_ = 0; 86 private java.lang.Object driver_; 87 88 public enum DriverCase 89 implements 90 com.google.protobuf.Internal.EnumLite, 91 com.google.protobuf.AbstractMessage.InternalOneOfEnum { 92 MAIN_JAR_FILE_URI(1), 93 MAIN_CLASS(2), 94 DRIVER_NOT_SET(0); 95 private final int value; 96 DriverCase(int value)97 private DriverCase(int value) { 98 this.value = value; 99 } 100 /** 101 * @param value The number of the enum to look for. 102 * @return The enum associated with the given number. 103 * @deprecated Use {@link #forNumber(int)} instead. 104 */ 105 @java.lang.Deprecated valueOf(int value)106 public static DriverCase valueOf(int value) { 107 return forNumber(value); 108 } 109 forNumber(int value)110 public static DriverCase forNumber(int value) { 111 switch (value) { 112 case 1: 113 return MAIN_JAR_FILE_URI; 114 case 2: 115 return MAIN_CLASS; 116 case 0: 117 return DRIVER_NOT_SET; 118 default: 119 return null; 120 } 121 } 122 getNumber()123 public int getNumber() { 124 return this.value; 125 } 126 }; 127 getDriverCase()128 public DriverCase getDriverCase() { 129 return DriverCase.forNumber(driverCase_); 130 } 131 132 public static final int MAIN_JAR_FILE_URI_FIELD_NUMBER = 1; 133 /** 134 * 135 * 136 * <pre> 137 * The HCFS URI of the jar file that contains the main class. 138 * </pre> 139 * 140 * <code>string main_jar_file_uri = 1;</code> 141 * 142 * @return Whether the mainJarFileUri field is set. 143 */ hasMainJarFileUri()144 public boolean hasMainJarFileUri() { 145 return driverCase_ == 1; 146 } 147 /** 148 * 149 * 150 * <pre> 151 * The HCFS URI of the jar file that contains the main class. 152 * </pre> 153 * 154 * <code>string main_jar_file_uri = 1;</code> 155 * 156 * @return The mainJarFileUri. 157 */ getMainJarFileUri()158 public java.lang.String getMainJarFileUri() { 159 java.lang.Object ref = ""; 160 if (driverCase_ == 1) { 161 ref = driver_; 162 } 163 if (ref instanceof java.lang.String) { 164 return (java.lang.String) ref; 165 } else { 166 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 167 java.lang.String s = bs.toStringUtf8(); 168 if (driverCase_ == 1) { 169 driver_ = s; 170 } 171 return s; 172 } 173 } 174 /** 175 * 176 * 177 * <pre> 178 * The HCFS URI of the jar file that contains the main class. 179 * </pre> 180 * 181 * <code>string main_jar_file_uri = 1;</code> 182 * 183 * @return The bytes for mainJarFileUri. 184 */ getMainJarFileUriBytes()185 public com.google.protobuf.ByteString getMainJarFileUriBytes() { 186 java.lang.Object ref = ""; 187 if (driverCase_ == 1) { 188 ref = driver_; 189 } 190 if (ref instanceof java.lang.String) { 191 com.google.protobuf.ByteString b = 192 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 193 if (driverCase_ == 1) { 194 driver_ = b; 195 } 196 return b; 197 } else { 198 return (com.google.protobuf.ByteString) ref; 199 } 200 } 201 202 public static final int MAIN_CLASS_FIELD_NUMBER = 2; 203 /** 204 * 205 * 206 * <pre> 207 * The name of the driver's main class. The jar file that contains the class 208 * must be in the default CLASSPATH or specified in `jar_file_uris`. 209 * </pre> 210 * 211 * <code>string main_class = 2;</code> 212 * 213 * @return Whether the mainClass field is set. 214 */ hasMainClass()215 public boolean hasMainClass() { 216 return driverCase_ == 2; 217 } 218 /** 219 * 220 * 221 * <pre> 222 * The name of the driver's main class. The jar file that contains the class 223 * must be in the default CLASSPATH or specified in `jar_file_uris`. 224 * </pre> 225 * 226 * <code>string main_class = 2;</code> 227 * 228 * @return The mainClass. 229 */ getMainClass()230 public java.lang.String getMainClass() { 231 java.lang.Object ref = ""; 232 if (driverCase_ == 2) { 233 ref = driver_; 234 } 235 if (ref instanceof java.lang.String) { 236 return (java.lang.String) ref; 237 } else { 238 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 239 java.lang.String s = bs.toStringUtf8(); 240 if (driverCase_ == 2) { 241 driver_ = s; 242 } 243 return s; 244 } 245 } 246 /** 247 * 248 * 249 * <pre> 250 * The name of the driver's main class. The jar file that contains the class 251 * must be in the default CLASSPATH or specified in `jar_file_uris`. 252 * </pre> 253 * 254 * <code>string main_class = 2;</code> 255 * 256 * @return The bytes for mainClass. 257 */ getMainClassBytes()258 public com.google.protobuf.ByteString getMainClassBytes() { 259 java.lang.Object ref = ""; 260 if (driverCase_ == 2) { 261 ref = driver_; 262 } 263 if (ref instanceof java.lang.String) { 264 com.google.protobuf.ByteString b = 265 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 266 if (driverCase_ == 2) { 267 driver_ = b; 268 } 269 return b; 270 } else { 271 return (com.google.protobuf.ByteString) ref; 272 } 273 } 274 275 public static final int ARGS_FIELD_NUMBER = 3; 276 277 @SuppressWarnings("serial") 278 private com.google.protobuf.LazyStringList args_; 279 /** 280 * 281 * 282 * <pre> 283 * Optional. The arguments to pass to the driver. Do not include arguments, 284 * such as `--conf`, that can be set as job properties, since a collision may 285 * occur that causes an incorrect job submission. 286 * </pre> 287 * 288 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 289 * 290 * @return A list containing the args. 291 */ getArgsList()292 public com.google.protobuf.ProtocolStringList getArgsList() { 293 return args_; 294 } 295 /** 296 * 297 * 298 * <pre> 299 * Optional. The arguments to pass to the driver. Do not include arguments, 300 * such as `--conf`, that can be set as job properties, since a collision may 301 * occur that causes an incorrect job submission. 302 * </pre> 303 * 304 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 305 * 306 * @return The count of args. 307 */ getArgsCount()308 public int getArgsCount() { 309 return args_.size(); 310 } 311 /** 312 * 313 * 314 * <pre> 315 * Optional. The arguments to pass to the driver. Do not include arguments, 316 * such as `--conf`, that can be set as job properties, since a collision may 317 * occur that causes an incorrect job submission. 318 * </pre> 319 * 320 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 321 * 322 * @param index The index of the element to return. 323 * @return The args at the given index. 324 */ getArgs(int index)325 public java.lang.String getArgs(int index) { 326 return args_.get(index); 327 } 328 /** 329 * 330 * 331 * <pre> 332 * Optional. The arguments to pass to the driver. Do not include arguments, 333 * such as `--conf`, that can be set as job properties, since a collision may 334 * occur that causes an incorrect job submission. 335 * </pre> 336 * 337 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 338 * 339 * @param index The index of the value to return. 340 * @return The bytes of the args at the given index. 341 */ getArgsBytes(int index)342 public com.google.protobuf.ByteString getArgsBytes(int index) { 343 return args_.getByteString(index); 344 } 345 346 public static final int JAR_FILE_URIS_FIELD_NUMBER = 4; 347 348 @SuppressWarnings("serial") 349 private com.google.protobuf.LazyStringList jarFileUris_; 350 /** 351 * 352 * 353 * <pre> 354 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 355 * Spark driver and tasks. 356 * </pre> 357 * 358 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 359 * 360 * @return A list containing the jarFileUris. 361 */ getJarFileUrisList()362 public com.google.protobuf.ProtocolStringList getJarFileUrisList() { 363 return jarFileUris_; 364 } 365 /** 366 * 367 * 368 * <pre> 369 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 370 * Spark driver and tasks. 371 * </pre> 372 * 373 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 374 * 375 * @return The count of jarFileUris. 376 */ getJarFileUrisCount()377 public int getJarFileUrisCount() { 378 return jarFileUris_.size(); 379 } 380 /** 381 * 382 * 383 * <pre> 384 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 385 * Spark driver and tasks. 386 * </pre> 387 * 388 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 389 * 390 * @param index The index of the element to return. 391 * @return The jarFileUris at the given index. 392 */ getJarFileUris(int index)393 public java.lang.String getJarFileUris(int index) { 394 return jarFileUris_.get(index); 395 } 396 /** 397 * 398 * 399 * <pre> 400 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 401 * Spark driver and tasks. 402 * </pre> 403 * 404 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 405 * 406 * @param index The index of the value to return. 407 * @return The bytes of the jarFileUris at the given index. 408 */ getJarFileUrisBytes(int index)409 public com.google.protobuf.ByteString getJarFileUrisBytes(int index) { 410 return jarFileUris_.getByteString(index); 411 } 412 413 public static final int FILE_URIS_FIELD_NUMBER = 5; 414 415 @SuppressWarnings("serial") 416 private com.google.protobuf.LazyStringList fileUris_; 417 /** 418 * 419 * 420 * <pre> 421 * Optional. HCFS URIs of files to be placed in the working directory of 422 * each executor. Useful for naively parallel tasks. 423 * </pre> 424 * 425 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 426 * 427 * @return A list containing the fileUris. 428 */ getFileUrisList()429 public com.google.protobuf.ProtocolStringList getFileUrisList() { 430 return fileUris_; 431 } 432 /** 433 * 434 * 435 * <pre> 436 * Optional. HCFS URIs of files to be placed in the working directory of 437 * each executor. Useful for naively parallel tasks. 438 * </pre> 439 * 440 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 441 * 442 * @return The count of fileUris. 443 */ getFileUrisCount()444 public int getFileUrisCount() { 445 return fileUris_.size(); 446 } 447 /** 448 * 449 * 450 * <pre> 451 * Optional. HCFS URIs of files to be placed in the working directory of 452 * each executor. Useful for naively parallel tasks. 453 * </pre> 454 * 455 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 456 * 457 * @param index The index of the element to return. 458 * @return The fileUris at the given index. 459 */ getFileUris(int index)460 public java.lang.String getFileUris(int index) { 461 return fileUris_.get(index); 462 } 463 /** 464 * 465 * 466 * <pre> 467 * Optional. HCFS URIs of files to be placed in the working directory of 468 * each executor. Useful for naively parallel tasks. 469 * </pre> 470 * 471 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 472 * 473 * @param index The index of the value to return. 474 * @return The bytes of the fileUris at the given index. 475 */ getFileUrisBytes(int index)476 public com.google.protobuf.ByteString getFileUrisBytes(int index) { 477 return fileUris_.getByteString(index); 478 } 479 480 public static final int ARCHIVE_URIS_FIELD_NUMBER = 6; 481 482 @SuppressWarnings("serial") 483 private com.google.protobuf.LazyStringList archiveUris_; 484 /** 485 * 486 * 487 * <pre> 488 * Optional. HCFS URIs of archives to be extracted into the working directory 489 * of each executor. Supported file types: 490 * .jar, .tar, .tar.gz, .tgz, and .zip. 491 * </pre> 492 * 493 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 494 * 495 * @return A list containing the archiveUris. 496 */ getArchiveUrisList()497 public com.google.protobuf.ProtocolStringList getArchiveUrisList() { 498 return archiveUris_; 499 } 500 /** 501 * 502 * 503 * <pre> 504 * Optional. HCFS URIs of archives to be extracted into the working directory 505 * of each executor. Supported file types: 506 * .jar, .tar, .tar.gz, .tgz, and .zip. 507 * </pre> 508 * 509 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 510 * 511 * @return The count of archiveUris. 512 */ getArchiveUrisCount()513 public int getArchiveUrisCount() { 514 return archiveUris_.size(); 515 } 516 /** 517 * 518 * 519 * <pre> 520 * Optional. HCFS URIs of archives to be extracted into the working directory 521 * of each executor. Supported file types: 522 * .jar, .tar, .tar.gz, .tgz, and .zip. 523 * </pre> 524 * 525 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 526 * 527 * @param index The index of the element to return. 528 * @return The archiveUris at the given index. 529 */ getArchiveUris(int index)530 public java.lang.String getArchiveUris(int index) { 531 return archiveUris_.get(index); 532 } 533 /** 534 * 535 * 536 * <pre> 537 * Optional. HCFS URIs of archives to be extracted into the working directory 538 * of each executor. Supported file types: 539 * .jar, .tar, .tar.gz, .tgz, and .zip. 540 * </pre> 541 * 542 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 543 * 544 * @param index The index of the value to return. 545 * @return The bytes of the archiveUris at the given index. 546 */ getArchiveUrisBytes(int index)547 public com.google.protobuf.ByteString getArchiveUrisBytes(int index) { 548 return archiveUris_.getByteString(index); 549 } 550 551 public static final int PROPERTIES_FIELD_NUMBER = 7; 552 553 private static final class PropertiesDefaultEntryHolder { 554 static final com.google.protobuf.MapEntry<java.lang.String, java.lang.String> defaultEntry = 555 com.google.protobuf.MapEntry.<java.lang.String, java.lang.String>newDefaultInstance( 556 com.google.cloud.dataproc.v1.JobsProto 557 .internal_static_google_cloud_dataproc_v1_SparkJob_PropertiesEntry_descriptor, 558 com.google.protobuf.WireFormat.FieldType.STRING, 559 "", 560 com.google.protobuf.WireFormat.FieldType.STRING, 561 ""); 562 } 563 564 @SuppressWarnings("serial") 565 private com.google.protobuf.MapField<java.lang.String, java.lang.String> properties_; 566 internalGetProperties()567 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetProperties() { 568 if (properties_ == null) { 569 return com.google.protobuf.MapField.emptyMapField(PropertiesDefaultEntryHolder.defaultEntry); 570 } 571 return properties_; 572 } 573 getPropertiesCount()574 public int getPropertiesCount() { 575 return internalGetProperties().getMap().size(); 576 } 577 /** 578 * 579 * 580 * <pre> 581 * Optional. A mapping of property names to values, used to configure Spark. 582 * Properties that conflict with values set by the Dataproc API may be 583 * overwritten. Can include properties set in 584 * /etc/spark/conf/spark-defaults.conf and classes in user code. 585 * </pre> 586 * 587 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 588 * </code> 589 */ 590 @java.lang.Override containsProperties(java.lang.String key)591 public boolean containsProperties(java.lang.String key) { 592 if (key == null) { 593 throw new NullPointerException("map key"); 594 } 595 return internalGetProperties().getMap().containsKey(key); 596 } 597 /** Use {@link #getPropertiesMap()} instead. */ 598 @java.lang.Override 599 @java.lang.Deprecated getProperties()600 public java.util.Map<java.lang.String, java.lang.String> getProperties() { 601 return getPropertiesMap(); 602 } 603 /** 604 * 605 * 606 * <pre> 607 * Optional. A mapping of property names to values, used to configure Spark. 608 * Properties that conflict with values set by the Dataproc API may be 609 * overwritten. Can include properties set in 610 * /etc/spark/conf/spark-defaults.conf and classes in user code. 611 * </pre> 612 * 613 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 614 * </code> 615 */ 616 @java.lang.Override getPropertiesMap()617 public java.util.Map<java.lang.String, java.lang.String> getPropertiesMap() { 618 return internalGetProperties().getMap(); 619 } 620 /** 621 * 622 * 623 * <pre> 624 * Optional. A mapping of property names to values, used to configure Spark. 625 * Properties that conflict with values set by the Dataproc API may be 626 * overwritten. Can include properties set in 627 * /etc/spark/conf/spark-defaults.conf and classes in user code. 628 * </pre> 629 * 630 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 631 * </code> 632 */ 633 @java.lang.Override getPropertiesOrDefault( java.lang.String key, java.lang.String defaultValue)634 public /* nullable */ java.lang.String getPropertiesOrDefault( 635 java.lang.String key, 636 /* nullable */ 637 java.lang.String defaultValue) { 638 if (key == null) { 639 throw new NullPointerException("map key"); 640 } 641 java.util.Map<java.lang.String, java.lang.String> map = internalGetProperties().getMap(); 642 return map.containsKey(key) ? map.get(key) : defaultValue; 643 } 644 /** 645 * 646 * 647 * <pre> 648 * Optional. A mapping of property names to values, used to configure Spark. 649 * Properties that conflict with values set by the Dataproc API may be 650 * overwritten. Can include properties set in 651 * /etc/spark/conf/spark-defaults.conf and classes in user code. 652 * </pre> 653 * 654 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 655 * </code> 656 */ 657 @java.lang.Override getPropertiesOrThrow(java.lang.String key)658 public java.lang.String getPropertiesOrThrow(java.lang.String key) { 659 if (key == null) { 660 throw new NullPointerException("map key"); 661 } 662 java.util.Map<java.lang.String, java.lang.String> map = internalGetProperties().getMap(); 663 if (!map.containsKey(key)) { 664 throw new java.lang.IllegalArgumentException(); 665 } 666 return map.get(key); 667 } 668 669 public static final int LOGGING_CONFIG_FIELD_NUMBER = 8; 670 private com.google.cloud.dataproc.v1.LoggingConfig loggingConfig_; 671 /** 672 * 673 * 674 * <pre> 675 * Optional. The runtime log config for job execution. 676 * </pre> 677 * 678 * <code> 679 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 680 * </code> 681 * 682 * @return Whether the loggingConfig field is set. 683 */ 684 @java.lang.Override hasLoggingConfig()685 public boolean hasLoggingConfig() { 686 return loggingConfig_ != null; 687 } 688 /** 689 * 690 * 691 * <pre> 692 * Optional. The runtime log config for job execution. 693 * </pre> 694 * 695 * <code> 696 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 697 * </code> 698 * 699 * @return The loggingConfig. 700 */ 701 @java.lang.Override getLoggingConfig()702 public com.google.cloud.dataproc.v1.LoggingConfig getLoggingConfig() { 703 return loggingConfig_ == null 704 ? com.google.cloud.dataproc.v1.LoggingConfig.getDefaultInstance() 705 : loggingConfig_; 706 } 707 /** 708 * 709 * 710 * <pre> 711 * Optional. The runtime log config for job execution. 712 * </pre> 713 * 714 * <code> 715 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 716 * </code> 717 */ 718 @java.lang.Override getLoggingConfigOrBuilder()719 public com.google.cloud.dataproc.v1.LoggingConfigOrBuilder getLoggingConfigOrBuilder() { 720 return loggingConfig_ == null 721 ? com.google.cloud.dataproc.v1.LoggingConfig.getDefaultInstance() 722 : loggingConfig_; 723 } 724 725 private byte memoizedIsInitialized = -1; 726 727 @java.lang.Override isInitialized()728 public final boolean isInitialized() { 729 byte isInitialized = memoizedIsInitialized; 730 if (isInitialized == 1) return true; 731 if (isInitialized == 0) return false; 732 733 memoizedIsInitialized = 1; 734 return true; 735 } 736 737 @java.lang.Override writeTo(com.google.protobuf.CodedOutputStream output)738 public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { 739 if (driverCase_ == 1) { 740 com.google.protobuf.GeneratedMessageV3.writeString(output, 1, driver_); 741 } 742 if (driverCase_ == 2) { 743 com.google.protobuf.GeneratedMessageV3.writeString(output, 2, driver_); 744 } 745 for (int i = 0; i < args_.size(); i++) { 746 com.google.protobuf.GeneratedMessageV3.writeString(output, 3, args_.getRaw(i)); 747 } 748 for (int i = 0; i < jarFileUris_.size(); i++) { 749 com.google.protobuf.GeneratedMessageV3.writeString(output, 4, jarFileUris_.getRaw(i)); 750 } 751 for (int i = 0; i < fileUris_.size(); i++) { 752 com.google.protobuf.GeneratedMessageV3.writeString(output, 5, fileUris_.getRaw(i)); 753 } 754 for (int i = 0; i < archiveUris_.size(); i++) { 755 com.google.protobuf.GeneratedMessageV3.writeString(output, 6, archiveUris_.getRaw(i)); 756 } 757 com.google.protobuf.GeneratedMessageV3.serializeStringMapTo( 758 output, internalGetProperties(), PropertiesDefaultEntryHolder.defaultEntry, 7); 759 if (loggingConfig_ != null) { 760 output.writeMessage(8, getLoggingConfig()); 761 } 762 getUnknownFields().writeTo(output); 763 } 764 765 @java.lang.Override getSerializedSize()766 public int getSerializedSize() { 767 int size = memoizedSize; 768 if (size != -1) return size; 769 770 size = 0; 771 if (driverCase_ == 1) { 772 size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, driver_); 773 } 774 if (driverCase_ == 2) { 775 size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, driver_); 776 } 777 { 778 int dataSize = 0; 779 for (int i = 0; i < args_.size(); i++) { 780 dataSize += computeStringSizeNoTag(args_.getRaw(i)); 781 } 782 size += dataSize; 783 size += 1 * getArgsList().size(); 784 } 785 { 786 int dataSize = 0; 787 for (int i = 0; i < jarFileUris_.size(); i++) { 788 dataSize += computeStringSizeNoTag(jarFileUris_.getRaw(i)); 789 } 790 size += dataSize; 791 size += 1 * getJarFileUrisList().size(); 792 } 793 { 794 int dataSize = 0; 795 for (int i = 0; i < fileUris_.size(); i++) { 796 dataSize += computeStringSizeNoTag(fileUris_.getRaw(i)); 797 } 798 size += dataSize; 799 size += 1 * getFileUrisList().size(); 800 } 801 { 802 int dataSize = 0; 803 for (int i = 0; i < archiveUris_.size(); i++) { 804 dataSize += computeStringSizeNoTag(archiveUris_.getRaw(i)); 805 } 806 size += dataSize; 807 size += 1 * getArchiveUrisList().size(); 808 } 809 for (java.util.Map.Entry<java.lang.String, java.lang.String> entry : 810 internalGetProperties().getMap().entrySet()) { 811 com.google.protobuf.MapEntry<java.lang.String, java.lang.String> properties__ = 812 PropertiesDefaultEntryHolder.defaultEntry 813 .newBuilderForType() 814 .setKey(entry.getKey()) 815 .setValue(entry.getValue()) 816 .build(); 817 size += com.google.protobuf.CodedOutputStream.computeMessageSize(7, properties__); 818 } 819 if (loggingConfig_ != null) { 820 size += com.google.protobuf.CodedOutputStream.computeMessageSize(8, getLoggingConfig()); 821 } 822 size += getUnknownFields().getSerializedSize(); 823 memoizedSize = size; 824 return size; 825 } 826 827 @java.lang.Override equals(final java.lang.Object obj)828 public boolean equals(final java.lang.Object obj) { 829 if (obj == this) { 830 return true; 831 } 832 if (!(obj instanceof com.google.cloud.dataproc.v1.SparkJob)) { 833 return super.equals(obj); 834 } 835 com.google.cloud.dataproc.v1.SparkJob other = (com.google.cloud.dataproc.v1.SparkJob) obj; 836 837 if (!getArgsList().equals(other.getArgsList())) return false; 838 if (!getJarFileUrisList().equals(other.getJarFileUrisList())) return false; 839 if (!getFileUrisList().equals(other.getFileUrisList())) return false; 840 if (!getArchiveUrisList().equals(other.getArchiveUrisList())) return false; 841 if (!internalGetProperties().equals(other.internalGetProperties())) return false; 842 if (hasLoggingConfig() != other.hasLoggingConfig()) return false; 843 if (hasLoggingConfig()) { 844 if (!getLoggingConfig().equals(other.getLoggingConfig())) return false; 845 } 846 if (!getDriverCase().equals(other.getDriverCase())) return false; 847 switch (driverCase_) { 848 case 1: 849 if (!getMainJarFileUri().equals(other.getMainJarFileUri())) return false; 850 break; 851 case 2: 852 if (!getMainClass().equals(other.getMainClass())) return false; 853 break; 854 case 0: 855 default: 856 } 857 if (!getUnknownFields().equals(other.getUnknownFields())) return false; 858 return true; 859 } 860 861 @java.lang.Override hashCode()862 public int hashCode() { 863 if (memoizedHashCode != 0) { 864 return memoizedHashCode; 865 } 866 int hash = 41; 867 hash = (19 * hash) + getDescriptor().hashCode(); 868 if (getArgsCount() > 0) { 869 hash = (37 * hash) + ARGS_FIELD_NUMBER; 870 hash = (53 * hash) + getArgsList().hashCode(); 871 } 872 if (getJarFileUrisCount() > 0) { 873 hash = (37 * hash) + JAR_FILE_URIS_FIELD_NUMBER; 874 hash = (53 * hash) + getJarFileUrisList().hashCode(); 875 } 876 if (getFileUrisCount() > 0) { 877 hash = (37 * hash) + FILE_URIS_FIELD_NUMBER; 878 hash = (53 * hash) + getFileUrisList().hashCode(); 879 } 880 if (getArchiveUrisCount() > 0) { 881 hash = (37 * hash) + ARCHIVE_URIS_FIELD_NUMBER; 882 hash = (53 * hash) + getArchiveUrisList().hashCode(); 883 } 884 if (!internalGetProperties().getMap().isEmpty()) { 885 hash = (37 * hash) + PROPERTIES_FIELD_NUMBER; 886 hash = (53 * hash) + internalGetProperties().hashCode(); 887 } 888 if (hasLoggingConfig()) { 889 hash = (37 * hash) + LOGGING_CONFIG_FIELD_NUMBER; 890 hash = (53 * hash) + getLoggingConfig().hashCode(); 891 } 892 switch (driverCase_) { 893 case 1: 894 hash = (37 * hash) + MAIN_JAR_FILE_URI_FIELD_NUMBER; 895 hash = (53 * hash) + getMainJarFileUri().hashCode(); 896 break; 897 case 2: 898 hash = (37 * hash) + MAIN_CLASS_FIELD_NUMBER; 899 hash = (53 * hash) + getMainClass().hashCode(); 900 break; 901 case 0: 902 default: 903 } 904 hash = (29 * hash) + getUnknownFields().hashCode(); 905 memoizedHashCode = hash; 906 return hash; 907 } 908 parseFrom(java.nio.ByteBuffer data)909 public static com.google.cloud.dataproc.v1.SparkJob parseFrom(java.nio.ByteBuffer data) 910 throws com.google.protobuf.InvalidProtocolBufferException { 911 return PARSER.parseFrom(data); 912 } 913 parseFrom( java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)914 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 915 java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 916 throws com.google.protobuf.InvalidProtocolBufferException { 917 return PARSER.parseFrom(data, extensionRegistry); 918 } 919 parseFrom(com.google.protobuf.ByteString data)920 public static com.google.cloud.dataproc.v1.SparkJob parseFrom(com.google.protobuf.ByteString data) 921 throws com.google.protobuf.InvalidProtocolBufferException { 922 return PARSER.parseFrom(data); 923 } 924 parseFrom( com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)925 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 926 com.google.protobuf.ByteString data, 927 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 928 throws com.google.protobuf.InvalidProtocolBufferException { 929 return PARSER.parseFrom(data, extensionRegistry); 930 } 931 parseFrom(byte[] data)932 public static com.google.cloud.dataproc.v1.SparkJob parseFrom(byte[] data) 933 throws com.google.protobuf.InvalidProtocolBufferException { 934 return PARSER.parseFrom(data); 935 } 936 parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)937 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 938 byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 939 throws com.google.protobuf.InvalidProtocolBufferException { 940 return PARSER.parseFrom(data, extensionRegistry); 941 } 942 parseFrom(java.io.InputStream input)943 public static com.google.cloud.dataproc.v1.SparkJob parseFrom(java.io.InputStream input) 944 throws java.io.IOException { 945 return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); 946 } 947 parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)948 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 949 java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 950 throws java.io.IOException { 951 return com.google.protobuf.GeneratedMessageV3.parseWithIOException( 952 PARSER, input, extensionRegistry); 953 } 954 parseDelimitedFrom(java.io.InputStream input)955 public static com.google.cloud.dataproc.v1.SparkJob parseDelimitedFrom(java.io.InputStream input) 956 throws java.io.IOException { 957 return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input); 958 } 959 parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)960 public static com.google.cloud.dataproc.v1.SparkJob parseDelimitedFrom( 961 java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 962 throws java.io.IOException { 963 return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException( 964 PARSER, input, extensionRegistry); 965 } 966 parseFrom( com.google.protobuf.CodedInputStream input)967 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 968 com.google.protobuf.CodedInputStream input) throws java.io.IOException { 969 return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); 970 } 971 parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)972 public static com.google.cloud.dataproc.v1.SparkJob parseFrom( 973 com.google.protobuf.CodedInputStream input, 974 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 975 throws java.io.IOException { 976 return com.google.protobuf.GeneratedMessageV3.parseWithIOException( 977 PARSER, input, extensionRegistry); 978 } 979 980 @java.lang.Override newBuilderForType()981 public Builder newBuilderForType() { 982 return newBuilder(); 983 } 984 newBuilder()985 public static Builder newBuilder() { 986 return DEFAULT_INSTANCE.toBuilder(); 987 } 988 newBuilder(com.google.cloud.dataproc.v1.SparkJob prototype)989 public static Builder newBuilder(com.google.cloud.dataproc.v1.SparkJob prototype) { 990 return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); 991 } 992 993 @java.lang.Override toBuilder()994 public Builder toBuilder() { 995 return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this); 996 } 997 998 @java.lang.Override newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)999 protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { 1000 Builder builder = new Builder(parent); 1001 return builder; 1002 } 1003 /** 1004 * 1005 * 1006 * <pre> 1007 * A Dataproc job for running [Apache Spark](https://spark.apache.org/) 1008 * applications on YARN. 1009 * </pre> 1010 * 1011 * Protobuf type {@code google.cloud.dataproc.v1.SparkJob} 1012 */ 1013 public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Builder> 1014 implements 1015 // @@protoc_insertion_point(builder_implements:google.cloud.dataproc.v1.SparkJob) 1016 com.google.cloud.dataproc.v1.SparkJobOrBuilder { getDescriptor()1017 public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { 1018 return com.google.cloud.dataproc.v1.JobsProto 1019 .internal_static_google_cloud_dataproc_v1_SparkJob_descriptor; 1020 } 1021 1022 @SuppressWarnings({"rawtypes"}) internalGetMapField(int number)1023 protected com.google.protobuf.MapField internalGetMapField(int number) { 1024 switch (number) { 1025 case 7: 1026 return internalGetProperties(); 1027 default: 1028 throw new RuntimeException("Invalid map field number: " + number); 1029 } 1030 } 1031 1032 @SuppressWarnings({"rawtypes"}) internalGetMutableMapField(int number)1033 protected com.google.protobuf.MapField internalGetMutableMapField(int number) { 1034 switch (number) { 1035 case 7: 1036 return internalGetMutableProperties(); 1037 default: 1038 throw new RuntimeException("Invalid map field number: " + number); 1039 } 1040 } 1041 1042 @java.lang.Override 1043 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()1044 internalGetFieldAccessorTable() { 1045 return com.google.cloud.dataproc.v1.JobsProto 1046 .internal_static_google_cloud_dataproc_v1_SparkJob_fieldAccessorTable 1047 .ensureFieldAccessorsInitialized( 1048 com.google.cloud.dataproc.v1.SparkJob.class, 1049 com.google.cloud.dataproc.v1.SparkJob.Builder.class); 1050 } 1051 1052 // Construct using com.google.cloud.dataproc.v1.SparkJob.newBuilder() Builder()1053 private Builder() {} 1054 Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)1055 private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { 1056 super(parent); 1057 } 1058 1059 @java.lang.Override clear()1060 public Builder clear() { 1061 super.clear(); 1062 bitField0_ = 0; 1063 args_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1064 bitField0_ = (bitField0_ & ~0x00000004); 1065 jarFileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1066 bitField0_ = (bitField0_ & ~0x00000008); 1067 fileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1068 bitField0_ = (bitField0_ & ~0x00000010); 1069 archiveUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1070 bitField0_ = (bitField0_ & ~0x00000020); 1071 internalGetMutableProperties().clear(); 1072 loggingConfig_ = null; 1073 if (loggingConfigBuilder_ != null) { 1074 loggingConfigBuilder_.dispose(); 1075 loggingConfigBuilder_ = null; 1076 } 1077 driverCase_ = 0; 1078 driver_ = null; 1079 return this; 1080 } 1081 1082 @java.lang.Override getDescriptorForType()1083 public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { 1084 return com.google.cloud.dataproc.v1.JobsProto 1085 .internal_static_google_cloud_dataproc_v1_SparkJob_descriptor; 1086 } 1087 1088 @java.lang.Override getDefaultInstanceForType()1089 public com.google.cloud.dataproc.v1.SparkJob getDefaultInstanceForType() { 1090 return com.google.cloud.dataproc.v1.SparkJob.getDefaultInstance(); 1091 } 1092 1093 @java.lang.Override build()1094 public com.google.cloud.dataproc.v1.SparkJob build() { 1095 com.google.cloud.dataproc.v1.SparkJob result = buildPartial(); 1096 if (!result.isInitialized()) { 1097 throw newUninitializedMessageException(result); 1098 } 1099 return result; 1100 } 1101 1102 @java.lang.Override buildPartial()1103 public com.google.cloud.dataproc.v1.SparkJob buildPartial() { 1104 com.google.cloud.dataproc.v1.SparkJob result = 1105 new com.google.cloud.dataproc.v1.SparkJob(this); 1106 buildPartialRepeatedFields(result); 1107 if (bitField0_ != 0) { 1108 buildPartial0(result); 1109 } 1110 buildPartialOneofs(result); 1111 onBuilt(); 1112 return result; 1113 } 1114 buildPartialRepeatedFields(com.google.cloud.dataproc.v1.SparkJob result)1115 private void buildPartialRepeatedFields(com.google.cloud.dataproc.v1.SparkJob result) { 1116 if (((bitField0_ & 0x00000004) != 0)) { 1117 args_ = args_.getUnmodifiableView(); 1118 bitField0_ = (bitField0_ & ~0x00000004); 1119 } 1120 result.args_ = args_; 1121 if (((bitField0_ & 0x00000008) != 0)) { 1122 jarFileUris_ = jarFileUris_.getUnmodifiableView(); 1123 bitField0_ = (bitField0_ & ~0x00000008); 1124 } 1125 result.jarFileUris_ = jarFileUris_; 1126 if (((bitField0_ & 0x00000010) != 0)) { 1127 fileUris_ = fileUris_.getUnmodifiableView(); 1128 bitField0_ = (bitField0_ & ~0x00000010); 1129 } 1130 result.fileUris_ = fileUris_; 1131 if (((bitField0_ & 0x00000020) != 0)) { 1132 archiveUris_ = archiveUris_.getUnmodifiableView(); 1133 bitField0_ = (bitField0_ & ~0x00000020); 1134 } 1135 result.archiveUris_ = archiveUris_; 1136 } 1137 buildPartial0(com.google.cloud.dataproc.v1.SparkJob result)1138 private void buildPartial0(com.google.cloud.dataproc.v1.SparkJob result) { 1139 int from_bitField0_ = bitField0_; 1140 if (((from_bitField0_ & 0x00000040) != 0)) { 1141 result.properties_ = internalGetProperties(); 1142 result.properties_.makeImmutable(); 1143 } 1144 if (((from_bitField0_ & 0x00000080) != 0)) { 1145 result.loggingConfig_ = 1146 loggingConfigBuilder_ == null ? loggingConfig_ : loggingConfigBuilder_.build(); 1147 } 1148 } 1149 buildPartialOneofs(com.google.cloud.dataproc.v1.SparkJob result)1150 private void buildPartialOneofs(com.google.cloud.dataproc.v1.SparkJob result) { 1151 result.driverCase_ = driverCase_; 1152 result.driver_ = this.driver_; 1153 } 1154 1155 @java.lang.Override clone()1156 public Builder clone() { 1157 return super.clone(); 1158 } 1159 1160 @java.lang.Override setField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)1161 public Builder setField( 1162 com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { 1163 return super.setField(field, value); 1164 } 1165 1166 @java.lang.Override clearField(com.google.protobuf.Descriptors.FieldDescriptor field)1167 public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) { 1168 return super.clearField(field); 1169 } 1170 1171 @java.lang.Override clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)1172 public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) { 1173 return super.clearOneof(oneof); 1174 } 1175 1176 @java.lang.Override setRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)1177 public Builder setRepeatedField( 1178 com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) { 1179 return super.setRepeatedField(field, index, value); 1180 } 1181 1182 @java.lang.Override addRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)1183 public Builder addRepeatedField( 1184 com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { 1185 return super.addRepeatedField(field, value); 1186 } 1187 1188 @java.lang.Override mergeFrom(com.google.protobuf.Message other)1189 public Builder mergeFrom(com.google.protobuf.Message other) { 1190 if (other instanceof com.google.cloud.dataproc.v1.SparkJob) { 1191 return mergeFrom((com.google.cloud.dataproc.v1.SparkJob) other); 1192 } else { 1193 super.mergeFrom(other); 1194 return this; 1195 } 1196 } 1197 mergeFrom(com.google.cloud.dataproc.v1.SparkJob other)1198 public Builder mergeFrom(com.google.cloud.dataproc.v1.SparkJob other) { 1199 if (other == com.google.cloud.dataproc.v1.SparkJob.getDefaultInstance()) return this; 1200 if (!other.args_.isEmpty()) { 1201 if (args_.isEmpty()) { 1202 args_ = other.args_; 1203 bitField0_ = (bitField0_ & ~0x00000004); 1204 } else { 1205 ensureArgsIsMutable(); 1206 args_.addAll(other.args_); 1207 } 1208 onChanged(); 1209 } 1210 if (!other.jarFileUris_.isEmpty()) { 1211 if (jarFileUris_.isEmpty()) { 1212 jarFileUris_ = other.jarFileUris_; 1213 bitField0_ = (bitField0_ & ~0x00000008); 1214 } else { 1215 ensureJarFileUrisIsMutable(); 1216 jarFileUris_.addAll(other.jarFileUris_); 1217 } 1218 onChanged(); 1219 } 1220 if (!other.fileUris_.isEmpty()) { 1221 if (fileUris_.isEmpty()) { 1222 fileUris_ = other.fileUris_; 1223 bitField0_ = (bitField0_ & ~0x00000010); 1224 } else { 1225 ensureFileUrisIsMutable(); 1226 fileUris_.addAll(other.fileUris_); 1227 } 1228 onChanged(); 1229 } 1230 if (!other.archiveUris_.isEmpty()) { 1231 if (archiveUris_.isEmpty()) { 1232 archiveUris_ = other.archiveUris_; 1233 bitField0_ = (bitField0_ & ~0x00000020); 1234 } else { 1235 ensureArchiveUrisIsMutable(); 1236 archiveUris_.addAll(other.archiveUris_); 1237 } 1238 onChanged(); 1239 } 1240 internalGetMutableProperties().mergeFrom(other.internalGetProperties()); 1241 bitField0_ |= 0x00000040; 1242 if (other.hasLoggingConfig()) { 1243 mergeLoggingConfig(other.getLoggingConfig()); 1244 } 1245 switch (other.getDriverCase()) { 1246 case MAIN_JAR_FILE_URI: 1247 { 1248 driverCase_ = 1; 1249 driver_ = other.driver_; 1250 onChanged(); 1251 break; 1252 } 1253 case MAIN_CLASS: 1254 { 1255 driverCase_ = 2; 1256 driver_ = other.driver_; 1257 onChanged(); 1258 break; 1259 } 1260 case DRIVER_NOT_SET: 1261 { 1262 break; 1263 } 1264 } 1265 this.mergeUnknownFields(other.getUnknownFields()); 1266 onChanged(); 1267 return this; 1268 } 1269 1270 @java.lang.Override isInitialized()1271 public final boolean isInitialized() { 1272 return true; 1273 } 1274 1275 @java.lang.Override mergeFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)1276 public Builder mergeFrom( 1277 com.google.protobuf.CodedInputStream input, 1278 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1279 throws java.io.IOException { 1280 if (extensionRegistry == null) { 1281 throw new java.lang.NullPointerException(); 1282 } 1283 try { 1284 boolean done = false; 1285 while (!done) { 1286 int tag = input.readTag(); 1287 switch (tag) { 1288 case 0: 1289 done = true; 1290 break; 1291 case 10: 1292 { 1293 java.lang.String s = input.readStringRequireUtf8(); 1294 driverCase_ = 1; 1295 driver_ = s; 1296 break; 1297 } // case 10 1298 case 18: 1299 { 1300 java.lang.String s = input.readStringRequireUtf8(); 1301 driverCase_ = 2; 1302 driver_ = s; 1303 break; 1304 } // case 18 1305 case 26: 1306 { 1307 java.lang.String s = input.readStringRequireUtf8(); 1308 ensureArgsIsMutable(); 1309 args_.add(s); 1310 break; 1311 } // case 26 1312 case 34: 1313 { 1314 java.lang.String s = input.readStringRequireUtf8(); 1315 ensureJarFileUrisIsMutable(); 1316 jarFileUris_.add(s); 1317 break; 1318 } // case 34 1319 case 42: 1320 { 1321 java.lang.String s = input.readStringRequireUtf8(); 1322 ensureFileUrisIsMutable(); 1323 fileUris_.add(s); 1324 break; 1325 } // case 42 1326 case 50: 1327 { 1328 java.lang.String s = input.readStringRequireUtf8(); 1329 ensureArchiveUrisIsMutable(); 1330 archiveUris_.add(s); 1331 break; 1332 } // case 50 1333 case 58: 1334 { 1335 com.google.protobuf.MapEntry<java.lang.String, java.lang.String> properties__ = 1336 input.readMessage( 1337 PropertiesDefaultEntryHolder.defaultEntry.getParserForType(), 1338 extensionRegistry); 1339 internalGetMutableProperties() 1340 .getMutableMap() 1341 .put(properties__.getKey(), properties__.getValue()); 1342 bitField0_ |= 0x00000040; 1343 break; 1344 } // case 58 1345 case 66: 1346 { 1347 input.readMessage(getLoggingConfigFieldBuilder().getBuilder(), extensionRegistry); 1348 bitField0_ |= 0x00000080; 1349 break; 1350 } // case 66 1351 default: 1352 { 1353 if (!super.parseUnknownField(input, extensionRegistry, tag)) { 1354 done = true; // was an endgroup tag 1355 } 1356 break; 1357 } // default: 1358 } // switch (tag) 1359 } // while (!done) 1360 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1361 throw e.unwrapIOException(); 1362 } finally { 1363 onChanged(); 1364 } // finally 1365 return this; 1366 } 1367 1368 private int driverCase_ = 0; 1369 private java.lang.Object driver_; 1370 getDriverCase()1371 public DriverCase getDriverCase() { 1372 return DriverCase.forNumber(driverCase_); 1373 } 1374 clearDriver()1375 public Builder clearDriver() { 1376 driverCase_ = 0; 1377 driver_ = null; 1378 onChanged(); 1379 return this; 1380 } 1381 1382 private int bitField0_; 1383 1384 /** 1385 * 1386 * 1387 * <pre> 1388 * The HCFS URI of the jar file that contains the main class. 1389 * </pre> 1390 * 1391 * <code>string main_jar_file_uri = 1;</code> 1392 * 1393 * @return Whether the mainJarFileUri field is set. 1394 */ 1395 @java.lang.Override hasMainJarFileUri()1396 public boolean hasMainJarFileUri() { 1397 return driverCase_ == 1; 1398 } 1399 /** 1400 * 1401 * 1402 * <pre> 1403 * The HCFS URI of the jar file that contains the main class. 1404 * </pre> 1405 * 1406 * <code>string main_jar_file_uri = 1;</code> 1407 * 1408 * @return The mainJarFileUri. 1409 */ 1410 @java.lang.Override getMainJarFileUri()1411 public java.lang.String getMainJarFileUri() { 1412 java.lang.Object ref = ""; 1413 if (driverCase_ == 1) { 1414 ref = driver_; 1415 } 1416 if (!(ref instanceof java.lang.String)) { 1417 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 1418 java.lang.String s = bs.toStringUtf8(); 1419 if (driverCase_ == 1) { 1420 driver_ = s; 1421 } 1422 return s; 1423 } else { 1424 return (java.lang.String) ref; 1425 } 1426 } 1427 /** 1428 * 1429 * 1430 * <pre> 1431 * The HCFS URI of the jar file that contains the main class. 1432 * </pre> 1433 * 1434 * <code>string main_jar_file_uri = 1;</code> 1435 * 1436 * @return The bytes for mainJarFileUri. 1437 */ 1438 @java.lang.Override getMainJarFileUriBytes()1439 public com.google.protobuf.ByteString getMainJarFileUriBytes() { 1440 java.lang.Object ref = ""; 1441 if (driverCase_ == 1) { 1442 ref = driver_; 1443 } 1444 if (ref instanceof String) { 1445 com.google.protobuf.ByteString b = 1446 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 1447 if (driverCase_ == 1) { 1448 driver_ = b; 1449 } 1450 return b; 1451 } else { 1452 return (com.google.protobuf.ByteString) ref; 1453 } 1454 } 1455 /** 1456 * 1457 * 1458 * <pre> 1459 * The HCFS URI of the jar file that contains the main class. 1460 * </pre> 1461 * 1462 * <code>string main_jar_file_uri = 1;</code> 1463 * 1464 * @param value The mainJarFileUri to set. 1465 * @return This builder for chaining. 1466 */ setMainJarFileUri(java.lang.String value)1467 public Builder setMainJarFileUri(java.lang.String value) { 1468 if (value == null) { 1469 throw new NullPointerException(); 1470 } 1471 driverCase_ = 1; 1472 driver_ = value; 1473 onChanged(); 1474 return this; 1475 } 1476 /** 1477 * 1478 * 1479 * <pre> 1480 * The HCFS URI of the jar file that contains the main class. 1481 * </pre> 1482 * 1483 * <code>string main_jar_file_uri = 1;</code> 1484 * 1485 * @return This builder for chaining. 1486 */ clearMainJarFileUri()1487 public Builder clearMainJarFileUri() { 1488 if (driverCase_ == 1) { 1489 driverCase_ = 0; 1490 driver_ = null; 1491 onChanged(); 1492 } 1493 return this; 1494 } 1495 /** 1496 * 1497 * 1498 * <pre> 1499 * The HCFS URI of the jar file that contains the main class. 1500 * </pre> 1501 * 1502 * <code>string main_jar_file_uri = 1;</code> 1503 * 1504 * @param value The bytes for mainJarFileUri to set. 1505 * @return This builder for chaining. 1506 */ setMainJarFileUriBytes(com.google.protobuf.ByteString value)1507 public Builder setMainJarFileUriBytes(com.google.protobuf.ByteString value) { 1508 if (value == null) { 1509 throw new NullPointerException(); 1510 } 1511 checkByteStringIsUtf8(value); 1512 driverCase_ = 1; 1513 driver_ = value; 1514 onChanged(); 1515 return this; 1516 } 1517 1518 /** 1519 * 1520 * 1521 * <pre> 1522 * The name of the driver's main class. The jar file that contains the class 1523 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1524 * </pre> 1525 * 1526 * <code>string main_class = 2;</code> 1527 * 1528 * @return Whether the mainClass field is set. 1529 */ 1530 @java.lang.Override hasMainClass()1531 public boolean hasMainClass() { 1532 return driverCase_ == 2; 1533 } 1534 /** 1535 * 1536 * 1537 * <pre> 1538 * The name of the driver's main class. The jar file that contains the class 1539 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1540 * </pre> 1541 * 1542 * <code>string main_class = 2;</code> 1543 * 1544 * @return The mainClass. 1545 */ 1546 @java.lang.Override getMainClass()1547 public java.lang.String getMainClass() { 1548 java.lang.Object ref = ""; 1549 if (driverCase_ == 2) { 1550 ref = driver_; 1551 } 1552 if (!(ref instanceof java.lang.String)) { 1553 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 1554 java.lang.String s = bs.toStringUtf8(); 1555 if (driverCase_ == 2) { 1556 driver_ = s; 1557 } 1558 return s; 1559 } else { 1560 return (java.lang.String) ref; 1561 } 1562 } 1563 /** 1564 * 1565 * 1566 * <pre> 1567 * The name of the driver's main class. The jar file that contains the class 1568 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1569 * </pre> 1570 * 1571 * <code>string main_class = 2;</code> 1572 * 1573 * @return The bytes for mainClass. 1574 */ 1575 @java.lang.Override getMainClassBytes()1576 public com.google.protobuf.ByteString getMainClassBytes() { 1577 java.lang.Object ref = ""; 1578 if (driverCase_ == 2) { 1579 ref = driver_; 1580 } 1581 if (ref instanceof String) { 1582 com.google.protobuf.ByteString b = 1583 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 1584 if (driverCase_ == 2) { 1585 driver_ = b; 1586 } 1587 return b; 1588 } else { 1589 return (com.google.protobuf.ByteString) ref; 1590 } 1591 } 1592 /** 1593 * 1594 * 1595 * <pre> 1596 * The name of the driver's main class. The jar file that contains the class 1597 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1598 * </pre> 1599 * 1600 * <code>string main_class = 2;</code> 1601 * 1602 * @param value The mainClass to set. 1603 * @return This builder for chaining. 1604 */ setMainClass(java.lang.String value)1605 public Builder setMainClass(java.lang.String value) { 1606 if (value == null) { 1607 throw new NullPointerException(); 1608 } 1609 driverCase_ = 2; 1610 driver_ = value; 1611 onChanged(); 1612 return this; 1613 } 1614 /** 1615 * 1616 * 1617 * <pre> 1618 * The name of the driver's main class. The jar file that contains the class 1619 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1620 * </pre> 1621 * 1622 * <code>string main_class = 2;</code> 1623 * 1624 * @return This builder for chaining. 1625 */ clearMainClass()1626 public Builder clearMainClass() { 1627 if (driverCase_ == 2) { 1628 driverCase_ = 0; 1629 driver_ = null; 1630 onChanged(); 1631 } 1632 return this; 1633 } 1634 /** 1635 * 1636 * 1637 * <pre> 1638 * The name of the driver's main class. The jar file that contains the class 1639 * must be in the default CLASSPATH or specified in `jar_file_uris`. 1640 * </pre> 1641 * 1642 * <code>string main_class = 2;</code> 1643 * 1644 * @param value The bytes for mainClass to set. 1645 * @return This builder for chaining. 1646 */ setMainClassBytes(com.google.protobuf.ByteString value)1647 public Builder setMainClassBytes(com.google.protobuf.ByteString value) { 1648 if (value == null) { 1649 throw new NullPointerException(); 1650 } 1651 checkByteStringIsUtf8(value); 1652 driverCase_ = 2; 1653 driver_ = value; 1654 onChanged(); 1655 return this; 1656 } 1657 1658 private com.google.protobuf.LazyStringList args_ = 1659 com.google.protobuf.LazyStringArrayList.EMPTY; 1660 ensureArgsIsMutable()1661 private void ensureArgsIsMutable() { 1662 if (!((bitField0_ & 0x00000004) != 0)) { 1663 args_ = new com.google.protobuf.LazyStringArrayList(args_); 1664 bitField0_ |= 0x00000004; 1665 } 1666 } 1667 /** 1668 * 1669 * 1670 * <pre> 1671 * Optional. The arguments to pass to the driver. Do not include arguments, 1672 * such as `--conf`, that can be set as job properties, since a collision may 1673 * occur that causes an incorrect job submission. 1674 * </pre> 1675 * 1676 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1677 * 1678 * @return A list containing the args. 1679 */ getArgsList()1680 public com.google.protobuf.ProtocolStringList getArgsList() { 1681 return args_.getUnmodifiableView(); 1682 } 1683 /** 1684 * 1685 * 1686 * <pre> 1687 * Optional. The arguments to pass to the driver. Do not include arguments, 1688 * such as `--conf`, that can be set as job properties, since a collision may 1689 * occur that causes an incorrect job submission. 1690 * </pre> 1691 * 1692 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1693 * 1694 * @return The count of args. 1695 */ getArgsCount()1696 public int getArgsCount() { 1697 return args_.size(); 1698 } 1699 /** 1700 * 1701 * 1702 * <pre> 1703 * Optional. The arguments to pass to the driver. Do not include arguments, 1704 * such as `--conf`, that can be set as job properties, since a collision may 1705 * occur that causes an incorrect job submission. 1706 * </pre> 1707 * 1708 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1709 * 1710 * @param index The index of the element to return. 1711 * @return The args at the given index. 1712 */ getArgs(int index)1713 public java.lang.String getArgs(int index) { 1714 return args_.get(index); 1715 } 1716 /** 1717 * 1718 * 1719 * <pre> 1720 * Optional. The arguments to pass to the driver. Do not include arguments, 1721 * such as `--conf`, that can be set as job properties, since a collision may 1722 * occur that causes an incorrect job submission. 1723 * </pre> 1724 * 1725 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1726 * 1727 * @param index The index of the value to return. 1728 * @return The bytes of the args at the given index. 1729 */ getArgsBytes(int index)1730 public com.google.protobuf.ByteString getArgsBytes(int index) { 1731 return args_.getByteString(index); 1732 } 1733 /** 1734 * 1735 * 1736 * <pre> 1737 * Optional. The arguments to pass to the driver. Do not include arguments, 1738 * such as `--conf`, that can be set as job properties, since a collision may 1739 * occur that causes an incorrect job submission. 1740 * </pre> 1741 * 1742 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1743 * 1744 * @param index The index to set the value at. 1745 * @param value The args to set. 1746 * @return This builder for chaining. 1747 */ setArgs(int index, java.lang.String value)1748 public Builder setArgs(int index, java.lang.String value) { 1749 if (value == null) { 1750 throw new NullPointerException(); 1751 } 1752 ensureArgsIsMutable(); 1753 args_.set(index, value); 1754 onChanged(); 1755 return this; 1756 } 1757 /** 1758 * 1759 * 1760 * <pre> 1761 * Optional. The arguments to pass to the driver. Do not include arguments, 1762 * such as `--conf`, that can be set as job properties, since a collision may 1763 * occur that causes an incorrect job submission. 1764 * </pre> 1765 * 1766 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1767 * 1768 * @param value The args to add. 1769 * @return This builder for chaining. 1770 */ addArgs(java.lang.String value)1771 public Builder addArgs(java.lang.String value) { 1772 if (value == null) { 1773 throw new NullPointerException(); 1774 } 1775 ensureArgsIsMutable(); 1776 args_.add(value); 1777 onChanged(); 1778 return this; 1779 } 1780 /** 1781 * 1782 * 1783 * <pre> 1784 * Optional. The arguments to pass to the driver. Do not include arguments, 1785 * such as `--conf`, that can be set as job properties, since a collision may 1786 * occur that causes an incorrect job submission. 1787 * </pre> 1788 * 1789 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1790 * 1791 * @param values The args to add. 1792 * @return This builder for chaining. 1793 */ addAllArgs(java.lang.Iterable<java.lang.String> values)1794 public Builder addAllArgs(java.lang.Iterable<java.lang.String> values) { 1795 ensureArgsIsMutable(); 1796 com.google.protobuf.AbstractMessageLite.Builder.addAll(values, args_); 1797 onChanged(); 1798 return this; 1799 } 1800 /** 1801 * 1802 * 1803 * <pre> 1804 * Optional. The arguments to pass to the driver. Do not include arguments, 1805 * such as `--conf`, that can be set as job properties, since a collision may 1806 * occur that causes an incorrect job submission. 1807 * </pre> 1808 * 1809 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1810 * 1811 * @return This builder for chaining. 1812 */ clearArgs()1813 public Builder clearArgs() { 1814 args_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1815 bitField0_ = (bitField0_ & ~0x00000004); 1816 onChanged(); 1817 return this; 1818 } 1819 /** 1820 * 1821 * 1822 * <pre> 1823 * Optional. The arguments to pass to the driver. Do not include arguments, 1824 * such as `--conf`, that can be set as job properties, since a collision may 1825 * occur that causes an incorrect job submission. 1826 * </pre> 1827 * 1828 * <code>repeated string args = 3 [(.google.api.field_behavior) = OPTIONAL];</code> 1829 * 1830 * @param value The bytes of the args to add. 1831 * @return This builder for chaining. 1832 */ addArgsBytes(com.google.protobuf.ByteString value)1833 public Builder addArgsBytes(com.google.protobuf.ByteString value) { 1834 if (value == null) { 1835 throw new NullPointerException(); 1836 } 1837 checkByteStringIsUtf8(value); 1838 ensureArgsIsMutable(); 1839 args_.add(value); 1840 onChanged(); 1841 return this; 1842 } 1843 1844 private com.google.protobuf.LazyStringList jarFileUris_ = 1845 com.google.protobuf.LazyStringArrayList.EMPTY; 1846 ensureJarFileUrisIsMutable()1847 private void ensureJarFileUrisIsMutable() { 1848 if (!((bitField0_ & 0x00000008) != 0)) { 1849 jarFileUris_ = new com.google.protobuf.LazyStringArrayList(jarFileUris_); 1850 bitField0_ |= 0x00000008; 1851 } 1852 } 1853 /** 1854 * 1855 * 1856 * <pre> 1857 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1858 * Spark driver and tasks. 1859 * </pre> 1860 * 1861 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1862 * 1863 * @return A list containing the jarFileUris. 1864 */ getJarFileUrisList()1865 public com.google.protobuf.ProtocolStringList getJarFileUrisList() { 1866 return jarFileUris_.getUnmodifiableView(); 1867 } 1868 /** 1869 * 1870 * 1871 * <pre> 1872 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1873 * Spark driver and tasks. 1874 * </pre> 1875 * 1876 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1877 * 1878 * @return The count of jarFileUris. 1879 */ getJarFileUrisCount()1880 public int getJarFileUrisCount() { 1881 return jarFileUris_.size(); 1882 } 1883 /** 1884 * 1885 * 1886 * <pre> 1887 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1888 * Spark driver and tasks. 1889 * </pre> 1890 * 1891 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1892 * 1893 * @param index The index of the element to return. 1894 * @return The jarFileUris at the given index. 1895 */ getJarFileUris(int index)1896 public java.lang.String getJarFileUris(int index) { 1897 return jarFileUris_.get(index); 1898 } 1899 /** 1900 * 1901 * 1902 * <pre> 1903 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1904 * Spark driver and tasks. 1905 * </pre> 1906 * 1907 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1908 * 1909 * @param index The index of the value to return. 1910 * @return The bytes of the jarFileUris at the given index. 1911 */ getJarFileUrisBytes(int index)1912 public com.google.protobuf.ByteString getJarFileUrisBytes(int index) { 1913 return jarFileUris_.getByteString(index); 1914 } 1915 /** 1916 * 1917 * 1918 * <pre> 1919 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1920 * Spark driver and tasks. 1921 * </pre> 1922 * 1923 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1924 * 1925 * @param index The index to set the value at. 1926 * @param value The jarFileUris to set. 1927 * @return This builder for chaining. 1928 */ setJarFileUris(int index, java.lang.String value)1929 public Builder setJarFileUris(int index, java.lang.String value) { 1930 if (value == null) { 1931 throw new NullPointerException(); 1932 } 1933 ensureJarFileUrisIsMutable(); 1934 jarFileUris_.set(index, value); 1935 onChanged(); 1936 return this; 1937 } 1938 /** 1939 * 1940 * 1941 * <pre> 1942 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1943 * Spark driver and tasks. 1944 * </pre> 1945 * 1946 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1947 * 1948 * @param value The jarFileUris to add. 1949 * @return This builder for chaining. 1950 */ addJarFileUris(java.lang.String value)1951 public Builder addJarFileUris(java.lang.String value) { 1952 if (value == null) { 1953 throw new NullPointerException(); 1954 } 1955 ensureJarFileUrisIsMutable(); 1956 jarFileUris_.add(value); 1957 onChanged(); 1958 return this; 1959 } 1960 /** 1961 * 1962 * 1963 * <pre> 1964 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1965 * Spark driver and tasks. 1966 * </pre> 1967 * 1968 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1969 * 1970 * @param values The jarFileUris to add. 1971 * @return This builder for chaining. 1972 */ addAllJarFileUris(java.lang.Iterable<java.lang.String> values)1973 public Builder addAllJarFileUris(java.lang.Iterable<java.lang.String> values) { 1974 ensureJarFileUrisIsMutable(); 1975 com.google.protobuf.AbstractMessageLite.Builder.addAll(values, jarFileUris_); 1976 onChanged(); 1977 return this; 1978 } 1979 /** 1980 * 1981 * 1982 * <pre> 1983 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 1984 * Spark driver and tasks. 1985 * </pre> 1986 * 1987 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 1988 * 1989 * @return This builder for chaining. 1990 */ clearJarFileUris()1991 public Builder clearJarFileUris() { 1992 jarFileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 1993 bitField0_ = (bitField0_ & ~0x00000008); 1994 onChanged(); 1995 return this; 1996 } 1997 /** 1998 * 1999 * 2000 * <pre> 2001 * Optional. HCFS URIs of jar files to add to the CLASSPATHs of the 2002 * Spark driver and tasks. 2003 * </pre> 2004 * 2005 * <code>repeated string jar_file_uris = 4 [(.google.api.field_behavior) = OPTIONAL];</code> 2006 * 2007 * @param value The bytes of the jarFileUris to add. 2008 * @return This builder for chaining. 2009 */ addJarFileUrisBytes(com.google.protobuf.ByteString value)2010 public Builder addJarFileUrisBytes(com.google.protobuf.ByteString value) { 2011 if (value == null) { 2012 throw new NullPointerException(); 2013 } 2014 checkByteStringIsUtf8(value); 2015 ensureJarFileUrisIsMutable(); 2016 jarFileUris_.add(value); 2017 onChanged(); 2018 return this; 2019 } 2020 2021 private com.google.protobuf.LazyStringList fileUris_ = 2022 com.google.protobuf.LazyStringArrayList.EMPTY; 2023 ensureFileUrisIsMutable()2024 private void ensureFileUrisIsMutable() { 2025 if (!((bitField0_ & 0x00000010) != 0)) { 2026 fileUris_ = new com.google.protobuf.LazyStringArrayList(fileUris_); 2027 bitField0_ |= 0x00000010; 2028 } 2029 } 2030 /** 2031 * 2032 * 2033 * <pre> 2034 * Optional. HCFS URIs of files to be placed in the working directory of 2035 * each executor. Useful for naively parallel tasks. 2036 * </pre> 2037 * 2038 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2039 * 2040 * @return A list containing the fileUris. 2041 */ getFileUrisList()2042 public com.google.protobuf.ProtocolStringList getFileUrisList() { 2043 return fileUris_.getUnmodifiableView(); 2044 } 2045 /** 2046 * 2047 * 2048 * <pre> 2049 * Optional. HCFS URIs of files to be placed in the working directory of 2050 * each executor. Useful for naively parallel tasks. 2051 * </pre> 2052 * 2053 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2054 * 2055 * @return The count of fileUris. 2056 */ getFileUrisCount()2057 public int getFileUrisCount() { 2058 return fileUris_.size(); 2059 } 2060 /** 2061 * 2062 * 2063 * <pre> 2064 * Optional. HCFS URIs of files to be placed in the working directory of 2065 * each executor. Useful for naively parallel tasks. 2066 * </pre> 2067 * 2068 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2069 * 2070 * @param index The index of the element to return. 2071 * @return The fileUris at the given index. 2072 */ getFileUris(int index)2073 public java.lang.String getFileUris(int index) { 2074 return fileUris_.get(index); 2075 } 2076 /** 2077 * 2078 * 2079 * <pre> 2080 * Optional. HCFS URIs of files to be placed in the working directory of 2081 * each executor. Useful for naively parallel tasks. 2082 * </pre> 2083 * 2084 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2085 * 2086 * @param index The index of the value to return. 2087 * @return The bytes of the fileUris at the given index. 2088 */ getFileUrisBytes(int index)2089 public com.google.protobuf.ByteString getFileUrisBytes(int index) { 2090 return fileUris_.getByteString(index); 2091 } 2092 /** 2093 * 2094 * 2095 * <pre> 2096 * Optional. HCFS URIs of files to be placed in the working directory of 2097 * each executor. Useful for naively parallel tasks. 2098 * </pre> 2099 * 2100 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2101 * 2102 * @param index The index to set the value at. 2103 * @param value The fileUris to set. 2104 * @return This builder for chaining. 2105 */ setFileUris(int index, java.lang.String value)2106 public Builder setFileUris(int index, java.lang.String value) { 2107 if (value == null) { 2108 throw new NullPointerException(); 2109 } 2110 ensureFileUrisIsMutable(); 2111 fileUris_.set(index, value); 2112 onChanged(); 2113 return this; 2114 } 2115 /** 2116 * 2117 * 2118 * <pre> 2119 * Optional. HCFS URIs of files to be placed in the working directory of 2120 * each executor. Useful for naively parallel tasks. 2121 * </pre> 2122 * 2123 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2124 * 2125 * @param value The fileUris to add. 2126 * @return This builder for chaining. 2127 */ addFileUris(java.lang.String value)2128 public Builder addFileUris(java.lang.String value) { 2129 if (value == null) { 2130 throw new NullPointerException(); 2131 } 2132 ensureFileUrisIsMutable(); 2133 fileUris_.add(value); 2134 onChanged(); 2135 return this; 2136 } 2137 /** 2138 * 2139 * 2140 * <pre> 2141 * Optional. HCFS URIs of files to be placed in the working directory of 2142 * each executor. Useful for naively parallel tasks. 2143 * </pre> 2144 * 2145 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2146 * 2147 * @param values The fileUris to add. 2148 * @return This builder for chaining. 2149 */ addAllFileUris(java.lang.Iterable<java.lang.String> values)2150 public Builder addAllFileUris(java.lang.Iterable<java.lang.String> values) { 2151 ensureFileUrisIsMutable(); 2152 com.google.protobuf.AbstractMessageLite.Builder.addAll(values, fileUris_); 2153 onChanged(); 2154 return this; 2155 } 2156 /** 2157 * 2158 * 2159 * <pre> 2160 * Optional. HCFS URIs of files to be placed in the working directory of 2161 * each executor. Useful for naively parallel tasks. 2162 * </pre> 2163 * 2164 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2165 * 2166 * @return This builder for chaining. 2167 */ clearFileUris()2168 public Builder clearFileUris() { 2169 fileUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 2170 bitField0_ = (bitField0_ & ~0x00000010); 2171 onChanged(); 2172 return this; 2173 } 2174 /** 2175 * 2176 * 2177 * <pre> 2178 * Optional. HCFS URIs of files to be placed in the working directory of 2179 * each executor. Useful for naively parallel tasks. 2180 * </pre> 2181 * 2182 * <code>repeated string file_uris = 5 [(.google.api.field_behavior) = OPTIONAL];</code> 2183 * 2184 * @param value The bytes of the fileUris to add. 2185 * @return This builder for chaining. 2186 */ addFileUrisBytes(com.google.protobuf.ByteString value)2187 public Builder addFileUrisBytes(com.google.protobuf.ByteString value) { 2188 if (value == null) { 2189 throw new NullPointerException(); 2190 } 2191 checkByteStringIsUtf8(value); 2192 ensureFileUrisIsMutable(); 2193 fileUris_.add(value); 2194 onChanged(); 2195 return this; 2196 } 2197 2198 private com.google.protobuf.LazyStringList archiveUris_ = 2199 com.google.protobuf.LazyStringArrayList.EMPTY; 2200 ensureArchiveUrisIsMutable()2201 private void ensureArchiveUrisIsMutable() { 2202 if (!((bitField0_ & 0x00000020) != 0)) { 2203 archiveUris_ = new com.google.protobuf.LazyStringArrayList(archiveUris_); 2204 bitField0_ |= 0x00000020; 2205 } 2206 } 2207 /** 2208 * 2209 * 2210 * <pre> 2211 * Optional. HCFS URIs of archives to be extracted into the working directory 2212 * of each executor. Supported file types: 2213 * .jar, .tar, .tar.gz, .tgz, and .zip. 2214 * </pre> 2215 * 2216 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2217 * 2218 * @return A list containing the archiveUris. 2219 */ getArchiveUrisList()2220 public com.google.protobuf.ProtocolStringList getArchiveUrisList() { 2221 return archiveUris_.getUnmodifiableView(); 2222 } 2223 /** 2224 * 2225 * 2226 * <pre> 2227 * Optional. HCFS URIs of archives to be extracted into the working directory 2228 * of each executor. Supported file types: 2229 * .jar, .tar, .tar.gz, .tgz, and .zip. 2230 * </pre> 2231 * 2232 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2233 * 2234 * @return The count of archiveUris. 2235 */ getArchiveUrisCount()2236 public int getArchiveUrisCount() { 2237 return archiveUris_.size(); 2238 } 2239 /** 2240 * 2241 * 2242 * <pre> 2243 * Optional. HCFS URIs of archives to be extracted into the working directory 2244 * of each executor. Supported file types: 2245 * .jar, .tar, .tar.gz, .tgz, and .zip. 2246 * </pre> 2247 * 2248 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2249 * 2250 * @param index The index of the element to return. 2251 * @return The archiveUris at the given index. 2252 */ getArchiveUris(int index)2253 public java.lang.String getArchiveUris(int index) { 2254 return archiveUris_.get(index); 2255 } 2256 /** 2257 * 2258 * 2259 * <pre> 2260 * Optional. HCFS URIs of archives to be extracted into the working directory 2261 * of each executor. Supported file types: 2262 * .jar, .tar, .tar.gz, .tgz, and .zip. 2263 * </pre> 2264 * 2265 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2266 * 2267 * @param index The index of the value to return. 2268 * @return The bytes of the archiveUris at the given index. 2269 */ getArchiveUrisBytes(int index)2270 public com.google.protobuf.ByteString getArchiveUrisBytes(int index) { 2271 return archiveUris_.getByteString(index); 2272 } 2273 /** 2274 * 2275 * 2276 * <pre> 2277 * Optional. HCFS URIs of archives to be extracted into the working directory 2278 * of each executor. Supported file types: 2279 * .jar, .tar, .tar.gz, .tgz, and .zip. 2280 * </pre> 2281 * 2282 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2283 * 2284 * @param index The index to set the value at. 2285 * @param value The archiveUris to set. 2286 * @return This builder for chaining. 2287 */ setArchiveUris(int index, java.lang.String value)2288 public Builder setArchiveUris(int index, java.lang.String value) { 2289 if (value == null) { 2290 throw new NullPointerException(); 2291 } 2292 ensureArchiveUrisIsMutable(); 2293 archiveUris_.set(index, value); 2294 onChanged(); 2295 return this; 2296 } 2297 /** 2298 * 2299 * 2300 * <pre> 2301 * Optional. HCFS URIs of archives to be extracted into the working directory 2302 * of each executor. Supported file types: 2303 * .jar, .tar, .tar.gz, .tgz, and .zip. 2304 * </pre> 2305 * 2306 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2307 * 2308 * @param value The archiveUris to add. 2309 * @return This builder for chaining. 2310 */ addArchiveUris(java.lang.String value)2311 public Builder addArchiveUris(java.lang.String value) { 2312 if (value == null) { 2313 throw new NullPointerException(); 2314 } 2315 ensureArchiveUrisIsMutable(); 2316 archiveUris_.add(value); 2317 onChanged(); 2318 return this; 2319 } 2320 /** 2321 * 2322 * 2323 * <pre> 2324 * Optional. HCFS URIs of archives to be extracted into the working directory 2325 * of each executor. Supported file types: 2326 * .jar, .tar, .tar.gz, .tgz, and .zip. 2327 * </pre> 2328 * 2329 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2330 * 2331 * @param values The archiveUris to add. 2332 * @return This builder for chaining. 2333 */ addAllArchiveUris(java.lang.Iterable<java.lang.String> values)2334 public Builder addAllArchiveUris(java.lang.Iterable<java.lang.String> values) { 2335 ensureArchiveUrisIsMutable(); 2336 com.google.protobuf.AbstractMessageLite.Builder.addAll(values, archiveUris_); 2337 onChanged(); 2338 return this; 2339 } 2340 /** 2341 * 2342 * 2343 * <pre> 2344 * Optional. HCFS URIs of archives to be extracted into the working directory 2345 * of each executor. Supported file types: 2346 * .jar, .tar, .tar.gz, .tgz, and .zip. 2347 * </pre> 2348 * 2349 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2350 * 2351 * @return This builder for chaining. 2352 */ clearArchiveUris()2353 public Builder clearArchiveUris() { 2354 archiveUris_ = com.google.protobuf.LazyStringArrayList.EMPTY; 2355 bitField0_ = (bitField0_ & ~0x00000020); 2356 onChanged(); 2357 return this; 2358 } 2359 /** 2360 * 2361 * 2362 * <pre> 2363 * Optional. HCFS URIs of archives to be extracted into the working directory 2364 * of each executor. Supported file types: 2365 * .jar, .tar, .tar.gz, .tgz, and .zip. 2366 * </pre> 2367 * 2368 * <code>repeated string archive_uris = 6 [(.google.api.field_behavior) = OPTIONAL];</code> 2369 * 2370 * @param value The bytes of the archiveUris to add. 2371 * @return This builder for chaining. 2372 */ addArchiveUrisBytes(com.google.protobuf.ByteString value)2373 public Builder addArchiveUrisBytes(com.google.protobuf.ByteString value) { 2374 if (value == null) { 2375 throw new NullPointerException(); 2376 } 2377 checkByteStringIsUtf8(value); 2378 ensureArchiveUrisIsMutable(); 2379 archiveUris_.add(value); 2380 onChanged(); 2381 return this; 2382 } 2383 2384 private com.google.protobuf.MapField<java.lang.String, java.lang.String> properties_; 2385 2386 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetProperties()2387 internalGetProperties() { 2388 if (properties_ == null) { 2389 return com.google.protobuf.MapField.emptyMapField( 2390 PropertiesDefaultEntryHolder.defaultEntry); 2391 } 2392 return properties_; 2393 } 2394 2395 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetMutableProperties()2396 internalGetMutableProperties() { 2397 if (properties_ == null) { 2398 properties_ = 2399 com.google.protobuf.MapField.newMapField(PropertiesDefaultEntryHolder.defaultEntry); 2400 } 2401 if (!properties_.isMutable()) { 2402 properties_ = properties_.copy(); 2403 } 2404 bitField0_ |= 0x00000040; 2405 onChanged(); 2406 return properties_; 2407 } 2408 getPropertiesCount()2409 public int getPropertiesCount() { 2410 return internalGetProperties().getMap().size(); 2411 } 2412 /** 2413 * 2414 * 2415 * <pre> 2416 * Optional. A mapping of property names to values, used to configure Spark. 2417 * Properties that conflict with values set by the Dataproc API may be 2418 * overwritten. Can include properties set in 2419 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2420 * </pre> 2421 * 2422 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2423 * </code> 2424 */ 2425 @java.lang.Override containsProperties(java.lang.String key)2426 public boolean containsProperties(java.lang.String key) { 2427 if (key == null) { 2428 throw new NullPointerException("map key"); 2429 } 2430 return internalGetProperties().getMap().containsKey(key); 2431 } 2432 /** Use {@link #getPropertiesMap()} instead. */ 2433 @java.lang.Override 2434 @java.lang.Deprecated getProperties()2435 public java.util.Map<java.lang.String, java.lang.String> getProperties() { 2436 return getPropertiesMap(); 2437 } 2438 /** 2439 * 2440 * 2441 * <pre> 2442 * Optional. A mapping of property names to values, used to configure Spark. 2443 * Properties that conflict with values set by the Dataproc API may be 2444 * overwritten. Can include properties set in 2445 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2446 * </pre> 2447 * 2448 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2449 * </code> 2450 */ 2451 @java.lang.Override getPropertiesMap()2452 public java.util.Map<java.lang.String, java.lang.String> getPropertiesMap() { 2453 return internalGetProperties().getMap(); 2454 } 2455 /** 2456 * 2457 * 2458 * <pre> 2459 * Optional. A mapping of property names to values, used to configure Spark. 2460 * Properties that conflict with values set by the Dataproc API may be 2461 * overwritten. Can include properties set in 2462 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2463 * </pre> 2464 * 2465 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2466 * </code> 2467 */ 2468 @java.lang.Override getPropertiesOrDefault( java.lang.String key, java.lang.String defaultValue)2469 public /* nullable */ java.lang.String getPropertiesOrDefault( 2470 java.lang.String key, 2471 /* nullable */ 2472 java.lang.String defaultValue) { 2473 if (key == null) { 2474 throw new NullPointerException("map key"); 2475 } 2476 java.util.Map<java.lang.String, java.lang.String> map = internalGetProperties().getMap(); 2477 return map.containsKey(key) ? map.get(key) : defaultValue; 2478 } 2479 /** 2480 * 2481 * 2482 * <pre> 2483 * Optional. A mapping of property names to values, used to configure Spark. 2484 * Properties that conflict with values set by the Dataproc API may be 2485 * overwritten. Can include properties set in 2486 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2487 * </pre> 2488 * 2489 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2490 * </code> 2491 */ 2492 @java.lang.Override getPropertiesOrThrow(java.lang.String key)2493 public java.lang.String getPropertiesOrThrow(java.lang.String key) { 2494 if (key == null) { 2495 throw new NullPointerException("map key"); 2496 } 2497 java.util.Map<java.lang.String, java.lang.String> map = internalGetProperties().getMap(); 2498 if (!map.containsKey(key)) { 2499 throw new java.lang.IllegalArgumentException(); 2500 } 2501 return map.get(key); 2502 } 2503 clearProperties()2504 public Builder clearProperties() { 2505 bitField0_ = (bitField0_ & ~0x00000040); 2506 internalGetMutableProperties().getMutableMap().clear(); 2507 return this; 2508 } 2509 /** 2510 * 2511 * 2512 * <pre> 2513 * Optional. A mapping of property names to values, used to configure Spark. 2514 * Properties that conflict with values set by the Dataproc API may be 2515 * overwritten. Can include properties set in 2516 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2517 * </pre> 2518 * 2519 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2520 * </code> 2521 */ removeProperties(java.lang.String key)2522 public Builder removeProperties(java.lang.String key) { 2523 if (key == null) { 2524 throw new NullPointerException("map key"); 2525 } 2526 internalGetMutableProperties().getMutableMap().remove(key); 2527 return this; 2528 } 2529 /** Use alternate mutation accessors instead. */ 2530 @java.lang.Deprecated getMutableProperties()2531 public java.util.Map<java.lang.String, java.lang.String> getMutableProperties() { 2532 bitField0_ |= 0x00000040; 2533 return internalGetMutableProperties().getMutableMap(); 2534 } 2535 /** 2536 * 2537 * 2538 * <pre> 2539 * Optional. A mapping of property names to values, used to configure Spark. 2540 * Properties that conflict with values set by the Dataproc API may be 2541 * overwritten. Can include properties set in 2542 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2543 * </pre> 2544 * 2545 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2546 * </code> 2547 */ putProperties(java.lang.String key, java.lang.String value)2548 public Builder putProperties(java.lang.String key, java.lang.String value) { 2549 if (key == null) { 2550 throw new NullPointerException("map key"); 2551 } 2552 if (value == null) { 2553 throw new NullPointerException("map value"); 2554 } 2555 internalGetMutableProperties().getMutableMap().put(key, value); 2556 bitField0_ |= 0x00000040; 2557 return this; 2558 } 2559 /** 2560 * 2561 * 2562 * <pre> 2563 * Optional. A mapping of property names to values, used to configure Spark. 2564 * Properties that conflict with values set by the Dataproc API may be 2565 * overwritten. Can include properties set in 2566 * /etc/spark/conf/spark-defaults.conf and classes in user code. 2567 * </pre> 2568 * 2569 * <code>map<string, string> properties = 7 [(.google.api.field_behavior) = OPTIONAL]; 2570 * </code> 2571 */ putAllProperties(java.util.Map<java.lang.String, java.lang.String> values)2572 public Builder putAllProperties(java.util.Map<java.lang.String, java.lang.String> values) { 2573 internalGetMutableProperties().getMutableMap().putAll(values); 2574 bitField0_ |= 0x00000040; 2575 return this; 2576 } 2577 2578 private com.google.cloud.dataproc.v1.LoggingConfig loggingConfig_; 2579 private com.google.protobuf.SingleFieldBuilderV3< 2580 com.google.cloud.dataproc.v1.LoggingConfig, 2581 com.google.cloud.dataproc.v1.LoggingConfig.Builder, 2582 com.google.cloud.dataproc.v1.LoggingConfigOrBuilder> 2583 loggingConfigBuilder_; 2584 /** 2585 * 2586 * 2587 * <pre> 2588 * Optional. The runtime log config for job execution. 2589 * </pre> 2590 * 2591 * <code> 2592 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2593 * </code> 2594 * 2595 * @return Whether the loggingConfig field is set. 2596 */ hasLoggingConfig()2597 public boolean hasLoggingConfig() { 2598 return ((bitField0_ & 0x00000080) != 0); 2599 } 2600 /** 2601 * 2602 * 2603 * <pre> 2604 * Optional. The runtime log config for job execution. 2605 * </pre> 2606 * 2607 * <code> 2608 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2609 * </code> 2610 * 2611 * @return The loggingConfig. 2612 */ getLoggingConfig()2613 public com.google.cloud.dataproc.v1.LoggingConfig getLoggingConfig() { 2614 if (loggingConfigBuilder_ == null) { 2615 return loggingConfig_ == null 2616 ? com.google.cloud.dataproc.v1.LoggingConfig.getDefaultInstance() 2617 : loggingConfig_; 2618 } else { 2619 return loggingConfigBuilder_.getMessage(); 2620 } 2621 } 2622 /** 2623 * 2624 * 2625 * <pre> 2626 * Optional. The runtime log config for job execution. 2627 * </pre> 2628 * 2629 * <code> 2630 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2631 * </code> 2632 */ setLoggingConfig(com.google.cloud.dataproc.v1.LoggingConfig value)2633 public Builder setLoggingConfig(com.google.cloud.dataproc.v1.LoggingConfig value) { 2634 if (loggingConfigBuilder_ == null) { 2635 if (value == null) { 2636 throw new NullPointerException(); 2637 } 2638 loggingConfig_ = value; 2639 } else { 2640 loggingConfigBuilder_.setMessage(value); 2641 } 2642 bitField0_ |= 0x00000080; 2643 onChanged(); 2644 return this; 2645 } 2646 /** 2647 * 2648 * 2649 * <pre> 2650 * Optional. The runtime log config for job execution. 2651 * </pre> 2652 * 2653 * <code> 2654 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2655 * </code> 2656 */ setLoggingConfig( com.google.cloud.dataproc.v1.LoggingConfig.Builder builderForValue)2657 public Builder setLoggingConfig( 2658 com.google.cloud.dataproc.v1.LoggingConfig.Builder builderForValue) { 2659 if (loggingConfigBuilder_ == null) { 2660 loggingConfig_ = builderForValue.build(); 2661 } else { 2662 loggingConfigBuilder_.setMessage(builderForValue.build()); 2663 } 2664 bitField0_ |= 0x00000080; 2665 onChanged(); 2666 return this; 2667 } 2668 /** 2669 * 2670 * 2671 * <pre> 2672 * Optional. The runtime log config for job execution. 2673 * </pre> 2674 * 2675 * <code> 2676 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2677 * </code> 2678 */ mergeLoggingConfig(com.google.cloud.dataproc.v1.LoggingConfig value)2679 public Builder mergeLoggingConfig(com.google.cloud.dataproc.v1.LoggingConfig value) { 2680 if (loggingConfigBuilder_ == null) { 2681 if (((bitField0_ & 0x00000080) != 0) 2682 && loggingConfig_ != null 2683 && loggingConfig_ != com.google.cloud.dataproc.v1.LoggingConfig.getDefaultInstance()) { 2684 getLoggingConfigBuilder().mergeFrom(value); 2685 } else { 2686 loggingConfig_ = value; 2687 } 2688 } else { 2689 loggingConfigBuilder_.mergeFrom(value); 2690 } 2691 bitField0_ |= 0x00000080; 2692 onChanged(); 2693 return this; 2694 } 2695 /** 2696 * 2697 * 2698 * <pre> 2699 * Optional. The runtime log config for job execution. 2700 * </pre> 2701 * 2702 * <code> 2703 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2704 * </code> 2705 */ clearLoggingConfig()2706 public Builder clearLoggingConfig() { 2707 bitField0_ = (bitField0_ & ~0x00000080); 2708 loggingConfig_ = null; 2709 if (loggingConfigBuilder_ != null) { 2710 loggingConfigBuilder_.dispose(); 2711 loggingConfigBuilder_ = null; 2712 } 2713 onChanged(); 2714 return this; 2715 } 2716 /** 2717 * 2718 * 2719 * <pre> 2720 * Optional. The runtime log config for job execution. 2721 * </pre> 2722 * 2723 * <code> 2724 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2725 * </code> 2726 */ getLoggingConfigBuilder()2727 public com.google.cloud.dataproc.v1.LoggingConfig.Builder getLoggingConfigBuilder() { 2728 bitField0_ |= 0x00000080; 2729 onChanged(); 2730 return getLoggingConfigFieldBuilder().getBuilder(); 2731 } 2732 /** 2733 * 2734 * 2735 * <pre> 2736 * Optional. The runtime log config for job execution. 2737 * </pre> 2738 * 2739 * <code> 2740 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2741 * </code> 2742 */ getLoggingConfigOrBuilder()2743 public com.google.cloud.dataproc.v1.LoggingConfigOrBuilder getLoggingConfigOrBuilder() { 2744 if (loggingConfigBuilder_ != null) { 2745 return loggingConfigBuilder_.getMessageOrBuilder(); 2746 } else { 2747 return loggingConfig_ == null 2748 ? com.google.cloud.dataproc.v1.LoggingConfig.getDefaultInstance() 2749 : loggingConfig_; 2750 } 2751 } 2752 /** 2753 * 2754 * 2755 * <pre> 2756 * Optional. The runtime log config for job execution. 2757 * </pre> 2758 * 2759 * <code> 2760 * .google.cloud.dataproc.v1.LoggingConfig logging_config = 8 [(.google.api.field_behavior) = OPTIONAL]; 2761 * </code> 2762 */ 2763 private com.google.protobuf.SingleFieldBuilderV3< 2764 com.google.cloud.dataproc.v1.LoggingConfig, 2765 com.google.cloud.dataproc.v1.LoggingConfig.Builder, 2766 com.google.cloud.dataproc.v1.LoggingConfigOrBuilder> getLoggingConfigFieldBuilder()2767 getLoggingConfigFieldBuilder() { 2768 if (loggingConfigBuilder_ == null) { 2769 loggingConfigBuilder_ = 2770 new com.google.protobuf.SingleFieldBuilderV3< 2771 com.google.cloud.dataproc.v1.LoggingConfig, 2772 com.google.cloud.dataproc.v1.LoggingConfig.Builder, 2773 com.google.cloud.dataproc.v1.LoggingConfigOrBuilder>( 2774 getLoggingConfig(), getParentForChildren(), isClean()); 2775 loggingConfig_ = null; 2776 } 2777 return loggingConfigBuilder_; 2778 } 2779 2780 @java.lang.Override setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields)2781 public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { 2782 return super.setUnknownFields(unknownFields); 2783 } 2784 2785 @java.lang.Override mergeUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields)2786 public final Builder mergeUnknownFields( 2787 final com.google.protobuf.UnknownFieldSet unknownFields) { 2788 return super.mergeUnknownFields(unknownFields); 2789 } 2790 2791 // @@protoc_insertion_point(builder_scope:google.cloud.dataproc.v1.SparkJob) 2792 } 2793 2794 // @@protoc_insertion_point(class_scope:google.cloud.dataproc.v1.SparkJob) 2795 private static final com.google.cloud.dataproc.v1.SparkJob DEFAULT_INSTANCE; 2796 2797 static { 2798 DEFAULT_INSTANCE = new com.google.cloud.dataproc.v1.SparkJob(); 2799 } 2800 getDefaultInstance()2801 public static com.google.cloud.dataproc.v1.SparkJob getDefaultInstance() { 2802 return DEFAULT_INSTANCE; 2803 } 2804 2805 private static final com.google.protobuf.Parser<SparkJob> PARSER = 2806 new com.google.protobuf.AbstractParser<SparkJob>() { 2807 @java.lang.Override 2808 public SparkJob parsePartialFrom( 2809 com.google.protobuf.CodedInputStream input, 2810 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 2811 throws com.google.protobuf.InvalidProtocolBufferException { 2812 Builder builder = newBuilder(); 2813 try { 2814 builder.mergeFrom(input, extensionRegistry); 2815 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 2816 throw e.setUnfinishedMessage(builder.buildPartial()); 2817 } catch (com.google.protobuf.UninitializedMessageException e) { 2818 throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); 2819 } catch (java.io.IOException e) { 2820 throw new com.google.protobuf.InvalidProtocolBufferException(e) 2821 .setUnfinishedMessage(builder.buildPartial()); 2822 } 2823 return builder.buildPartial(); 2824 } 2825 }; 2826 parser()2827 public static com.google.protobuf.Parser<SparkJob> parser() { 2828 return PARSER; 2829 } 2830 2831 @java.lang.Override getParserForType()2832 public com.google.protobuf.Parser<SparkJob> getParserForType() { 2833 return PARSER; 2834 } 2835 2836 @java.lang.Override getDefaultInstanceForType()2837 public com.google.cloud.dataproc.v1.SparkJob getDefaultInstanceForType() { 2838 return DEFAULT_INSTANCE; 2839 } 2840 } 2841