SISIPKAN DIREKTORI TIMPA

  • Artikel

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

Menimpa data yang ada di direktori dengan nilai baru menggunakan format file Spark tertentu. Anda menentukan ekspresi baris menurut nilai yang disisipkan 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. Ini juga dapat ditentukan dalam OPTIONS menggunakan path. Kata LOCAL kunci digunakan untuk menentukan bahwa direktori ada di sistem file lokal.

  • file_format

    Format file yang digunakan untuk penyisipan. Opsi yang valid adalah TEXT, , JSONCSV, JDBC, ORCPARQUET, , HIVE, LIBSVM, atau nama kelas yang sepenuhnya memenuhi syarat dari implementasi org.apache.spark.sql.execution.datasources.FileFormatkustom .

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

    Menentukan satu atau beberapa opsi untuk penulisan format file.

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

    Nilai yang akan disisipkan. Nilai yang ditentukan secara eksplisit atau NULL dapat disisipkan. Koma harus digunakan untuk memisahkan setiap nilai dalam klausa. Lebih dari satu set nilai dapat ditentukan untuk menyisipkan beberapa baris.

  • Query

    Kueri yang menghasilkan baris yang akan disisipkan. Salah satu 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;