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