在 PySpark 中将聚合流数据帧与流数据帧联接
作者：Ravi Kiran.M 提问时间：11/17/2023
这是我尝试运行的代码 streaming_df = ( spark.readStream .option("option1", "value1") ) agg_df = ( streamin...
spark-structured-streaming 问答列表
将数据从 apache kafka 流式传输到 apache spark，然后流式传输到 ubuntu 中的 elasticsearch
作者：Ilyas Ch 提问时间：11/16/2023
我想用python脚本通过apache spark从apache kafka主题中读取数据，然后对数据进行一些操作，然后实时流式传输到elasticsearch;最终，我将构建一个模型来对数据执行，并...