INSERT OVERWRITE DIRECTORY With Hive format

  • Cikk

A következőre vonatkozik: yes Databricks Runtime jelölésű ellenőrzés

Felülírja a könyvtárban meglévő adatokat az új értékekkel a Hive SerDehasználatával. A parancs használatához engedélyezni kell a Hive-támogatást. A beszúrt sorokat értékkifejezések vagy lekérdezés eredménye alapján adhatja meg.

Szintaxis

INSERT OVERWRITE [ LOCAL ] DIRECTORY directory_path
    [ ROW FORMAT row_format ] [ STORED AS file_format ]
    { VALUES ( { value | NULL } [ , ... ] ) [ , ( ... ) ] | query }

Paraméterek

  • directory_path

    A célkönyvtár. A LOCAL kulcsszó azt adja meg, hogy a könyvtár a helyi fájlrendszerben található.

  • row_format

    A beszúrás sorformátuma. Az érvényes lehetőségek a záradék és a SERDEDELIMITED záradék. SERDE záradék használatával egyéni értéket adhat meg SerDe ehhez a beszúráshoz. Alternatív megoldásként a záradékkal megadhatja a natív SerDe értéket, DELIMITED és megadhatja az elválasztó karaktert, a feloldókaraktert, a null karaktert stb.

  • file_format

    A beszúrás fájlformátuma. Az érvényes lehetőségek a következők: TEXTFILE, SEQUENCEFILE, RCFILE, ORC, PARQUETés AVRO. A és OUTPUTFORMATa használatával saját bemeneti és kimeneti formátumot INPUTFORMAT is megadhat. ROW FORMAT SERDEcsak a , SEQUENCEFILEa vagy RCFILEa TEXTFILE, míg ROW FORMAT DELIMITED a csak a -nal TEXTFILEhasználható.

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

    A beszúrandó értékek. Beszúrhat explicit módon megadott értéket vagy NULL értéket. A záradék minden egyes értékének elválasztásához vesszőt kell használni. Több sor beszúrásához több érték is megadható.

  • query

    Egy lekérdezés, amely létrehozza a beszúrni kívánt sorokat. Az alábbi formátumok egyike:

    • Egy SELECT utasítás
    • Egy TABLE utasítás
    • Egy FROM utasítás

Példák

INSERT OVERWRITE LOCAL DIRECTORY '/tmp/destination'
    STORED AS orc
    SELECT * FROM test_table;

INSERT OVERWRITE LOCAL DIRECTORY '/tmp/destination'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
    SELECT * FROM test_table;