Package org.axonframework.conversion.avro

Class ByteArrayToGenericRecordConverter

java.lang.Object

org.axonframework.conversion.avro.ByteArrayToGenericRecordConverter

All Implemented Interfaces:

ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>

public class ByteArrayToGenericRecordConverter
extends Object
implements ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>

A ContentTypeConverter implementation that converts byte[] into an Avro GenericRecord.

Searches for the correct Avro Schema by extracting the fingerprint from the given byte[].

Since:

4.11.0

Author:

Simon Zambrovski, Jan Galinski

Constructor Summary

Constructors

Constructor	Description
ByteArrayToGenericRecordConverter(org.apache.avro.message.SchemaStore schemaStore)	Constructs a content type converter used during deserialization for upcasting, to create GenericRecord from single-object-encoded for a given schema.

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	convert(byte[] input)	Converts the given input object of generic type S into an object of generic type T.
Class<byte[]>	expectedSourceType()	Returns the expected type of input data for this ContentTypeConverter to ContentTypeConverter.convert(Object).
Class<org.apache.avro.generic.GenericRecord>	targetType()	Returns the type of output for this ContentTypeConverter to ContentTypeConverter.convert(Object) into.

Methods inherited from class java.lang.Object

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

Constructor Details

ByteArrayToGenericRecordConverter

public ByteArrayToGenericRecordConverter(@Nonnull
 org.apache.avro.message.SchemaStore schemaStore)

Constructs a content type converter used during deserialization for upcasting, to create GenericRecord from single-object-encoded for a given schema.

Parameters:

schemaStore - The schema store to resolve schemas with based on a fingerprint.

Method Details

expectedSourceType

@Nonnull
public Class<byte[]> expectedSourceType()

Description copied from interface: ContentTypeConverter

Returns the expected type of input data for this ContentTypeConverter to ContentTypeConverter.convert(Object).

Specified by:

expectedSourceType in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>

Returns:

The expected type of input data for this ContentTypeConverter to ContentTypeConverter.convert(Object).

targetType

@Nonnull
public Class<org.apache.avro.generic.GenericRecord> targetType()

Description copied from interface: ContentTypeConverter

Returns the type of output for this ContentTypeConverter to ContentTypeConverter.convert(Object) into.

Specified by:

targetType in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>

Returns:

The type of output for this ContentTypeConverter to ContentTypeConverter.convert(Object) into.

convert

@Nullable
public org.apache.avro.generic.GenericRecord convert(@Nullable
 byte[] input)

Description copied from interface: ContentTypeConverter

Converts the given input object of generic type S into an object of generic type T.

Specified by:

convert in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>

Parameters:

input - The object of generic type S to convert into an object of generic type T.

Returns:

The converted version of the given input in type T.