Как правильно записать avro-записи в каталог HDFS с помощью StreamingFileSink?StreamingFileSink имеет метод RowFormat, который может выводить по одной записи за раз, используя предоставленный кодировщик, что неправильно для создания файлов в формате avro со схемой.Существует AvroParquetWriter (с использованием BulkWriter), который может конвертировать записи Avro в Parquet.Что может быть похожим способом создания avro файлов?Какие интерфейсы необходимо реализовать, чтобы запись была синхронизирована с контрольной точкой Флинка?Существуют ли какие-либо реализации, на которые можно ссылаться для создания таких файлов avro?