📄️ 数据导入
在数据库中,用户经常使用 insert 语句插入数据。但在流处理中,数据连续不断地从上有系统导入,显然 insert 语句无法满足需求。RisingWave 允许用户直接创建 table 与 source 来导入上游数据。当上游系统有新的数据进入时,RisingWave 便会直接消费数据并进行增量计算。
📄️ 物化视图与流计算
RisingWave 的核心功能是流计算,而流计算在流数据库中的呈现方式就是物化视图。
📄️ 数据查询与可视化
RisingWave 与传统数据库一样,可以存储数据,并允许用户对数据进行随机查询。 不过需要特别注意的是,RisingWave 的 source 不会持久化数据,也不能被用户直接进行随机查询(基于 Kafka 的 source 除外)。主要原因还是数据所有权相关的数据一致性与性能问题。
📄️ 数据更新与删除
与传统数据库一样,RisingWave 支持表内数据更新与删除。同时,当表内数据更改或删除时,建立在该表上的
📄️ 数据导出
一些用户希望使用 RisingWave 做流计算,然后将计算后的结果导出到下游系统中去。这是常见的流式 ETL 场景。
📄️ 连接器(connector)
在将数据导入或者导出RisingWave时,我们需要使用连接器。数据导入和导出的概览可参考数据导入以及数据导出。