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

createTable

データソース内のデータセットに基づいてテーブルを作成します。

構文

createTable(tableName: str, path: str = None, source: str = None, schema: StructType = None, description: str = None, **options: str)

パラメーター

パラメーター

Type

説明

tableName

str

作成するテーブルの名前。カタログ名で修飾できます。

path

文字列、オプション

このテーブルのデータが存在するパス。pathを指定すると、指定されたパスのデータから外部テーブルが作成されます。それ以外の場合は、マネージドテーブルが作成されます。

source

文字列、オプション

このテーブルのソースは'parquet''orc'などです。sourceが指定されていない場合、 spark.sql.sources.defaultで設定されたデフォルトのデータソースが使用されます。

schema

StructTypeオプション

このテーブルのスキーマ。

description

文字列、オプション

この表の説明。

**options

辞書、オプション

表に指定できる追加オプション。

戻り値

DataFrame

テーブルに関連付けられたDataFrame 。

Python
# Creating a managed table.
_ = spark.catalog.createTable("tbl1", schema=spark.range(1).schema, source='parquet')
_ = spark.sql("DROP TABLE tbl1")

# Creating an external table.
import tempfile
with tempfile.TemporaryDirectory(prefix="createTable") as d:
_ = spark.catalog.createTable(
"tbl2", schema=spark.range(1).schema, path=d, source='parquet')
_ = spark.sql("DROP TABLE tbl2")
このページの見出し