Aracılığıyla paylaş

INSERT OVERWRITE DIRECTORY

Şunlar için geçerlidir:onay işareti evet olarak işaretlenmiş Databricks SQL onay işareti evet olarak işaretlenmiş Databricks Runtime

Belirli bir Spark dosya biçimini kullanarak dizindeki mevcut verilerin üzerine yeni değerleri yazar. Eklenen satırı değer ifadelerine göre veya sorgunun sonucunu belirtirsiniz.

Sözdizimi

INSERT OVERWRITE [ LOCAL ] DIRECTORY [ directory_path ]
    USING file_format [ OPTIONS ( { key [ = ] val } [ , ... ] ) ]
    { VALUES ( { value | NULL } [ , ... ] ) [ , ( ... ) ] | query }

Parametreler

  • directory_path

    Hedef dizin. OPTIONS içinde path kullanılarak da belirtilebilir. LOCAL anahtar sözcüğü, dizinin yerel dosya sisteminde olduğunu belirtmek için kullanılır.

  • dosya formatı

    Ekleme için kullanılacak dosya biçimi. Geçerli seçenekler TEXT, CSV, JSON, JDBC, PARQUET, ORC, HIVE, LIBSVM veya org.apache.spark.sql.execution.datasources.FileFormat özel uygulamasının tam nitelikli sınıf adıdır.

  • OPTIONS ( { key [ = ] val } [ , ... ] )

    Dosya biçimini yazmak için bir veya daha fazla seçenek belirtir.

  • VALUES ( { değer | NULL } [ , ... ] ) [ , ( … ) ]

    Eklenecek değerler. Açıkça belirtilen bir değer veya NULL eklenebilir. Yan tümcesindeki her değeri ayırmak için virgül kullanılmalıdır. Birden çok satır eklemek için birden fazla değer kümesi belirtilebilir.

  • query

    Eklenecek satırları üreten sorgu. Aşağıdaki biçimlerden biri:

    • Bir SELECT ifade
    • Bir TABLE ifade
    • Bir FROM ifade

Örnekler

INSERT OVERWRITE DIRECTORY '/Volumes/my_catalog/my_schema/my_volume/'
    USING parquet
    OPTIONS (col1 1, col2 2, col3 'test')
    SELECT * FROM test_table;

INSERT OVERWRITE DIRECTORY
    USING parquet
    OPTIONS ('path' '/Volumes/my_catalog/my_schema/my_volume/', col1 1, col2 2, col3 'test')
    SELECT * FROM test_table;