Source code

001/**
002 * Autogenerated by Avro
003 *
004 * DO NOT EDIT DIRECTLY
005 */
006package org.apache.reef.io.watcher.driver.context;
007
008import org.apache.avro.specific.SpecificData;
009
010@SuppressWarnings("all")
011@org.apache.avro.specific.AvroGenerated
012public class AvroClosedContext extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
013  private static final long serialVersionUID = -2710604834284196495L;
014  public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroClosedContext\",\"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\"]}]}},{\"name\":\"parentContext\",\"type\":{\"type\":\"record\",\"name\":\"AvroActiveContext\",\"fields\":[{\"name\":\"base\",\"type\":\"AvroContextBase\"}]}}]}");
015  public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
016  @Deprecated public org.apache.reef.io.watcher.driver.context.AvroContextBase base;
017  @Deprecated public org.apache.reef.io.watcher.driver.context.AvroActiveContext parentContext;
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 AvroClosedContext() {}
025
026  /**
027   * All-args constructor.
028   * @param base The new value for base
029   * @param parentContext The new value for parentContext
030   */
031  public AvroClosedContext(org.apache.reef.io.watcher.driver.context.AvroContextBase base, org.apache.reef.io.watcher.driver.context.AvroActiveContext parentContext) {
032    this.base = base;
033    this.parentContext = parentContext;
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 base;
041    case 1: return parentContext;
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: base = (org.apache.reef.io.watcher.driver.context.AvroContextBase)value$; break;
051    case 1: parentContext = (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 'base' field.
058   * @return The value of the 'base' field.
059   */
060  public org.apache.reef.io.watcher.driver.context.AvroContextBase getBase() {
061    return base;
062  }
063
064  /**
065   * Sets the value of the 'base' field.
066   * @param value the value to set.
067   */
068  public void setBase(org.apache.reef.io.watcher.driver.context.AvroContextBase value) {
069    this.base = value;
070  }
071
072  /**
073   * Gets the value of the 'parentContext' field.
074   * @return The value of the 'parentContext' field.
075   */
076  public org.apache.reef.io.watcher.driver.context.AvroActiveContext getParentContext() {
077    return parentContext;
078  }
079
080  /**
081   * Sets the value of the 'parentContext' field.
082   * @param value the value to set.
083   */
084  public void setParentContext(org.apache.reef.io.watcher.driver.context.AvroActiveContext value) {
085    this.parentContext = value;
086  }
087
088  /**
089   * Creates a new AvroClosedContext RecordBuilder.
090   * @return A new AvroClosedContext RecordBuilder
091   */
092  public static org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder newBuilder() {
093    return new org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder();
094  }
095
096  /**
097   * Creates a new AvroClosedContext RecordBuilder by copying an existing Builder.
098   * @param other The existing builder to copy.
099   * @return A new AvroClosedContext RecordBuilder
100   */
101  public static org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder newBuilder(org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder other) {
102    return new org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder(other);
103  }
104
105  /**
106   * Creates a new AvroClosedContext RecordBuilder by copying an existing AvroClosedContext instance.
107   * @param other The existing instance to copy.
108   * @return A new AvroClosedContext RecordBuilder
109   */
110  public static org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder newBuilder(org.apache.reef.io.watcher.driver.context.AvroClosedContext other) {
111    return new org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder(other);
112  }
113
114  /**
115   * RecordBuilder for AvroClosedContext instances.
116   */
117  public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroClosedContext>
118    implements org.apache.avro.data.RecordBuilder<AvroClosedContext> {
119
120    private org.apache.reef.io.watcher.driver.context.AvroContextBase base;
121    private org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder baseBuilder;
122    private org.apache.reef.io.watcher.driver.context.AvroActiveContext parentContext;
123    private org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder parentContextBuilder;
124
125    /** Creates a new Builder */
126    private Builder() {
127      super(SCHEMA$);
128    }
129
130    /**
131     * Creates a Builder by copying an existing Builder.
132     * @param other The existing Builder to copy.
133     */
134    private Builder(org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder other) {
135      super(other);
136      if (isValidValue(fields()[0], other.base)) {
137        this.base = data().deepCopy(fields()[0].schema(), other.base);
138        fieldSetFlags()[0] = true;
139      }
140      if (other.hasBaseBuilder()) {
141        this.baseBuilder = org.apache.reef.io.watcher.driver.context.AvroContextBase.newBuilder(other.getBaseBuilder());
142      }
143      if (isValidValue(fields()[1], other.parentContext)) {
144        this.parentContext = data().deepCopy(fields()[1].schema(), other.parentContext);
145        fieldSetFlags()[1] = true;
146      }
147      if (other.hasParentContextBuilder()) {
148        this.parentContextBuilder = org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder(other.getParentContextBuilder());
149      }
150    }
151
152    /**
153     * Creates a Builder by copying an existing AvroClosedContext instance
154     * @param other The existing instance to copy.
155     */
156    private Builder(org.apache.reef.io.watcher.driver.context.AvroClosedContext other) {
157            super(SCHEMA$);
158      if (isValidValue(fields()[0], other.base)) {
159        this.base = data().deepCopy(fields()[0].schema(), other.base);
160        fieldSetFlags()[0] = true;
161      }
162      this.baseBuilder = null;
163      if (isValidValue(fields()[1], other.parentContext)) {
164        this.parentContext = data().deepCopy(fields()[1].schema(), other.parentContext);
165        fieldSetFlags()[1] = true;
166      }
167      this.parentContextBuilder = null;
168    }
169
170    /**
171      * Gets the value of the 'base' field.
172      * @return The value.
173      */
174    public org.apache.reef.io.watcher.driver.context.AvroContextBase getBase() {
175      return base;
176    }
177
178    /**
179      * Sets the value of the 'base' field.
180      * @param value The value of 'base'.
181      * @return This builder.
182      */
183    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder setBase(org.apache.reef.io.watcher.driver.context.AvroContextBase value) {
184      validate(fields()[0], value);
185      this.baseBuilder = null;
186      this.base = value;
187      fieldSetFlags()[0] = true;
188      return this;
189    }
190
191    /**
192      * Checks whether the 'base' field has been set.
193      * @return True if the 'base' field has been set, false otherwise.
194      */
195    public boolean hasBase() {
196      return fieldSetFlags()[0];
197    }
198
199    /**
200     * Gets the Builder instance for the 'base' field and creates one if it doesn't exist yet.
201     * @return This builder.
202     */
203    public org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder getBaseBuilder() {
204      if (baseBuilder == null) {
205        if (hasBase()) {
206          setBaseBuilder(org.apache.reef.io.watcher.driver.context.AvroContextBase.newBuilder(base));
207        } else {
208          setBaseBuilder(org.apache.reef.io.watcher.driver.context.AvroContextBase.newBuilder());
209        }
210      }
211      return baseBuilder;
212    }
213
214    /**
215     * Sets the Builder instance for the 'base' field
216     * @param value The builder instance that must be set.
217     * @return This builder.
218     */
219    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder setBaseBuilder(org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder value) {
220      clearBase();
221      baseBuilder = value;
222      return this;
223    }
224
225    /**
226     * Checks whether the 'base' field has an active Builder instance
227     * @return True if the 'base' field has an active Builder instance
228     */
229    public boolean hasBaseBuilder() {
230      return baseBuilder != null;
231    }
232
233    /**
234      * Clears the value of the 'base' field.
235      * @return This builder.
236      */
237    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder clearBase() {
238      base = null;
239      baseBuilder = null;
240      fieldSetFlags()[0] = false;
241      return this;
242    }
243
244    /**
245      * Gets the value of the 'parentContext' field.
246      * @return The value.
247      */
248    public org.apache.reef.io.watcher.driver.context.AvroActiveContext getParentContext() {
249      return parentContext;
250    }
251
252    /**
253      * Sets the value of the 'parentContext' field.
254      * @param value The value of 'parentContext'.
255      * @return This builder.
256      */
257    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder setParentContext(org.apache.reef.io.watcher.driver.context.AvroActiveContext value) {
258      validate(fields()[1], value);
259      this.parentContextBuilder = null;
260      this.parentContext = value;
261      fieldSetFlags()[1] = true;
262      return this;
263    }
264
265    /**
266      * Checks whether the 'parentContext' field has been set.
267      * @return True if the 'parentContext' field has been set, false otherwise.
268      */
269    public boolean hasParentContext() {
270      return fieldSetFlags()[1];
271    }
272
273    /**
274     * Gets the Builder instance for the 'parentContext' field and creates one if it doesn't exist yet.
275     * @return This builder.
276     */
277    public org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder getParentContextBuilder() {
278      if (parentContextBuilder == null) {
279        if (hasParentContext()) {
280          setParentContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder(parentContext));
281        } else {
282          setParentContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.newBuilder());
283        }
284      }
285      return parentContextBuilder;
286    }
287
288    /**
289     * Sets the Builder instance for the 'parentContext' field
290     * @param value The builder instance that must be set.
291     * @return This builder.
292     */
293    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder setParentContextBuilder(org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder value) {
294      clearParentContext();
295      parentContextBuilder = value;
296      return this;
297    }
298
299    /**
300     * Checks whether the 'parentContext' field has an active Builder instance
301     * @return True if the 'parentContext' field has an active Builder instance
302     */
303    public boolean hasParentContextBuilder() {
304      return parentContextBuilder != null;
305    }
306
307    /**
308      * Clears the value of the 'parentContext' field.
309      * @return This builder.
310      */
311    public org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder clearParentContext() {
312      parentContext = null;
313      parentContextBuilder = null;
314      fieldSetFlags()[1] = false;
315      return this;
316    }
317
318    @Override
319    public AvroClosedContext build() {
320      try {
321        AvroClosedContext record = new AvroClosedContext();
322        if (baseBuilder != null) {
323          record.base = this.baseBuilder.build();
324        } else {
325          record.base = fieldSetFlags()[0] ? this.base : (org.apache.reef.io.watcher.driver.context.AvroContextBase) defaultValue(fields()[0]);
326        }
327        if (parentContextBuilder != null) {
328          record.parentContext = this.parentContextBuilder.build();
329        } else {
330          record.parentContext = fieldSetFlags()[1] ? this.parentContext : (org.apache.reef.io.watcher.driver.context.AvroActiveContext) defaultValue(fields()[1]);
331        }
332        return record;
333      } catch (Exception e) {
334        throw new org.apache.avro.AvroRuntimeException(e);
335      }
336    }
337  }
338
339  private static final org.apache.avro.io.DatumWriter
340    WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$);
341
342  @Override public void writeExternal(java.io.ObjectOutput out)
343    throws java.io.IOException {
344    WRITER$.write(this, SpecificData.getEncoder(out));
345  }
346
347  private static final org.apache.avro.io.DatumReader
348    READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$);
349
350  @Override public void readExternal(java.io.ObjectInput in)
351    throws java.io.IOException {
352    READER$.read(this, SpecificData.getDecoder(in));
353  }
354
355}