Join前后优化器估计的数据行数在阈值以下。 Join的子节点均为Stream节点。 为了方便举例，让Join的子节点都为Stream节点，关闭了Broadcast。 gaussdb=# set enable_broadcast=false; SET gaussdb=# set explain_perf_mode=pretty;

查看更多 →

join前后优化器估算的数据行数在阈值以下。 join的子节点均为Stream节点。 为了方便举例，设置join的子节点都为Stream节点，关闭了Broadcast。 gaussdb=# set enable_broadcast=false; SET gaussdb=# set explain_perf_mode=pretty;

查看更多 →

ock)], agg_redistribute_agg[(@queryblock)] 参数说明 @queryblock请参见指定Hint所处于的查询块Queryblock，可省略，表示在当前查询块生效。 redistribute_agg指定stream hashagg使用重分布-聚合的计划。

查看更多 →

setA不是setB的一个子集。 对于这种场景，Stream执行框架分为如下三种计划形态： hashagg + gather(redistribute) + hashagg； redistribute + hashagg(+gather)； hashagg + redistribute + hashagg(+gather)。

查看更多 →

setA不是setB的一个子集。 对于这种场景，Stream执行框架分为如下三种计划形态： hashagg + gather(redistribute) + hashagg； redistribute + hashagg(+ gather)； hashagg + redistribute + hashagg(+

查看更多 →

STREAMING_REAPER_STATUS STREAMING_REAPER_STATUS系统表存储流引擎reaper线程的状态信息。由于规格变更，当前版本已经不再支持本特性，请不要使用。 表1 STREAMING_REAPER_STATUS字段 名称 类型 描述 id integer

查看更多 →

STREAMING_CONT_QUERY STREAMING_CONT_QUERY系统表存储所有CONTVIEW对象的元数据信息。 表1 STREAMING_CONT_QUERY字段 名称 类型 描述 id integer CONTVIEW对象唯一的标识符，不可重复。 type "char"

查看更多 →

STREAMING_STREAM STREAMING_STREAM系统表存储所有STREAM对象的元数据信息。 表1 STREAMING_STREAM字段 名称 类型 描述 relid oid STREAM对象的标识。 queries bytea 该STREAM对应CONTVIEW的位图映射。

查看更多 →

STREAMING_CONT_QUERY STREAMING_CONT_QUERY系统表存储所有CONTVIEW对象的元数据信息。 表1 STREAMING_CONT_QUERY字段 名称 类型 描述 id integer CONTVIEW对象唯一的标识符，不可重复。 type "char"

查看更多 →

Stream方式的Hint 功能描述 指明stream使用的方法，可以为broadcast和redistribute，或者直接指定生成gather计划。 语法格式 1 2 [no] broadcast|redistribute( [@queryblock] table_list)

查看更多 →

Stream方式的Hint 功能描述 指明stream使用的方法，可以为broadcast和redistribute，或者直接指定生成gather计划。 语法格式 1 2 [no] broadcast|redistribute|local_roundrobin( [@queryblock]

查看更多 →

对于这种场景，Stream执行框架分为如下三种计划形态： hashagg+gather(redistribute)+hashagg redistribute+hashagg(+gather) hashagg+redistribute+hashagg(+gather) GaussDB 提供了

查看更多 →

对于这种场景，Stream执行框架分为如下三种计划形态： hashagg+gather(redistribute)+hashagg redistribute+hashagg(+gather) hashagg+redistribute+hashagg(+gather) GaussDB(DW

查看更多 →

StreamingML 异常检测 时间序列预测 实时聚类 深度学习模型预测 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）

查看更多 →

STREAMING_STREAM STREAMING_STREAM系统表存储所有STREAM对象的元数据信息。 表1 STREAMING_STREAM字段 名称 类型 描述 relid oid STREAM对象的标识。 queries bytea 该STREAM对应CONTVIEW的位图映射。

查看更多 →

STREAMING_REAPER_STATUS STREAMING_REAPER_STATUS系统表存储流引擎（由于规格变更，当前版本已经不再支持本特性，请不要使用）reaper线程的状态信息。 表1 STREAMING_REAPER_STATUS字段 名称 类型 描述 id integer

查看更多 →

STREAMING_CONT_QUERY STREAMING_CONT_QUERY系统表存储所有CONTVIEW对象的元数据信息。 表1 STREAMING_CONT_QUERY字段 名称 类型 描述 id integer CONTVIEW对象唯一的标识符，不可重复。 type "char"

查看更多 →

Stream Load Stream load是一个同步的导入方式，用户通过发送HTTP协议发送请求将本地文件或数据流导入到Doris中。Stream load同步执行导入并返回导入结果。用户可直接通过请求的返回体判断本次导入是否成功。 Stream load主要适用于导入本地文件，或通过程序导入数据流中的数据。

查看更多 →

况： join两侧都需要做重分布： 对倾斜侧做PART_REDISTRIBUTE_PART_ROUNDROBIN，其中对倾斜数据做roundrobin，非倾斜数据做redistribute； 对非倾斜侧做PART_REDISTRIBUTE_PART_BROADCAST，其中对倾斜

查看更多 →

x和t.x均不是表的分布列，因此需要重分布（REDISTRIBUTE算子）。其中s.x列上存在倾斜值，t.x上不存在倾斜。id=6的stream算子在datanode2节点输出的结果集是其他DN的3倍，从而导致了计算倾斜。 1 gaussdb=# explain select * from

查看更多 →

数据做redistribute。 数据0在skew_scol表上是非倾斜侧，对倾斜数据做broadcast，非倾斜数据做redistribute。 由此可以看到两个stream类型分别是PART REDISTRIBUTE PART ROUNDROBIN和PART REDISTRIBUTE

查看更多 →