Anton Solovev tonycox

Avro serialization

There are 4 possible serialization format when using avro:

Avro Json encoding
Avro Data Serialization (https://avro.apache.org/docs/current/spec.html#Data+Serialization) Binary format with an header that contains the full schema, this is the format usually used when writing Avro files
Avro Single Object Encoding (https://avro.apache.org/docs/current/spec.html#single_object_encoding) Binary format with an header with only the fingerprint/id of the schema, this it the format used by Kafka (see this
Avro Binary Encoding (https://avro.apache.org/docs/current/spec.html#binary_encoding)

	package dev.irontools.flink.state;

	import org.apache.flink.api.common.typeinfo.TypeInformation;
	import org.apache.flink.configuration.Configuration;
	import org.apache.flink.runtime.state.hashmap.HashMapStateBackend;
	import org.apache.flink.state.api.OperatorIdentifier;
	import org.apache.flink.state.api.SavepointReader;
	import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

	import java.io.ByteArrayInputStream;