arrowFlight - ClickHouse Documentation

Permet de lire et d’écrire des données exposées via un serveur Apache Arrow Flight. Syntaxe

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

Arguments

host:port — Adresse du serveur Arrow Flight. Si le port est omis, le port par défaut 8815 est utilisé. String.
dataset_name — Nom du jeu de données ou du descripteur disponible sur le serveur Arrow Flight. String.
username — Nom d’utilisateur pour l’authentification HTTP de base. String.
password — Mot de passe pour l’authentification HTTP de base. String.

Si username et password ne sont pas spécifiés, l’authentification n’est pas utilisée (cela fonctionne uniquement si le serveur Arrow Flight autorise l’accès sans authentification). La fonction prend également en charge les named collections — voir le moteur de table ArrowFlight pour la liste des paramètres pris en charge. Valeur retournée Un objet table représentant le jeu de données distant. Le schéma est inféré à partir du serveur Arrow Flight. 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 : path (par défaut) ou command. Voir le moteur de table ArrowFlight pour plus de détails.

Exemples Lecture depuis un serveur Arrow Flight distant :

Query

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

Response

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

Insertion de données sur un serveur Arrow Flight distant :

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

Utiliser une named collection :

SELECT * FROM arrowFlight(named_collection_name);

Voir aussi