jishmisc28/SparkStreaming-Hudi-Pipeline

Scala code example for using Spark Streaming to read data from a kafka topic, process and write to a Hudi table then read from Hudi table, perform a join and aggregation, and write the result to a Parquet file.

语言：Scala · GitHub 星标：4 · Fork：0

在 GitHub 上查看原仓库