Package org.apache.flink.formats.avro.utils
-
Class Summary Class Description AvroKryoSerializerUtils Utilities for integrating Avro serializers in Kryo.AvroKryoSerializerUtils.AvroSchemaSerializer Slow serialization approach for Avro schemas.DataInputDecoder ADecoder
that reads from aDataInput
.DataOutputEncoder AnEncoder
that writes data to aDataOutput
.FSDataInputStreamWrapper Code copy pasted from org.apache.avro.mapred.FSInput (which is Apache licensed as well).MutableByteArrayInputStream An extension of the ByteArrayInputStream that allows to change a buffer that should be read without creating a new ByteArrayInputStream instance.