Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Создает таблицу на основе набора данных в источнике данных.
Синтаксис
createTable(tableName: str, path: str = None, source: str = None, schema: StructType = None, description: str = None, **options: str)
Параметры
| Параметр | Тип | Описание |
|---|---|---|
tableName |
str | Имя создаваемой таблицы. Может быть квалифицировано с именем каталога. |
path |
str, необязательный | Путь, в котором существуют данные для этой таблицы. При path указании внешняя таблица создается из данных по указанному пути. В противном случае создается управляемая таблица. |
source |
str, необязательный | Источник этой таблицы, например 'parquet', 'orc'и т. д. Если source не указано, будет использоваться источник данных по умолчанию, настроенный spark.sql.sources.default по умолчанию. |
schema |
StructTypeнеобязательный |
Схема для этой таблицы. |
description |
str, необязательный | Описание этой таблицы. |
**options |
дикт, необязательный | Дополнительные параметры для указания в таблице. |
Возвраты
DataFrame
Кадр данных, связанный с таблицей.
Примеры
# 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")