指定的目录下,定义一个DefaultSource 类,在类里面实现自定义source,就可以实现我们的目标。 import org.apache.spark.sql.sources.v2.{ ...
確定! 回上一頁