INSERIR DIRETÓRIO DE SUBSTITUIÇÃO

  • Artigo

Aplica-se a:verificar a verificação sim Databricks SQL marcada como sim Databricks Runtime

Substitui os dados existentes no diretório pelos novos valores através de um determinado formato de ficheiro spark. Especifique a linha inserida por expressões de valor ou o resultado de uma consulta.

Sintaxe

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

Parâmetros

  • directory_path

    O diretório de destino. Também pode ser especificado na OPTIONS utilização de path. A LOCAL palavra-chave é utilizada para especificar que o diretório está no sistema de ficheiros local.

  • file_format

    O formato de ficheiro a utilizar para a inserção. As opções válidas são , , , , , , , ou LIBSVMum nome de classe completamente qualificado de uma implementação personalizada de org.apache.spark.sql.execution.datasources.FileFormat. HIVEORCPARQUETJDBCJSONCSVTEXT

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

    Especifica uma ou mais opções para a escrita do formato de ficheiro.

  • VALORES ( { valor | NULL } [ , ... ] ) [ , ( ... ) ]

    Os valores a inserir. Pode inserir um valor explicitamente especificado ou um NULL. Tem de ser utilizada uma vírgula para separar cada valor na cláusula. Pode especificar mais do que um conjunto de valores para inserir várias linhas.

  • consulta

    Uma consulta que produz as linhas a inserir. Um dos seguintes formatos:

    • Uma SELECT instrução
    • Uma TABLE instrução
    • Uma FROM instrução

Exemplos

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;