-
Notifications
You must be signed in to change notification settings - Fork 38
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
695 changed files
with
43,083 additions
and
11,279 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
5 changes: 5 additions & 0 deletions
5
...ntributor-guide/datanode/metric-engine.md → ...ntributor-guide/datanode/metric-engine.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
5 changes: 5 additions & 0 deletions
5
....7/contributor-guide/datanode/overview.md → ...12/contributor-guide/datanode/overview.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
5 changes: 5 additions & 0 deletions
5
...tributor-guide/datanode/python-scripts.md → ...tributor-guide/datanode/python-scripts.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
5 changes: 5 additions & 0 deletions
5
...ontributor-guide/datanode/query-engine.md → ...ontributor-guide/datanode/query-engine.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
18 changes: 18 additions & 0 deletions
18
...urus-plugin-content-docs/version-0.12/contributor-guide/flownode/arrangement.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,18 @@ | ||
--- | ||
keywords: [Arrangement, 状态存储, 键值对] | ||
description: 描述了 Arrangement 在数据流进程中的状态存储功能,包括键值对存储、查询和删除操作的实现。 | ||
--- | ||
|
||
# Arrangement | ||
|
||
Arrangement 存储数据流进程中的状态,存储 flow 的更新流(stream)以供进一步查询和更新。 | ||
|
||
Arrangement 本质上存储的是带有时间戳的键值对。 | ||
在内部,Arrangement 接收类似 `((Key Row, Value Row), timestamp, diff)` 的 tuple,并将其存储在内存中。 | ||
你可以使用 `get(now: Timestamp, key: Row)` 查询某个时间的键值对。 | ||
Arrangement 假定早于某个时间(也称为 Low Watermark)的所有内容都已被写入到 sink 表中,不会为其保留历史记录。 | ||
|
||
:::tip 注意 | ||
Arrangement 允许通过将传入 tuple 的 `diff` 设置为 -1 来删除键。 | ||
此外,如果已将行数据添加到 Arrangement 并且使用不同的值插入相同的键,则原始值将被新值覆盖。 | ||
::: |
18 changes: 18 additions & 0 deletions
18
...usaurus-plugin-content-docs/version-0.12/contributor-guide/flownode/dataflow.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,18 @@ | ||
--- | ||
keywords: [Dataflow, SQL 查询, 执行计划, 数据流, map, reduce] | ||
description: 解释了 Dataflow 模块的核心计算功能,包括 SQL 查询转换、内部执行计划、数据流的触发运行和支持的操作。 | ||
--- | ||
|
||
# 数据流 | ||
|
||
Dataflow 模块(参见 `flow::compute` 模块)是 `flow` 的核心计算模块。 | ||
它接收 SQL 查询并将其转换为 `flow` 的内部执行计划。 | ||
然后,该执行计划被转化为实际的数据流,而数据流本质上是一个由带有输入和输出端口的函数组成的有向无环图(DAG)。 | ||
数据流会在需要时被触发运行。 | ||
|
||
目前该数据流只支持 `map`和 `reduce` 操作,未来将添加对 `join` 等操作的支持。 | ||
|
||
在内部,数据流使用 `tuple(row, time, diff)` 以行格式处理数据。 | ||
这里 `row` 表示实际传递的数据,可能包含多个 `value` 对象。 | ||
`time` 是系统时间,用于跟踪数据流的进度,`diff` 通常表示行的插入或删除(+1 或 -1)。 | ||
因此,`tuple` 表示给定系统时间的 `row` 的插入/删除操作。 |
21 changes: 21 additions & 0 deletions
21
...usaurus-plugin-content-docs/version-0.12/contributor-guide/flownode/overview.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,21 @@ | ||
--- | ||
keywords: [Flownode, 流处理, FlownodeManager, FlowWorker] | ||
description: 介绍了 Flownode 的基本概念、组件和当前版本的支持情况,包括 FlownodeManager、FlowWorker 和 Flow 的功能。 | ||
--- | ||
|
||
# 概述 | ||
|
||
## 简介 | ||
|
||
`Flownode` 为数据库提供了一种简单的流处理(称为 `flow`)能力。 | ||
`Flownode` 管理 `flow`,这些 `flow` 是从 `source` 接收数据并将数据发送到 `sink` 的任务。 | ||
|
||
在当前版本中,`Flownode` 仅在单机模式中支持,未来将支持分布式模式。 | ||
|
||
## 组件 | ||
|
||
`Flownode` 包含了 flow 流式处理的所有组件,以下是关键部分: | ||
|
||
- `FlownodeManager`:用于接收从 `Frontend` 转发的插入数据并将结果发送回 flow 的 sink 表。 | ||
- 一定数量的 `FlowWorker` 实例,每个实例在单独的线程中运行。当前在单机模式中只有一个 flow worker,但这可能会在未来发生变化。 | ||
- `Flow` 是一个主动从 `source` 接收数据并将数据发送到 `sink` 的任务。由 `FlownodeManager` 管理并由 `FlowWorker` 运行。 |
5 changes: 5 additions & 0 deletions
5
...or-guide/frontend/distributed-querying.md → ...or-guide/frontend/distributed-querying.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
46 changes: 6 additions & 40 deletions
46
...tributor-guide/frontend/table-sharding.md → ...tributor-guide/frontend/table-sharding.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.