sparkStreaming之transform的细节前言代码总结黑名单
val socketLineDStream: ReceiverInputDStream[String] = streamingContext.socketTextStream('linux1', 8888)// TODO Driver中执行一次// 例如val a = 1 在Driver中只执行一次// 首先看一下DStream的其他Transformations(转换)操作socketLineDStream.map({ case x => { // TODO