Snowflake Create Stream

create stream

create stream mystream on table mytable;

data lineage

mytable -> fdd -> mysteam

column level lineage

mytable.PseudoRows -> fdd -> mysteam.PseudoRows

table level lineage

mytable -> create stream process -> mystream

sample SQLs

create stream mystream on table mytable before (timestamp => to_timestamp(40*365*86400));
create stream mystream on table mytable at (timestamp => to_timestamp_tz('02/02/2019 01:02:03', 'mm/dd/yyyy hh24:mi:ss'));
create stream mystream on table mytable at(offset => -60*5);
create stream mystream on table mytable before(statement => '8e5d0ca9-005e-44e6-b858-a8f5b37c5726');

-- external table
-- Create an external table that points to the MY_EXT_STAGE stage.
-- The external table is partitioned by the date (in YYYY/MM/DD format) in the file path.
create external table my_ext_table (
  date_part date as to_date(substr(metadata$filename, 1, 10), 'YYYY/MM/DD'),
  ts timestamp as (value:time::timestamp),
  user_id varchar as (value:userId::varchar),
  color varchar as (value:color::varchar)
) partition by (date_part)
  location=@my_ext_stage
  auto_refresh = false
  file_format=(type=json);

-- Create a stream on the external table
create stream my_ext_table_stream on external table my_ext_table insert_only = true;

reference

https://docs.snowflake.com/en/sql-reference/sql/create-stream.html