arrowFlight | ClickHouse Docs

Permite ler e gravar dados expostos por meio de um servidor Apache Arrow Flight.

Sintaxe

arrowFlight('host:port', 'dataset_name' [, 'username', 'password'])

Argumentos

host:port — Endereço do servidor Arrow Flight. Se a porta for omitida, será usada a porta padrão 8815. String.
dataset_name — Nome do conjunto de dados ou descritor disponível no servidor Arrow Flight. String.
username — Nome de usuário para autenticação HTTP básica. String.
password — Senha para autenticação HTTP básica. String.

Se username e password não forem especificados, a autenticação não será usada (isso funciona apenas se o servidor Arrow Flight permitir acesso sem autenticação).

A função também oferece suporte a coleções nomeadas — consulte o motor de tabela ArrowFlight para obter a lista de parâmetros compatíveis.

Valor retornado

Um objeto de tabela que representa o conjunto de dados remoto. O esquema é inferido do servidor Arrow Flight.

Configurações

arrow_flight_request_descriptor_type — Controla como o nome do conjunto de dados é enviado ao servidor Flight. Valores: path (padrão) ou command. Consulte o motor de tabela ArrowFlight para mais detalhes.

Exemplos

Leitura de um servidor Arrow Flight remoto:

Querysql

SELECT * FROM arrowFlight('127.0.0.1:9005', 'sample_dataset') ORDER BY id;

Responsetext

┌─id─┬─name────┬─value─┐
│  1 │ foo     │ 42.1  │
│  2 │ bar     │ 13.3  │
│  3 │ baz     │ 77.0  │
└────┴─────────┴───────┘

Inserindo dados em um servidor remoto do Arrow Flight:

INSERT INTO FUNCTION arrowFlight('127.0.0.1:9005', 'sample_dataset') VALUES (4, 'qux', 99.9);

Usando uma coleção nomeada:

SELECT * FROM arrowFlight(named_collection_name);

Veja também