Package org.apache.avro.ipc
Class HandshakeRequest
java.lang.Object
org.apache.avro.specific.SpecificRecordBase
org.apache.avro.ipc.HandshakeRequest
- 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 HandshakeRequest
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classRecordBuilder for HandshakeRequest instances. -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionDefault constructor.HandshakeRequest(MD5 clientHash, String clientProtocol, MD5 serverHash, Map<String, ByteBuffer> meta) All-args constructor. -
Method Summary
Modifier and TypeMethodDescriptionstatic org.apache.avro.message.BinaryMessageDecoder<HandshakeRequest> createDecoder(org.apache.avro.message.SchemaStore resolver) Create a new BinaryMessageDecoder instance for this class that uses the specifiedSchemaStore.voidcustomDecode(org.apache.avro.io.ResolvingDecoder in) voidcustomEncode(org.apache.avro.io.Encoder out) static HandshakeRequestDeserializes a HandshakeRequest from a ByteBuffer.get(int field$) static org.apache.avro.SchemaGets the value of the 'clientHash' field.Gets the value of the 'clientProtocol' field.static org.apache.avro.message.BinaryMessageDecoder<HandshakeRequest> Return the BinaryMessageDecoder instance used by this class.static org.apache.avro.message.BinaryMessageEncoder<HandshakeRequest> Return the BinaryMessageEncoder instance used by this class.getMeta()Gets the value of the 'meta' field.Gets the value of the 'clientHash' field as an Optional<org.apache.avro.ipc.MD5>.Gets the value of the 'clientProtocol' field as an Optional<java.lang.String>.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>.org.apache.avro.SchemaGets the value of the 'serverHash' field.org.apache.avro.specific.SpecificDataprotected booleanstatic HandshakeRequest.BuilderCreates a new HandshakeRequest RecordBuilder.static HandshakeRequest.BuildernewBuilder(HandshakeRequest other) Creates a new HandshakeRequest RecordBuilder by copying an existing HandshakeRequest instance.static HandshakeRequest.BuilderCreates a new HandshakeRequest RecordBuilder by copying an existing Builder.voidvoidvoidsetClientHash(MD5 value) Sets the value of the 'clientHash' field.voidsetClientProtocol(String value) Sets the value of the 'clientProtocol' field.voidsetMeta(Map<String, ByteBuffer> value) Sets the value of the 'meta' field.voidsetServerHash(MD5 value) Sets the value of the 'serverHash' field.Serializes this HandshakeRequest to a ByteBuffer.voidMethods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, equals, get, getConversion, getConversion, hashCode, put, toStringMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.avro.generic.GenericRecord
hasField
-
Field Details
-
SCHEMA$
public static final org.apache.avro.Schema SCHEMA$
-
-
Constructor Details
-
HandshakeRequest
public HandshakeRequest()Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should usenewBuilder(). -
HandshakeRequest
public HandshakeRequest(MD5 clientHash, String clientProtocol, MD5 serverHash, Map<String, ByteBuffer> meta) All-args constructor.- Parameters:
clientHash- The new value for clientHashclientProtocol- The new value for clientProtocolserverHash- The new value for serverHashmeta- The new value for meta
-
-
Method Details
-
getClassSchema
public static org.apache.avro.Schema 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
public static org.apache.avro.message.BinaryMessageDecoder<HandshakeRequest> createDecoder(org.apache.avro.message.SchemaStore resolver) Create a new BinaryMessageDecoder instance for this class that uses the specifiedSchemaStore.- Parameters:
resolver- aSchemaStoreused to find schemas by fingerprint- Returns:
- a BinaryMessageDecoder instance for this class backed by the given SchemaStore
-
toByteBuffer
Serializes this HandshakeRequest 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 HandshakeRequest from a ByteBuffer.- Parameters:
b- a byte buffer holding serialized data for an instance of this class- Returns:
- a HandshakeRequest 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:
getSpecificDatain classorg.apache.avro.specific.SpecificRecordBase
-
getSchema
public org.apache.avro.Schema getSchema()- Specified by:
getSchemain interfaceorg.apache.avro.generic.GenericContainer
-
get
- Specified by:
getin interfaceorg.apache.avro.generic.IndexedRecord
-
put
- Specified by:
putin interfaceorg.apache.avro.generic.IndexedRecord
-
getClientHash
Gets the value of the 'clientHash' field.- Returns:
- The value of the 'clientHash' field.
-
getOptionalClientHash
Gets the value of the 'clientHash' field as an Optional<org.apache.avro.ipc.MD5>.- Returns:
- The value wrapped in an Optional<org.apache.avro.ipc.MD5>.
-
setClientHash
Sets the value of the 'clientHash' field.- Parameters:
value- the value to set.
-
getClientProtocol
Gets the value of the 'clientProtocol' field.- Returns:
- The value of the 'clientProtocol' field.
-
getOptionalClientProtocol
Gets the value of the 'clientProtocol' field as an Optional<java.lang.String>.- Returns:
- The value wrapped in an Optional<java.lang.String>.
-
setClientProtocol
Sets the value of the 'clientProtocol' 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 HandshakeRequest RecordBuilder.- Returns:
- A new HandshakeRequest RecordBuilder
-
newBuilder
Creates a new HandshakeRequest RecordBuilder by copying an existing Builder.- Parameters:
other- The existing builder to copy.- Returns:
- A new HandshakeRequest RecordBuilder
-
newBuilder
Creates a new HandshakeRequest RecordBuilder by copying an existing HandshakeRequest instance.- Parameters:
other- The existing instance to copy.- Returns:
- A new HandshakeRequest RecordBuilder
-
writeExternal
- Specified by:
writeExternalin interfaceExternalizable- Overrides:
writeExternalin classorg.apache.avro.specific.SpecificRecordBase- Throws:
IOException
-
readExternal
- Specified by:
readExternalin interfaceExternalizable- Overrides:
readExternalin classorg.apache.avro.specific.SpecificRecordBase- Throws:
IOException
-
hasCustomCoders
protected boolean hasCustomCoders()- Overrides:
hasCustomCodersin classorg.apache.avro.specific.SpecificRecordBase
-
customEncode
- Overrides:
customEncodein classorg.apache.avro.specific.SpecificRecordBase- Throws:
IOException
-
customDecode
- Overrides:
customDecodein classorg.apache.avro.specific.SpecificRecordBase- Throws:
IOException
-