函數重載 第一個參數：返回的行數 第二個參數：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 ...