com.amazonaws.services.schemaregistry.deserializers

Class AWSDeserializer

java.lang.Object

com.amazonaws.services.schemaregistry.deserializers.AWSDeserializer

All Implemented Interfaces:

Closeable, AutoCloseable

public class AWSDeserializer
extends Object
implements Closeable

Protocol agnostic AWS Generic de-serializer

Constructor Summary

Constructors

Constructor and Description
AWSDeserializer(GlueSchemaRegistryConfiguration configuration, software.amazon.awssdk.auth.credentials.AwsCredentialsProvider credentialsProvider)
AWSDeserializer(Map<String,?> configs, Properties properties, software.amazon.awssdk.auth.credentials.AwsCredentialsProvider credentialProvider, AWSSchemaRegistryClient schemaRegistryClient) Constructor accepting various dependencies.

Method Summary

Modifier and Type	Method and Description
boolean	canDeserialize(byte[] data) Returns if the given data array can be deserialized.
void	close() Resource clean up for Closeable.
Object	deserialize(AWSDeserializerInput deserializerInput) De-serializes the given data and returns an Object.
byte[]	getActualData(byte[] data)
byte[]	getAvroDeserializedData(ByteBuffer buffer) Get the byte array of Avro object to be de-serialized
Schema	getSchema(byte[] data)
String	getSchemaDefinition(byte[] data) Fetches the schema definition for a the serialized data.
String	getSchemaDefinition(ByteBuffer buffer) Fetches the schema definition for the serialized data.

Methods inherited from class java.lang.Object

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

Constructor Detail

AWSDeserializer

public AWSDeserializer(Map<String,?> configs,
                       Properties properties,
                       @NonNull
                       software.amazon.awssdk.auth.credentials.AwsCredentialsProvider credentialProvider,
                       AWSSchemaRegistryClient schemaRegistryClient)

Constructor accepting various dependencies.

Parameters:

configs - configuration map

properties - configuration properties

credentialProvider - credentials provider for integrating with schema registry service

schemaRegistryClient - schema registry client for communicating with schema registry service

AWSDeserializer

public AWSDeserializer(@NonNull
                       GlueSchemaRegistryConfiguration configuration,
                       @NonNull
                       software.amazon.awssdk.auth.credentials.AwsCredentialsProvider credentialsProvider)

Method Detail

getSchemaDefinition

public String getSchemaDefinition(@NonNull
                                  ByteBuffer buffer)

Fetches the schema definition for the serialized data.

Parameters:

buffer - data for which schema definition is needed as ByteBuffer

Returns:

schema definition

Throws:

AWSIncompatibleDataException - when data is incompatible with schema registry

getActualData

public byte[] getActualData(byte[] data)

getSchema

public Schema getSchema(@NonNull
                        byte[] data)

getSchemaDefinition

public String getSchemaDefinition(@NonNull
                                  byte[] data)

Fetches the schema definition for a the serialized data.

Parameters:

data - data for which schema definition is needed as byte array

Returns:

schema for the passed data

Throws:

AWSIncompatibleDataException - when data is incompatible with schema registry

deserialize

public Object deserialize(@NonNull
                          AWSDeserializerInput deserializerInput)
                   throws AWSSchemaRegistryException

De-serializes the given data and returns an Object. Accepts encapsulated deserializer input.

Parameters:

deserializerInput - Input data object for deserializer

Returns:

de-serialized object instance

Throws:

AWSSchemaRegistryException - Exception during de-serialization

canDeserialize

public boolean canDeserialize(byte[] data)

Returns if the given data array can be deserialized.

Parameters:

data - byte[] of data.

Returns:

boolean.

getAvroDeserializedData

public byte[] getAvroDeserializedData(@NonNull
                                      ByteBuffer buffer)
                               throws IOException

Get the byte array of Avro object to be de-serialized

Parameters:

buffer - byte buffer to be de-serialized

Returns:

byte array of Avro object to be de-serialized

Throws:

IOException - Exception during decompression

close

public void close()

Resource clean up for Closeable. This method internally shuts down the background thread for publishing cloud watch metrics. After this is called, a new instance of this class should be created to enable the metrics publishing feature.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable