Spark之SparkStreaming的DStream操作

DStream的转换操作和输出、累加器等： 转换 DStream上的原语分为Transformations（转换）和Output Operations（输出）两种，此外转换操作中还有一些比较特殊的原语，如：updateStateByKey()、transform()以及各种Window相关的原语。 Transformation Meaning map(func) 将源DStream中的每个元素通过

>>阅读原文<<