概述

简介

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

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

组件

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

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