001/** 002 * Autogenerated by Avro 003 * 004 * DO NOT EDIT DIRECTLY 005 */ 006package org.apache.reef.io.watcher.driver.evaluator; 007@SuppressWarnings("all") 008@org.apache.avro.specific.AvroGenerated 009public class AvroAllocatedEvaluator extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { 010 public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroAllocatedEvaluator\",\"namespace\":\"org.apache.reef.io.watcher.driver.evaluator\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"evaluatorDescriptor\",\"type\":{\"type\":\"record\",\"name\":\"AvroEvaluatorDescriptor\",\"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\"}]}}]}"); 011 public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } 012 @Deprecated public java.lang.CharSequence id; 013 @Deprecated public org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor evaluatorDescriptor; 014 015 /** 016 * Default constructor. Note that this does not initialize fields 017 * to their default values from the schema. If that is desired then 018 * one should use <code>newBuilder()</code>. 019 */ 020 public AvroAllocatedEvaluator() {} 021 022 /** 023 * All-args constructor. 024 */ 025 public AvroAllocatedEvaluator(java.lang.CharSequence id, org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor evaluatorDescriptor) { 026 this.id = id; 027 this.evaluatorDescriptor = evaluatorDescriptor; 028 } 029 030 public org.apache.avro.Schema getSchema() { return SCHEMA$; } 031 // Used by DatumWriter. Applications should not call. 032 public java.lang.Object get(int field$) { 033 switch (field$) { 034 case 0: return id; 035 case 1: return evaluatorDescriptor; 036 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 037 } 038 } 039 // Used by DatumReader. Applications should not call. 040 @SuppressWarnings(value="unchecked") 041 public void put(int field$, java.lang.Object value$) { 042 switch (field$) { 043 case 0: id = (java.lang.CharSequence)value$; break; 044 case 1: evaluatorDescriptor = (org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor)value$; break; 045 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 046 } 047 } 048 049 /** 050 * Gets the value of the 'id' field. 051 */ 052 public java.lang.CharSequence getId() { 053 return id; 054 } 055 056 /** 057 * Sets the value of the 'id' field. 058 * @param value the value to set. 059 */ 060 public void setId(java.lang.CharSequence value) { 061 this.id = value; 062 } 063 064 /** 065 * Gets the value of the 'evaluatorDescriptor' field. 066 */ 067 public org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor getEvaluatorDescriptor() { 068 return evaluatorDescriptor; 069 } 070 071 /** 072 * Sets the value of the 'evaluatorDescriptor' field. 073 * @param value the value to set. 074 */ 075 public void setEvaluatorDescriptor(org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor value) { 076 this.evaluatorDescriptor = value; 077 } 078 079 /** Creates a new AvroAllocatedEvaluator RecordBuilder */ 080 public static org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder newBuilder() { 081 return new org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder(); 082 } 083 084 /** Creates a new AvroAllocatedEvaluator RecordBuilder by copying an existing Builder */ 085 public static org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder newBuilder(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder other) { 086 return new org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder(other); 087 } 088 089 /** Creates a new AvroAllocatedEvaluator RecordBuilder by copying an existing AvroAllocatedEvaluator instance */ 090 public static org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder newBuilder(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator other) { 091 return new org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder(other); 092 } 093 094 /** 095 * RecordBuilder for AvroAllocatedEvaluator instances. 096 */ 097 public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroAllocatedEvaluator> 098 implements org.apache.avro.data.RecordBuilder<AvroAllocatedEvaluator> { 099 100 private java.lang.CharSequence id; 101 private org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor evaluatorDescriptor; 102 103 /** Creates a new Builder */ 104 private Builder() { 105 super(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.SCHEMA$); 106 } 107 108 /** Creates a Builder by copying an existing Builder */ 109 private Builder(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder other) { 110 super(other); 111 if (isValidValue(fields()[0], other.id)) { 112 this.id = data().deepCopy(fields()[0].schema(), other.id); 113 fieldSetFlags()[0] = true; 114 } 115 if (isValidValue(fields()[1], other.evaluatorDescriptor)) { 116 this.evaluatorDescriptor = data().deepCopy(fields()[1].schema(), other.evaluatorDescriptor); 117 fieldSetFlags()[1] = true; 118 } 119 } 120 121 /** Creates a Builder by copying an existing AvroAllocatedEvaluator instance */ 122 private Builder(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator other) { 123 super(org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.SCHEMA$); 124 if (isValidValue(fields()[0], other.id)) { 125 this.id = data().deepCopy(fields()[0].schema(), other.id); 126 fieldSetFlags()[0] = true; 127 } 128 if (isValidValue(fields()[1], other.evaluatorDescriptor)) { 129 this.evaluatorDescriptor = data().deepCopy(fields()[1].schema(), other.evaluatorDescriptor); 130 fieldSetFlags()[1] = true; 131 } 132 } 133 134 /** Gets the value of the 'id' field */ 135 public java.lang.CharSequence getId() { 136 return id; 137 } 138 139 /** Sets the value of the 'id' field */ 140 public org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder setId(java.lang.CharSequence value) { 141 validate(fields()[0], value); 142 this.id = value; 143 fieldSetFlags()[0] = true; 144 return this; 145 } 146 147 /** Checks whether the 'id' field has been set */ 148 public boolean hasId() { 149 return fieldSetFlags()[0]; 150 } 151 152 /** Clears the value of the 'id' field */ 153 public org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder clearId() { 154 id = null; 155 fieldSetFlags()[0] = false; 156 return this; 157 } 158 159 /** Gets the value of the 'evaluatorDescriptor' field */ 160 public org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor getEvaluatorDescriptor() { 161 return evaluatorDescriptor; 162 } 163 164 /** Sets the value of the 'evaluatorDescriptor' field */ 165 public org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder setEvaluatorDescriptor(org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor value) { 166 validate(fields()[1], value); 167 this.evaluatorDescriptor = value; 168 fieldSetFlags()[1] = true; 169 return this; 170 } 171 172 /** Checks whether the 'evaluatorDescriptor' field has been set */ 173 public boolean hasEvaluatorDescriptor() { 174 return fieldSetFlags()[1]; 175 } 176 177 /** Clears the value of the 'evaluatorDescriptor' field */ 178 public org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder clearEvaluatorDescriptor() { 179 evaluatorDescriptor = null; 180 fieldSetFlags()[1] = false; 181 return this; 182 } 183 184 @Override 185 public AvroAllocatedEvaluator build() { 186 try { 187 AvroAllocatedEvaluator record = new AvroAllocatedEvaluator(); 188 record.id = fieldSetFlags()[0] ? this.id : (java.lang.CharSequence) defaultValue(fields()[0]); 189 record.evaluatorDescriptor = fieldSetFlags()[1] ? this.evaluatorDescriptor : (org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor) defaultValue(fields()[1]); 190 return record; 191 } catch (Exception e) { 192 throw new org.apache.avro.AvroRuntimeException(e); 193 } 194 } 195 } 196}