Включение сериализации Avro для определенных POJO в Apache Flink
Для моих требований я хотел бы явно зарегистрировать Avro Serializer для конкретных POJO. Например, в случае Apache Beam я могу аннотировать данный POJO с помощью @DefaultCoder(AvroCoder.class) и всякий раз, когда указанный POJO должен быть сериализован, Beam будет использовать сериализацию Avro.
Я посмотрел на Flink API и придумал что-то ближе, как показано ниже:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.getConfig().enableForceAvro();
env.getConfig().disableForceKryo();
Но, как я понимаю, вышеизложенное включает Avro для всех POJO.
Есть ли способ, которым я могу зарегистрировать Avro serialiser для конкретных POJO(ов) явно во Flink? Что-то на линии...
registerSerializer(Class<T> clazz, AvroSerializer<T> serializer);
Я использую Flink 1.7.1