X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fmicroservices;a=blobdiff_plain;f=validate-user%2Fsrc%2Fmain%2Fjava%2Fde%2Ftrion%2Fmicroservices%2Favro%2FUser.java;fp=validate-user%2Fsrc%2Fmain%2Fjava%2Fde%2Ftrion%2Fmicroservices%2Favro%2FUser.java;h=0000000000000000000000000000000000000000;hp=c745e7a00ca97f7f249fb681bf5aa9b0f2e76a84;hb=525feeb10e1c653b8a88d50c472c034945bf4d6e;hpb=c095e577a546dd6270d9c0b062f2c8ffe8ad28f7 diff --git a/validate-user/src/main/java/de/trion/microservices/avro/User.java b/validate-user/src/main/java/de/trion/microservices/avro/User.java deleted file mode 100644 index c745e7a..0000000 --- a/validate-user/src/main/java/de/trion/microservices/avro/User.java +++ /dev/null @@ -1,469 +0,0 @@ -/** - * Autogenerated by Avro - * - * DO NOT EDIT DIRECTLY - */ -package de.trion.microservices.avro; - -import org.apache.avro.generic.GenericArray; -import org.apache.avro.specific.SpecificData; -import org.apache.avro.util.Utf8; -import org.apache.avro.message.BinaryMessageEncoder; -import org.apache.avro.message.BinaryMessageDecoder; -import org.apache.avro.message.SchemaStore; - -@org.apache.avro.specific.AvroGenerated -public class User extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { - private static final long serialVersionUID = 2154150202977610190L; - public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"User\",\"namespace\":\"de.trion.microservices.avro\",\"fields\":[{\"name\":\"id\",\"type\":\"long\"},{\"name\":\"level\",\"type\":{\"type\":\"enum\",\"name\":\"CustomerLevel\",\"symbols\":[\"BRONZE\",\"SILVER\",\"GOLD\",\"UNWANTED\"]}},{\"name\":\"name\",\"type\":\"string\"}]}"); - public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } - - private static SpecificData MODEL$ = new SpecificData(); - - private static final BinaryMessageEncoder ENCODER = - new BinaryMessageEncoder(MODEL$, SCHEMA$); - - private static final BinaryMessageDecoder DECODER = - new BinaryMessageDecoder(MODEL$, SCHEMA$); - - /** - * Return the BinaryMessageEncoder instance used by this class. - * @return the message encoder used by this class - */ - public static BinaryMessageEncoder getEncoder() { - return ENCODER; - } - - /** - * Return the BinaryMessageDecoder instance used by this class. - * @return the message decoder used by this class - */ - public static BinaryMessageDecoder getDecoder() { - return DECODER; - } - - /** - * Create a new BinaryMessageDecoder instance for this class that uses the specified {@link SchemaStore}. - * @param resolver a {@link SchemaStore} used to find schemas by fingerprint - * @return a BinaryMessageDecoder instance for this class backed by the given SchemaStore - */ - public static BinaryMessageDecoder createDecoder(SchemaStore resolver) { - return new BinaryMessageDecoder(MODEL$, SCHEMA$, resolver); - } - - /** - * Serializes this User to a ByteBuffer. - * @return a buffer holding the serialized data for this instance - * @throws java.io.IOException if this instance could not be serialized - */ - public java.nio.ByteBuffer toByteBuffer() throws java.io.IOException { - return ENCODER.encode(this); - } - - /** - * Deserializes a User from a ByteBuffer. - * @param b a byte buffer holding serialized data for an instance of this class - * @return a User instance decoded from the given buffer - * @throws java.io.IOException if the given bytes could not be deserialized into an instance of this class - */ - public static User fromByteBuffer( - java.nio.ByteBuffer b) throws java.io.IOException { - return DECODER.decode(b); - } - - @Deprecated public long id; - @Deprecated public de.trion.microservices.avro.CustomerLevel level; - @Deprecated public java.lang.CharSequence name; - - /** - * Default constructor. Note that this does not initialize fields - * to their default values from the schema. If that is desired then - * one should use newBuilder(). - */ - public User() {} - - /** - * All-args constructor. - * @param id The new value for id - * @param level The new value for level - * @param name The new value for name - */ - public User(java.lang.Long id, de.trion.microservices.avro.CustomerLevel level, java.lang.CharSequence name) { - this.id = id; - this.level = level; - this.name = name; - } - - public org.apache.avro.specific.SpecificData getSpecificData() { return MODEL$; } - public org.apache.avro.Schema getSchema() { return SCHEMA$; } - // Used by DatumWriter. Applications should not call. - public java.lang.Object get(int field$) { - switch (field$) { - case 0: return id; - case 1: return level; - case 2: return name; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); - } - } - - // Used by DatumReader. Applications should not call. - @SuppressWarnings(value="unchecked") - public void put(int field$, java.lang.Object value$) { - switch (field$) { - case 0: id = (java.lang.Long)value$; break; - case 1: level = (de.trion.microservices.avro.CustomerLevel)value$; break; - case 2: name = (java.lang.CharSequence)value$; break; - default: throw new org.apache.avro.AvroRuntimeException("Bad index"); - } - } - - /** - * Gets the value of the 'id' field. - * @return The value of the 'id' field. - */ - public long getId() { - return id; - } - - - /** - * Sets the value of the 'id' field. - * @param value the value to set. - */ - public void setId(long value) { - this.id = value; - } - - /** - * Gets the value of the 'level' field. - * @return The value of the 'level' field. - */ - public de.trion.microservices.avro.CustomerLevel getLevel() { - return level; - } - - - /** - * Sets the value of the 'level' field. - * @param value the value to set. - */ - public void setLevel(de.trion.microservices.avro.CustomerLevel value) { - this.level = value; - } - - /** - * Gets the value of the 'name' field. - * @return The value of the 'name' field. - */ - public java.lang.CharSequence getName() { - return name; - } - - - /** - * Sets the value of the 'name' field. - * @param value the value to set. - */ - public void setName(java.lang.CharSequence value) { - this.name = value; - } - - /** - * Creates a new User RecordBuilder. - * @return A new User RecordBuilder - */ - public static de.trion.microservices.avro.User.Builder newBuilder() { - return new de.trion.microservices.avro.User.Builder(); - } - - /** - * Creates a new User RecordBuilder by copying an existing Builder. - * @param other The existing builder to copy. - * @return A new User RecordBuilder - */ - public static de.trion.microservices.avro.User.Builder newBuilder(de.trion.microservices.avro.User.Builder other) { - if (other == null) { - return new de.trion.microservices.avro.User.Builder(); - } else { - return new de.trion.microservices.avro.User.Builder(other); - } - } - - /** - * Creates a new User RecordBuilder by copying an existing User instance. - * @param other The existing instance to copy. - * @return A new User RecordBuilder - */ - public static de.trion.microservices.avro.User.Builder newBuilder(de.trion.microservices.avro.User other) { - if (other == null) { - return new de.trion.microservices.avro.User.Builder(); - } else { - return new de.trion.microservices.avro.User.Builder(other); - } - } - - /** - * RecordBuilder for User instances. - */ - public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase - implements org.apache.avro.data.RecordBuilder { - - private long id; - private de.trion.microservices.avro.CustomerLevel level; - private java.lang.CharSequence name; - - /** Creates a new Builder */ - private Builder() { - super(SCHEMA$); - } - - /** - * Creates a Builder by copying an existing Builder. - * @param other The existing Builder to copy. - */ - private Builder(de.trion.microservices.avro.User.Builder other) { - super(other); - if (isValidValue(fields()[0], other.id)) { - this.id = data().deepCopy(fields()[0].schema(), other.id); - fieldSetFlags()[0] = other.fieldSetFlags()[0]; - } - if (isValidValue(fields()[1], other.level)) { - this.level = data().deepCopy(fields()[1].schema(), other.level); - fieldSetFlags()[1] = other.fieldSetFlags()[1]; - } - if (isValidValue(fields()[2], other.name)) { - this.name = data().deepCopy(fields()[2].schema(), other.name); - fieldSetFlags()[2] = other.fieldSetFlags()[2]; - } - } - - /** - * Creates a Builder by copying an existing User instance - * @param other The existing instance to copy. - */ - private Builder(de.trion.microservices.avro.User other) { - super(SCHEMA$); - if (isValidValue(fields()[0], other.id)) { - this.id = data().deepCopy(fields()[0].schema(), other.id); - fieldSetFlags()[0] = true; - } - if (isValidValue(fields()[1], other.level)) { - this.level = data().deepCopy(fields()[1].schema(), other.level); - fieldSetFlags()[1] = true; - } - if (isValidValue(fields()[2], other.name)) { - this.name = data().deepCopy(fields()[2].schema(), other.name); - fieldSetFlags()[2] = true; - } - } - - /** - * Gets the value of the 'id' field. - * @return The value. - */ - public long getId() { - return id; - } - - - /** - * Sets the value of the 'id' field. - * @param value The value of 'id'. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder setId(long value) { - validate(fields()[0], value); - this.id = value; - fieldSetFlags()[0] = true; - return this; - } - - /** - * Checks whether the 'id' field has been set. - * @return True if the 'id' field has been set, false otherwise. - */ - public boolean hasId() { - return fieldSetFlags()[0]; - } - - - /** - * Clears the value of the 'id' field. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder clearId() { - fieldSetFlags()[0] = false; - return this; - } - - /** - * Gets the value of the 'level' field. - * @return The value. - */ - public de.trion.microservices.avro.CustomerLevel getLevel() { - return level; - } - - - /** - * Sets the value of the 'level' field. - * @param value The value of 'level'. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder setLevel(de.trion.microservices.avro.CustomerLevel value) { - validate(fields()[1], value); - this.level = value; - fieldSetFlags()[1] = true; - return this; - } - - /** - * Checks whether the 'level' field has been set. - * @return True if the 'level' field has been set, false otherwise. - */ - public boolean hasLevel() { - return fieldSetFlags()[1]; - } - - - /** - * Clears the value of the 'level' field. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder clearLevel() { - level = null; - fieldSetFlags()[1] = false; - return this; - } - - /** - * Gets the value of the 'name' field. - * @return The value. - */ - public java.lang.CharSequence getName() { - return name; - } - - - /** - * Sets the value of the 'name' field. - * @param value The value of 'name'. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder setName(java.lang.CharSequence value) { - validate(fields()[2], value); - this.name = value; - fieldSetFlags()[2] = true; - return this; - } - - /** - * Checks whether the 'name' field has been set. - * @return True if the 'name' field has been set, false otherwise. - */ - public boolean hasName() { - return fieldSetFlags()[2]; - } - - - /** - * Clears the value of the 'name' field. - * @return This builder. - */ - public de.trion.microservices.avro.User.Builder clearName() { - name = null; - fieldSetFlags()[2] = false; - return this; - } - - @Override - @SuppressWarnings("unchecked") - public User build() { - try { - User record = new User(); - record.id = fieldSetFlags()[0] ? this.id : (java.lang.Long) defaultValue(fields()[0]); - record.level = fieldSetFlags()[1] ? this.level : (de.trion.microservices.avro.CustomerLevel) defaultValue(fields()[1]); - record.name = fieldSetFlags()[2] ? this.name : (java.lang.CharSequence) defaultValue(fields()[2]); - return record; - } catch (org.apache.avro.AvroMissingFieldException e) { - throw e; - } catch (java.lang.Exception e) { - throw new org.apache.avro.AvroRuntimeException(e); - } - } - } - - @SuppressWarnings("unchecked") - private static final org.apache.avro.io.DatumWriter - WRITER$ = (org.apache.avro.io.DatumWriter)MODEL$.createDatumWriter(SCHEMA$); - - @Override public void writeExternal(java.io.ObjectOutput out) - throws java.io.IOException { - WRITER$.write(this, SpecificData.getEncoder(out)); - } - - @SuppressWarnings("unchecked") - private static final org.apache.avro.io.DatumReader - READER$ = (org.apache.avro.io.DatumReader)MODEL$.createDatumReader(SCHEMA$); - - @Override public void readExternal(java.io.ObjectInput in) - throws java.io.IOException { - READER$.read(this, SpecificData.getDecoder(in)); - } - - @Override protected boolean hasCustomCoders() { return true; } - - @Override public void customEncode(org.apache.avro.io.Encoder out) - throws java.io.IOException - { - out.writeLong(this.id); - - out.writeEnum(this.level.ordinal()); - - out.writeString(this.name); - - } - - @Override public void customDecode(org.apache.avro.io.ResolvingDecoder in) - throws java.io.IOException - { - org.apache.avro.Schema.Field[] fieldOrder = in.readFieldOrderIfDiff(); - if (fieldOrder == null) { - this.id = in.readLong(); - - this.level = de.trion.microservices.avro.CustomerLevel.values()[in.readEnum()]; - - this.name = in.readString(this.name instanceof Utf8 ? (Utf8)this.name : null); - - } else { - for (int i = 0; i < 3; i++) { - switch (fieldOrder[i].pos()) { - case 0: - this.id = in.readLong(); - break; - - case 1: - this.level = de.trion.microservices.avro.CustomerLevel.values()[in.readEnum()]; - break; - - case 2: - this.name = in.readString(this.name instanceof Utf8 ? (Utf8)this.name : null); - break; - - default: - throw new java.io.IOException("Corrupt ResolvingDecoder."); - } - } - } - } -} - - - - - - - - - -