Bagikan melalui

DIREKTORI INSERT OVERWRITE

  • Artikel

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 yang diberikan. 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 akan digunakan untuk menyisipkan. 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 ( { value | NULL } [ , … ] ) [ , ( … ) ]

    Nilai yang akan disisipkan. Baik nilai yang ditentukan secara eksplisit maupun NULL dapat disisipkan. Koma harus digunakan untuk memisahkan setiap nilai dalam klausul. Dapat menentukan lebih dari satu set nilai untuk menyisipkan banyak baris.

  • query

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

    • Pernyataan SELECT
    • Pernyataan TABLE
    • Pernyataan FROM

Contoh

INSERT OVERWRITE DIRECTORY '/tmp/destination'
    USING parquet
    OPTIONS (col1 1, col2 2, col3 'test')
    SELECT * FROM test_table;

INSERT OVERWRITE DIRECTORY
    USING parquet
    OPTIONS ('path' '/tmp/destination', col1 1, col2 2, col3 'test')
    SELECT * FROM test_table;