结构与特点
在Vastbase G100中，流（Stream）是以FDW（Foreign Data Wrapper）的形式存在的，开启流支持后，将创建对应的foreign server。时序数据通过ZeroMQ写入流视图（Continuous view）或者经过流转换（TransForm）被提取。在此过程中可过滤流中数据，剔除不需要的内容，使符合规则的数据进入计算，消除了大量数据传输中的ETL过程，极大提高了数据处理的实时性，Vastbase数据流结构如下图所示：
Vastbase G100流技术具有以下特点：
- 具备丰富的SQL语法和自定义函数（User Definition Function，即UDF）支持，流引擎和SQL引擎无缝结合；
- 支持持续聚合运算、滑动窗口查询、连续关联查询，单实例即可处理数百亿数据，具备了高吐量实时流数据处理的能力。
