INSERT OVERWRITE DIRECTORY

  • 2 minuter för att läsa

Skriver över befintliga data i katalogen med de nya värdena med ett angivet Spark-filformat. Du anger den infogade raden efter värde uttryck eller resultatet av en fråga.

Syntax

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

Parametrar

  • directory_path

    Mål katalogen. Det kan också anges i OPTIONS med path . LOCALNyckelordet används för att ange att katalogen finns i det lokala fil systemet.

  • file_format

    Fil formatet som ska användas för INSERT. Giltiga alternativ är,,,,,, TEXT CSV JSON JDBC PARQUET ORC HIVE LIBSVM eller ett fullständigt kvalificerat klass namn för en anpassad implementering av org.apache.spark.sql.execution.datasources.FileFormat .

  • ALTERNATIV (nyckel = val [,...])

    Anger ett eller flera alternativ för skrivning av fil formatet.

  • VÄRDEN ({Value | NULL} [,...]) [ , ( ... ) ]

    Värdena som ska infogas. Antingen ett explicit angivet värde eller ett NULL-värde kan infogas. Ett kommatecken måste användas för att avgränsa varje värde i-satsen. Fler än en uppsättning värden kan anges för att infoga flera rader.

  • frågeterm

    En fråga som producerar de rader som ska infogas. Ett av följande format:

    • En SELECT instruktion
    • En TABLE instruktion
    • En FROM instruktion

Exempel

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;