val inputDStream = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder, (String, String)](ssc, kafkaParams, fromOffsets, messageHandler)val inputDStream = KafkaUtils.createDirectStream[S
阅读背景：
spark streaming(2) DAG静态定义及DStream,DStreamGraph
来源：互联网
分享到：
