zoukankan      html  css  js  c++  java
  • 【Spark篇】---SparkStreaming中算子中OutPutOperator类算子

    一、前述

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

    Transformation类算子updateStateByKey,reduceByKeyAndWindow,transform

    OutPutOperator类算子print,foreachRDD,saveAsTextFile

    本文讲解OutPutOperator类算子。

    二、具体

         1、foreachRDD

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

  • 相关阅读:
    flash做的按扭突然在页面上获取不到焦点之后
    收集 关于js的接口和 继承实现的代码例子
    从我丢失了;号 之后说开来去
    你真的会写JavaScript吗?
    json.js + jquery 在 ie7下 的 bug
    如何减少浏览器的repaint和reflow? [转]
    2012我们需要什么样的前的工程师
    JavaScript是否可实现多线程 — 深入理解JavaScript定时机制
    是时候了,我们需要前端架构师
    JS事件模型小结
  • 原文地址:https://www.cnblogs.com/LHWorldBlog/p/8521574.html
Copyright © 2011-2022 走看看