Source code

001/**
002 * Autogenerated by Avro
003 *
004 * DO NOT EDIT DIRECTLY
005 */
006package org.apache.reef.io.watcher.driver.task;
007
008import org.apache.avro.specific.SpecificData;
009
010@SuppressWarnings("all")
011@org.apache.avro.specific.AvroGenerated
012public class AvroRunningTask extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
013  private static final long serialVersionUID = -504230958324499171L;
014  public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroRunningTask\",\"namespace\":\"org.apache.reef.io.watcher.driver.task\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"activeContext\",\"type\":{\"type\":\"record\",\"name\":\"AvroActiveContext\",\"namespace\":\"org.apache.reef.io.watcher.driver.context\",\"fields\":[{\"name\":\"base\",\"type\":{\"type\":\"record\",\"name\":\"AvroContextBase\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"evaluatorId\",\"type\":\"string\"},{\"name\":\"parentId\",\"type\":[\"string\",\"null\"]},{\"name\":\"evaluatorDescriptor\",\"type\":[{\"type\":\"record\",\"name\":\"AvroEvaluatorDescriptor\",\"namespace\":\"org.apache.reef.io.watcher.driver.evaluator\",\"fields\":[{\"name\":\"nodeDescriptor\",\"type\":{\"type\":\"record\",\"name\":\"AvroNodeDescriptor\",\"namespace\":\"org.apache.reef.io.watcher.driver.catalog\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"},{\"name\":\"rackDescriptor\",\"type\":{\"type\":\"record\",\"name\":\"AvroRackDescriptor\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"nodes\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"AvroNodeDescriptorInRackDescriptor\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"inetSocketAddress\",\"type\":\"string\"}]}}}]}}]}},{\"name\":\"process\",\"type\":{\"type\":\"record\",\"name\":\"AvroEvaluatorProcess\",\"fields\":[{\"name\":\"commandLines\",\"type\":{\"type\":\"array\",\"items\":[\"string\",\"null\"]}},{\"name\":\"evaluatorType\",\"type\":{\"type\":\"enum\",\"name\":\"AvroEvaluatorType\",\"symbols\":[\"JVM\",\"CLR\",\"UNDECIDED\"]}},{\"name\":\"isOptionSet\",\"type\":\"boolean\"}]}},{\"name\":\"memory\",\"type\":\"int\"},{\"name\":\"numberOfCores\",\"type\":\"int\"}]},\"null\"]}]}}]}}]}");
015  public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
016  @Deprecated public java.lang.CharSequence id;
017  @Deprecated public org.apache.reef.io.watcher.driver.context.AvroActiveContext activeContext;
018
019  /**
020   * Default constructor.  Note that this does not initialize fields
021   * to their default values from the schema.  If that is desired then
022   * one should use <code>newBuilder()</code>.
023   */
024  public AvroRunningTask() {}
025
026  /**
027   * All-args constructor.
028   * @param id The new value for id
029   * @param activeContext The new value for activeContext
030   */
031  public AvroRunningTask(java.lang.CharSequence id, org.apache.reef.io.watcher.driver.context.AvroActiveContext activeContext) {
032    this.id = id;
033    this.activeContext = activeContext;
034  }
035
036  public org.apache.avro.Schema getSchema() { return SCHEMA$; }
037  // Used by DatumWriter.  Applications should not call.
038  public java.lang.Object get(int field$) {
039    switch (field$) {
040    case 0: return id;
041    case 1: return activeContext;
042    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
043    }
044  }
045
046  // Used by DatumReader.  Applications should not call.
047  @SuppressWarnings(value="unchecked")
048  public void put(int field$, java.lang.Object value$) {
049    switch (field$) {
050    case 0: id = (java.lang.CharSequence)value$; break;
051    case 1: activeContext = (org.apache.reef.io.watcher.driver.context.AvroActiveContext)value$; break;
052    default: throw new org.apache.avro.AvroRuntimeException("Bad index");
053    }
054  }
055
056  /**
057   * Gets the value of the 'id' field.
058   * @return The value of the 'id' field.
059   */
060  public java.lang.CharSequence getId() {
061    return id;
062  }
063
064  /**
065   * Sets the value of the 'id' field.
066   * @param value the value to set.
067   */
068  public void setId(java.lang.CharSequence value) {
069    this.id = value;
070  }
071
072  /**
073   * Gets the value of the 'activeContext' field.
074   * @return The value of the 'activeContext' field.
075   */
076  public org.apache.reef.io.watcher.driver.context.AvroActiveContext getActiveContext() {
077    return activeContext;
078  }
079
080  /**
081   * Sets the value of the 'activeContext' field.
082   * @param value the value to set.
083   */
084  public void setActiveContext(org.apache.reef.io.watcher.driver.context.AvroActiveContext value) {
085    this.activeContext = value;
086  }
087
088  /**
089   * Creates a new AvroRunningTask RecordBuilder.
090   * @return A new AvroRunningTask RecordBuilder
091   */
092  public static org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder newBuilder() {
093    return new org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder();
094  }
095
096  /**
097   * Creates a new AvroRunningTask RecordBuilder by copying an existing Builder.
098   * @param other The existing builder to copy.
099   * @return A new AvroRunningTask RecordBuilder
100   */
101  public static org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder newBuilder(org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder other) {
102    return new org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder(other);
103  }
104
105  /**
106   * Creates a new AvroRunningTask RecordBuilder by copying an existing AvroRunningTask instance.
107   * @param other The existing instance to copy.
108   * @return A new AvroRunningTask RecordBuilder
109   */
110  public static org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder newBuilder(org.apache.reef.io.watcher.driver.task.AvroRunningTask other) {
111    return new org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder(other);
112  }
113
114  /**
115   * RecordBuilder for AvroRunningTask instances.
116   */
117  public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroRunningTask>
118    implements org.apache.avro.data.RecordBuilder<AvroRunningTask> {
119
120    private java.lang.CharSequence id;
121    private org.apache.reef.io.watcher.driver.context.AvroActiveContext activeContext;
122    private org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder activeContextBuilder;
123
124    /** Creates a new Builder */
125    private Builder() {
126      super(SCHEMA$);
127    }
128
129    /**
130     * Creates a Builder by copying an existing Builder.
131     * @param other The existing Builder to copy.
132     */
133    private Builder(org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder other) {
134      super(other);
135      if (isValidValue(fields()[0], other.id)) {
136        this.id = data().deepCopy(fields()[0].schema(), other.id);
137        fieldSetFlags()[0] = true;
138      }
139      if (isValidValue(fields()[1], other.activeContext)) {
140        this.activeContext = data().deepCopy(fields()[1].schema(), other.activeContext);
141        fieldSetFlags()[1] = true;
142      }
143      if (other.hasActiveContextBuilder()) {
144        this.activeContextBuilder = org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder(other.getActiveContextBuilder());
145      }
146    }
147
148    /**
149     * Creates a Builder by copying an existing AvroRunningTask instance
150     * @param other The existing instance to copy.
151     */
152    private Builder(org.apache.reef.io.watcher.driver.task.AvroRunningTask other) {
153            super(SCHEMA$);
154      if (isValidValue(fields()[0], other.id)) {
155        this.id = data().deepCopy(fields()[0].schema(), other.id);
156        fieldSetFlags()[0] = true;
157      }
158      if (isValidValue(fields()[1], other.activeContext)) {
159        this.activeContext = data().deepCopy(fields()[1].schema(), other.activeContext);
160        fieldSetFlags()[1] = true;
161      }
162      this.activeContextBuilder = null;
163    }
164
165    /**
166      * Gets the value of the 'id' field.
167      * @return The value.
168      */
169    public java.lang.CharSequence getId() {
170      return id;
171    }
172
173    /**
174      * Sets the value of the 'id' field.
175      * @param value The value of 'id'.
176      * @return This builder.
177      */
178    public org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder setId(java.lang.CharSequence value) {
179      validate(fields()[0], value);
180      this.id = value;
181      fieldSetFlags()[0] = true;
182      return this;
183    }
184
185    /**
186      * Checks whether the 'id' field has been set.
187      * @return True if the 'id' field has been set, false otherwise.
188      */
189    public boolean hasId() {
190      return fieldSetFlags()[0];
191    }
192
193
194    /**
195      * Clears the value of the 'id' field.
196      * @return This builder.
197      */
198    public org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder clearId() {
199      id = null;
200      fieldSetFlags()[0] = false;
201      return this;
202    }
203
204    /**
205      * Gets the value of the 'activeContext' field.
206      * @return The value.
207      */
208    public org.apache.reef.io.watcher.driver.context.AvroActiveContext getActiveContext() {
209      return activeContext;
210    }
211
212    /**
213      * Sets the value of the 'activeContext' field.
214      * @param value The value of 'activeContext'.
215      * @return This builder.
216      */
217    public org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder setActiveContext(org.apache.reef.io.watcher.driver.context.AvroActiveContext value) {
218      validate(fields()[1], value);
219      this.activeContextBuilder = null;
220      this.activeContext = value;
221      fieldSetFlags()[1] = true;
222      return this;
223    }
224
225    /**
226      * Checks whether the 'activeContext' field has been set.
227      * @return True if the 'activeContext' field has been set, false otherwise.
228      */
229    public boolean hasActiveContext() {
230      return fieldSetFlags()[1];
231    }
232
233    /**
234     * Gets the Builder instance for the 'activeContext' field and creates one if it doesn't exist yet.
235     * @return This builder.
236     */
237    public org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder getActiveContextBuilder() {
238      if (activeContextBuilder == null) {
239        if (hasActiveContext()) {
240          setActiveContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder(activeContext));
241        } else {
242          setActiveContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder());
243        }
244      }
245      return activeContextBuilder;
246    }
247
248    /**
249     * Sets the Builder instance for the 'activeContext' field
250     * @param value The builder instance that must be set.
251     * @return This builder.
252     */
253    public org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder setActiveContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder value) {
254      clearActiveContext();
255      activeContextBuilder = value;
256      return this;
257    }
258
259    /**
260     * Checks whether the 'activeContext' field has an active Builder instance
261     * @return True if the 'activeContext' field has an active Builder instance
262     */
263    public boolean hasActiveContextBuilder() {
264      return activeContextBuilder != null;
265    }
266
267    /**
268      * Clears the value of the 'activeContext' field.
269      * @return This builder.
270      */
271    public org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder clearActiveContext() {
272      activeContext = null;
273      activeContextBuilder = null;
274      fieldSetFlags()[1] = false;
275      return this;
276    }
277
278    @Override
279    public AvroRunningTask build() {
280      try {
281        AvroRunningTask record = new AvroRunningTask();
282        record.id = fieldSetFlags()[0] ? this.id : (java.lang.CharSequence) defaultValue(fields()[0]);
283        if (activeContextBuilder != null) {
284          record.activeContext = this.activeContextBuilder.build();
285        } else {
286          record.activeContext = fieldSetFlags()[1] ? this.activeContext : (org.apache.reef.io.watcher.driver.context.AvroActiveContext) defaultValue(fields()[1]);
287        }
288        return record;
289      } catch (Exception e) {
290        throw new org.apache.avro.AvroRuntimeException(e);
291      }
292    }
293  }
294
295  private static final org.apache.avro.io.DatumWriter
296    WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
297
298  @Override public void writeExternal(java.io.ObjectOutput out)
299    throws java.io.IOException {
300    WRITER$.write(this, SpecificData.getEncoder(out));
301  }
302
303  private static final org.apache.avro.io.DatumReader
304    READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
305
306  @Override public void readExternal(java.io.ObjectInput in)
307    throws java.io.IOException {
308    READER$.read(this, SpecificData.getDecoder(in));
309  }
310
311}