我有一个要求,我需要使用结构化流将流写入 Hudi 数据集。我发现有一项针对 Apache Hudi Jira 问题的规定,但想知道是否有人成功实现了这一点并有一个例子。我正在尝试使用 spark 结构化流将数据从 AWS Kinesis Firehose 结构化流到 Apache Hudi
快速帮助表示赞赏。
我有一个要求,我需要使用结构化流将流写入 Hudi 数据集。我发现有一项针对 Apache Hudi Jira 问题的规定,但想知道是否有人成功实现了这一点并有一个例子。我正在尝试使用 spark 结构化流将数据从 AWS Kinesis Firehose 结构化流到 Apache Hudi
快速帮助表示赞赏。
我知道至少有一个用户在 Hudi 中使用结构流式接收器。https://github.com/apache/incubator-hudi/blob/master/hudi-spark/src/test/scala/DataSourceTest.scala#L190可以帮忙吗?