Moteur de table ArrowFlight

​

Créer une table

CREATE TABLE [IF NOT EXISTS] [db.]table_name (name1 [type1], name2 [type2], ...)
    ENGINE = ArrowFlight('host:port', 'dataset_name' [, 'username', 'password']);

• host:port — Adresse du serveur Arrow Flight distant. Si le port n’est pas renseigné, le port par défaut 8815 est utilisé. String.
• dataset_name — Identifiant du jeu de données sur le serveur Flight (utilisé comme descripteur PATH ou dans une requête SELECT *, selon le paramètre arrow_flight_request_descriptor_type). String.
• username — Nom d’utilisateur pour l’authentification HTTP basique. String.
• password — Mot de passe pour l’authentification HTTP basique. String.

​

Collections nommées

CREATE TABLE remote_flight_data
    ENGINE = ArrowFlight(named_collection_name);

​

Paramètres

• arrow_flight_request_descriptor_type — Contrôle la façon dont le nom du jeu de données est envoyé au serveur Flight. Valeurs possibles : path (par défaut, l’envoie sous forme de descripteur PATH) ou command (l’envoie sous forme de descripteur CMD avec SELECT * FROM <dataset>). Utilisez command pour les serveurs Flight qui attendent des commandes SQL (par exemple, Dremio).
• arrow_flight_request_timeout_sec — Délai d’expiration, en secondes, d’une requête Arrow Flight individuelle, 300 par défaut. Il s’applique à l’ensemble de la requête : pour un SELECT, il couvre la totalité du flux de résultats, et pas seulement l’attente du premier lot d’enregistrements. 0 désactive le délai d’expiration ; dans ce cas, un serveur Flight qui accepte une requête sans jamais y répondre bloque la requête jusqu’à la fermeture de la connexion.

​

Exemple d’utilisation

CREATE TABLE remote_flight_data
(
    id UInt32,
    name String,
    value Float64
) ENGINE = ArrowFlight('127.0.0.1:9005', 'sample_dataset');

SELECT * FROM remote_flight_data ORDER BY id;

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

INSERT INTO remote_flight_data VALUES (4, 'qux', 99.9);

​

Remarques

• Si des colonnes sont spécifiées dans l’instruction CREATE TABLE, elles doivent correspondre au schéma renvoyé par le serveur Flight.
• Si les colonnes sont omises, le schéma est déduit automatiquement depuis le serveur distant.
• La lecture (SELECT) et l’écriture (INSERT) sont toutes deux prises en charge.
• Le paramètre arrow_flight_request_descriptor_type détermine si le nom du jeu de données est envoyé sous forme de descripteur PATH ou de descripteur CMD encapsulant une requête SELECT *.

​

Voir aussi

• table function arrowFlight
• Interface Arrow Flight
• Apache Arrow Flight SQL
• intégration du format Arrow dans ClickHouse