有人使用过ApacheFlink的StreamingFileLink.forrowformat（）进行avro记录编码和合并吗。因此，任何人都可以帮助如何实现avro记录编码器。flink通过bulkwriter提供了开箱即用的avro支持，但这限制了在每个检查点上滚动部分文件。
谢谢