メインコンテンツまでスキップ

テーブル(SparkSession)

指定されたテーブルをDataFrameとして返します。

構文

table(tableName)

パラメーター

パラメーター

Type

説明

tableName

str

取得するテーブル名。

戻り値

DataFrame

注意

Spark Classicでは、 spark.tableで参照される一時ビューは即座に解決されます。Spark Connect では、遅延分析が行われるため、 spark.tableの後にビューが削除、変更、または置き換えられた場合、実行が失敗したり、異なる結果が生成されたりする可能性があります。

Python
spark.range(5).createOrReplaceTempView("table1")
spark.table("table1").sort("id").show()
# +---+
# | id|
# +---+
# | 0|
# | 1|
# | 2|
# | 3|
# | 4|
# +---+