Package org.apache.flink.avro.generated
Class Address
- java.lang.Object
-
- org.apache.avro.specific.SpecificRecordBase
-
- org.apache.flink.avro.generated.Address
-
- All Implemented Interfaces:
Externalizable
,Serializable
,Comparable<org.apache.avro.specific.SpecificRecord>
,org.apache.avro.generic.GenericContainer
,org.apache.avro.generic.GenericRecord
,org.apache.avro.generic.IndexedRecord
,org.apache.avro.specific.SpecificRecord
public class Address extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Address.Builder
RecordBuilder for Address instances.
-
Field Summary
Fields Modifier and Type Field Description static org.apache.avro.Schema
SCHEMA$
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static org.apache.avro.message.BinaryMessageDecoder<Address>
createDecoder(org.apache.avro.message.SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specifiedSchemaStore
.void
customDecode(org.apache.avro.io.ResolvingDecoder in)
void
customEncode(org.apache.avro.io.Encoder out)
static Address
fromByteBuffer(ByteBuffer b)
Deserializes a Address from a ByteBuffer.Object
get(int field$)
String
getAppno()
Gets the value of the 'appno' field.String
getCity()
Gets the value of the 'city' field.static org.apache.avro.Schema
getClassSchema()
static org.apache.avro.message.BinaryMessageDecoder<Address>
getDecoder()
Return the BinaryMessageDecoder instance used by this class.static org.apache.avro.message.BinaryMessageEncoder<Address>
getEncoder()
Return the BinaryMessageEncoder instance used by this class.int
getNum()
Gets the value of the 'num' field.org.apache.avro.Schema
getSchema()
org.apache.avro.specific.SpecificData
getSpecificData()
String
getState()
Gets the value of the 'state' field.String
getStreet()
Gets the value of the 'street' field.String
getZip()
Gets the value of the 'zip' field.protected boolean
hasCustomCoders()
static Address.Builder
newBuilder()
Creates a new Address RecordBuilder.static Address.Builder
newBuilder(Address other)
Creates a new Address RecordBuilder by copying an existing Address instance.static Address.Builder
newBuilder(Address.Builder other)
Creates a new Address RecordBuilder by copying an existing Builder.void
put(int field$, Object value$)
void
readExternal(ObjectInput in)
void
setAppno(String value)
Sets the value of the 'appno' field.void
setCity(String value)
Sets the value of the 'city' field.void
setNum(int value)
Sets the value of the 'num' field.void
setState(String value)
Sets the value of the 'state' field.void
setStreet(String value)
Sets the value of the 'street' field.void
setZip(String value)
Sets the value of the 'zip' field.ByteBuffer
toByteBuffer()
Serializes this Address to a ByteBuffer.void
writeExternal(ObjectOutput out)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, equals, get, getConversion, getConversion, hashCode, put, toString
-
-
-
-
Constructor Detail
-
Address
public Address()
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder()
.
-
Address
public Address(Integer num, String street, String city, String state, String zip, String appno)
All-args constructor.- Parameters:
num
- The new value for numstreet
- The new value for streetcity
- The new value for citystate
- The new value for statezip
- The new value for zipappno
- The new value for appno
-
-
Method Detail
-
getClassSchema
public static org.apache.avro.Schema getClassSchema()
-
getEncoder
public static org.apache.avro.message.BinaryMessageEncoder<Address> getEncoder()
Return the BinaryMessageEncoder instance used by this class.- Returns:
- the message encoder used by this class
-
getDecoder
public static org.apache.avro.message.BinaryMessageDecoder<Address> getDecoder()
Return the BinaryMessageDecoder instance used by this class.- Returns:
- the message decoder used by this class
-
createDecoder
public static org.apache.avro.message.BinaryMessageDecoder<Address> createDecoder(org.apache.avro.message.SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specifiedSchemaStore
.- Parameters:
resolver
- aSchemaStore
used to find schemas by fingerprint- Returns:
- a BinaryMessageDecoder instance for this class backed by the given SchemaStore
-
toByteBuffer
public ByteBuffer toByteBuffer() throws IOException
Serializes this Address to a ByteBuffer.- Returns:
- a buffer holding the serialized data for this instance
- Throws:
IOException
- if this instance could not be serialized
-
fromByteBuffer
public static Address fromByteBuffer(ByteBuffer b) throws IOException
Deserializes a Address from a ByteBuffer.- Parameters:
b
- a byte buffer holding serialized data for an instance of this class- Returns:
- a Address instance decoded from the given buffer
- Throws:
IOException
- if the given bytes could not be deserialized into an instance of this class
-
getSpecificData
public org.apache.avro.specific.SpecificData getSpecificData()
- Overrides:
getSpecificData
in classorg.apache.avro.specific.SpecificRecordBase
-
getSchema
public org.apache.avro.Schema getSchema()
- Specified by:
getSchema
in interfaceorg.apache.avro.generic.GenericContainer
- Specified by:
getSchema
in classorg.apache.avro.specific.SpecificRecordBase
-
get
public Object get(int field$)
- Specified by:
get
in interfaceorg.apache.avro.generic.IndexedRecord
- Specified by:
get
in classorg.apache.avro.specific.SpecificRecordBase
-
put
public void put(int field$, Object value$)
- Specified by:
put
in interfaceorg.apache.avro.generic.IndexedRecord
- Specified by:
put
in classorg.apache.avro.specific.SpecificRecordBase
-
getNum
public int getNum()
Gets the value of the 'num' field.- Returns:
- The value of the 'num' field.
-
setNum
public void setNum(int value)
Sets the value of the 'num' field.- Parameters:
value
- the value to set.
-
getStreet
public String getStreet()
Gets the value of the 'street' field.- Returns:
- The value of the 'street' field.
-
setStreet
public void setStreet(String value)
Sets the value of the 'street' field.- Parameters:
value
- the value to set.
-
getCity
public String getCity()
Gets the value of the 'city' field.- Returns:
- The value of the 'city' field.
-
setCity
public void setCity(String value)
Sets the value of the 'city' field.- Parameters:
value
- the value to set.
-
getState
public String getState()
Gets the value of the 'state' field.- Returns:
- The value of the 'state' field.
-
setState
public void setState(String value)
Sets the value of the 'state' field.- Parameters:
value
- the value to set.
-
getZip
public String getZip()
Gets the value of the 'zip' field.- Returns:
- The value of the 'zip' field.
-
setZip
public void setZip(String value)
Sets the value of the 'zip' field.- Parameters:
value
- the value to set.
-
getAppno
public String getAppno()
Gets the value of the 'appno' field.- Returns:
- The value of the 'appno' field.
-
setAppno
public void setAppno(String value)
Sets the value of the 'appno' field.- Parameters:
value
- the value to set.
-
newBuilder
public static Address.Builder newBuilder()
Creates a new Address RecordBuilder.- Returns:
- A new Address RecordBuilder
-
newBuilder
public static Address.Builder newBuilder(Address.Builder other)
Creates a new Address RecordBuilder by copying an existing Builder.- Parameters:
other
- The existing builder to copy.- Returns:
- A new Address RecordBuilder
-
newBuilder
public static Address.Builder newBuilder(Address other)
Creates a new Address RecordBuilder by copying an existing Address instance.- Parameters:
other
- The existing instance to copy.- Returns:
- A new Address RecordBuilder
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternal
in interfaceExternalizable
- Overrides:
writeExternal
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException
- Specified by:
readExternal
in interfaceExternalizable
- Overrides:
readExternal
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
IOException
-
hasCustomCoders
protected boolean hasCustomCoders()
- Overrides:
hasCustomCoders
in classorg.apache.avro.specific.SpecificRecordBase
-
customEncode
public void customEncode(org.apache.avro.io.Encoder out) throws IOException
- Overrides:
customEncode
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
IOException
-
customDecode
public void customDecode(org.apache.avro.io.ResolvingDecoder in) throws IOException
- Overrides:
customDecode
in classorg.apache.avro.specific.SpecificRecordBase
- Throws:
IOException
-
-