需要支持 CsvToAvro 中的“MAP”类型字段

Question

我指的是下面的 URL 以将 CSV 转换为 Avro

https://github.com/GoogleCloudPlatform/java-docs-samples/blob/master/dataflow/transforms/src/main/java/com/example/CsvToAvro.java

我的要求，我的 CSV 中有一个“地图”作为字段。

{id=1,name=rahul,{address1=Pune,address2=Hyderabad},电话：78888888888}

现在 {address1=Pune,address2=Hyderabad} 这个字段将失败，因为它是 MAP 类型。

任何人，请告诉我如何解决这个问题。

Answer 1

如果您检查“CsvToAvro.java”实现，它接受“分隔符”作为参数。 因此，如果我们传递像 ",(?![^\{]*\})) 之类的正则表达式作为参数，那么它会拆分 CSV 字符串，但不会在大括号 ({}) 内拆分。