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/** General cross-language application submission parameters shared by all runtimes */
012@org.apache.avro.specific.AvroGenerated
013public class AvroAppSubmissionParameters extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
014  private static final long serialVersionUID = 6226120013061148611L;
015  public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroAppSubmissionParameters\",\"namespace\":\"org.apache.reef.reef.bridge.client.avro\",\"doc\":\"General cross-language application submission parameters shared by all runtimes\",\"fields\":[{\"name\":\"tcpBeginPort\",\"type\":\"int\"},{\"name\":\"tcpRangeCount\",\"type\":\"int\"},{\"name\":\"tcpTryCount\",\"type\":\"int\"}]}");
016  public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
017  @Deprecated public int tcpBeginPort;
018  @Deprecated public int tcpRangeCount;
019  @Deprecated public int tcpTryCount;
020
021  /**
022   * Default constructor.  Note that this does not initialize fields
023   * to their default values from the schema.  If that is desired then
024   * one should use <code>newBuilder()</code>.
025   */
026  public AvroAppSubmissionParameters() {}
027
028  /**
029   * All-args constructor.
030   * @param tcpBeginPort The new value for tcpBeginPort
031   * @param tcpRangeCount The new value for tcpRangeCount
032   * @param tcpTryCount The new value for tcpTryCount
033   */
034  public AvroAppSubmissionParameters(java.lang.Integer tcpBeginPort, java.lang.Integer tcpRangeCount, java.lang.Integer tcpTryCount) {
035    this.tcpBeginPort = tcpBeginPort;
036    this.tcpRangeCount = tcpRangeCount;
037    this.tcpTryCount = tcpTryCount;
038  }
039
040  public org.apache.avro.Schema getSchema() { return SCHEMA$; }
041  // Used by DatumWriter.  Applications should not call.
042  public java.lang.Object get(int field$) {
043    switch (field$) {
044    case 0: return tcpBeginPort;
045    case 1: return tcpRangeCount;
046    case 2: return tcpTryCount;
047    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
048    }
049  }
050
051  // Used by DatumReader.  Applications should not call.
052  @SuppressWarnings(value="unchecked")
053  public void put(int field$, java.lang.Object value$) {
054    switch (field$) {
055    case 0: tcpBeginPort = (java.lang.Integer)value$; break;
056    case 1: tcpRangeCount = (java.lang.Integer)value$; break;
057    case 2: tcpTryCount = (java.lang.Integer)value$; break;
058    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
059    }
060  }
061
062  /**
063   * Gets the value of the 'tcpBeginPort' field.
064   * @return The value of the 'tcpBeginPort' field.
065   */
066  public java.lang.Integer getTcpBeginPort() {
067    return tcpBeginPort;
068  }
069
070  /**
071   * Sets the value of the 'tcpBeginPort' field.
072   * @param value the value to set.
073   */
074  public void setTcpBeginPort(java.lang.Integer value) {
075    this.tcpBeginPort = value;
076  }
077
078  /**
079   * Gets the value of the 'tcpRangeCount' field.
080   * @return The value of the 'tcpRangeCount' field.
081   */
082  public java.lang.Integer getTcpRangeCount() {
083    return tcpRangeCount;
084  }
085
086  /**
087   * Sets the value of the 'tcpRangeCount' field.
088   * @param value the value to set.
089   */
090  public void setTcpRangeCount(java.lang.Integer value) {
091    this.tcpRangeCount = value;
092  }
093
094  /**
095   * Gets the value of the 'tcpTryCount' field.
096   * @return The value of the 'tcpTryCount' field.
097   */
098  public java.lang.Integer getTcpTryCount() {
099    return tcpTryCount;
100  }
101
102  /**
103   * Sets the value of the 'tcpTryCount' field.
104   * @param value the value to set.
105   */
106  public void setTcpTryCount(java.lang.Integer value) {
107    this.tcpTryCount = value;
108  }
109
110  /**
111   * Creates a new AvroAppSubmissionParameters RecordBuilder.
112   * @return A new AvroAppSubmissionParameters RecordBuilder
113   */
114  public static org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder newBuilder() {
115    return new org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder();
116  }
117
118  /**
119   * Creates a new AvroAppSubmissionParameters RecordBuilder by copying an existing Builder.
120   * @param other The existing builder to copy.
121   * @return A new AvroAppSubmissionParameters RecordBuilder
122   */
123  public static org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder newBuilder(org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder other) {
124    return new org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder(other);
125  }
126
127  /**
128   * Creates a new AvroAppSubmissionParameters RecordBuilder by copying an existing AvroAppSubmissionParameters instance.
129   * @param other The existing instance to copy.
130   * @return A new AvroAppSubmissionParameters RecordBuilder
131   */
132  public static org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder newBuilder(org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters other) {
133    return new org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder(other);
134  }
135
136  /**
137   * RecordBuilder for AvroAppSubmissionParameters instances.
138   */
139  public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroAppSubmissionParameters>
140    implements org.apache.avro.data.RecordBuilder<AvroAppSubmissionParameters> {
141
142    private int tcpBeginPort;
143    private int tcpRangeCount;
144    private int tcpTryCount;
145
146    /** Creates a new Builder */
147    private Builder() {
148      super(SCHEMA$);
149    }
150
151    /**
152     * Creates a Builder by copying an existing Builder.
153     * @param other The existing Builder to copy.
154     */
155    private Builder(org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder other) {
156      super(other);
157      if (isValidValue(fields()[0], other.tcpBeginPort)) {
158        this.tcpBeginPort = data().deepCopy(fields()[0].schema(), other.tcpBeginPort);
159        fieldSetFlags()[0] = true;
160      }
161      if (isValidValue(fields()[1], other.tcpRangeCount)) {
162        this.tcpRangeCount = data().deepCopy(fields()[1].schema(), other.tcpRangeCount);
163        fieldSetFlags()[1] = true;
164      }
165      if (isValidValue(fields()[2], other.tcpTryCount)) {
166        this.tcpTryCount = data().deepCopy(fields()[2].schema(), other.tcpTryCount);
167        fieldSetFlags()[2] = true;
168      }
169    }
170
171    /**
172     * Creates a Builder by copying an existing AvroAppSubmissionParameters instance
173     * @param other The existing instance to copy.
174     */
175    private Builder(org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters other) {
176            super(SCHEMA$);
177      if (isValidValue(fields()[0], other.tcpBeginPort)) {
178        this.tcpBeginPort = data().deepCopy(fields()[0].schema(), other.tcpBeginPort);
179        fieldSetFlags()[0] = true;
180      }
181      if (isValidValue(fields()[1], other.tcpRangeCount)) {
182        this.tcpRangeCount = data().deepCopy(fields()[1].schema(), other.tcpRangeCount);
183        fieldSetFlags()[1] = true;
184      }
185      if (isValidValue(fields()[2], other.tcpTryCount)) {
186        this.tcpTryCount = data().deepCopy(fields()[2].schema(), other.tcpTryCount);
187        fieldSetFlags()[2] = true;
188      }
189    }
190
191    /**
192      * Gets the value of the 'tcpBeginPort' field.
193      * @return The value.
194      */
195    public java.lang.Integer getTcpBeginPort() {
196      return tcpBeginPort;
197    }
198
199    /**
200      * Sets the value of the 'tcpBeginPort' field.
201      * @param value The value of 'tcpBeginPort'.
202      * @return This builder.
203      */
204    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder setTcpBeginPort(int value) {
205      validate(fields()[0], value);
206      this.tcpBeginPort = value;
207      fieldSetFlags()[0] = true;
208      return this;
209    }
210
211    /**
212      * Checks whether the 'tcpBeginPort' field has been set.
213      * @return True if the 'tcpBeginPort' field has been set, false otherwise.
214      */
215    public boolean hasTcpBeginPort() {
216      return fieldSetFlags()[0];
217    }
218
219
220    /**
221      * Clears the value of the 'tcpBeginPort' field.
222      * @return This builder.
223      */
224    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder clearTcpBeginPort() {
225      fieldSetFlags()[0] = false;
226      return this;
227    }
228
229    /**
230      * Gets the value of the 'tcpRangeCount' field.
231      * @return The value.
232      */
233    public java.lang.Integer getTcpRangeCount() {
234      return tcpRangeCount;
235    }
236
237    /**
238      * Sets the value of the 'tcpRangeCount' field.
239      * @param value The value of 'tcpRangeCount'.
240      * @return This builder.
241      */
242    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder setTcpRangeCount(int value) {
243      validate(fields()[1], value);
244      this.tcpRangeCount = value;
245      fieldSetFlags()[1] = true;
246      return this;
247    }
248
249    /**
250      * Checks whether the 'tcpRangeCount' field has been set.
251      * @return True if the 'tcpRangeCount' field has been set, false otherwise.
252      */
253    public boolean hasTcpRangeCount() {
254      return fieldSetFlags()[1];
255    }
256
257
258    /**
259      * Clears the value of the 'tcpRangeCount' field.
260      * @return This builder.
261      */
262    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder clearTcpRangeCount() {
263      fieldSetFlags()[1] = false;
264      return this;
265    }
266
267    /**
268      * Gets the value of the 'tcpTryCount' field.
269      * @return The value.
270      */
271    public java.lang.Integer getTcpTryCount() {
272      return tcpTryCount;
273    }
274
275    /**
276      * Sets the value of the 'tcpTryCount' field.
277      * @param value The value of 'tcpTryCount'.
278      * @return This builder.
279      */
280    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder setTcpTryCount(int value) {
281      validate(fields()[2], value);
282      this.tcpTryCount = value;
283      fieldSetFlags()[2] = true;
284      return this;
285    }
286
287    /**
288      * Checks whether the 'tcpTryCount' field has been set.
289      * @return True if the 'tcpTryCount' field has been set, false otherwise.
290      */
291    public boolean hasTcpTryCount() {
292      return fieldSetFlags()[2];
293    }
294
295
296    /**
297      * Clears the value of the 'tcpTryCount' field.
298      * @return This builder.
299      */
300    public org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder clearTcpTryCount() {
301      fieldSetFlags()[2] = false;
302      return this;
303    }
304
305    @Override
306    public AvroAppSubmissionParameters build() {
307      try {
308        AvroAppSubmissionParameters record = new AvroAppSubmissionParameters();
309        record.tcpBeginPort = fieldSetFlags()[0] ? this.tcpBeginPort : (java.lang.Integer) defaultValue(fields()[0]);
310        record.tcpRangeCount = fieldSetFlags()[1] ? this.tcpRangeCount : (java.lang.Integer) defaultValue(fields()[1]);
311        record.tcpTryCount = fieldSetFlags()[2] ? this.tcpTryCount : (java.lang.Integer) defaultValue(fields()[2]);
312        return record;
313      } catch (Exception e) {
314        throw new org.apache.avro.AvroRuntimeException(e);
315      }
316    }
317  }
318
319  private static final org.apache.avro.io.DatumWriter
320    WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
321
322  @Override public void writeExternal(java.io.ObjectOutput out)
323    throws java.io.IOException {
324    WRITER$.write(this, SpecificData.getEncoder(out));
325  }
326
327  private static final org.apache.avro.io.DatumReader
328    READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
329
330  @Override public void readExternal(java.io.ObjectInput in)
331    throws java.io.IOException {
332    READER$.read(this, SpecificData.getDecoder(in));
333  }
334
335}