Package com.amazonaws.services.schemaregistry.serializers.protobuf

Class ProtobufSerializer

java.lang.Object

com.amazonaws.services.schemaregistry.serializers.protobuf.ProtobufSerializer

All Implemented Interfaces:

GlueSchemaRegistryDataFormatSerializer

public class ProtobufSerializer
extends Object
implements GlueSchemaRegistryDataFormatSerializer

Protobuf serialization helper. This class is instantiated by GlueSchemaRegistryFacade to serialize Protobuf-type objects

Field Summary

Fields

Modifier and Type	Field	Description
protected final @NonNull com.google.common.cache.LoadingCache<com.google.protobuf.DescriptorProtos.FileDescriptorProto,String>	schemaGeneratorCache

Constructor Summary

Constructors

Constructor	Description
ProtobufSerializer(GlueSchemaRegistryConfiguration configs)	Constructor

Method Summary

Modifier and Type	Method	Description
String	getSchemaDefinition(@NonNull Object object)	Get the schema definition.
byte[]	serialize(@NonNull Object data)	Serialize the Protobuf object to bytes
void	validate(@NonNull Object object)
void	validate(@NonNull String schemaDefinition, @lombok.NonNull byte[] data)

Methods inherited from class java.lang.Object

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

Field Details

schemaGeneratorCache

@NonNull
protected final @NonNull com.google.common.cache.LoadingCache<com.google.protobuf.DescriptorProtos.FileDescriptorProto,String> schemaGeneratorCache

Constructor Details

ProtobufSerializer

public ProtobufSerializer(GlueSchemaRegistryConfiguration configs)

Constructor

Parameters:

configs - configuration elements

Method Details

serialize

public byte[] serialize(@NonNull
 @NonNull Object data)

Serialize the Protobuf object to bytes

Specified by:

serialize in interface GlueSchemaRegistryDataFormatSerializer

Parameters:

data - the Protobuf object for serialization

Returns:

the serialized byte array

Throws:

AWSSchemaRegistryException - AWS Schema Registry Exception

getSchemaDefinition

public String getSchemaDefinition(@NonNull
 @NonNull Object object)

Get the schema definition.

Specified by:

getSchemaDefinition in interface GlueSchemaRegistryDataFormatSerializer

Parameters:

object - object for which schema definition has to be derived

Returns:

schema string

validate

public void validate(@NonNull
 @NonNull String schemaDefinition,
 @NonNull
 @lombok.NonNull byte[] data)

Specified by:

validate in interface GlueSchemaRegistryDataFormatSerializer

validate

public void validate(@NonNull
 @NonNull Object object)

Specified by:

validate in interface GlueSchemaRegistryDataFormatSerializer