企业宣传,产品推广,广告招商,广告投放联系seowdb

经常使用Spark Streaming转换不同的JSON有效负载

一旦咱们有了数据帧,咱们就可以运转尽或许多的sql查问,并依据所需的有效负载写入 kafka 主题。因此,咱们可以创立一个蕴含一切sql查问的列表,并经过该列表启动循环,并调用writeStream函数。让咱们假定,咱们有一个名为 queryList 的列表,它只蕴含字符串(即sql查问)。

© 版权声明
评论 抢沙发
加载中~
每日一言
不怕万人阻挡,只怕自己投降
Not afraid of people blocking, I'm afraid their surrender