• 從R原生data.frame和list創(chuàng)建
• 從SparkR RDD創(chuàng)建
• 從特定的數(shù)據(jù)源(JSON和Parquet格式的文件)創(chuàng)建
• 從通用的數(shù)據(jù)源創(chuàng)建
• 將指定位置的數(shù)據(jù)源保存為外部SQL表，并返回相應(yīng)的DataFrame
• 從Spark SQL表創(chuàng)建
• 從一個(gè)SQL查詢的結(jié)果創(chuàng)建

支持的主要的DataFrame操作有：

·數(shù)據(jù)緩存，持久化控制：cache(),persist(),unpersist()

• 數(shù)據(jù)保存：saveAsParquetFile(), saveDF() （將DataFrame的內(nèi)容保存到一個(gè)數(shù)據(jù)源），saveAsTable() （將DataFrame的內(nèi)容保存存為數(shù)據(jù)源的一張表）
• 集合運(yùn)算：unionAll()，intersect(), except()
• Join操作：join()，支持inner、full outer、left/right outer和semi join。

   6/11   首頁(yè) 上一頁(yè) 4 5 6 7 8 9 下一頁(yè) 尾頁(yè)