ALTER STREAMING TABLE

  • [アーティクル]

適用対象: Databricks SQL

次のいずれかを実行できます:

  • 既存のストリーミング テーブルを更新するためのスケジュールを追加します。
  • ストリーミング テーブルの既存の更新スケジュールを変更します。
  • ストリーミング テーブルの更新スケジュールを削除します。 スケジュールが削除された場合、最新のデータを反映するには、オブジェクトを手動で更新する必要があります。

構文

ALTER STREAMING TABLE table_name
  {
    { ADD | ALTER } SCHEDULE [ REFRESH ] schedule_clause |
    DROP SCHEDULE
  }

  schedule_clause
  { EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS } |
    CRON cron_string [ AT TIME ZONE timezone_id ] }

パラメーター

  • table_name

    定義を変更するストリーミング テーブルの名前。 この名前には、テンポラル仕様を含めることはできません。

  • SCHEDULE [ REFRESH ] schedule_clause

    ストリーミング テーブルにスケジュールを追加したり、スケジュールを変更したりできます。

    • EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS }

      重要

      この機能はパブリック プレビュー段階にあります。

      定期的に更新をスケジュールするには、 EVERY 構文を使用します。 EVERY構文が指定されている場合、ストリーミング テーブルまたは具体化されたビューは、指定された値 (HOUR、HOURS、DAY、DAYS、WEEK、WEEKSなど) に基づいて、指定した間隔で定期的に更新されます。 次の表に、 numberに使用できる整数値を示します。

      Time unit 整数値
      HOUR or HOURS 1 <= H <= 72
      DAY or DAYS 1 <= D <= 31
      WEEK or WEEKS 1 <= W <= 8

      Note

      含まれる時間単位の単数形と複数形は、意味的に同等です。

    • CRON cron_string [ AT TIME ZONE timezone_id ]

      quartz cron 値を使用して更新をスケジュールします。 有効な time_zone_values が受け入れられます。 AT TIME ZONE LOCAL はサポートされません。

      AT TIME ZONE が存在しない場合は、セッション タイム ゾーンが使用されます。 AT TIME ZONE が存在せず、セッション タイム ゾーンも設定されていない場合は、エラーがスローされます。 SCHEDULE は意味的に SCHEDULE REFRESH と同等です。

例

-- Adds a schedule to refresh the streaming table once a day
-- at midnight in Los Angeles
> ALTER STREAMING TABLE my_st
  ADD SCHEDULE CRON '0 0 0 * * ? *' AT TIME ZONE 'America/Los_Angeles';

-- Alters the schedule to run every 15 minutes for a streaming table
> ALTER STREAMING TABLE my_st
  ALTER SCHEDULE CRON '0 0/15 * * * ? *';

-- Drops the schedule for a streaming table
> ALTER STREAMING TABLE my_st
  DROP SCHEDULE;