مشاركة عبر

read_statestore دالة ذات قيمة جدولية

ينطبق على: وضع علامة Databricks SQL وضع علامة Databricks Runtime 14.3 وما فوق

هام

هذه الميزة في المعاينة العامة.

دالة قيم الجدول لقراءة السجلات من مخزن الحالة للاستعلامات المتدفقة. تدعم العلاقة التي تم إرجاعها فقط التشغيل كتعلام دفعي.

بناء الجملة

read_statestore ( path [, option_key => option_value ] [ ... ] )

الوسيطات

read_statestoreيتطلب استدعاء المعلمة المسماة للمعلمات الاختيارية الخاصة بها.

  • path: A STRING literal. مسار موقع نقطة فحص استعلام البث.
  • option_key: اسم خيار التكوين. تحتاج إلى استخدام backticks (') للخيارات التي تحتوي على نقاط (.).
  • option_value: تعبير ثابت لتعيين الخيار إليه. يقبل القيم الحرفية والدالات العددية.

جميعها option_valueغير حساسة لحالة الأحرف.

option_key نوع Default ‏‏الوصف
batchId BIGINT أحدث معرف دفعة يمثل الدفعة المستهدفة للقراءة منها. يتم استخدام هذا الخيار عندما يرغب المستخدمون في إجراء السفر عبر الوقت. يجب الالتزام بالدفعة ولكن لم يتم تنظيفها بعد.
OperatorId BIGINT 0 يمثل عامل التشغيل الهدف للقراءة منه. يستخدم هذا الخيار عندما يستخدم الاستعلام عوامل تشغيل متعددة ذات حالة.
storeName STRING 'DEFAULT' يمثل الجانب الهدف للقراءة منه. يتم استخدام هذا الخيار عندما يرغب المستخدمون في قراءة الحالة من ربط دفق البث.
joinSide STRING 'None' يمثل الجانب الهدف للقراءة منه. يتم استخدام هذا الخيار عندما يرغب المستخدمون في قراءة الحالة من ربط دفق البث. واحد من: 'Left'، ، 'Right'. 'None'

المرتجعات

ترجع الدالة مجموعة نتائج بالأعمدة التالية.

إشعار

تعتمد الأعمدة المتداخلة للمفتاح والقيمة بشكل كبير على مخطط الإدخال للمشغل ذي الحالة ونوع عامل التشغيل.

الاسم نوع البيانات بدون قيمة قياسي ‏‏الوصف
id STRUCT لا صف المفتاح لعامل التشغيل ذي الحالة المخزنة في نقطة التحقق الخاصة بالحالة.
value STRUCT ‏‏نعم‬ صف القيمة لعامل التشغيل ذي الحالة المخزن في نقطة التحقق الخاصة بالحالة.
partition_id INTEGER لا القسم الذي يحتوي على السجل.
shardId STRING لا معرف فريد للجزء الذي تمت قراءة البيانات منه.
sequenceNumber BIGINT لا المعرف الفريد للسجل داخل الجزء الخاص به.
approximateArrivalTimestamp TIMESTAMP لا الوقت التقريبي الذي تم فيه إدراج السجل في الدفق.

الأمثلة

- Read from state
> SELECT * FROM read_statestore('/checkpoint/path');

– Read from state with storeName option
> SELECT * FROM read_statestore(
      '/checkpoint/path',
      operatorId => 0,
      batchId => 2,
      storeName => 'default'
  );

– Read from state with joinSide option

> SELECT * FROM read_statestore(
      '/checkpoint/path',
      joinSide => 'left'
  );
  • Last updated on