shopId:int dt:string not null hr:int not null col0:int col1:row(f0:string f1:int f2:list(int)) col2:map(int, int)
partition key: dt hr
primary key: shopId dt hr
bucket key: shopId
bucket count: 2

Msgs:
INSERT: [1000, "2025-04-14, 10,  0, ["str-0",   0, [0, null, 1]], [[0, 0], [100, 100]]]
INSERT: [1001, "2025-04-14, 10, 10, ["str-1", 100, [1, null, 2]], [[1, 1], [101, 101]]]
INSERT: [1002, "2025-04-14, 10, 20, ["str-2", 200, [2, null, 3]], [[2, 2], [102, 102]]]
INSERT: [1003, "2025-04-14, 10, 30, ["str-3", 300, [3, null, 4]], [[3, 3], [103, 103]]]
INSERT: [1004, "2025-04-14, 10, 40, ["str-4", 400, [4, null, 5]], [[4, 4], [104, 104]]]
INSERT: [1005, "2025-04-14, 10, 50, ["str-5", 500, [4, null, 5]], [[4, 4], [104, 104]]]
INSERT: [1006, "2025-04-14, 10, 60, ["str-6", 600, [4, null, 5]], [[4, 4], [104, 104]]]
INSERT: [1007, "2025-04-14, 10, 70, ["str-7", 700, [4, null, 5]], [[4, 4], [104, 104]]]

Commit - snapshot 1

DELETE:        [1000, "2025-04-14, 10,  0, ["str-0",   0, [0, null, 1]], [[0, 0], [100, 100]]]
UPDATE_AFTER:  [1001, "2025-04-14, 10, 10, ["str-1", 100, [1, null, 2]], [[1, 1], [101, 101]]]
DELETE:        [1002, "2025-04-14, 10, 20, ["str-2", 200, [2, null, 3]], [[2, 2], [102, 102]]]
UPDATE_BEFORE: [1003, "2025-04-14, 10, 30, ["str-3", 300, [3, null, 4]], [[3, 3], [103, 103]]]

Commit - snapshot 2
