public class ByteArrayToGenericRecordConverter extends Object implements ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>
Constructor and 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. |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.generic.GenericRecord |
convert(byte[] singleObjectEncodeBytes)
Converts the given object into another.
|
Class<byte[]> |
expectedSourceType()
The expected type of input data.
|
Class<org.apache.avro.generic.GenericRecord> |
targetType()
The returned type of IntermediateRepresentation
|
public ByteArrayToGenericRecordConverter(org.apache.avro.message.SchemaStore schemaStore)
GenericRecord
from single-object-encoded for a given schema.schemaStore
- schema store to resolve schema from fingerprint.public Class<byte[]> expectedSourceType()
ContentTypeConverter
expectedSourceType
in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>
public Class<org.apache.avro.generic.GenericRecord> targetType()
ContentTypeConverter
targetType
in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>
public org.apache.avro.generic.GenericRecord convert(byte[] singleObjectEncodeBytes)
ContentTypeConverter
SerializedObject
instance.convert
in interface ContentTypeConverter<byte[],org.apache.avro.generic.GenericRecord>
singleObjectEncodeBytes
- the value to convertCopyright © 2010–2025. All rights reserved.