001/** 002 * Autogenerated by Avro 003 * 004 * DO NOT EDIT DIRECTLY 005 */ 006package org.apache.reef.reef.bridge.client.avro; 007 008import org.apache.avro.specific.SpecificData; 009 010@SuppressWarnings("all") 011/** Cross-language submission parameters to the YARN runtime using Hadoop's submission client */ 012@org.apache.avro.specific.AvroGenerated 013public class AvroYarnClusterJobSubmissionParameters extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { 014 private static final long serialVersionUID = 2208825346642604359L; 015 public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroYarnClusterJobSubmissionParameters\",\"namespace\":\"org.apache.reef.reef.bridge.client.avro\",\"doc\":\"Cross-language submission parameters to the YARN runtime using Hadoop's submission client\",\"fields\":[{\"name\":\"yarnJobSubmissionParameters\",\"type\":{\"type\":\"record\",\"name\":\"AvroYarnJobSubmissionParameters\",\"doc\":\"General cross-language submission parameters to the YARN runtime\",\"fields\":[{\"name\":\"sharedJobSubmissionParameters\",\"type\":{\"type\":\"record\",\"name\":\"AvroJobSubmissionParameters\",\"doc\":\"General cross-language job submission parameters shared by all runtimes\",\"fields\":[{\"name\":\"jobId\",\"type\":\"string\"},{\"name\":\"jobSubmissionFolder\",\"type\":\"string\"}]}},{\"name\":\"dfsJobSubmissionFolder\",\"type\":\"string\",\"default\":\"NULL\"},{\"name\":\"fileSystemUrl\",\"type\":\"string\",\"default\":\"NULL\"},{\"name\":\"jobSubmissionDirectoryPrefix\",\"type\":\"string\"}]}},{\"name\":\"securityTokenKind\",\"type\":\"string\",\"default\":\"NULL\"},{\"name\":\"securityTokenService\",\"type\":\"string\",\"default\":\"NULL\"},{\"name\":\"driverMemory\",\"type\":\"int\"},{\"name\":\"maxApplicationSubmissions\",\"type\":\"int\"},{\"name\":\"driverStdoutFilePath\",\"type\":\"string\"},{\"name\":\"driverStderrFilePath\",\"type\":\"string\"}]}"); 016 public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } 017 @Deprecated public org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters yarnJobSubmissionParameters; 018 @Deprecated public java.lang.CharSequence securityTokenKind; 019 @Deprecated public java.lang.CharSequence securityTokenService; 020 @Deprecated public int driverMemory; 021 @Deprecated public int maxApplicationSubmissions; 022 @Deprecated public java.lang.CharSequence driverStdoutFilePath; 023 @Deprecated public java.lang.CharSequence driverStderrFilePath; 024 025 /** 026 * Default constructor. Note that this does not initialize fields 027 * to their default values from the schema. If that is desired then 028 * one should use <code>newBuilder()</code>. 029 */ 030 public AvroYarnClusterJobSubmissionParameters() {} 031 032 /** 033 * All-args constructor. 034 * @param yarnJobSubmissionParameters The new value for yarnJobSubmissionParameters 035 * @param securityTokenKind The new value for securityTokenKind 036 * @param securityTokenService The new value for securityTokenService 037 * @param driverMemory The new value for driverMemory 038 * @param maxApplicationSubmissions The new value for maxApplicationSubmissions 039 * @param driverStdoutFilePath The new value for driverStdoutFilePath 040 * @param driverStderrFilePath The new value for driverStderrFilePath 041 */ 042 public AvroYarnClusterJobSubmissionParameters(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters yarnJobSubmissionParameters, java.lang.CharSequence securityTokenKind, java.lang.CharSequence securityTokenService, java.lang.Integer driverMemory, java.lang.Integer maxApplicationSubmissions, java.lang.CharSequence driverStdoutFilePath, java.lang.CharSequence driverStderrFilePath) { 043 this.yarnJobSubmissionParameters = yarnJobSubmissionParameters; 044 this.securityTokenKind = securityTokenKind; 045 this.securityTokenService = securityTokenService; 046 this.driverMemory = driverMemory; 047 this.maxApplicationSubmissions = maxApplicationSubmissions; 048 this.driverStdoutFilePath = driverStdoutFilePath; 049 this.driverStderrFilePath = driverStderrFilePath; 050 } 051 052 public org.apache.avro.Schema getSchema() { return SCHEMA$; } 053 // Used by DatumWriter. Applications should not call. 054 public java.lang.Object get(int field$) { 055 switch (field$) { 056 case 0: return yarnJobSubmissionParameters; 057 case 1: return securityTokenKind; 058 case 2: return securityTokenService; 059 case 3: return driverMemory; 060 case 4: return maxApplicationSubmissions; 061 case 5: return driverStdoutFilePath; 062 case 6: return driverStderrFilePath; 063 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 064 } 065 } 066 067 // Used by DatumReader. Applications should not call. 068 @SuppressWarnings(value="unchecked") 069 public void put(int field$, java.lang.Object value$) { 070 switch (field$) { 071 case 0: yarnJobSubmissionParameters = (org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters)value$; break; 072 case 1: securityTokenKind = (java.lang.CharSequence)value$; break; 073 case 2: securityTokenService = (java.lang.CharSequence)value$; break; 074 case 3: driverMemory = (java.lang.Integer)value$; break; 075 case 4: maxApplicationSubmissions = (java.lang.Integer)value$; break; 076 case 5: driverStdoutFilePath = (java.lang.CharSequence)value$; break; 077 case 6: driverStderrFilePath = (java.lang.CharSequence)value$; break; 078 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 079 } 080 } 081 082 /** 083 * Gets the value of the 'yarnJobSubmissionParameters' field. 084 * @return The value of the 'yarnJobSubmissionParameters' field. 085 */ 086 public org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters getYarnJobSubmissionParameters() { 087 return yarnJobSubmissionParameters; 088 } 089 090 /** 091 * Sets the value of the 'yarnJobSubmissionParameters' field. 092 * @param value the value to set. 093 */ 094 public void setYarnJobSubmissionParameters(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters value) { 095 this.yarnJobSubmissionParameters = value; 096 } 097 098 /** 099 * Gets the value of the 'securityTokenKind' field. 100 * @return The value of the 'securityTokenKind' field. 101 */ 102 public java.lang.CharSequence getSecurityTokenKind() { 103 return securityTokenKind; 104 } 105 106 /** 107 * Sets the value of the 'securityTokenKind' field. 108 * @param value the value to set. 109 */ 110 public void setSecurityTokenKind(java.lang.CharSequence value) { 111 this.securityTokenKind = value; 112 } 113 114 /** 115 * Gets the value of the 'securityTokenService' field. 116 * @return The value of the 'securityTokenService' field. 117 */ 118 public java.lang.CharSequence getSecurityTokenService() { 119 return securityTokenService; 120 } 121 122 /** 123 * Sets the value of the 'securityTokenService' field. 124 * @param value the value to set. 125 */ 126 public void setSecurityTokenService(java.lang.CharSequence value) { 127 this.securityTokenService = value; 128 } 129 130 /** 131 * Gets the value of the 'driverMemory' field. 132 * @return The value of the 'driverMemory' field. 133 */ 134 public java.lang.Integer getDriverMemory() { 135 return driverMemory; 136 } 137 138 /** 139 * Sets the value of the 'driverMemory' field. 140 * @param value the value to set. 141 */ 142 public void setDriverMemory(java.lang.Integer value) { 143 this.driverMemory = value; 144 } 145 146 /** 147 * Gets the value of the 'maxApplicationSubmissions' field. 148 * @return The value of the 'maxApplicationSubmissions' field. 149 */ 150 public java.lang.Integer getMaxApplicationSubmissions() { 151 return maxApplicationSubmissions; 152 } 153 154 /** 155 * Sets the value of the 'maxApplicationSubmissions' field. 156 * @param value the value to set. 157 */ 158 public void setMaxApplicationSubmissions(java.lang.Integer value) { 159 this.maxApplicationSubmissions = value; 160 } 161 162 /** 163 * Gets the value of the 'driverStdoutFilePath' field. 164 * @return The value of the 'driverStdoutFilePath' field. 165 */ 166 public java.lang.CharSequence getDriverStdoutFilePath() { 167 return driverStdoutFilePath; 168 } 169 170 /** 171 * Sets the value of the 'driverStdoutFilePath' field. 172 * @param value the value to set. 173 */ 174 public void setDriverStdoutFilePath(java.lang.CharSequence value) { 175 this.driverStdoutFilePath = value; 176 } 177 178 /** 179 * Gets the value of the 'driverStderrFilePath' field. 180 * @return The value of the 'driverStderrFilePath' field. 181 */ 182 public java.lang.CharSequence getDriverStderrFilePath() { 183 return driverStderrFilePath; 184 } 185 186 /** 187 * Sets the value of the 'driverStderrFilePath' field. 188 * @param value the value to set. 189 */ 190 public void setDriverStderrFilePath(java.lang.CharSequence value) { 191 this.driverStderrFilePath = value; 192 } 193 194 /** 195 * Creates a new AvroYarnClusterJobSubmissionParameters RecordBuilder. 196 * @return A new AvroYarnClusterJobSubmissionParameters RecordBuilder 197 */ 198 public static org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder newBuilder() { 199 return new org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder(); 200 } 201 202 /** 203 * Creates a new AvroYarnClusterJobSubmissionParameters RecordBuilder by copying an existing Builder. 204 * @param other The existing builder to copy. 205 * @return A new AvroYarnClusterJobSubmissionParameters RecordBuilder 206 */ 207 public static org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder newBuilder(org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder other) { 208 return new org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder(other); 209 } 210 211 /** 212 * Creates a new AvroYarnClusterJobSubmissionParameters RecordBuilder by copying an existing AvroYarnClusterJobSubmissionParameters instance. 213 * @param other The existing instance to copy. 214 * @return A new AvroYarnClusterJobSubmissionParameters RecordBuilder 215 */ 216 public static org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder newBuilder(org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters other) { 217 return new org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder(other); 218 } 219 220 /** 221 * RecordBuilder for AvroYarnClusterJobSubmissionParameters instances. 222 */ 223 public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroYarnClusterJobSubmissionParameters> 224 implements org.apache.avro.data.RecordBuilder<AvroYarnClusterJobSubmissionParameters> { 225 226 private org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters yarnJobSubmissionParameters; 227 private org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder yarnJobSubmissionParametersBuilder; 228 private java.lang.CharSequence securityTokenKind; 229 private java.lang.CharSequence securityTokenService; 230 private int driverMemory; 231 private int maxApplicationSubmissions; 232 private java.lang.CharSequence driverStdoutFilePath; 233 private java.lang.CharSequence driverStderrFilePath; 234 235 /** Creates a new Builder */ 236 private Builder() { 237 super(SCHEMA$); 238 } 239 240 /** 241 * Creates a Builder by copying an existing Builder. 242 * @param other The existing Builder to copy. 243 */ 244 private Builder(org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder other) { 245 super(other); 246 if (isValidValue(fields()[0], other.yarnJobSubmissionParameters)) { 247 this.yarnJobSubmissionParameters = data().deepCopy(fields()[0].schema(), other.yarnJobSubmissionParameters); 248 fieldSetFlags()[0] = true; 249 } 250 if (other.hasYarnJobSubmissionParametersBuilder()) { 251 this.yarnJobSubmissionParametersBuilder = org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.newBuilder(other.getYarnJobSubmissionParametersBuilder()); 252 } 253 if (isValidValue(fields()[1], other.securityTokenKind)) { 254 this.securityTokenKind = data().deepCopy(fields()[1].schema(), other.securityTokenKind); 255 fieldSetFlags()[1] = true; 256 } 257 if (isValidValue(fields()[2], other.securityTokenService)) { 258 this.securityTokenService = data().deepCopy(fields()[2].schema(), other.securityTokenService); 259 fieldSetFlags()[2] = true; 260 } 261 if (isValidValue(fields()[3], other.driverMemory)) { 262 this.driverMemory = data().deepCopy(fields()[3].schema(), other.driverMemory); 263 fieldSetFlags()[3] = true; 264 } 265 if (isValidValue(fields()[4], other.maxApplicationSubmissions)) { 266 this.maxApplicationSubmissions = data().deepCopy(fields()[4].schema(), other.maxApplicationSubmissions); 267 fieldSetFlags()[4] = true; 268 } 269 if (isValidValue(fields()[5], other.driverStdoutFilePath)) { 270 this.driverStdoutFilePath = data().deepCopy(fields()[5].schema(), other.driverStdoutFilePath); 271 fieldSetFlags()[5] = true; 272 } 273 if (isValidValue(fields()[6], other.driverStderrFilePath)) { 274 this.driverStderrFilePath = data().deepCopy(fields()[6].schema(), other.driverStderrFilePath); 275 fieldSetFlags()[6] = true; 276 } 277 } 278 279 /** 280 * Creates a Builder by copying an existing AvroYarnClusterJobSubmissionParameters instance 281 * @param other The existing instance to copy. 282 */ 283 private Builder(org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters other) { 284 super(SCHEMA$); 285 if (isValidValue(fields()[0], other.yarnJobSubmissionParameters)) { 286 this.yarnJobSubmissionParameters = data().deepCopy(fields()[0].schema(), other.yarnJobSubmissionParameters); 287 fieldSetFlags()[0] = true; 288 } 289 this.yarnJobSubmissionParametersBuilder = null; 290 if (isValidValue(fields()[1], other.securityTokenKind)) { 291 this.securityTokenKind = data().deepCopy(fields()[1].schema(), other.securityTokenKind); 292 fieldSetFlags()[1] = true; 293 } 294 if (isValidValue(fields()[2], other.securityTokenService)) { 295 this.securityTokenService = data().deepCopy(fields()[2].schema(), other.securityTokenService); 296 fieldSetFlags()[2] = true; 297 } 298 if (isValidValue(fields()[3], other.driverMemory)) { 299 this.driverMemory = data().deepCopy(fields()[3].schema(), other.driverMemory); 300 fieldSetFlags()[3] = true; 301 } 302 if (isValidValue(fields()[4], other.maxApplicationSubmissions)) { 303 this.maxApplicationSubmissions = data().deepCopy(fields()[4].schema(), other.maxApplicationSubmissions); 304 fieldSetFlags()[4] = true; 305 } 306 if (isValidValue(fields()[5], other.driverStdoutFilePath)) { 307 this.driverStdoutFilePath = data().deepCopy(fields()[5].schema(), other.driverStdoutFilePath); 308 fieldSetFlags()[5] = true; 309 } 310 if (isValidValue(fields()[6], other.driverStderrFilePath)) { 311 this.driverStderrFilePath = data().deepCopy(fields()[6].schema(), other.driverStderrFilePath); 312 fieldSetFlags()[6] = true; 313 } 314 } 315 316 /** 317 * Gets the value of the 'yarnJobSubmissionParameters' field. 318 * @return The value. 319 */ 320 public org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters getYarnJobSubmissionParameters() { 321 return yarnJobSubmissionParameters; 322 } 323 324 /** 325 * Sets the value of the 'yarnJobSubmissionParameters' field. 326 * @param value The value of 'yarnJobSubmissionParameters'. 327 * @return This builder. 328 */ 329 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setYarnJobSubmissionParameters(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters value) { 330 validate(fields()[0], value); 331 this.yarnJobSubmissionParametersBuilder = null; 332 this.yarnJobSubmissionParameters = value; 333 fieldSetFlags()[0] = true; 334 return this; 335 } 336 337 /** 338 * Checks whether the 'yarnJobSubmissionParameters' field has been set. 339 * @return True if the 'yarnJobSubmissionParameters' field has been set, false otherwise. 340 */ 341 public boolean hasYarnJobSubmissionParameters() { 342 return fieldSetFlags()[0]; 343 } 344 345 /** 346 * Gets the Builder instance for the 'yarnJobSubmissionParameters' field and creates one if it doesn't exist yet. 347 * @return This builder. 348 */ 349 public org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder getYarnJobSubmissionParametersBuilder() { 350 if (yarnJobSubmissionParametersBuilder == null) { 351 if (hasYarnJobSubmissionParameters()) { 352 setYarnJobSubmissionParametersBuilder(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.newBuilder(yarnJobSubmissionParameters)); 353 } else { 354 setYarnJobSubmissionParametersBuilder(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.newBuilder()); 355 } 356 } 357 return yarnJobSubmissionParametersBuilder; 358 } 359 360 /** 361 * Sets the Builder instance for the 'yarnJobSubmissionParameters' field 362 * @param value The builder instance that must be set. 363 * @return This builder. 364 */ 365 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setYarnJobSubmissionParametersBuilder(org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder value) { 366 clearYarnJobSubmissionParameters(); 367 yarnJobSubmissionParametersBuilder = value; 368 return this; 369 } 370 371 /** 372 * Checks whether the 'yarnJobSubmissionParameters' field has an active Builder instance 373 * @return True if the 'yarnJobSubmissionParameters' field has an active Builder instance 374 */ 375 public boolean hasYarnJobSubmissionParametersBuilder() { 376 return yarnJobSubmissionParametersBuilder != null; 377 } 378 379 /** 380 * Clears the value of the 'yarnJobSubmissionParameters' field. 381 * @return This builder. 382 */ 383 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearYarnJobSubmissionParameters() { 384 yarnJobSubmissionParameters = null; 385 yarnJobSubmissionParametersBuilder = null; 386 fieldSetFlags()[0] = false; 387 return this; 388 } 389 390 /** 391 * Gets the value of the 'securityTokenKind' field. 392 * @return The value. 393 */ 394 public java.lang.CharSequence getSecurityTokenKind() { 395 return securityTokenKind; 396 } 397 398 /** 399 * Sets the value of the 'securityTokenKind' field. 400 * @param value The value of 'securityTokenKind'. 401 * @return This builder. 402 */ 403 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setSecurityTokenKind(java.lang.CharSequence value) { 404 validate(fields()[1], value); 405 this.securityTokenKind = value; 406 fieldSetFlags()[1] = true; 407 return this; 408 } 409 410 /** 411 * Checks whether the 'securityTokenKind' field has been set. 412 * @return True if the 'securityTokenKind' field has been set, false otherwise. 413 */ 414 public boolean hasSecurityTokenKind() { 415 return fieldSetFlags()[1]; 416 } 417 418 419 /** 420 * Clears the value of the 'securityTokenKind' field. 421 * @return This builder. 422 */ 423 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearSecurityTokenKind() { 424 securityTokenKind = null; 425 fieldSetFlags()[1] = false; 426 return this; 427 } 428 429 /** 430 * Gets the value of the 'securityTokenService' field. 431 * @return The value. 432 */ 433 public java.lang.CharSequence getSecurityTokenService() { 434 return securityTokenService; 435 } 436 437 /** 438 * Sets the value of the 'securityTokenService' field. 439 * @param value The value of 'securityTokenService'. 440 * @return This builder. 441 */ 442 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setSecurityTokenService(java.lang.CharSequence value) { 443 validate(fields()[2], value); 444 this.securityTokenService = value; 445 fieldSetFlags()[2] = true; 446 return this; 447 } 448 449 /** 450 * Checks whether the 'securityTokenService' field has been set. 451 * @return True if the 'securityTokenService' field has been set, false otherwise. 452 */ 453 public boolean hasSecurityTokenService() { 454 return fieldSetFlags()[2]; 455 } 456 457 458 /** 459 * Clears the value of the 'securityTokenService' field. 460 * @return This builder. 461 */ 462 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearSecurityTokenService() { 463 securityTokenService = null; 464 fieldSetFlags()[2] = false; 465 return this; 466 } 467 468 /** 469 * Gets the value of the 'driverMemory' field. 470 * @return The value. 471 */ 472 public java.lang.Integer getDriverMemory() { 473 return driverMemory; 474 } 475 476 /** 477 * Sets the value of the 'driverMemory' field. 478 * @param value The value of 'driverMemory'. 479 * @return This builder. 480 */ 481 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setDriverMemory(int value) { 482 validate(fields()[3], value); 483 this.driverMemory = value; 484 fieldSetFlags()[3] = true; 485 return this; 486 } 487 488 /** 489 * Checks whether the 'driverMemory' field has been set. 490 * @return True if the 'driverMemory' field has been set, false otherwise. 491 */ 492 public boolean hasDriverMemory() { 493 return fieldSetFlags()[3]; 494 } 495 496 497 /** 498 * Clears the value of the 'driverMemory' field. 499 * @return This builder. 500 */ 501 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearDriverMemory() { 502 fieldSetFlags()[3] = false; 503 return this; 504 } 505 506 /** 507 * Gets the value of the 'maxApplicationSubmissions' field. 508 * @return The value. 509 */ 510 public java.lang.Integer getMaxApplicationSubmissions() { 511 return maxApplicationSubmissions; 512 } 513 514 /** 515 * Sets the value of the 'maxApplicationSubmissions' field. 516 * @param value The value of 'maxApplicationSubmissions'. 517 * @return This builder. 518 */ 519 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setMaxApplicationSubmissions(int value) { 520 validate(fields()[4], value); 521 this.maxApplicationSubmissions = value; 522 fieldSetFlags()[4] = true; 523 return this; 524 } 525 526 /** 527 * Checks whether the 'maxApplicationSubmissions' field has been set. 528 * @return True if the 'maxApplicationSubmissions' field has been set, false otherwise. 529 */ 530 public boolean hasMaxApplicationSubmissions() { 531 return fieldSetFlags()[4]; 532 } 533 534 535 /** 536 * Clears the value of the 'maxApplicationSubmissions' field. 537 * @return This builder. 538 */ 539 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearMaxApplicationSubmissions() { 540 fieldSetFlags()[4] = false; 541 return this; 542 } 543 544 /** 545 * Gets the value of the 'driverStdoutFilePath' field. 546 * @return The value. 547 */ 548 public java.lang.CharSequence getDriverStdoutFilePath() { 549 return driverStdoutFilePath; 550 } 551 552 /** 553 * Sets the value of the 'driverStdoutFilePath' field. 554 * @param value The value of 'driverStdoutFilePath'. 555 * @return This builder. 556 */ 557 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setDriverStdoutFilePath(java.lang.CharSequence value) { 558 validate(fields()[5], value); 559 this.driverStdoutFilePath = value; 560 fieldSetFlags()[5] = true; 561 return this; 562 } 563 564 /** 565 * Checks whether the 'driverStdoutFilePath' field has been set. 566 * @return True if the 'driverStdoutFilePath' field has been set, false otherwise. 567 */ 568 public boolean hasDriverStdoutFilePath() { 569 return fieldSetFlags()[5]; 570 } 571 572 573 /** 574 * Clears the value of the 'driverStdoutFilePath' field. 575 * @return This builder. 576 */ 577 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearDriverStdoutFilePath() { 578 driverStdoutFilePath = null; 579 fieldSetFlags()[5] = false; 580 return this; 581 } 582 583 /** 584 * Gets the value of the 'driverStderrFilePath' field. 585 * @return The value. 586 */ 587 public java.lang.CharSequence getDriverStderrFilePath() { 588 return driverStderrFilePath; 589 } 590 591 /** 592 * Sets the value of the 'driverStderrFilePath' field. 593 * @param value The value of 'driverStderrFilePath'. 594 * @return This builder. 595 */ 596 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder setDriverStderrFilePath(java.lang.CharSequence value) { 597 validate(fields()[6], value); 598 this.driverStderrFilePath = value; 599 fieldSetFlags()[6] = true; 600 return this; 601 } 602 603 /** 604 * Checks whether the 'driverStderrFilePath' field has been set. 605 * @return True if the 'driverStderrFilePath' field has been set, false otherwise. 606 */ 607 public boolean hasDriverStderrFilePath() { 608 return fieldSetFlags()[6]; 609 } 610 611 612 /** 613 * Clears the value of the 'driverStderrFilePath' field. 614 * @return This builder. 615 */ 616 public org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder clearDriverStderrFilePath() { 617 driverStderrFilePath = null; 618 fieldSetFlags()[6] = false; 619 return this; 620 } 621 622 @Override 623 public AvroYarnClusterJobSubmissionParameters build() { 624 try { 625 AvroYarnClusterJobSubmissionParameters record = new AvroYarnClusterJobSubmissionParameters(); 626 if (yarnJobSubmissionParametersBuilder != null) { 627 record.yarnJobSubmissionParameters = this.yarnJobSubmissionParametersBuilder.build(); 628 } else { 629 record.yarnJobSubmissionParameters = fieldSetFlags()[0] ? this.yarnJobSubmissionParameters : (org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters) defaultValue(fields()[0]); 630 } 631 record.securityTokenKind = fieldSetFlags()[1] ? this.securityTokenKind : (java.lang.CharSequence) defaultValue(fields()[1]); 632 record.securityTokenService = fieldSetFlags()[2] ? this.securityTokenService : (java.lang.CharSequence) defaultValue(fields()[2]); 633 record.driverMemory = fieldSetFlags()[3] ? this.driverMemory : (java.lang.Integer) defaultValue(fields()[3]); 634 record.maxApplicationSubmissions = fieldSetFlags()[4] ? this.maxApplicationSubmissions : (java.lang.Integer) defaultValue(fields()[4]); 635 record.driverStdoutFilePath = fieldSetFlags()[5] ? this.driverStdoutFilePath : (java.lang.CharSequence) defaultValue(fields()[5]); 636 record.driverStderrFilePath = fieldSetFlags()[6] ? this.driverStderrFilePath : (java.lang.CharSequence) defaultValue(fields()[6]); 637 return record; 638 } catch (Exception e) { 639 throw new org.apache.avro.AvroRuntimeException(e); 640 } 641 } 642 } 643 644 private static final org.apache.avro.io.DatumWriter 645 WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$); 646 647 @Override public void writeExternal(java.io.ObjectOutput out) 648 throws java.io.IOException { 649 WRITER$.write(this, SpecificData.getEncoder(out)); 650 } 651 652 private static final org.apache.avro.io.DatumReader 653 READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$); 654 655 @Override public void readExternal(java.io.ObjectInput in) 656 throws java.io.IOException { 657 READER$.read(this, SpecificData.getDecoder(in)); 658 } 659 660}