001/** 002 * Autogenerated by Avro 003 * 004 * DO NOT EDIT DIRECTLY 005 */ 006package org.apache.reef.io.data.loading.avro; 007 008import org.apache.avro.specific.SpecificData; 009 010@SuppressWarnings("all") 011@org.apache.avro.specific.AvroGenerated 012public class AvroEvaluatorRequest extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { 013 private static final long serialVersionUID = -7522174834381464354L; 014 public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"AvroEvaluatorRequest\",\"namespace\":\"org.apache.reef.io.data.loading.avro\",\"fields\":[{\"name\":\"megaBytes\",\"type\":\"int\"},{\"name\":\"number\",\"type\":\"int\"},{\"name\":\"cores\",\"type\":\"int\"},{\"name\":\"nodeNames\",\"type\":{\"type\":\"array\",\"items\":\"string\"}},{\"name\":\"rackNames\",\"type\":{\"type\":\"array\",\"items\":\"string\"}}]}"); 015 public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } 016 @Deprecated public int megaBytes; 017 @Deprecated public int number; 018 @Deprecated public int cores; 019 @Deprecated public java.util.List<java.lang.CharSequence> nodeNames; 020 @Deprecated public java.util.List<java.lang.CharSequence> rackNames; 021 022 /** 023 * Default constructor. Note that this does not initialize fields 024 * to their default values from the schema. If that is desired then 025 * one should use <code>newBuilder()</code>. 026 */ 027 public AvroEvaluatorRequest() {} 028 029 /** 030 * All-args constructor. 031 * @param megaBytes The new value for megaBytes 032 * @param number The new value for number 033 * @param cores The new value for cores 034 * @param nodeNames The new value for nodeNames 035 * @param rackNames The new value for rackNames 036 */ 037 public AvroEvaluatorRequest(java.lang.Integer megaBytes, java.lang.Integer number, java.lang.Integer cores, java.util.List<java.lang.CharSequence> nodeNames, java.util.List<java.lang.CharSequence> rackNames) { 038 this.megaBytes = megaBytes; 039 this.number = number; 040 this.cores = cores; 041 this.nodeNames = nodeNames; 042 this.rackNames = rackNames; 043 } 044 045 public org.apache.avro.Schema getSchema() { return SCHEMA$; } 046 // Used by DatumWriter. Applications should not call. 047 public java.lang.Object get(int field$) { 048 switch (field$) { 049 case 0: return megaBytes; 050 case 1: return number; 051 case 2: return cores; 052 case 3: return nodeNames; 053 case 4: return rackNames; 054 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 055 } 056 } 057 058 // Used by DatumReader. Applications should not call. 059 @SuppressWarnings(value="unchecked") 060 public void put(int field$, java.lang.Object value$) { 061 switch (field$) { 062 case 0: megaBytes = (java.lang.Integer)value$; break; 063 case 1: number = (java.lang.Integer)value$; break; 064 case 2: cores = (java.lang.Integer)value$; break; 065 case 3: nodeNames = (java.util.List<java.lang.CharSequence>)value$; break; 066 case 4: rackNames = (java.util.List<java.lang.CharSequence>)value$; break; 067 default: throw new org.apache.avro.AvroRuntimeException("Bad index"); 068 } 069 } 070 071 /** 072 * Gets the value of the 'megaBytes' field. 073 * @return The value of the 'megaBytes' field. 074 */ 075 public java.lang.Integer getMegaBytes() { 076 return megaBytes; 077 } 078 079 /** 080 * Sets the value of the 'megaBytes' field. 081 * @param value the value to set. 082 */ 083 public void setMegaBytes(java.lang.Integer value) { 084 this.megaBytes = value; 085 } 086 087 /** 088 * Gets the value of the 'number' field. 089 * @return The value of the 'number' field. 090 */ 091 public java.lang.Integer getNumber() { 092 return number; 093 } 094 095 /** 096 * Sets the value of the 'number' field. 097 * @param value the value to set. 098 */ 099 public void setNumber(java.lang.Integer value) { 100 this.number = value; 101 } 102 103 /** 104 * Gets the value of the 'cores' field. 105 * @return The value of the 'cores' field. 106 */ 107 public java.lang.Integer getCores() { 108 return cores; 109 } 110 111 /** 112 * Sets the value of the 'cores' field. 113 * @param value the value to set. 114 */ 115 public void setCores(java.lang.Integer value) { 116 this.cores = value; 117 } 118 119 /** 120 * Gets the value of the 'nodeNames' field. 121 * @return The value of the 'nodeNames' field. 122 */ 123 public java.util.List<java.lang.CharSequence> getNodeNames() { 124 return nodeNames; 125 } 126 127 /** 128 * Sets the value of the 'nodeNames' field. 129 * @param value the value to set. 130 */ 131 public void setNodeNames(java.util.List<java.lang.CharSequence> value) { 132 this.nodeNames = value; 133 } 134 135 /** 136 * Gets the value of the 'rackNames' field. 137 * @return The value of the 'rackNames' field. 138 */ 139 public java.util.List<java.lang.CharSequence> getRackNames() { 140 return rackNames; 141 } 142 143 /** 144 * Sets the value of the 'rackNames' field. 145 * @param value the value to set. 146 */ 147 public void setRackNames(java.util.List<java.lang.CharSequence> value) { 148 this.rackNames = value; 149 } 150 151 /** 152 * Creates a new AvroEvaluatorRequest RecordBuilder. 153 * @return A new AvroEvaluatorRequest RecordBuilder 154 */ 155 public static org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder newBuilder() { 156 return new org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder(); 157 } 158 159 /** 160 * Creates a new AvroEvaluatorRequest RecordBuilder by copying an existing Builder. 161 * @param other The existing builder to copy. 162 * @return A new AvroEvaluatorRequest RecordBuilder 163 */ 164 public static org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder newBuilder(org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder other) { 165 return new org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder(other); 166 } 167 168 /** 169 * Creates a new AvroEvaluatorRequest RecordBuilder by copying an existing AvroEvaluatorRequest instance. 170 * @param other The existing instance to copy. 171 * @return A new AvroEvaluatorRequest RecordBuilder 172 */ 173 public static org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder newBuilder(org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest other) { 174 return new org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder(other); 175 } 176 177 /** 178 * RecordBuilder for AvroEvaluatorRequest instances. 179 */ 180 public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<AvroEvaluatorRequest> 181 implements org.apache.avro.data.RecordBuilder<AvroEvaluatorRequest> { 182 183 private int megaBytes; 184 private int number; 185 private int cores; 186 private java.util.List<java.lang.CharSequence> nodeNames; 187 private java.util.List<java.lang.CharSequence> rackNames; 188 189 /** Creates a new Builder */ 190 private Builder() { 191 super(SCHEMA$); 192 } 193 194 /** 195 * Creates a Builder by copying an existing Builder. 196 * @param other The existing Builder to copy. 197 */ 198 private Builder(org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder other) { 199 super(other); 200 if (isValidValue(fields()[0], other.megaBytes)) { 201 this.megaBytes = data().deepCopy(fields()[0].schema(), other.megaBytes); 202 fieldSetFlags()[0] = true; 203 } 204 if (isValidValue(fields()[1], other.number)) { 205 this.number = data().deepCopy(fields()[1].schema(), other.number); 206 fieldSetFlags()[1] = true; 207 } 208 if (isValidValue(fields()[2], other.cores)) { 209 this.cores = data().deepCopy(fields()[2].schema(), other.cores); 210 fieldSetFlags()[2] = true; 211 } 212 if (isValidValue(fields()[3], other.nodeNames)) { 213 this.nodeNames = data().deepCopy(fields()[3].schema(), other.nodeNames); 214 fieldSetFlags()[3] = true; 215 } 216 if (isValidValue(fields()[4], other.rackNames)) { 217 this.rackNames = data().deepCopy(fields()[4].schema(), other.rackNames); 218 fieldSetFlags()[4] = true; 219 } 220 } 221 222 /** 223 * Creates a Builder by copying an existing AvroEvaluatorRequest instance 224 * @param other The existing instance to copy. 225 */ 226 private Builder(org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest other) { 227 super(SCHEMA$); 228 if (isValidValue(fields()[0], other.megaBytes)) { 229 this.megaBytes = data().deepCopy(fields()[0].schema(), other.megaBytes); 230 fieldSetFlags()[0] = true; 231 } 232 if (isValidValue(fields()[1], other.number)) { 233 this.number = data().deepCopy(fields()[1].schema(), other.number); 234 fieldSetFlags()[1] = true; 235 } 236 if (isValidValue(fields()[2], other.cores)) { 237 this.cores = data().deepCopy(fields()[2].schema(), other.cores); 238 fieldSetFlags()[2] = true; 239 } 240 if (isValidValue(fields()[3], other.nodeNames)) { 241 this.nodeNames = data().deepCopy(fields()[3].schema(), other.nodeNames); 242 fieldSetFlags()[3] = true; 243 } 244 if (isValidValue(fields()[4], other.rackNames)) { 245 this.rackNames = data().deepCopy(fields()[4].schema(), other.rackNames); 246 fieldSetFlags()[4] = true; 247 } 248 } 249 250 /** 251 * Gets the value of the 'megaBytes' field. 252 * @return The value. 253 */ 254 public java.lang.Integer getMegaBytes() { 255 return megaBytes; 256 } 257 258 /** 259 * Sets the value of the 'megaBytes' field. 260 * @param value The value of 'megaBytes'. 261 * @return This builder. 262 */ 263 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder setMegaBytes(int value) { 264 validate(fields()[0], value); 265 this.megaBytes = value; 266 fieldSetFlags()[0] = true; 267 return this; 268 } 269 270 /** 271 * Checks whether the 'megaBytes' field has been set. 272 * @return True if the 'megaBytes' field has been set, false otherwise. 273 */ 274 public boolean hasMegaBytes() { 275 return fieldSetFlags()[0]; 276 } 277 278 279 /** 280 * Clears the value of the 'megaBytes' field. 281 * @return This builder. 282 */ 283 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder clearMegaBytes() { 284 fieldSetFlags()[0] = false; 285 return this; 286 } 287 288 /** 289 * Gets the value of the 'number' field. 290 * @return The value. 291 */ 292 public java.lang.Integer getNumber() { 293 return number; 294 } 295 296 /** 297 * Sets the value of the 'number' field. 298 * @param value The value of 'number'. 299 * @return This builder. 300 */ 301 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder setNumber(int value) { 302 validate(fields()[1], value); 303 this.number = value; 304 fieldSetFlags()[1] = true; 305 return this; 306 } 307 308 /** 309 * Checks whether the 'number' field has been set. 310 * @return True if the 'number' field has been set, false otherwise. 311 */ 312 public boolean hasNumber() { 313 return fieldSetFlags()[1]; 314 } 315 316 317 /** 318 * Clears the value of the 'number' field. 319 * @return This builder. 320 */ 321 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder clearNumber() { 322 fieldSetFlags()[1] = false; 323 return this; 324 } 325 326 /** 327 * Gets the value of the 'cores' field. 328 * @return The value. 329 */ 330 public java.lang.Integer getCores() { 331 return cores; 332 } 333 334 /** 335 * Sets the value of the 'cores' field. 336 * @param value The value of 'cores'. 337 * @return This builder. 338 */ 339 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder setCores(int value) { 340 validate(fields()[2], value); 341 this.cores = value; 342 fieldSetFlags()[2] = true; 343 return this; 344 } 345 346 /** 347 * Checks whether the 'cores' field has been set. 348 * @return True if the 'cores' field has been set, false otherwise. 349 */ 350 public boolean hasCores() { 351 return fieldSetFlags()[2]; 352 } 353 354 355 /** 356 * Clears the value of the 'cores' field. 357 * @return This builder. 358 */ 359 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder clearCores() { 360 fieldSetFlags()[2] = false; 361 return this; 362 } 363 364 /** 365 * Gets the value of the 'nodeNames' field. 366 * @return The value. 367 */ 368 public java.util.List<java.lang.CharSequence> getNodeNames() { 369 return nodeNames; 370 } 371 372 /** 373 * Sets the value of the 'nodeNames' field. 374 * @param value The value of 'nodeNames'. 375 * @return This builder. 376 */ 377 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder setNodeNames(java.util.List<java.lang.CharSequence> value) { 378 validate(fields()[3], value); 379 this.nodeNames = value; 380 fieldSetFlags()[3] = true; 381 return this; 382 } 383 384 /** 385 * Checks whether the 'nodeNames' field has been set. 386 * @return True if the 'nodeNames' field has been set, false otherwise. 387 */ 388 public boolean hasNodeNames() { 389 return fieldSetFlags()[3]; 390 } 391 392 393 /** 394 * Clears the value of the 'nodeNames' field. 395 * @return This builder. 396 */ 397 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder clearNodeNames() { 398 nodeNames = null; 399 fieldSetFlags()[3] = false; 400 return this; 401 } 402 403 /** 404 * Gets the value of the 'rackNames' field. 405 * @return The value. 406 */ 407 public java.util.List<java.lang.CharSequence> getRackNames() { 408 return rackNames; 409 } 410 411 /** 412 * Sets the value of the 'rackNames' field. 413 * @param value The value of 'rackNames'. 414 * @return This builder. 415 */ 416 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder setRackNames(java.util.List<java.lang.CharSequence> value) { 417 validate(fields()[4], value); 418 this.rackNames = value; 419 fieldSetFlags()[4] = true; 420 return this; 421 } 422 423 /** 424 * Checks whether the 'rackNames' field has been set. 425 * @return True if the 'rackNames' field has been set, false otherwise. 426 */ 427 public boolean hasRackNames() { 428 return fieldSetFlags()[4]; 429 } 430 431 432 /** 433 * Clears the value of the 'rackNames' field. 434 * @return This builder. 435 */ 436 public org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder clearRackNames() { 437 rackNames = null; 438 fieldSetFlags()[4] = false; 439 return this; 440 } 441 442 @Override 443 public AvroEvaluatorRequest build() { 444 try { 445 AvroEvaluatorRequest record = new AvroEvaluatorRequest(); 446 record.megaBytes = fieldSetFlags()[0] ? this.megaBytes : (java.lang.Integer) defaultValue(fields()[0]); 447 record.number = fieldSetFlags()[1] ? this.number : (java.lang.Integer) defaultValue(fields()[1]); 448 record.cores = fieldSetFlags()[2] ? this.cores : (java.lang.Integer) defaultValue(fields()[2]); 449 record.nodeNames = fieldSetFlags()[3] ? this.nodeNames : (java.util.List<java.lang.CharSequence>) defaultValue(fields()[3]); 450 record.rackNames = fieldSetFlags()[4] ? this.rackNames : (java.util.List<java.lang.CharSequence>) defaultValue(fields()[4]); 451 return record; 452 } catch (Exception e) { 453 throw new org.apache.avro.AvroRuntimeException(e); 454 } 455 } 456 } 457 458 private static final org.apache.avro.io.DatumWriter 459 WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$); 460 461 @Override public void writeExternal(java.io.ObjectOutput out) 462 throws java.io.IOException { 463 WRITER$.write(this, SpecificData.getEncoder(out)); 464 } 465 466 private static final org.apache.avro.io.DatumReader 467 READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$); 468 469 @Override public void readExternal(java.io.ObjectInput in) 470 throws java.io.IOException { 471 READER$.read(this, SpecificData.getDecoder(in)); 472 } 473 474}