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.

See also:

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