This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository
https://gitbox.apache.org/repos/asf/incubator-streampark-website.git
The following commit(s) were added to refs/heads/dev by this push:
new 0fb484db Repair some path error. (#152)
0fb484db is described below
commit 0fb484db38ad4e1c369faf15016ab59af7b84123
Author: 第一片心意 <[email protected]>
AuthorDate: Tue Oct 11 18:41:02 2022 +0800
Repair some path error. (#152)
---
docs/flinksql/2-performance-tuning.md | 2 +-
docs/flinksql/syntax/4-create.md | 6 +++---
docs/flinksql/syntax/7-select.md | 20 ++++++++++----------
docs/flinksql/syntax/9-alter.md | 2 +-
4 files changed, 15 insertions(+), 15 deletions(-)
diff --git a/docs/flinksql/2-performance-tuning.md
b/docs/flinksql/2-performance-tuning.md
index a62c4c1e..21a234a3 100644
--- a/docs/flinksql/2-performance-tuning.md
+++ b/docs/flinksql/2-performance-tuning.md
@@ -35,7 +35,7 @@ SQL是数据分析中使用最广泛的语言。Flink的Table API和SQL使用户
默认情况下，分组聚合会禁用`MiniBatch`优化。
为了启用此优化，需要设置**table.exec.mini-batch.enabled**、**table.exec.mini-batch.allow-latency**、**table.exec.mini-batch.size**。
-详情请参阅[查询配置](1-1-query-config)页面。
+详情请参阅[查询配置](1-query-config)页面。
无论上述配置如何，窗口TVF聚合始终启用MiniBatch优化。窗口TVF聚合缓冲区记录在托管内存中，而不是JVM堆中，因此没有过载GC或OOM问题的风险。
diff --git a/docs/flinksql/syntax/4-create.md b/docs/flinksql/syntax/4-create.md
index 9d711ff3..3afeb2ff 100644
--- a/docs/flinksql/syntax/4-create.md
+++ b/docs/flinksql/syntax/4-create.md
@@ -85,7 +85,7 @@ CREATE TABLE MyTable (
元数据列是SQL标准的扩展，允许访问连接器和/或表中每一行的特定字段。元数据列由metadata关键字表示。例如，元数据列可以用来读取和写入Kafka记录的时间戳，以进行基于时间的操作。
-[连接器](docs/flinksql/connector)和[格式](docs/flinksql/format)文档列出了每个组件的可用元数据字段。在表的模式中声明元数据列是可选的。
+[连接器](docs/flinksql/connector/1-introduce)和[格式](docs/flinksql/format/1-introduce)文档列出了每个组件的可用元数据字段。在表的模式中声明元数据列是可选的。
下面的语句创建了一个表，其中包含引用元数据timestamp的附加元数据列：
@@ -246,7 +246,7 @@ SQL标准指定约束可以是强制的，也可以是不强制的。这将控
用于创建表source/sink的表属性，属性通常用于查找和创建底层连接器。
-表达式`key1=val1`的键和值都应该是字符串字面值。有关不同连接器的所有受支持的表属性，请参阅[连接器](docs/flinksql/connector)中的详细信息。
+表达式`key1=val1`的键和值都应该是字符串字面值。有关不同连接器的所有受支持的表属性，请参阅[连接器](docs/flinksql/connector/1-introduce)中的详细信息。
表名可以是三种格式:
@@ -482,7 +482,7 @@ CREATE [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF NOT
EXISTS] [catalog_name.][db_
创建一个函数，该函数具有带有标识符和可选语言标记的catalog和数据库名称空间。如果目录中已经存在同名的函数，则会引发异常。
-如果语言标记是JAVA/SCALA，则标识符是UDF的完整类路径。关于Java/Scala
UDF的实现，请参考用户[自定义函数](docs/flinksql/udf)。
+如果语言标记是JAVA/SCALA，则标识符是UDF的完整类路径。关于Java/Scala
UDF的实现，请参考用户[自定义函数](../udf/1-introduce)。
如果语言标记是PYTHON，则标识符是UDF的完全限定名，例如pyflink.table.tests.test_udf.add。
diff --git a/docs/flinksql/syntax/7-select.md b/docs/flinksql/syntax/7-select.md
index 0aaeb800..eeca68a9 100644
--- a/docs/flinksql/syntax/7-select.md
+++ b/docs/flinksql/syntax/7-select.md
@@ -167,8 +167,8 @@ SELECT PRETTY_PRINT(order_id) FROM Orders;
SELECT DISTINCT id FROM Orders;
```
-对于流式查询，计算查询结果所需的状态可能会无限增长。状态大小取决于不同的数据行数量。可以提供具有适当状态生存时间(TTL)的[查询配置](../1-1-query-config)，以防止状态存储过大。
-注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-1-query-config)。
+对于流式查询，计算查询结果所需的状态可能会无限增长。状态大小取决于不同的数据行数量。可以提供具有适当状态生存时间(TTL)的[查询配置](../1-query-config)，以防止状态存储过大。
+注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-query-config)。
## 窗口表值函数TVF
@@ -787,9 +787,9 @@ GROUP BY order_id;
```
对于流式查询，计算查询结果所需的状态可能会无限增长。状态大小取决于组的数量以及聚合函数的数量和类型。可以配置查询的状态生存时间(TTL)，以防止状态大小过大。但这可能会影响查询结果的正确性。
-详细信息请参见[查询配置](../1-1-query-config)。
+详细信息请参见[查询配置](../1-query-config)。
-Apache Flink为Group
Aggregation提供了一系列性能调优方法，请参阅更多的[性能调优](../2-2-performance-tuning)。
+Apache Flink为Group
Aggregation提供了一系列性能调优方法，请参阅更多的[性能调优](../2-performance-tuning)。
### DISTINCT聚合
@@ -800,7 +800,7 @@ SELECT COUNT(DISTINCT order_id) FROM Orders;
```
对于流式查询，计算查询结果所需的状态可能无限增长。状态大小主要取决于不同的行数和组维护的时间，短时间的窗口组聚合不是问题。可以配置查询的状态生存时间(TTL)，以防止状态大小过大。
-注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-1-query-config)。
+注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-query-config)。
### GROUPING SETS
@@ -835,7 +835,7 @@ GROUPING SETS的每个子列表可以指定零个或多个列或表达式，并
对于分组中集中未出现的列或表达式，会使用NULL进行替换，如上图所示。
对于流式查询，计算查询结果所需的状态可能无限增长。状态大小取决于组集的数量和聚合函数的类型。可以配置查询的状态生存时间(TTL)，以防止状态大小过大。注意，这可能会影响查询结果的正确性。
-详细信息请参见[查询配置](../1-1-query-config)。
+详细信息请参见[查询配置](../1-query-config)。
#### ROLLUP
@@ -1007,9 +1007,9 @@ ON Orders.productId = Product.id;
对于流查询，常规连接的语法是最灵活的，可以使用任何类型的更新(插入、更新、删除)输入表。然而，该操作具有重要的含义：它要求连接输入的两张表永远在Flink中保持state状态。
因此，计算查询结果所需的状态可能会无限增长，这取决于所有输入表和中间连接结果的不同输入行数。可以适当配置查询的状态生存时间(TTL)，以防止状态大小过大。
-注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-1-query-config)。
+注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-query-config)。
-对于流查询，计算查询结果所需的状态可能会无限增长，这取决于聚合的类型和不同分组键的数量。请提供具有有效保留间隔的[查询配置](../1-1-query-config)，以防止状态大小过大。
+对于流查询，计算查询结果所需的状态可能会无限增长，这取决于聚合的类型和不同分组键的数量。请提供具有有效保留间隔的[查询配置](../1-query-config)，以防止状态大小过大。
#### INNER等值连接
@@ -1596,7 +1596,7 @@ WHERE product IN
```
优化器将IN条件重写为join和group操作。对于流查询，计算查询结果所需的状态可能会无限增长，这取决于不同的输入行数。
-可以通过配置合适的状态生存时间(TTL)，以防止状态大小过大。注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-1-query-config)。
+可以通过配置合适的状态生存时间(TTL)，以防止状态大小过大。注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-query-config)。
### EXISTS
@@ -1614,7 +1614,7 @@ WHERE product EXISTS
如果子查询返回至少一行，则返回true。只有当操作可以在join和group操作中重写时才支持该语法。
优化器将EXISTS操作重写为join和group操作。对于流查询，计算查询结果所需的状态可能会无限增长，这取决于不同的输入行数。
-可以通过配置合适的状态生存时间(TTL)，以防止状态大小过大。注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-1-query-config)。
+可以通过配置合适的状态生存时间(TTL)，以防止状态大小过大。注意，这可能会影响查询结果的正确性。详细信息请参见[查询配置](../1-query-config)。
## ORDER BY子句
diff --git a/docs/flinksql/syntax/9-alter.md b/docs/flinksql/syntax/9-alter.md
index eee1723b..1e7e8936 100644
--- a/docs/flinksql/syntax/9-alter.md
+++ b/docs/flinksql/syntax/9-alter.md
@@ -61,7 +61,7 @@ ALTER DATABASE [catalog_name.]db_name SET (key1=val1,
key2=val2, ...)
ALTER [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS]
[catalog_name.][db_name.]function_name AS identifier [LANGUAGE
JAVA|SCALA|PYTHON]
```
-使用新的标识符和可选的语言标记更改catalog函数。如果函数在catalog中不存在，则抛出异常。如果语言标记是JAVA/SCALA，则标识符是UDF的完整类路径。关于Java/Scala
UDF的实现，请参考用户[自定义函数](docs/flinksql/udf)。
+使用新的标识符和可选的语言标记更改catalog函数。如果函数在catalog中不存在，则抛出异常。如果语言标记是JAVA/SCALA，则标识符是UDF的完整类路径。关于Java/Scala
UDF的实现，请参考用户[自定义函数](../udf/1-introduce)。
**TEMPORARY**
