默认按页码顺序显示所有勘误,也可以通过选择印次,来查过该印次的勘误。如果您有新发现的勘误,欢迎提交!

  • 第2页
    图1-1 第一行最后一个方框内的单词拼写错误,应该是GraphX
    英子 提交于 2016-01-25 16:14 · 纸质版 · 第5印 ·
  • 第24页
    根据例 3-14,后面的例子这里需要添加一个Scala进行union()转换操作:
    val errorsRDD = inputRDD.filter(line => line.contains("ERROR"))
    val warnsRDD = inputRDD.filter(line => line.contains("WARN"))
    val badLinesRDD = errorsRDD.union(warnsRDD)
    这一段代码的badLinesRDD 在例 3-16中有使用到。
    CharlesLi 提交于 2016-04-20 14:21 · 纸质版 · 第20印 ·
    • 原书中没有用Scala进行union()转化操作的示例,仅在此补充。请忽略印次。

      岳新欣  发表于 2016-04-20 14:21:06
  • 第34页
    正文最后一段第2行,“它接收一个函数作为参数,这个函数要操作两个 RDD 的元素类型的数据并返回一个同样类型的新元素。”修改为:“它接收一个函数作为参数,这个函数要操作两个相同元素类型的 RDD 数据,并返回一个同样类型的新元素。”
    胡彬 提交于 2015-11-18 11:32 · 纸质版 · 第2印 ·
  • 第38页
    P 38
    原文:如果要从 T 类型的 RDD 创建出一个 DoubleRDD
    改为:
    如果要从 T 类型的 RDD 创建出一个 JavaDoubleRDD
    胡彬 提交于 2015-11-18 17:16 · 纸质版 · 第2印 ·
  • 第38页
    P 38
    2. Java第三段第二行的“当需要一个DoubleRDD 时,”

    改为:当需要一个 JavaDoubleRDD 时 ,
    胡彬 提交于 2015-11-18 17:18 · 纸质版 · 第2印 ·
  • 第40页
    P 40
    例3-40 代码段前面加一行:
    import org.apache.spark.storage.StorageLevel
    胡彬 提交于 2015-11-19 10:18 · 纸质版 · 第2印 ·
  • 第43页
    P 43
    表4-1倒数第三行:
    rdd.keys()改为:rdd.keys
    胡彬 提交于 2015-11-19 14:32 · 纸质版 · 第2印 ·
  • 第43页
    P 43
    表4-1倒数第二行:
    rdd.values()改为:rdd.values
    胡彬 提交于 2015-11-19 14:32 · 纸质版 · 第2印 ·
  • 第49页
    P 49
    例4-16第三行
    原文:sc.parallelize(data).reduceByKey((x, y) => x + y)

    改为sc.parallelize(data).reduceByKey((x, y) => x + y, 10)
    胡彬 提交于 2015-11-19 17:55 · 纸质版 · 第2印 ·
  • 第49页
    P 49 4.3.2上面第二行
    原文:你可以使用 Java 或 Scala 中的 rdd.partitions.size()


    改为:你可以使用 Java 或 Scala 中的 rdd.partitions.size
    胡彬 提交于 2015-11-19 17:59 · 纸质版 · 第2印 ·