无模式JSON到Apache Beam“行”类型?

问题描述

是否有一种使用Java SDK将任意无模式的JSON字符串转换为Apache Beam“行”类型的方法?如果不是,是否有可能从现有对象派生Beam Schema类型?

我已经找到了JsonToRowParseJsons的文档,但是它们要么需要提供Schema,要么需要提供POJO类才能工作。我还发现,您可以将JSON字符串读取到BigQuery TableRow中,但似乎没有将TableRow转换为Row的方法,而该方法不涉及已经拥有模式。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)