public interface AvroSerializer extends ObjectSerializer
Modifier and Type | Method and Description |
---|---|
<T> T |
deserialize(InputStream stream,
TypeReference<T> typeReference)
Reads an Avro stream into its object representation.
|
<T> Mono<T> |
deserializeAsync(InputStream stream,
TypeReference<T> typeReference)
Reads an Avro stream into its object representation.
|
default <T> T |
deserializeFromBytes(byte[] data,
TypeReference<T> typeReference)
Reads an Avro byte array into its object representation.
|
default <T> Mono<T> |
deserializeFromBytesAsync(byte[] data,
TypeReference<T> typeReference)
Reads an Avro byte array into its object representation.
|
void |
serialize(OutputStream stream,
Object value)
Writes an object's Avro representation into a stream.
|
Mono<Void> |
serializeAsync(OutputStream stream,
Object value)
Writes an object's Avro representation into a stream.
|
default byte[] |
serializeToBytes(Object value)
Converts the object into an Avro byte array.
|
default Mono<byte[]> |
serializeToBytesAsync(Object value)
Converts the object into a Avro byte array.
|
default <T> T deserializeFromBytes(byte[] data, TypeReference<T> typeReference)
deserializeFromBytes
in interface ObjectSerializer
T
- Type of the object.data
- Avro byte array.typeReference
- TypeReference
representing the object.<T> T deserialize(InputStream stream, TypeReference<T> typeReference)
deserialize
in interface ObjectSerializer
T
- Type of the object.stream
- Avro stream.typeReference
- TypeReference
representing the object.default <T> Mono<T> deserializeFromBytesAsync(byte[] data, TypeReference<T> typeReference)
deserializeFromBytesAsync
in interface ObjectSerializer
T
- Type of the object.data
- Avro byte array.typeReference
- TypeReference
representing the object.<T> Mono<T> deserializeAsync(InputStream stream, TypeReference<T> typeReference)
deserializeAsync
in interface ObjectSerializer
T
- Type of the object.stream
- Avro stream.typeReference
- TypeReference
representing the object.default byte[] serializeToBytes(Object value)
serializeToBytes
in interface ObjectSerializer
value
- The object.void serialize(OutputStream stream, Object value)
serialize
in interface ObjectSerializer
stream
- OutputStream
where the object's Avro representation will be written.value
- The object.default Mono<byte[]> serializeToBytesAsync(Object value)
serializeToBytesAsync
in interface ObjectSerializer
value
- The object.Mono<Void> serializeAsync(OutputStream stream, Object value)
serializeAsync
in interface ObjectSerializer
stream
- OutputStream
where the object's Avro representation will be written.value
- The object.Copyright © 2021 Microsoft Corporation. All rights reserved.