ALTER STREAMING TABLE
S’applique à : Databricks SQL
Vous permet soit de :
- Ajoutez une planification pour actualiser une table de diffusion en continu existante.
- Modifiez une planification d’actualisation existante pour une table de diffusion en continu.
- Annulez la planification d’actualisation d’une table de diffusion en continu. Si la planification est supprimée, l'objet doit être actualisé manuellement pour refléter les dernières données.
Syntaxe
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 ] }
Paramètres
-
Le nom de la table de streaming dont vous souhaitez modifier la définition. Le nom ne doit pas inclure une spécification temporelle.
SCHEDULE [ REFRESH ] schedule_clause
Vous permet d’ajouter une planification ou de modifier la planification d’une table de diffusion en continu.
EVERY number { HOUR | HOURS | DAY | DAYS | WEEK | WEEKS }
Important
Cette fonctionnalité est disponible en préversion publique.
Pour planifier une actualisation qui se produit régulièrement, utilisez
EVERY
la syntaxe. SiEVERY
la syntaxe est spécifiée, la table de diffusion en continu ou la vue matérialisée est actualisée régulièrement à l’intervalle spécifié en fonction de la valeur fournie, telle queHOUR
, , ,HOURS
,WEEK
DAY
DAYS
ou .WEEKS
Le tableau suivant répertorie les valeurs entières acceptées pournumber
.Unité de temps Valeur entière HOUR or HOURS
1 <= H <= 72 DAY or DAYS
1 <= D <= 31 WEEK or WEEKS
1 <= W <= 8 Remarque
Les formes singulières et plurielles de l’unité de temps incluse sont sémantiquement équivalentes.
CRON cron_string [ AT TIME ZONE timezone_id ]
Pour planifier une actualisation à l’aide d’une valeur cron de quartz. Les time_zone_values valides sont acceptées. La fonction
AT TIME ZONE LOCAL
n'est pas prise en charge.Si
AT TIME ZONE
est absent, le fuseau horaire de session est utilisé. SiAT TIME ZONE
est absent et que le fuseau horaire de session n’est pas défini, une erreur est générée.SCHEDULE
est équivalent sémantiquement àSCHEDULE REFRESH
.
Exemples
-- 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;