Spark原理篇之Spark Streaming转化操作和输出操作

1 转化操作       DStream的转化操作可以分为无状态和有状态两种。       ① 在无状态转化操作中，每个批次的处理不依赖于之前批次的数据。例如map()、filter()和reduceByKey()等都是无状态转化操作。       ② 有状态转化操作需要使用之前批次的数据或者是中间结果来计算当前批次的数据。有状态转化操作包括基于滑动窗口的转化操作和追踪状态变化的转化操作。 1.1

>>阅读原文<<