Bagikan melalui

INSERT OVERWRITE DIRECTORY

Berlaku untuk:centang ditandai ya Databricks SQL centang ditandai ya Databricks Runtime

Menimpa data yang ada di direktori dengan nilai baru menggunakan format file Spark tertentu. Anda menentukan baris yang disisipkan menurut ekspresi nilai atau hasil kueri.

Sintaks

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

Parameter

  • directory_path

    Direktori tujuan. Dapat juga ditentukan pada OPTIONS menggunakan path. Kata kunci LOCAL digunakan untuk menentukan bahwa direktori ada di sistem file lokal.

  • file_format

    Format file yang digunakan untuk penyisipan. Opsi yang valid adalah TEXT, CSV, JSON, JDBC, PARQUET, ORC, HIVE, LIBSVMatau nama kelas yang sepenuhnya memenuhi syarat penerapan kustom dari org.apache.spark.sql.execution.datasources.FileFormat.

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

    Menentukan satu atau opsi lebih untuk penulisan format file.

  • VALUES ( { nilai | NULL } [ , ... ] ) [ , ( … ) ]

    Nilai yang akan disisipkan. Baik nilai yang ditentukan secara eksplisit maupun NULL dapat disisipkan. Koma harus digunakan untuk memisahkan setiap nilai dalam klausul. Lebih dari satu set nilai dapat ditentukan untuk memasukkan beberapa baris.

  • query

    Kueri yang menghasilkan baris yang akan disisipkan. Salah satu dari format berikut:

    • Pernyataan SELECT
    • Pernyataan TABLE
    • Pernyataan FROM

Contoh

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;
  • Last updated on