spark.table(“表a”)和spark.read.(“表a”)有什么区别

rm5edbpk  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(361)

作为题目,我正在学习sparksql,但是我不能很好地理解它们之间的区别。谢谢。

ct3nt3jp

ct3nt3jp1#

两者之间没有区别 spark.table & spark.read.table 功能。
内部 spark.read.table 又来电话了 spark.table 功能。
检查以下代码。 spark.table 里面有 package org.apache.spark.sql.SparkSession Spark放电

package org.apache.spark.sql.SparkSession

def table(tableName: String): DataFrame = {
  table(sessionState.sqlParser.parseTableIdentifier(tableName))
}
``` `spark.read.table` 功能在中可用 `package org.apache.spark.sql.DataFrameReader` &又来了 `spark.table` 功能。
Dataframe读取器

package org.apache.spark.sql.DataFrameReader

def table(tableName: String): DataFrame = {
assertNoSpecifiedSchema("table")
sparkSession.table(tableName)
}

相关问题