SparkStream之OutPutOperator类算子

一、概述

SparkStreaming中的算子分为两类，一类是Transformation类算子，一类是OutPutOperator类算子。

1. Transformation类算子updateStateByKey，reduceByKeyAndWindow，transform
2. OutPutOperator类算子print，foreachRDD，saveAsTextFile

二、foreachRDD算子

      可以拿到DStream中的一个个的RDD，对拿到的RDD可以使用Transformation类算子对数据进行转换，foreachRDD方法内，拿到的RDD Transformation类算子外的代码是在Driver端执行