Introducing-Scylla-Open-Source-4.0

01-create-table.cql

> CREATE TABLE base_table (
	pk text,
	ck text,
	val1 text,
	val2 text,
	PRIMARY KEY (pk, ck)
) WITH cdc = { ‘enabled’ = ‘true’, preimage = ‘true’ };

02-insert-into-base_table.cql

> insert into base_table(pk, ck, val1, val2) values(“foo”, “bar”, “val1”, “val2”);
> insert into base_table(pk, ck, val1, val2) values(“foo”, “baz”, “vaz1”, “vaz2”);

03-insert-stream.cql

Stream_id |   time | batch_seq |  operation | ttl |   _pk |    _ck | _val1(op, value, ttl)|           _val2(...)
----------+--------+-----------+------------+-----+-------+--------+----------------------+---------------------
    UUID1 | <time1>|         0 |     UPDATE |     | “foo” |  “bar” |  (ADD, “val1”, null) |  (ADD, “val2”, null)
    UUID1 | <time2>|         0 |     UPDATE |     | “foo” |  “baz” |  (ADD, “vaz1”, null) |  (ADD, “vaz2”, null)

04-update-base_table.cql

> update base_table set val1 = “val3” where pk = “foo” and ck = “bar”;

05-update-stream.cql

Stream_id |   time  | batch_seq |  operation | ttl |   _pk |    _ck |                _val1 |               _val2
----------+---------+-----------+------------+-----+-------+--------+----------------------+---------------------
    UUID1 | <time3> |         0 |   PREIMAGE |     | “foo” |  “bar” |  (ADD, “val1”, null) |  
    UUID1 | <time3> |         1 |     UPDATE |     | “foo” |  “bar” |  (ADD, “val3”, null) |

06-delete.cql

> delete val2 from base_table where pk = “foo” and ck = “bar”;

07-delete-stream.cql

Stream_id |   time  | batch_seq |  operation | ttl |   _pk |    _ck |                _val1 |               _val2
----------+---------+-----------+------------+-----+-------+--------+----------------------+---------------------
    UUID1 | <time4> |         0 |   PREIMAGE |     | “foo” |  “bar” |                      | (ADD, “val2”, null)
    UUID1 | <time4> |         1 |     UPDATE |     | “foo” |  “bar” |                      | (DEL, null, null)