增量流计算功能

曲昭曲昭
1 min read

RisingWave

支持incremental material view

CREATE MATERIALIZED VIEW average_exam_scores AS
SELECT
    exam_id,
    AVG(score) AS average_score,
    COUNT(score) AS total_scores
FROM
    exam_scores
GROUP BY
    exam_id;

支持 IMV

  1. FLINK CDC Source

  2. FLINK SQL Sink

0
Subscribe to my newsletter

Read articles from 曲昭 directly inside your inbox. Subscribe to the newsletter, and don't miss out.

Written by

曲昭
曲昭