如何使用 scala 生成 avro ocf 格式(带架构)data/file?

How to generate avro ocf format(with schema) data/file using scala?

我是 Scala 的新手。

我有一个要求,我的数据(以防 class)需要以 avro OCF(包含架构)格式写入 S3 存储桶。 我可以在 scala 中看到 generate/serialise avro 非 ocf(schemaless) 格式数据的方法,但找不到生成 OCF 格式的方法。

这个link示例展示了如何生成非OCF格式,但我正在寻找OCF格式生成 https://dzone.com/articles/kafka-avro-scala-example

任何 help/suggestion 将不胜感激。

您需要使用 com.sksamuel.avro4s.AvroDataOutputStream class.