SparkStreaming通过双输入流动态配置业务 一、背景 业务部门需要获得由数据部门实时采集的业务事件数据。当业务部门订阅指定事件时，则需...

Spark解决Map算子中调用自定义方法出现的初始化问题 1. 背景 有一批JSON数据需要被要存成parquet格式，但是这些json数据中有...