This is an automated email from the ASF dual-hosted git repository. panxiaolei pushed a commit to branch dev_rec in repository https://gitbox.apache.org/repos/asf/doris.git
commit 573f49f142e6d4cc9f73032209eea747606e3d64 Author: BiteTheDDDDt <[email protected]> AuthorDate: Thu Sep 18 21:02:33 2025 +0800 add rec cte thrift struct --- gensrc/thrift/PaloInternalService.thrift | 7 +++++++ gensrc/thrift/PlanNodes.thrift | 19 ++++++++++++++++++- 2 files changed, 25 insertions(+), 1 deletion(-) diff --git a/gensrc/thrift/PaloInternalService.thrift b/gensrc/thrift/PaloInternalService.thrift index 71179e17c48..df43e2d7683 100644 --- a/gensrc/thrift/PaloInternalService.thrift +++ b/gensrc/thrift/PaloInternalService.thrift @@ -662,6 +662,12 @@ struct TRuntimeFilterInfo { 2: optional list<PlanNodes.TTopnFilterDesc> topn_filter_descs } +struct TRecCTEMgr { + 1: optional i32 global_cte_node_number + 2: optional list<Types.TNetworkAddress> mgr_addrs + 3: optional list<Types.TUniqueId> fragment_instance_ids_to_reset +} + struct TPipelineFragmentParamsList { 1: optional list<TPipelineFragmentParams> params_list; 2: optional Descriptors.TDescriptorTable desc_tbl; @@ -679,4 +685,5 @@ struct TPipelineFragmentParamsList { 12: optional list<i32> topn_filter_source_node_ids 13: optional Types.TNetworkAddress runtime_filter_merge_addr 14: optional TRuntimeFilterInfo runtime_filter_info + 15: optional list<TRecCTEMgr> rec_cte_mgrs } diff --git a/gensrc/thrift/PlanNodes.thrift b/gensrc/thrift/PlanNodes.thrift index 4ce7b4770d6..2131e0c8330 100644 --- a/gensrc/thrift/PlanNodes.thrift +++ b/gensrc/thrift/PlanNodes.thrift @@ -60,7 +60,9 @@ enum TPlanNodeType { TEST_EXTERNAL_SCAN_NODE = 31, PARTITION_SORT_NODE = 32, GROUP_COMMIT_SCAN_NODE = 33, - MATERIALIZATION_NODE = 34 + MATERIALIZATION_NODE = 34, + REC_CTE_NODE = 35, + REC_CTE_SCAN_NODE = 36 } struct TKeyRange { @@ -692,6 +694,21 @@ struct TFileScanNode { 2: optional string table_name } +struct TRecCTETarget { + 1: optional Types.TNetworkAddress addr + 2: optional Types.TUniqueId fragment_instance_id + 3: optional i32 node_id +} + +struct TRecCTENode { + 1: optional list<TRecCTETarget> targets + 2: optional bool is_union_all +} + +struct TRecCTEScanNode { + 1: optional i32 source_instance_number +} + struct TEsScanNode { 1: required Types.TTupleId tuple_id 2: optional map<string,string> properties --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
