محرك جدول ArrowFlight

​

إنشاء جدول

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

• host:port — عنوان خادم Arrow Flight البعيد. إذا لم يُحدَّد المنفذ، فسيُستخدم المنفذ الافتراضي 8815. String.
• dataset_name — معرّف مجموعة البيانات على خادم Flight (يُستخدم كواصف PATH أو في استعلام SELECT *، بحسب الإعداد arrow_flight_request_descriptor_type). String.
• username — اسم المستخدم لمصادقة HTTP الأساسية. String.
• password — كلمة المرور لمصادقة HTTP الأساسية. String.

​

المجموعات المُسمّاة

CREATE TABLE remote_flight_data
    ENGINE = ArrowFlight(named_collection_name);

​

الإعدادات

• arrow_flight_request_descriptor_type — يتحكّم في كيفية إرسال اسم مجموعة البيانات إلى خادم Flight. القيم المحتملة: path (الافتراضي، ويُرسَل على هيئة واصف PATH) أو command (ويُرسَل على هيئة واصف CMD مع SELECT * FROM <dataset>). استخدم command مع خوادم Flight التي تتوقع أوامر SQL (مثل Dremio).
• arrow_flight_request_timeout_sec — مهلة الانتظار بالثواني لطلب Arrow Flight واحد، والقيمة الافتراضية 300. تسري هذه المهلة على الطلب بأكمله: ففي حالة SELECT تشمل دفق النتائج كاملًا، لا مجرد انتظار أول دفعة من السجلات. تعني القيمة 0 عدم وجود مهلة، وفي هذه الحالة إذا قَبِل خادم Flight الطلب ثم لم يستجب أبدًا، يظل الاستعلام معلّقًا إلى أن يُغلَق الاتصال.

​

مثال على الاستخدام

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);

​

ملاحظات

• إذا جرى تحديد الأعمدة في عبارة CREATE TABLE، فيجب أن تتطابق مع المخطط الذي يعيده خادم Flight.
• إذا لم تُحدَّد الأعمدة، فسيُستنتَج المخطط تلقائيًا من الخادم البعيد.
• كلٌّ من القراءة (SELECT) والكتابة (INSERT) مدعومان.
• يتحكم الإعداد arrow_flight_request_descriptor_type في ما إذا كان اسم مجموعة البيانات يُرسَل كواصف PATH أو كواصف CMD يتضمّن استعلام SELECT *.

​

انظر أيضًا

• الدالة الجدولية arrowFlight
• واجهة Arrow Flight
• Apache Arrow Flight SQL
• تكامل تنسيق Arrow في ClickHouse