函数重载 第一个参数：返回的行数 第二个参数：bool或者int类型，flase代表字段内容全部展示，true代表只展示20个字符，或者可以自动指定 第三个参数：是否垂直打印，默认 ...

总结 map的作用很容易理解就是对rdd之中的元素进行逐一进行函数操作，映射为另外一个rdd。 flatMap的操作是将函数应用于rdd之中的每一个元素，将返回的迭代器的所有内容构成新的rdd。通常 ...

输入参数：withReplacement、fraction，seed 返回： 数组集组成的RDD withReplacement：表示抽出样本后是否在放回去，true表示会放回去，这 ...

foreach 是一个action算子，不会触发shuffle 读取数据后，查看idea提示，foreach算子要求输入一个函数，这个函数的输入和数据相关（本次是String类型的变量）， ...

DataFrame注册成一张表格，如果通过CreateTempView这种方式来创建，那么该表格Session有效，如果通过CreateGlobalTempView来创建，那么该表格跨Session ...

1.在本地安装jdk环境和scala环境 2.读取本地文件： 3.词频topN计算 ...

官网介绍 http://spark.apache.org/docs/2.3.0/streaming-kafka-0-10-integration.html#creating-a-direct-str ...