SparkStreaming transform算子入门案例
概念解析参数为函数,且函数的形参是个rdd类型,返回值为Dstream类型def transform[U : ClassTag](transformFunc: RDD[T] => RDD[U]): DStream[U]Return a new DStream in which each RDD is generated by applying afunction on each RDD of ‘this’ DStream.案例以nc作为测试源nc -lk mypc01 10087