Spark Structured Streaming允许使用unifrom DataFrame和Dataset API处理实时数据流。
连续处理模式和python udf
Spark 2.4.0是否支持具有连续处理模式的Python UDF?在我的简单代码中,我正在使用kafka主题,每行进行一些简单的处理(基本上为...添加一个虚拟字段)