Package org.apache.avro.ipc
Class HandshakeResponse
java.lang.Object
org.apache.avro.specific.SpecificRecordBase
org.apache.avro.ipc.HandshakeResponse
- All Implemented Interfaces:
Externalizable
,Serializable
,Comparable<SpecificRecord>
,GenericContainer
,GenericRecord
,IndexedRecord
,SpecificRecord
- See Also:
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
RecordBuilder for HandshakeResponse instances. -
Field Summary
-
Constructor Summary
ConstructorDescriptionDefault constructor.HandshakeResponse
(HandshakeMatch match, String serverProtocol, MD5 serverHash, Map<String, ByteBuffer> meta) All-args constructor. -
Method Summary
Modifier and TypeMethodDescriptioncreateDecoder
(SchemaStore resolver) Create a new BinaryMessageDecoder instance for this class that uses the specifiedSchemaStore
.void
void
customEncode
(Encoder out) static HandshakeResponse
Deserializes a HandshakeResponse from a ByteBuffer.get
(int field$) Return the value of a field given its position in the schema.static Schema
Return the BinaryMessageDecoder instance used by this class.Return the BinaryMessageEncoder instance used by this class.getMatch()
Gets the value of the 'match' field.getMeta()
Gets the value of the 'meta' field.Gets the value of the 'match' field as an Optional<org.apache.avro.ipc.HandshakeMatch>.Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.Gets the value of the 'serverProtocol' field as an Optional<java.lang.String>.The schema of this instance.Gets the value of the 'serverHash' field.Gets the value of the 'serverProtocol' field.protected boolean
Returns true iff an instance supports theMessageEncoder.encode(D)
andMessageDecoder.decode(java.io.InputStream)
operations.static HandshakeResponse.Builder
Creates a new HandshakeResponse RecordBuilder.static HandshakeResponse.Builder
newBuilder
(HandshakeResponse other) Creates a new HandshakeResponse RecordBuilder by copying an existing HandshakeResponse instance.static HandshakeResponse.Builder
Creates a new HandshakeResponse RecordBuilder by copying an existing Builder.void
Set the value of a field given its position in the schema.void
void
setMatch
(HandshakeMatch value) Sets the value of the 'match' field.void
setMeta
(Map<String, ByteBuffer> value) Sets the value of the 'meta' field.void
setServerHash
(MD5 value) Sets the value of the 'serverHash' field.void
setServerProtocol
(String value) Sets the value of the 'serverProtocol' field.Serializes this HandshakeResponse to a ByteBuffer.void
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, equals, get, getConversion, getConversion, hashCode, put, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.avro.generic.GenericRecord
hasField
-
Field Details
-
SCHEMA$
-
-
Constructor Details
-
HandshakeResponse
public HandshakeResponse()Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder()
. -
HandshakeResponse
public HandshakeResponse(HandshakeMatch match, String serverProtocol, MD5 serverHash, Map<String, ByteBuffer> meta) All-args constructor.- Parameters:
match
- The new value for matchserverProtocol
- The new value for serverProtocolserverHash
- The new value for serverHashmeta
- The new value for meta
-
-
Method Details
-
getClassSchema
-
getEncoder
Return the BinaryMessageEncoder instance used by this class.- Returns:
- the message encoder used by this class
-
getDecoder
Return the BinaryMessageDecoder instance used by this class.- Returns:
- the message decoder used by this class
-
createDecoder
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
Serializes this HandshakeResponse to a ByteBuffer.- Returns:
- a buffer holding the serialized data for this instance
- Throws:
IOException
- if this instance could not be serialized
-
fromByteBuffer
Deserializes a HandshakeResponse from a ByteBuffer.- Parameters:
b
- a byte buffer holding serialized data for an instance of this class- Returns:
- a HandshakeResponse instance decoded from the given buffer
- Throws:
IOException
- if the given bytes could not be deserialized into an instance of this class
-
getSpecificData
- Overrides:
getSpecificData
in classSpecificRecordBase
-
getSchema
Description copied from interface:GenericContainer
The schema of this instance.- Specified by:
getSchema
in interfaceGenericContainer
-
get
Description copied from interface:IndexedRecord
Return the value of a field given its position in the schema.This method is not meant to be called by user code, but only by
DatumWriter
implementations.- Specified by:
get
in interfaceIndexedRecord
-
put
Description copied from interface:IndexedRecord
Set the value of a field given its position in the schema.This method is not meant to be called by user code, but only by
DatumReader
implementations.- Specified by:
put
in interfaceIndexedRecord
-
getMatch
Gets the value of the 'match' field.- Returns:
- The value of the 'match' field.
-
getOptionalMatch
Gets the value of the 'match' field as an Optional<org.apache.avro.ipc.HandshakeMatch>.- Returns:
- The value wrapped in an Optional<org.apache.avro.ipc.HandshakeMatch>.
-
setMatch
Sets the value of the 'match' field.- Parameters:
value
- the value to set.
-
getServerProtocol
Gets the value of the 'serverProtocol' field.- Returns:
- The value of the 'serverProtocol' field.
-
getOptionalServerProtocol
Gets the value of the 'serverProtocol' field as an Optional<java.lang.String>.- Returns:
- The value wrapped in an Optional<java.lang.String>.
-
setServerProtocol
Sets the value of the 'serverProtocol' field.- Parameters:
value
- the value to set.
-
getServerHash
Gets the value of the 'serverHash' field.- Returns:
- The value of the 'serverHash' field.
-
getOptionalServerHash
Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.- Returns:
- The value wrapped in an Optional<org.apache.avro.ipc.MD5>.
-
setServerHash
Sets the value of the 'serverHash' field.- Parameters:
value
- the value to set.
-
getMeta
Gets the value of the 'meta' field.- Returns:
- The value of the 'meta' field.
-
getOptionalMeta
Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.- Returns:
- The value wrapped in an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.
-
setMeta
Sets the value of the 'meta' field.- Parameters:
value
- the value to set.
-
newBuilder
Creates a new HandshakeResponse RecordBuilder.- Returns:
- A new HandshakeResponse RecordBuilder
-
newBuilder
Creates a new HandshakeResponse RecordBuilder by copying an existing Builder.- Parameters:
other
- The existing builder to copy.- Returns:
- A new HandshakeResponse RecordBuilder
-
newBuilder
Creates a new HandshakeResponse RecordBuilder by copying an existing HandshakeResponse instance.- Parameters:
other
- The existing instance to copy.- Returns:
- A new HandshakeResponse RecordBuilder
-
writeExternal
- Specified by:
writeExternal
in interfaceExternalizable
- Overrides:
writeExternal
in classSpecificRecordBase
- Throws:
IOException
-
readExternal
- Specified by:
readExternal
in interfaceExternalizable
- Overrides:
readExternal
in classSpecificRecordBase
- Throws:
IOException
-
hasCustomCoders
protected boolean hasCustomCoders()Description copied from class:SpecificRecordBase
Returns true iff an instance supports theMessageEncoder.encode(D)
andMessageDecoder.decode(java.io.InputStream)
operations. Should only be used bySpecificDatumReader/Writer
to selectively useSpecificRecordBase.customEncode(org.apache.avro.io.Encoder)
andSpecificRecordBase.customDecode(org.apache.avro.io.ResolvingDecoder)
to optimize the (de)serialization of values.- Overrides:
hasCustomCoders
in classSpecificRecordBase
-
customEncode
- Overrides:
customEncode
in classSpecificRecordBase
- Throws:
IOException
-
customDecode
- Overrides:
customDecode
in classSpecificRecordBase
- Throws:
IOException
-