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

Need support for type "MAP" field in CsvToAvro

我在下面提到 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},phone:78888888888}

现在对于 {address1=Pune,address2=Hyderabad} 此字段将失败,因为它是 MAP 类型。

任何人,你能告诉我如何解决这个问题吗?

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