spark SQL編程動手實戰-01

首先創建SparkContext上下文: 接着引入隱身轉換,用於把RDD轉成SchemaRDD: 接下來定義一個case class 來用於描述和存儲SQL表中的每一行數據: 接下來要加載數據,這裏的測試數據是user.txt文件: 我們創建好use.txt增加內容並上傳到hdfs中: web控制檯查詢: hdfs命令查詢:   加載數據: 驗證數據是否加載成功:   註冊成爲user的table
相關文章
相關標籤/搜索