SparkSQL2.0擴展外部數據源原理（讀取外部系統）

比較靈活，能夠鏈接外部任何系統，spark-jdbc、Cassandra的實現方式都是這種。須要實現下面幾個類java DefaultSource 入口類，用來創建外部數據源鏈接，SparkSQL默認會找這個名字，不要改類名。node import org.apache.spark.sql.SQLContext import org.apache.spark.sql.sources.{BaseRe

>>阅读原文<<