spark.table("TABLE A")和spark.read有什么区别。( "TABLE A" )

Question

问题的标题是，我正在学习sparkSQL，但我无法很好地理解它们之间的区别。谢谢

Answer 1

spark.table&CCD_ 2函数。

spark.read.table内部再次调用spark.table函数。

检查以下代码。

spark.table在package org.apache.spark.sql.SparkSession内可用

SparkSession

package org.apache.spark.sql.SparkSession
def table(tableName: String): DataFrame = {
table(sessionState.sqlParser.parseTableIdentifier(tableName))
}

CCD_ 7功能在CCD_；它再次调用spark.table函数。

DataFrameReader

package org.apache.spark.sql.DataFrameReader
def table(tableName: String): DataFrame = {
assertNoSpecifiedSchema("table")
sparkSession.table(tableName)
}