Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Veri kaynağındaki veri kümesini temel alan bir tablo oluşturur.
Sözdizimi
createTable(tableName: str, path: str = None, source: str = None, schema: StructType = None, description: str = None, **options: str)
Parametreler
| Parametre | Türü | Açıklama |
|---|---|---|
tableName |
str | Oluşturulacak tablonun adı. Katalog adıyla nitelenebilir. |
path |
str, isteğe bağlı | Bu tablonun verilerinin bulunduğu yol. Belirtildiğinde path , verilen yoldaki verilerden bir dış tablo oluşturulur. Aksi takdirde yönetilen bir tablo oluşturulur. |
source |
str, isteğe bağlı | Bu tablonun kaynağı , 'parquet''orc'vb. Belirtilmezsesource, tarafından spark.sql.sources.default yapılandırılan varsayılan veri kaynağı kullanılır. |
schema |
StructTypeopsiyonel |
Bu tablonun şeması. |
description |
str, isteğe bağlı | Bu tablonun açıklaması. |
**options |
dict, isteğe bağlı | Tabloda belirtilmesi gereken ek seçenekler. |
İadeler
DataFrame
Tabloyla ilişkilendirilmiş DataFrame.
Örnekler
# 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")