@@ -18,43 +18,43 @@ For more details on the motivation behind Mutable Streams, see [this blog post](
1818``` sql
1919CREATE MUTABLE STREAM [IF NOT EXISTS] < db .mutable - stream- name>
2020(
21- name1 [type1] [DEFAULT | ALIAS expr1] [COMMENT ' column-comment ' ],
22- name2 [type2] [DEFAULT | ALIAS expr1] [COMMENT ' column-comment ' ],
21+ name1 [type1] [DEFAULT | ALIAS expr1] [COMMENT ' column_comment ' ],
22+ name2 [type2] [DEFAULT | ALIAS expr1] [COMMENT ' column_comment ' ],
2323 ...
2424 < column definitions> ,
25- INDEX < secondary - index - name1 > (column, ...) [UNIQUE] STORING (column, ...),
26- INDEX < secondary - index - name2 > (column, ...) [UNIQUE] STORING (column, ...),
25+ INDEX < secondary_index_name1 > (column, ...) [UNIQUE] STORING (column, ...),
26+ INDEX < secondary_index_name2 > (column, ...) [UNIQUE] STORING (column, ...),
2727 ...
28- FAMILY < column - family - name1 > (column, ...),
29- FAMILY < column - family - name2 > (column, ...),
28+ FAMILY < column_family_name1 > (column, ...),
29+ FAMILY < column_family_name2 > (column, ...),
3030 ...
3131)
3232PRIMARY KEY (column, ...)
33- COMMENT ' <stream-comment >'
33+ COMMENT ' <stream_comment >'
3434SETTINGS
35- shards=< num - of - shards > ,
36- replication_factor=< replication - factor > ,
37- version_column=< version - column > ,
35+ shards=< num_of_shards > ,
36+ replication_factor=< replication_factor > ,
37+ version_column=< version_column > ,
3838 coalesced= [true|false],
3939 logstore_codec= [' lz4' |' zstd' |' none' ],
40- logstore_retention_bytes=< retention - bytes > ,
41- logstore_retention_ms=< retention - ms > ,
42- ttl_seconds=< ttl - seconds > ,
43- ttl_column=< ttl - column > ,
40+ logstore_retention_bytes=< retention_bytes > ,
41+ logstore_retention_ms=< retention_ms > ,
42+ ttl_seconds=< ttl_seconds > ,
43+ ttl_column=< ttl_column > ,
4444 auto_cf= [true|false],
45- placement_policies= ' <placement-policies >' ,
45+ placement_policies= ' <placement_policies >' ,
4646 late_insert_overrides= [true|false],
47- shared_disk= ' <shared-disk >' ,
47+ shared_disk= ' <shared_disk >' ,
4848 ingest_mode= [' async' |' sync' ],
4949 ack= [' quorum' |' local' |' none' ],
50- ingest_batch_max_bytes=< batch - bytes > ,
51- ingest_batch_timeout_ms=< batch - timeout > ,
52- fetch_threads=< remote - fetch - threads > ,
53- flush_rows=< batch - flush - rows > ,
54- flush_ms=< batch - flush - timeout > ,
50+ ingest_batch_max_bytes=< batch_bytes > ,
51+ ingest_batch_timeout_ms=< batch_timeout > ,
52+ fetch_threads=< remote_fetch_threads > ,
53+ flush_rows=< batch_flush_rows > ,
54+ flush_ms=< batch_flush_timeout > ,
5555 log_kvstore= [true|false],
5656 kvstore_codec= [' snappy' |' lz4' |' zstd' ],
57- kvstore_options= ' <kvstore-options >' ,
57+ kvstore_options= ' <kvstore_options >' ,
5858 enable_hash_index= [true|false],
5959 enable_statistics= [true|false];
6060```
@@ -348,7 +348,7 @@ Using column families can slow down ingestion speed, since each family is intern
348348You can delete rows from a Mutable Stream using the ` DELETE ` statement:
349349
350350``` sql
351- DELETE FROM < db .mutable - stream - name > WHERE < predicates> ;
351+ DELETE FROM < db .mutable_stream_name > WHERE < predicates> ;
352352```
353353
354354- If the ` WHERE ` predicates can leverage the primary index or a secondary index, the delete operation will be fast.
0 commit comments