SparkSQL2.0扩展外部数据源原理(读取外部系统)

比较灵活,能够链接外部任何系统,spark-jdbc、Cassandra的实现方式都是这种。须要实现下面几个类java DefaultSource 入口类,用来创建外部数据源链接,SparkSQL默认会找这个名字,不要改类名。node import org.apache.spark.sql.SQLContext import org.apache.spark.sql.sources.{BaseRe
相关文章
相关标签/搜索