如何使用 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.
我是 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.