INSERT OVERWRITE DIRECTORY

Platí pro:zaškrtnutí označeného ano Databricks SQL zaškrtnutí označeného ano Databricks Runtime

Přepíše existující data v adresáři novými hodnotami pomocí zadaného formátu souboru Spark. Vložený řádek zadáte podle výrazů hodnot nebo výsledku dotazu.

Syntaxe

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

Parametry

  • directory_path

    Cílový adresář. Můžete ho také zadat pomocí OPTIONSpath. Klíčové LOCAL slovo určuje, že adresář je v místním systému souborů.

  • file_format

    Formát souboru, který se má použít pro vložení. Platné možnosti jsou TEXT, , CSV, JSONJDBC, PARQUETORCHIVE, LIBSVM, nebo plně kvalifikovaný název třídy vlastní implementace .org.apache.spark.sql.execution.datasources.FileFormat

  • OPTIONS ( { klíč [ = ] val } [ , ... ] )

    Určuje jednu nebo více možností zápisu formátu souboru. Platné klíče a hodnoty závisí na vybraném klíči file_format . Možnosti podporované v jednotlivých formátech najdete v tématu Možnosti formátu dat. Můžete také nastavit path klíč pro zadání cílového adresáře.

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

    Hodnoty, které chcete vložit. Můžete vložit explicitně zadanou hodnotu nebo hodnotu NULL. Jednotlivé hodnoty v klauzuli oddělte čárkou. Pokud chcete vložit více řádků, zadejte více než jednu sadu hodnot.

  • query

    Dotaz, který vytvoří řádky, které se mají vložit. Použijte jeden z následujících formátů:

    • Příkaz A SELECT
    • Příkaz A TABLE
    • Příkaz A FROM

Příklady

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