2、DStream的操作

• Transform

  

• RDD操作

  

  RDD中提供了丰富的API接口，Dstream对RDD的操作进行了封装，但封装并不完全，如果有些方法没有封装进去，但是还是需要使用这些方法，就可以调用transform方法，相当于直接对RDD进行操作。

• State操作

  

  每一个State对应一个时间片段的数据，计算时，对应是这个时间段内的计算（例如：求和操作），如果要进行全天的操作，那会对应很多的Dstream，在计算全天的结果，就可以用此方法。类似于累加器(保存流数据的全局状态)。

• 输出操作

  

  类似于RDD中的action，触发Dstream的延迟操作。