This project has retired. For details please refer to its Attic page.
Source code
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}