feat: create stream at navigation point

[zhyass]

I hereby agree to the terms of the CLA available at: https://docs.databend.com/dev/policies/cla/

Summary

CREATE [ OR REPLACE ] STREAM [IF NOT EXISTS]
  <name>
  ON TABLE <table_name>
  [ AT ( { TIMESTAMP => <timestamp> | SNAPSHOT => <sid> | STREAM => '<name>' } ) ]
  [ APPEND_ONLY = TRUE | FALSE ]
  [ COMMENT = '<string_literal>' ]

mysql> create or replace stream s on table t;
Query OK, 0 rows affected (0.10 sec)

mysql> select * from t;
+------+
| a    |
+------+
|    1 |
|    2 |
+------+
2 rows in set (0.13 sec)
Read 2 rows, 9.00 B in 0.021 sec., 96 rows/sec., 432.02 B/sec.

mysql> select * from s;
Empty set (0.16 sec)
Read 0 rows, 0.00 B in 0.006 sec., 0 rows/sec., 0.00 B/sec.

mysql> insert into t values(3);
Query OK, 1 row affected (0.18 sec)

mysql> select * from fuse_snapshot('default','t');
+----------------------------------+--------------------------------------------------+----------------+----------------------------------+---------------+-------------+-----------+--------------------+------------------+------------+----------------------------+
| snapshot_id                      | snapshot_location                                | format_version | previous_snapshot_id             | segment_count | block_count | row_count | bytes_uncompressed | bytes_compressed | index_size | timestamp                  |
+----------------------------------+--------------------------------------------------+----------------+----------------------------------+---------------+-------------+-----------+--------------------+------------------+------------+----------------------------+
| 1f7ec30caf514099823edf630afbe4fa | 1/13/_ss/1f7ec30caf514099823edf630afbe4fa_v4.mpk |              4 | 664b7580be9046f491d94c271d2164b5 |             2 |           2 |         3 |                 14 |              763 |        674 | 2024-03-21 17:38:54.418932 |
| 664b7580be9046f491d94c271d2164b5 | 1/13/_ss/664b7580be9046f491d94c271d2164b5_v4.mpk |              4 | NULL                             |             1 |           1 |         2 |                  9 |              384 |        337 | 2024-03-21 17:31:01.004308 |
+----------------------------------+--------------------------------------------------+----------------+----------------------------------+---------------+-------------+-----------+--------------------+------------------+------------+----------------------------+
2 rows in set (0.09 sec)
Read 2 rows, 394.00 B in 0.072 sec., 27.85 rows/sec., 5.36 KiB/sec.

mysql> insert into t values(4);
Query OK, 1 row affected (0.17 sec)

mysql> create or replace stream s1 on table t at(snapshot=>'1f7ec30caf514099823edf630afbe4fa');
Query OK, 0 rows affected (0.08 sec)

mysql> select * from s1;
+------+---------------+------------------+----------------------------------------+
| a    | change$action | change$is_update | change$row_id                          |
+------+---------------+------------------+----------------------------------------+
|    4 | INSERT        |                0 | a82642a8baf74318a7e6e7391cd0c691000000 |
+------+---------------+------------------+----------------------------------------+
1 row in set (0.18 sec)
Read 1 rows, 197.00 B in 0.013 sec., 75.86 rows/sec., 14.59 KiB/sec.

• Fixes feat: stream support specify offset #14145

Tests

• Unit Test
• Logic Test
• Benchmark Test
• No Test - Explain why

Type of change

• Bug Fix (non-breaking change which fixes an issue)
• New Feature (non-breaking change which adds functionality)
• Breaking Change (fix or feature that could cause existing functionality not to work as expected)
• Documentation Update
• Refactoring
• Performance Improvement
• Other (please describe):

[github-actions]

Docker Image for PR

• tag: pr-15062-3f18a21

note: this image tag is only available for internal use,
please check the internal doc for more details.

[dantengsky]

LGTM, except databend-common-ast::it parser::test_statement need adjustment

[dantengsky]

cc @zhyass

seems golden file of databend-common-ast::it parser::test_statement need some tweaks .

https://github.com/datafuselabs/databend/actions/runs/8430425986/job/23086265896?pr=15062#step:4:3301

[BohuTANG]

@PsiACE @soyeric128

This PR is a new feature of stream, we introduce a new syntax for stream:

 [ AT ( { TIMESTAMP => <timestamp> | SNAPSHOT => <sid> | STREAM => '<name>' } ) ]

Documentation update needed.