com.amazonaws.services.schemaregistry.deserializers.avro

Class AWSAvroDeserializer

java.lang.Object

com.amazonaws.services.schemaregistry.deserializers.avro.AWSAvroDeserializer

All Implemented Interfaces:

AWSDataFormatDeserializer

public class AWSAvroDeserializer
extends Object
implements AWSDataFormatDeserializer

Avro specific de-serializer responsible for handling the Avro protocol specific conversion behavior.

Constructor Summary

Constructors

Constructor and Description
AWSAvroDeserializer(GlueSchemaRegistryConfiguration configs) Constructor accepting various dependencies.

Method Summary

Modifier and Type	Method and Description
org.apache.avro.io.DatumReader<Object>	createDatumReader(org.apache.avro.Schema writerSchema, UUID schemaVersionId) This method is used to create Avro datum reader for deserialization.
Object	deserialize(byte[] data, String schema) Deserialize the bytes to the original Avro message for the supplied schema.
Object	deserialize(ByteBuffer buffer, String schema) Deserialize the bytes to the original Avro message for the supplied schema.
Object	deserialize(UUID schemaVersionId, ByteBuffer buffer, String schema) Deserialize the bytes to the original Avro message given the schema retrieved from the schema registry.
byte[]	getDeserializedData(ByteBuffer buffer)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AWSAvroDeserializer

public AWSAvroDeserializer(GlueSchemaRegistryConfiguration configs)

Constructor accepting various dependencies.

Parameters:

configs - configuration elements

Method Detail

deserialize

public Object deserialize(@NonNull
                          byte[] data,
                          @NonNull
                          String schema)

Deserialize the bytes to the original Avro message for the supplied schema.

Specified by:

deserialize in interface AWSDataFormatDeserializer

Parameters:

data - data to be de-serialized

schema - Avro schema

Returns:

de-serialized object

Throws:

AWSSchemaRegistryException - Exception during de-serialization

deserialize

public Object deserialize(@NonNull
                          ByteBuffer buffer,
                          @NonNull
                          String schema)

Deserialize the bytes to the original Avro message for the supplied schema.

Specified by:

deserialize in interface AWSDataFormatDeserializer

Parameters:

buffer - data to be de-serialized

schema - Avro schema

Returns:

de-serialized object

Throws:

AWSSchemaRegistryException - Exception during de-serialization

deserialize

public Object deserialize(@NonNull
                          UUID schemaVersionId,
                          @NonNull
                          ByteBuffer buffer,
                          @NonNull
                          String schema)

Deserialize the bytes to the original Avro message given the schema retrieved from the schema registry.

Specified by:

deserialize in interface AWSDataFormatDeserializer

Parameters:

schemaVersionId - schema version id for the Avro writer schema

buffer - data to be de-serialized

schema - Avro schema

Returns:

de-serialized object

Throws:

AWSSchemaRegistryException - Exception during de-serialization

getDeserializedData

public byte[] getDeserializedData(ByteBuffer buffer)
                           throws IOException

Throws:

IOException

createDatumReader

public org.apache.avro.io.DatumReader<Object> createDatumReader(org.apache.avro.Schema writerSchema,
                                                                UUID schemaVersionId)
                                                         throws InstantiationException,
                                                                IllegalAccessException

This method is used to create Avro datum reader for deserialization. By default, it is GenericDatumReader; SpecificDatumReader will only be created if the user specifies. In this case, the program will check if the user have those specific code-generated schema class locally. ReaderSchema will be supplied if the user wants to use a specific schema to deserialize the message. (Compatibility check will be invoked)

Parameters:

writerSchema - schema that writes the Avro message

schemaVersionId - schema version id for the Avro writer schema

Returns:

Avro datum reader for de-serialization

Throws:

InstantiationException - can be thrown for readerClass.newInstance() from java.lang.Class implementation

IllegalAccessException - can be thrown readerClass.newInstance() from java.lang.Class implementation