Categories:: System functions (System Control)

SYSTEM$SNOWPIPE_STREAMING_UPDATE_CHANNEL_OFFSET_TOKEN¶

Updates the offset token for a particular channel used by Snowpipe Streaming with a new offset token.

For more information about channels and offset tokens, see Snowpipe Streaming.

Syntax¶

SYSTEM$SNOWPIPE_STREAMING_UPDATE_CHANNEL_OFFSET_TOKEN('<dbName>.<schemaName>.<tableName>', '<channelName>', '<new_offset_token>')

Copy

Arguments¶

dbName: Name of the database in which the channel is stored.
schemaName: Name of the schema in which the channel is stored.
tableName: Name of the table where the channel is mapped to.
channelName: Name of the channel.
new_offset_token: The new offset token.

Usage notes¶

The role that executes this function must have at least the INSERT privilege on the table where the channel is mapped to.

Examples¶

Updates the offset token for mychannel in mydb.myschema.mytable with a <new_offset_token>:

show channels;
select SYSTEM$SNOWPIPE_STREAMING_UPDATE_CHANNEL_OFFSET_TOKEN('mydb.myschema.mytable', 'mychannel', '<new_offset_token>');
show channels;

Copy