作为题目,我正在学习sparksql,但是我不能很好地理解它们之间的区别。谢谢。
ct3nt3jp1#
两者之间没有区别 spark.table & spark.read.table 功能。内部 spark.read.table 又来电话了 spark.table 功能。检查以下代码。 spark.table 里面有 package org.apache.spark.sql.SparkSession Spark放电
spark.table
spark.read.table
package org.apache.spark.sql.SparkSession
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)}
1条答案
按热度按时间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.DataFrameReader
def table(tableName: String): DataFrame = {
assertNoSpecifiedSchema("table")
sparkSession.table(tableName)
}