proto.lib

Streaming SQL: khai báo transform thay vì code — materialized view tự cập nhật

Một câu SQL trên stream (ví dụ Flink SQL, ksqlDB) được compile thành một job chạy liên tục, duy trì kết quả dưới dạng materialized view (aggregate theo key, join giữa stream/table); các query phía sau chỉ đọc view đó, engine tự lo state và phát cập nhật khi input thay đổi.

MessagingNâng cao2026-08-24
Streaming SQL: khai báo transform thay vì code — materialized view tự cập nhật

Tags

#streaming-sql#materialized-view#ksqldb#flink#stream-table-join#windowing#state

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingTrung bình

Session Window theo khoảng ngừng hoạt động (Session Window Gaps)

Session window không cắt theo mốc thời gian cố định mà gom các sự kiện của một khoá khi chúng còn liên tiếp đến, và đóng lại sau một khoảng ngừng (gap) không có sự kiện mới; một sự kiện trễ có thể buộc engine gộp lại hai session tưởng đã tách rời.

#session-window#stream-processing#windowing#gap-timeout
MessagingNâng cao

Allowed Lateness và Side Output cho sự kiện trễ

Sau khi watermark vượt qua biên window, kết quả on-time được phát ra nhưng state vẫn giữ lại trong một khoảng allowed lateness để một sự kiện trễ còn có thể tạo ra kết quả UPDATED; sự kiện đến sau cả khoảng đó bị định tuyến sang side output thay vì bị âm thầm bỏ.

#allowed-lateness#side-output#windowing#late-events
MessagingNâng cao

Retraction Stream và Upsert Stream cho Aggregate có thể giảm

Một aggregate streaming có thể giảm giá trị (ví dụ đếm bản ghi đang active) không thể publish như append-only; nó phải phát cặp RETRACT rồi INSERT (retraction stream) hoặc phát một bản ghi upsert theo khoá với ngữ nghĩa latest-wins.

#retraction-stream#upsert#changelog#stream-processing