テーブル(SparkSession)
指定されたテーブルをDataFrameとして返します。
構文
table(tableName)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| 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|
# +---+