概述

简介

Flownode 为数据库提供了一种简单的流处理(称为 flow)能力。 Flownode 管理 flow,这些 flow 是从 source 接收数据并将数据发送到 sink 的任务。

在当前版本中,Flownode 仅在单机模式中支持,未来将支持分布式模式。

组件

Flownode 包含了 flow 流式处理的所有组件,以下是关键部分:

  • FlownodeManager:用于接收从 Frontend 转发的插入数据并将结果发送回 flow 的 sink 表。
  • 一定数量的 FlowWorker 实例,每个实例在单独的线程中运行。当前在单机模式中只有一个 flow worker,但这可能会在未来发生变化。
  • Flow 是一个主动从 source 接收数据并将数据发送到 sink 的任务。由 FlownodeManager 管理并由 FlowWorker 运行。