From 50230625f0cdb758c20b16c6f4fa5cf9652c280a Mon Sep 17 00:00:00 2001 From: ljh0804 Date: Thu, 10 Aug 2023 20:52:45 +0800 Subject: [PATCH] Update execClusterResize.cpp --- .../runtime/executor/execClusterResize.cpp | 340 +++++++++--------- 1 file changed, 170 insertions(+), 170 deletions(-) diff --git a/src/gausskernel/runtime/executor/execClusterResize.cpp b/src/gausskernel/runtime/executor/execClusterResize.cpp index 4eb0444a5..1492a6a80 100644 --- a/src/gausskernel/runtime/executor/execClusterResize.cpp +++ b/src/gausskernel/runtime/executor/execClusterResize.cpp @@ -3,9 +3,9 @@ * execClusterResize.cpp * MPPDB ClusterResizing relevant routines * - * Portions Copyright (c) 2020 Huawei Technologies Co.,Ltd. - * Portions Copyright (c) 1996-2012, PostgreSQL Global Development Group - * Portions Copyright (c) 1994, Regents of the University of California + * 部分版权 （c） 2020 华为技术有限公司 + * 部分版权所有 （c） 1996-2012，PostgreSQL 全球开发集团 + * 部分版权 （c） 1994，加州大学摄政 * * IDENTIFICATION * src/gausskernel/runtime/executor/execClusterResize.cpp @@ -44,10 +44,10 @@ /* * --------------------------------------------------------------------------------- - * *Local functions/variables declaration fields* + * 局部函数/变量声明字段* * --------------------------------------------------------------------------------- */ -/* delete delta table definition */ +/*删除增量表定义 */ #define Natts_pg_delete_delta 3 #define Anum_pg_delete_delta_xcnodeid_and_dntableoid 1 @@ -120,12 +120,12 @@ static inline bool redis_ctid_retrive_function(const char* funcname, Oid rettype /* - * - Brief: Record the given tuple's tupleid into pg_delete_delta table - * - Parameter: - * @rel: target relation of UPDATE/DELETE operation - * @tupleid: tupleid that needs record - * - Return: - * no return value + *简介：将给定元组的元组记录到pg_delete_delta表中 + * -参数： + * @rel：更新/删除操作的目标关系 + * @tupleid：需要记录的元组 + *-返回： + * 无返回值 */ void RecordDeletedTuple(Oid relid, int2 bucketid, const ItemPointer tupleid, const Relation deldelta_rel) { @@ -134,10 +134,10 @@ void RecordDeletedTuple(Oid relid, int2 bucketid, const ItemPointer tupleid, con HeapTuple tup = NULL; Assert(deldelta_rel); - /* In redistribution, table delete_delta has 3 or 2 column. */ + /*在重新分发中，表 delete_delta 有 3 列或 2 列。 */ Assert(RelationGetDescr(deldelta_rel)->natts <= 3); - /* Iterate through attributes initializing nulls and values */ + /*循环访问初始化空值和值的属性 */ for (int i = 0; i < Natts_pg_delete_delta; i++) { nulls[i] = false; values[i] = (Datum)0; @@ -149,7 +149,7 @@ void RecordDeletedTuple(Oid relid, int2 bucketid, const ItemPointer tupleid, con if (BUCKET_NODE_IS_VALID(bucketid)) { values[Anum_pg_delete_delta_tablebucketid_and_ctid - 1] |= ((uint64)bucketid << 48); } - /* Record delta */ + /* 记录增量 */ tup = heap_form_tuple(RelationGetDescr(deldelta_rel), values, nulls); (void)simple_heap_insert(deldelta_rel, tup); @@ -157,18 +157,18 @@ void RecordDeletedTuple(Oid relid, int2 bucketid, const ItemPointer tupleid, con } /* - * - Brief: Determine if the relation is under cluster resizing operation - * - Parameter: - * @rel: relation that needs to check - * - Return: - * @TRUE: relation is under cluster resizing - * @FALSE: relation is not under cluster resizing + * - 简介：确定关系是否正在执行群集大小调整操作 + * - 参数： + * @rel：需要检查的关系 + * - 返回： + * @TRUE：关系正在调整集群大小 + * @FALSE: 关系未调整集群大小 */ bool RelationInClusterResizing(const Relation rel) { Assert(rel != NULL); - /* Check relation's append_mode status */ + /*检查关系的append_mode状态 */ if (!IsInitdb && RelationInRedistribute(rel)) return true; @@ -176,18 +176,18 @@ bool RelationInClusterResizing(const Relation rel) } /* - * - Brief: Determine if the relation is under cluster resizing read only operation - * - Parameter: - * @rel: relation that needs to check - * - Return: - * @TRUE: relation is under cluster resizing read only - * @FALSE: relation is not under cluster resizing read only + * - 简要:确定关系是否处于集群调整只读操作下 + * - 参数: + * @rel:需要检查的关系 + * - 返回: + * @TRUE: 关系处于集群调整大小只读状态 + * @FALSE: 关系不处于集群调整大小只读状态 */ bool RelationInClusterResizingReadOnly(const Relation rel) { Assert(rel != NULL); - /* Check relation's append_mode status */ + /*检查关系的append_mode状态 */ if (!IsInitdb && RelationInRedistributeReadOnly(rel)) return true; @@ -195,18 +195,18 @@ bool RelationInClusterResizingReadOnly(const Relation rel) } /* - * - Brief: Determine if the relation is under cluster resizing read only operation - * - Parameter: - * @rel: relation that needs to check - * - Return: - * @TRUE: relation is under cluster resizing endcatchup(write error) - * @FALSE: relation is not under cluster resizing endcatchup(write error) + * - 简要:确定关系是否处于集群调整只读操作下 + * - 参数: + * @rel: 需要检查的关系 + * - 返回: + * @TRUE: 关系处于群集调整大小状态endcatchup(写错误) + * @FALSE: 关系不在群集调整大小范围内endcatchup(写错误) */ bool RelationInClusterResizingEndCatchup(const Relation rel) { Assert(rel != NULL); - /* Check relation's append_mode status */ + /* 检查关系的append_mode状态*/ if (!IsInitdb && RelationInRedistributeEndCatchup(rel)) return true; @@ -214,9 +214,9 @@ bool RelationInClusterResizingEndCatchup(const Relation rel) } /* - * @Description: check whether relation is in redistribution though range variable. - * @in range_var: range variable which stored relation info. - * @return: true for in redistribution. + * @说明:通过范围变量检查关系是否在重新分配。 + * @在range_var:存储关系信息的范围变量。 + * @在重新分配中返回:true。 */ bool CheckRangeVarInRedistribution(const RangeVar* range_var) { @@ -228,7 +228,7 @@ bool CheckRangeVarInRedistribution(const RangeVar* range_var) if (OidIsValid(relid)) { relation = relation_open(relid, NoLock); - /* If the relation is index, we should check the related table is resizing or not. */ + /* 如果关系是索引，我们应该检查相关表是否在调整大小。*/ if (RelationIsIndex(relation)) { Oid heapOid = IndexGetRelation(relid, false); Relation heapRelation = relation_open(heapOid, AccessShareLock); @@ -245,12 +245,12 @@ bool CheckRangeVarInRedistribution(const RangeVar* range_var) } /* - * - Brief: Determine if the table name is delete_delta table. - * - Parameter: - * @relname: name of target table - * - Return: - * @TRUE: the table is delete_delta table - * @FALSE: the table is not delete_delta table + * - 简要:确定表名是否为delete_delta table。 + * - 参数: + * @relname: 目标表名 + * - 返回: + * @TRUE: 表为delete_delta表 + * @FALSE: 这个表不是delete_delta表 */ bool RelationIsDeleteDeltaTable(char* delete_delta_name) { @@ -292,10 +292,10 @@ bool RelationIsDeleteDeltaTable(char* delete_delta_name) } /* - * - Brief: Determine if the Progress is under cluster resizing status - * - Return: - * @TRUE: Progress is under cluster resizing - * @FALSE: Progress is not under cluster resizing + * - 简要:确定进度是否处于集群调整状态 + * - 返回: + * @TRUE: 正在调整集群大小 + * @FALSE: 进度并不在集群调整中 */ bool ClusterResizingInProgress() { @@ -329,27 +329,27 @@ bool ClusterResizingInProgress() } /* - * - Brief: get the name of delete_delta table - * - Parameter: - * @relname: name of target table - * @delta_delta_name: output value for delete_delta table name - * @isMultiCatchup: multi catchup delta or not - * - Return: - * no return value + * -简介:获取delete_delta表的名称 + * - 参数: + * @relname: 目标表名 + * @delta_delta_name: delete_delta表名的输出值 + * @isMultiCatchup: 是不是多追赶delta + * - 返回: + * 无返回值 */ static inline void RelationGetDeleteDeltaTableName(Relation rel, char* delete_delta_name, bool isMultiCatchup) { int rc = 0; - /* Check if output parameter it not palloc()-ed from caller side */ + /* 检查输出参数是否没有从调用方palloc()-ed */ if (delete_delta_name == NULL || rel == NULL) { ereport(ERROR, (errcode(ERRCODE_INVALID_PARAMETER_VALUE), errmsg("Invalid parameter in function '%s'", __FUNCTION__))); } /* - * Look up Relation's reloptions to get table's cnoid to - * form the name of delete_delta table + * 查找Relation的关联以获得表的id + * 形成delete_delta表的名称 */ if (!IsInitdb) { if (RelationInClusterResizing(rel) && !RelationInClusterResizingReadOnly(rel)) { @@ -381,12 +381,12 @@ static inline void RelationGetDeleteDeltaTableName(Relation rel, char* delete_de } /* - * - Brief: get and open delete_delta rel - * - Parameter: - * @rel: target relation of UPDATE/DELETE/TRUNCATE operation - * @lockmode: lock mode - * @isMultiCatchup: multi catchup delta or not - * - Return: + * - 简介:获取并打开delete_delta rel + * - 参数: + * @rel: UPDATE/DELETE/TRUNCATE操作的目标关系 + * @lockmode: 锁定模式 + * @isMultiCatchup: 是不是多追赶delta + * - 返回: * delete_delta rel */ Relation GetAndOpenDeleteDeltaRel(const Relation rel, LOCKMODE lockmode, bool isMultiCatchup) @@ -403,22 +403,22 @@ Relation GetAndOpenDeleteDeltaRel(const Relation rel, LOCKMODE lockmode, bool is RelationGetDeleteDeltaTableName(rel, (char*)delete_delta_tablename, isMultiCatchup); data_redis_namespace = get_namespace_oid("data_redis", false); - /* We are going to fetch the delete delta relation under data_redis schema. */ + /* 我们将在data_redis模式下获取delete delta关系。 */ deldelta_relid = get_relname_relid(delete_delta_tablename, data_redis_namespace); if (!OidIsValid(deldelta_relid)) { /* - * If multi catchup delta table is not there, just return NULL. We should not - * report error, because it is a valid case. Multi catchup delta table is - * dropped in each catchup iteration. + * 如果多追赶增量表不存在，则返回NULL。否则不是 （We should not） + * 报告错误，因为这是一个有效的案例。多追赶delta表是( Multi catchup delta table is) + * 在每次追赶迭代中被丢弃。 */ if (isMultiCatchup) { return NULL; } /* - * To support Update or Delete during extension, we need to add 2 more columns. - * more columns. Limited by MaxHeapAttributeNumber, if the table already contains too many columns, - * we don't allow update or delete anymore, but insert statement can still proceed. + * 为了在扩展期间支持更新或删除，我们需要添加2列。 + * 更多的列。如果表已经包含了太多的列，受maxheapattributennumber的限制， + * 我们不再允许更新或删除，但插入语句仍然可以进行。 */ if (((rel->rd_att->natts > (MaxHeapAttributeNumber - (Natts_pg_delete_delta - 1))) && !RELATION_IS_PARTITIONED(rel)) || @@ -429,7 +429,7 @@ Relation GetAndOpenDeleteDeltaRel(const Relation rel, LOCKMODE lockmode, bool is RelationGetRelationName(rel)), errdetail("Can not support online extension, if the table contains too many columns"))); } - /* ERROR case, should never come here */ + /* 错误情况下，不应该出现在这里 */ ereport(ERROR, (errcode(ERRCODE_UNDEFINED_TABLE), errmsg("delete delta table %s is not found when do cluster resizing table \"%s\"", @@ -446,11 +446,11 @@ Relation GetAndOpenDeleteDeltaRel(const Relation rel, LOCKMODE lockmode, bool is } /* - * - Brief: Check the stmtment during online expansion, block unsupported ddl in cluster resizing. - * - Parameter: - * @rel: parsetree of DDL - * - Return: - * no return value + * - 简介:检查在线扩展期间的配置，在集群调整中阻止不支持的ddl。 + * - 参数: + * @rel: DDL的解析树 + * -返回: + * 无返回值 */ void BlockUnsupportedDDL(const Node* parsetree) { @@ -466,11 +466,11 @@ void BlockUnsupportedDDL(const Node* parsetree) LOCKMODE lockmode_openrel = AccessShareLock; /* - * Check for shared-cache-inval messages before trying to access the - * relation. This is needed to cover the case where the name - * identifies a rel that has been dropped and recreated since the - * start of our transaction: if we don't flush the old syscache entry, - * then we'll latch onto that entry and suffer an error later. + * 文件之前，请检查是否存在共享缓存无效消息 + * relation. 关系。这是需要覆盖的情况下的名称 + * 对象之后已删除并重新创建的rel + * 事务开始:如果我们不刷新旧的syscache条目， + * 然后我们将锁定该条目并在稍后遭受错误。 */ AcceptInvalidationMessages(); @@ -501,13 +501,13 @@ void BlockUnsupportedDDL(const Node* parsetree) return; } break; - /* Block CURSOR for while table in cluster resizing */ + /* 在集群调整大小时阻塞游标 */ case T_PlannedStmt: { PlannedStmt* stmt = (PlannedStmt*)parsetree; relidlist = stmt->relationOids; } break; - /* Block RENAME while table in cluster resizing */ + /* 当表在集群中调整大小时，块RENAME */ case T_RenameStmt: { RenameStmt* stmt = (RenameStmt*)parsetree; @@ -540,11 +540,11 @@ void BlockUnsupportedDDL(const Node* parsetree) stmt->relation->relname))); } break; - /* Block ALTER set schema while table in cluster resizing */ + /* 当表在集群中调整大小时，Block ALTER设置模式 */ case T_AlterObjectSchemaStmt: { AlterObjectSchemaStmt* stmt = (AlterObjectSchemaStmt*)parsetree; - /* disable alter table set schema when transfer */ + /* 在传输时禁用alter table set schema */ if (stmt->relation != NULL) { Oid relOid = RangeVarGetRelid(stmt->relation, AccessShareLock, true); if (OidIsValid(relOid)) { @@ -567,7 +567,7 @@ void BlockUnsupportedDDL(const Node* parsetree) stmt->relation->relname))); } break; - /* Block CREATE index while table in cluster resizing(for row table only) */ + /* 当表在集群中调整大小时，阻塞创建索引(仅适用于行表) */ case T_IndexStmt: { IndexStmt* stmt = (IndexStmt*)parsetree; if (stmt->relation) { @@ -590,13 +590,13 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block REINDEX while table in cluster resizing(for row table only) */ + /* 当表在集群中调整大小时，块REINDEX(仅适用于行表) */ case T_ReindexStmt: { ReindexStmt* stmt = (ReindexStmt*)parsetree; if (stmt->relation) { relid = RangeVarGetRelid(stmt->relation, AccessShareLock, true); if (OidIsValid(relid)) { - /* release index lock before lock table to avoid deadlock */ + /* 在锁表之前释放索引锁以避免死锁 */ UnlockRelationOid(relid, AccessShareLock); Relation relation = relation_open(relid, NoLock); @@ -622,7 +622,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block ALTER-Table while table in cluster resizing */ + /* 当表在集群中调整大小时，阻塞ALTER-Table */ case T_AlterTableStmt: { AlterTableStmt* stmt = (AlterTableStmt*)parsetree; AlterTableCmd* cmd = NULL; @@ -631,13 +631,13 @@ void BlockUnsupportedDDL(const Node* parsetree) switch (cmd->subtype) { case AT_TruncatePartition: { /* - * We do not allow truncate partition when the target is in read only - * mode during online expansion time. + * 当目标处于只读状态时，我们不允许截断分区 + *在线扩容时的模式 */ if (stmt->relation) { relid = RangeVarGetRelid(stmt->relation, lockmode_getrelid, true); if (OidIsValid(relid)) { - /* disable alter table truncate partition during transfer */ + /* 禁止在传输过程中截断分区 */ if (CheckRangeVarInRedistribution(stmt->relation)) { Oid nsOid = GetNamespaceIdbyRelId(relid); TRANSFER_DISABLE_DDL(nsOid); @@ -704,12 +704,12 @@ void BlockUnsupportedDDL(const Node* parsetree) } } - /* If rel option contain append_mode, then not check. */ + /* 如果rel选项包含append_mode，则不检查。 */ if (opt != NULL) { break; } } - /* fall through */ + /* 失败 */ default: { if (stmt->relation && !u_sess->attr.attr_sql.enable_cluster_resize && CheckRangeVarInRedistribution(stmt->relation)) @@ -725,7 +725,7 @@ void BlockUnsupportedDDL(const Node* parsetree) return; } break; - /* Block CREATE-RULE statements while target table in cluster resizing */ + /* 当集群中的目标表调整大小时，阻塞CREATE-RULE语句 */ case T_RuleStmt: { RuleStmt* stmt = (RuleStmt*)parsetree; if (stmt->relation) { @@ -734,7 +734,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block CREATE SEQUENCE set schema while owner table in cluster resizing */ + /* 当所有者表在集群中调整大小时，Block CREATE SEQUENCE设置模式 */ case T_CreateSeqStmt: { CreateSeqStmt* stmt = (CreateSeqStmt*)parsetree; List* owned_by = NULL; @@ -761,7 +761,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block ALTER SEQUENCE while owner table in cluster resizing */ + /* 当集群中的所有者表调整大小时，阻塞ALTER SEQUENCE */ case T_AlterSeqStmt: { AlterSeqStmt* stmt = (AlterSeqStmt*)parsetree; List* owned_by = NIL; @@ -788,7 +788,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block CLUSTER while table in cluster resizing */ + /* 当表在集群中调整大小时阻塞集群 */ case T_ClusterStmt: { ClusterStmt* stmt = (ClusterStmt*)parsetree; if (stmt->relation && CheckRangeVarInRedistribution(stmt->relation)) @@ -799,7 +799,7 @@ void BlockUnsupportedDDL(const Node* parsetree) stmt->relation->relname))); } break; - /* Block VACUUM FULL while table in cluster resizing */ + /* 当表在集群中调整大小时，块真空已满 */ case T_VacuumStmt: { VacuumStmt* stmt = (VacuumStmt*)parsetree; if ((stmt->options & VACOPT_VACUUM) || (stmt->options & VACOPT_MERGE)) { @@ -822,7 +822,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } } break; - /* Block truncate DDL when the target table is read only in cluster resizing */ + /* 在集群调整大小时，当目标表为只读时，块截断DDL */ case T_TruncateStmt: { ListCell* cell = NULL; TruncateStmt* stmt = (TruncateStmt*)parsetree; @@ -857,7 +857,7 @@ void BlockUnsupportedDDL(const Node* parsetree) DropStmt* stmt = (DropStmt*)parsetree; switch (stmt->removeType) { case OBJECT_TABLE: { - /* disable drop table when transfer */ + /* 在传输时禁用drop表 */ ListCell* cell = NULL; foreach (cell, stmt->objects) { RangeVar* rel = makeRangeVarFromNameList((List*)lfirst(cell)); @@ -871,7 +871,7 @@ void BlockUnsupportedDDL(const Node* parsetree) break; } case OBJECT_SCHEMA: { - /* disable drop schema when transfer */ + /* 传输时禁用删除模式 */ ListCell* cell = NULL; foreach (cell, stmt->objects) { List* objname = (List*)lfirst(cell); @@ -887,7 +887,7 @@ void BlockUnsupportedDDL(const Node* parsetree) } break; case T_CreateStmt: { - /* disable create table when transfer */ + /* 禁止传输时创建表 */ CreateStmt* stmt = (CreateStmt*)parsetree; if (stmt->relation != NULL) { Oid nsOid = RangeVarGetCreationNamespace(stmt->relation); @@ -916,14 +916,14 @@ void BlockUnsupportedDDL(const Node* parsetree) } /* - * - Brief: For online expanions, the shippable function is evaluated here, the module - * will be invoked in optimizer when do FQS evaluation, we have to define function - * as STABLE - * - Parameter: - * @funcid: oid of user defined function which is createed/dropped in scope of gs_redis - * - Return: - * @true: shippable - * @false: unshippable + * - 简介:对于在线扩展，这里评估的是可发布功能模块 + * 在优化器中调用FQS评估时，我们必须定义函数 + * 是稳定的（as STABLE） + * - 参数: + * @funcid: 在gs_redis范围内创建/删除的用户定义函数的Oid + * - 返回: + * @true: 可交付 + * @false: 不可交付 */ bool redis_func_shippable(Oid funcid) { @@ -937,11 +937,11 @@ bool redis_func_shippable(Oid funcid) ereport(ERROR, (errcode(ERRCODE_UNDEFINED_FUNCTION), errmsg("function with OID %u does not exist", funcid))); } - /* Fetch function signatures */ + /* 获取函数签名 */ rettype = get_func_signature(funcid, &argstype, &nargs); if (redis_tupleid_retrive_function(func_name, rettype, argstype, nargs)) { - /* tupleid retrive functions is shippable to datanodes */ + /* Tupleid检索函数可以发布到数据节点 */ result = true; } else if (redis_offset_retrive_function(func_name, rettype, argstype, nargs)) { result = true; @@ -961,11 +961,11 @@ bool redis_func_shippable(Oid funcid) } /* - * - Brief: determine if given funcid reflects a dn-stable function - * - Parameter: - * @funcid: function oid that to evaluate - * - Return: - * @result: true:dnstable false: not-dnstable function + * - 简介:确定给定的函数是否反映了一个非稳定函数 + * - 参数: + * @funcid: 要求值的函数oid + * - 返回: + * @result: true:不稳定的 false: 不稳定的函数 */ bool redis_func_dnstable(Oid funcid) { @@ -981,11 +981,11 @@ bool redis_func_dnstable(Oid funcid) errmsg("function with OID %u does not exist when checking function dnstable", funcid))); } - /* Fetch function signatures */ + /* 获取函数签名 */ rettype = get_func_signature(funcid, &argstype, &nargs); if (redis_tupleid_retrive_function(func_name, rettype, argstype, nargs)) { - /* tupleid retrive functions is dnstable */ + /* 管状反射函数是不稳定的 */ result = true; } @@ -993,23 +993,23 @@ bool redis_func_dnstable(Oid funcid) } /* - * - Brief: evaluate ctid functions into a const value to avoid per-scanning - * tuple invokation in seqscan. - * - Parameter: - * @rel: the rel being redistributing - * @original_quals: the original quals possible contains ctid_funcs - * @isRangeScanInRedis: if is a redis range scan - * - Return: - * @new_quals: quals which func call be replaced by a const + * - 简介:将ctid函数求值为const值以避免每次扫描 + * 在seqscan中调用元组。 + * - 参数: + * @rel: 真正的问题是再分配 + * @original_quals: 原始的quals可能包含ctid_funcs + * @isRangeScanInRedis: 这是一个redis范围扫描 + * - 返回: + * @new_quals: 函数调用的Quals将被const替换 */ List* eval_ctid_funcs(Relation rel, List* original_quals, RangeScanInRedis *rangeScanInRedis) { StringInfo qual_str = makeStringInfo(); /* - * we have to make a copy of the original quals, since the eval_dnstable_func_mutator - * will modify the it. the original qual will be needed again and again in later - * to be re-eval in partition table scans. + * 由于eval_dnstable_func_mutator的存在，我们必须对原始的quals进行复制 + * 将修改它。在以后的时间里，将会一次又一次地需要原始的质量 + * 要在分区表扫描中重新计算。 */ List* new_quals = (List*)copyObject((const void*)(original_quals)); @@ -1033,16 +1033,16 @@ static int32 get_expr_const_val(Node *val){ } /* - * - Brief: working house for eval_dnstable_func() to evaluate dn stable function into a const - * value to avoid per-scanning tuple invocation in seqscan - * - Parameter: - * @rel: the rel being redistributing - * @node: expression node - * @qual_str: predicate pattern - * @isRangeScanInRedis: output to indicate if the predicate pattern is range scan in redis - * @isRoot: we want to compare the predicate pattern only once at root level - * - Return: - * @result: expression tree with dn stable function const-evaluated + * - 简介:eval_dnstable_func()的工作库，用于将一个稳定函数求值为const + * 值以避免在seqscan中调用每次扫描的元组 + * - 参数: + * @rel: 真正的问题是再分配 + * @node: 表达式节点 + * @qual_str: 谓词模式 + * @isRangeScanInRedis: 输出以指示谓词模式是否为redis中的范围扫描 + * @isRoot: 我们只想在根级别对谓词模式进行一次比较 + * - 返回: + * @result: 表达式树与dn稳定函数const评估 */ static Node* eval_dnstable_func_mutator( Relation rel, Node* node, StringInfo qual_str, RangeScanInRedis *rangeScanInRedis, bool isRoot) @@ -1057,7 +1057,7 @@ static Node* eval_dnstable_func_mutator( case T_FuncExpr: { FuncExpr* expr = (FuncExpr*)node; - /* flatten dn stable function into const value */ + /* 将一个稳定函数扁平化为const值 */ if (redis_func_dnstable(expr->funcid)) { Node* new_const = NULL; char* funcname = get_func_name(expr->funcid); @@ -1093,8 +1093,8 @@ static Node* eval_dnstable_func_mutator( Node* new_expr = eval_dnstable_func_mutator(rel, expr, qual_str, rangeScanInRedis, false); /* - * If a FuncExpr node is evalated into a T_Const value, we are hitting - * the point so replace it in qual list. + * 如果将FuncExpr节点求值为T_Const值，则为命中 + * 将点替换为等号列表。 */ if (expr && IsA(expr, FuncExpr) && new_expr && IsA(new_expr, Const)) { l = list_delete_ptr(l, expr); @@ -1103,8 +1103,8 @@ static Node* eval_dnstable_func_mutator( } /* - * If the predicate at root is something like "where ctid between pg_get_redis_rel_start_ctid('xx') - * and pg_get_redis_rel_end_ctid('xx')" on DN, we will pushdown the predicate at scan node. + * 如果在根的谓词类似于“where ctid between pg_get_redis_rel_start_ctid('xx')” + * 和pg_get_redis_rel_end_ctid('xx')"在DN上，我们将在扫描节点下推谓词。 */ if (isRoot && pg_strcasecmp(qual_str->data, RANGE_SCAN_IN_REDIS) == 0) { rangeScanInRedis->isRangeScanInRedis = true; @@ -1129,7 +1129,7 @@ static Node* eval_dnstable_func_mutator( } case T_Var: { Var* var = (Var*)node; - /* we only expect tid column in the predicate */ + /* 我们只期望谓词中有tid列 */ if (var->vartype == TIDOID) { appendStringInfoString(qual_str, "tid"); appendStringInfoString(qual_str, "+"); @@ -1147,10 +1147,10 @@ static Node* eval_dnstable_func_mutator( } /* - * - Brief: get and open new_table rel - * - Parameter: - * @rel: target relation of TRUNCATE operation - * - Return: + * - 简介:获取并打开new_table rel + * - 参数: + * @rel: TRUNCATE操作的目标关系 + * - 返回: * new_table rel */ Relation GetAndOpenNewTableRel(const Relation rel, LOCKMODE lockmode) @@ -1168,7 +1168,7 @@ Relation GetAndOpenNewTableRel(const Relation rel, LOCKMODE lockmode) data_redis_namespace = get_namespace_oid("data_redis", false); newtable_relid = get_relname_relid(new_tablename, data_redis_namespace); if (!OidIsValid(newtable_relid)) { - /* ERROR case, should never come here */ + /* 错误情况下，不应该出现在这里 */ ereport(ERROR, (errcode(ERRCODE_DATA_EXCEPTION), errmsg("new table %s is not found when do cluster resizing table \"%s\"", @@ -1185,18 +1185,18 @@ Relation GetAndOpenNewTableRel(const Relation rel, LOCKMODE lockmode) } /* - * - Brief: get the name of new table - * - Parameter: - * @relname: name of target table - * @newtable_name: output value for new table name - * - Return: - * no return value + * - 简介:获得新表的名称 + * - 参数: + * @relname: 目标表名 + * @newtable_name: 新表名的输出值 + * - 返回: + * 无返回值 */ void RelationGetNewTableName(Relation rel, char* newtable_name) { int rc = 0; - /* Check if output parameter it not palloc()-ed from caller side */ + /* 检查输出参数是否没有从调用方palloc()-ed */ if (newtable_name == NULL || rel == NULL) { ereport(ERROR, (errcode(ERRCODE_INVALID_PARAMETER_VALUE), @@ -1204,8 +1204,8 @@ void RelationGetNewTableName(Relation rel, char* newtable_name) } /* - * Look up relaion's reloptions to get table's cnoid to - * form the name of new table + * 查找关系的关联以获得表的关联 + * 形成新表的名称 */ if (!IsInitdb) { Oid rel_cn_oid = RelationGetRelCnOid(rel); @@ -1216,19 +1216,19 @@ void RelationGetNewTableName(Relation rel, char* newtable_name) rc = snprintf_s( newtable_name, NAMEDATALEN, NAMEDATALEN - 1, "data_redis_tmp_%s", RelationGetRelationName(rel)); } - /* check the return value of security function */ + /* 检查安全函数的返回值 */ securec_check_ss(rc, "\0", "\0"); } return; } /* - * - Brief: Determine if the relation is under cluster resizing write error mode - * - Parameter: - * @rel: relation that needs to check - * - Return: - * @TRUE: relation is under cluster resizing write error mode - * @FALSE: relation is not under cluster resizing write error mode + * - 简介:确定关系是否处于群集调整大小写错误模式 + * - 参数: + * @rel: 需要检查的关系 + * - 参数: + * @TRUE: 关系处于群集调整大小写错误模式 + * @FALSE: 关系不在群集调整大小写错误模式下 */ bool RelationInClusterResizingWriteErrorMode(const Relation rel) {