100644 blob f6a9c2cdc4211d6ee8223a1095f8c13dcdc12f3e	aggregation_sink_operator.cpp
100644 blob f0cc6b70d4e567f85b3756777b5f91046c561c69	aggregation_sink_operator.h
100644 blob d5385efdd06fe0164b1b4de071cc9db36e640ab6	aggregation_source_operator.cpp
100644 blob c9348826ca4f85dead552852f916c27519342d46	aggregation_source_operator.h
100644 blob f4fb437d31c023e9e89e7adf03d8fda0ac2adf27	analytic_sink_operator.cpp
100644 blob 9a64ba1d0b7ed7c8781d8b101d3345c8e17b4f04	analytic_sink_operator.h
100644 blob 3d25b20c7a40faf7ecf92f01c7f0477ee455b449	analytic_source_operator.cpp
100644 blob 696ec74cb69a3ba490703281b2a8bd0722daaac9	analytic_source_operator.h
100644 blob 0013eb294affc13491522cb5e20ceb63a75b4d5f	assert_num_rows_operator.cpp
100644 blob 29da76e8a964f5237164eb2dc3e8de4cdcee811c	assert_num_rows_operator.h
100644 blob 0745c3285ccea088dd33748ecd8f46c4676dd8dd	blackhole_sink_operator.cpp
100644 blob 23a2e9953063b09e738482169a91c57357de0575	blackhole_sink_operator.h
100644 blob 58f47001185983738a50a48cb0fd95d1e0b13d00	bucketed_aggregation_sink_operator.cpp
100644 blob 34b8103155e9dfbbe60d5bb3fe3e20748950b0ed	bucketed_aggregation_sink_operator.h
100644 blob 966b0acbc90a080f61a2d04551b47d494d24e053	bucketed_aggregation_source_operator.cpp
100644 blob 1a90c464ce73e5d10b6742b0cbd7a88bc8dd6f38	bucketed_aggregation_source_operator.h
100644 blob 88c1580f8d2e7d8479cfdea771cbf80653daebdd	cache_sink_operator.cpp
100644 blob a644a89416cd3d4d9508d19b3a401c0338f00a8a	cache_sink_operator.h
100644 blob aec8206f54b682d170c8856c9a18c84f46cd29a7	cache_source_operator.cpp
100644 blob fed5e3bb4f28284f016b45eecfce3c6e4b8c2be2	cache_source_operator.h
100644 blob 752e972c3e642fa9311defd6a30d50becda3709b	data_queue.cpp
100644 blob 1443e2ed5205bc7f8912db364eb7be7cfbc4c49d	data_queue.h
100644 blob a51b4fc978dc8056a02867fb3e755980bd907afa	datagen_operator.cpp
100644 blob 376f5960483b9eecf2396cb85b51174db36b7c06	datagen_operator.h
100644 blob bb0d1d9d146d085e5b258d4c6e0d1e29dff6f643	dict_sink_operator.cpp
100644 blob 2ae82b67a8977c99d5d41ca647ad89bdf7dcef41	dict_sink_operator.h
100644 blob 298896401d6f3e4a12a340d2fcfd1c1233ccdf24	distinct_streaming_aggregation_operator.cpp
100644 blob abf42eb50cc97738ec9b3386630fb680e63cbaa9	distinct_streaming_aggregation_operator.h
100644 blob 58c69bf91bc5da319450e9a4603ae61b8761c6f0	empty_set_operator.cpp
100644 blob 62dd855ea21e41cda71df175c058c41e71321cc8	empty_set_operator.h
100644 blob 2c564891da02f7e6d4902d1af1ff5298b9ec0175	exchange_sink_buffer.cpp
100644 blob 7478c63f4e8f12f02e1ebece5f3269a9466345d8	exchange_sink_buffer.h
100644 blob 35698f5217d70991cf208de27386bc41534c72c7	exchange_sink_operator.cpp
100644 blob ea224ed99bd4de109222639d232216ee3e690054	exchange_sink_operator.h
100644 blob e008d599078d7713e288497c404a96051637dd1f	exchange_source_operator.cpp
100644 blob da00e088586437654e21a2e9a46fcc6c86440f99	exchange_source_operator.h
100644 blob abb74523827afe93fd49cd06e5cd5ad783e9b126	file_scan_operator.cpp
100644 blob 39b97b11665114423e343411c9e6dd1c2462a330	file_scan_operator.h
100644 blob f29029ead7cc268cf6698013f8250a2c4b102215	group_commit_block_sink_operator.cpp
100644 blob 644100d42b045267382bc817dff58f6168f8f679	group_commit_block_sink_operator.h
100644 blob e591ed22eddfa2af483944f87e84cb78588a757c	group_commit_scan_operator.cpp
100644 blob 7ed01c16931ab9f079a6e2522f96f4b652e6e0fc	group_commit_scan_operator.h
100644 blob b75bd253026dbf4edbabb9ad8b27424e45347640	hashjoin_build_sink.cpp
100644 blob be77ef6cc690bc93722b96c76a3a8cb10f2c0cfe	hashjoin_build_sink.h
100644 blob 9b913cc9b234515e14ec8470cb89e7e9d28e31f2	hashjoin_probe_operator.cpp
100644 blob da60e8b52313c5c880859b0d5030d0f7b065fa74	hashjoin_probe_operator.h
100644 blob d40c90c71cc360deeea460c9aab45c0af8c2c574	hive_table_sink_operator.cpp
100644 blob a18af89f5df7405f23cfa553c924bebf722a1169	hive_table_sink_operator.h
100644 blob f4f8e0d926e1545032d7d386d327ded145796dc9	iceberg_delete_sink_operator.cpp
100644 blob f1d292a8b597ad0707b2abec6173d9d4025d54f6	iceberg_delete_sink_operator.h
100644 blob bc0ea96466e3579fed9f5bd9fea025a45f8c835f	iceberg_merge_sink_operator.cpp
100644 blob 6de1fbe59eb52a45c97b464bbf7cc5390730fc57	iceberg_merge_sink_operator.h
100644 blob 8d2074e3a49f689b07e75247bf0ec73d65e2ac8e	iceberg_table_sink_operator.cpp
100644 blob 2a9b59d7e3619e8d5b21e0b65e7a7d4638c88934	iceberg_table_sink_operator.h
100644 blob 5e1c8e97899fff774337b8b3e8e68ab4525fc8a4	jdbc_scan_operator.cpp
100644 blob feb11ff331a129e29243a2ae63be1ac1449c9617	jdbc_scan_operator.h
100644 blob ac5354df9882e5c3d46d63fa74f1f70730605ec4	jdbc_table_sink_operator.cpp
100644 blob 58a8e52cc7fddb94d466089eaa3c115ad9cf1c4c	jdbc_table_sink_operator.h
040000 tree 7b9e25d62c516fd66569e74bf8444dbf5eb199af	join
100644 blob 01b61ae1e81c381cb7a6522b3d691cb895f1c3a8	join_build_sink_operator.cpp
100644 blob 006d6c1f551c575a19be150af62da7685d148ee5	join_build_sink_operator.h
100644 blob cc36172b69d4c8b45fd3ca99944eac33a9ace3d4	join_probe_operator.cpp
100644 blob 2bea53b66a560a43d2b4c4fafa2b88d5891366e0	join_probe_operator.h
100644 blob dacd97357d391eb2c34c0545eb2a113ba46635f9	local_merge_sort_source_operator.cpp
100644 blob 6219edc4224983aa7dfdb4262c8fe06180ae62de	local_merge_sort_source_operator.h
100644 blob b8558218a4c99124642241321f3d1db22018d7a0	materialization_opertor.cpp
100644 blob 5cf2bf1ee9ee1b72c300b2eb64a3d5cfeabcbb48	materialization_opertor.h
100644 blob b364d2f461ae7e44612d4d045fbb65d210731a5e	maxcompute_table_sink_operator.cpp
100644 blob e1ec3b20ab1a3969c247692a9475b11bb7ecbfb0	maxcompute_table_sink_operator.h
100644 blob ff9e4d4f50846cb6303545cf1cc4b3017e51fd1e	memory_scratch_sink_operator.cpp
100644 blob 77fadc0c8da417bea160cf6fb607da1011fe1fc5	memory_scratch_sink_operator.h
100644 blob c94c7e213de8eb71454799d46a26771d85b3b66c	meta_scan_operator.cpp
100644 blob 05829c76a19dc2301cdb8b79ef7ae79966a6d475	meta_scan_operator.h
100644 blob a83b5de5448176b710b5dc8bed93632bd436323d	mock_operator.h
100644 blob 3250a4219b3587be717d0bb0bd168268d457ee16	mock_scan_operator.h
100644 blob 2d2ddcce458a9903b8e4e79233ddd8fe90f67a2a	multi_cast_data_stream_sink.cpp
100644 blob d1fcc8789244317f2c948cfa6f2aec2a2fcab610	multi_cast_data_stream_sink.h
100644 blob 8a669d3fbff65ef8eefc53058deeec9773611eac	multi_cast_data_stream_source.cpp
100644 blob f7ed78e376c3b986d9fb8d5acd09d89768af77ac	multi_cast_data_stream_source.h
100644 blob 538af373b4a95a43519184a250fbffb979974643	multi_cast_data_streamer.cpp
100644 blob 461e7ff34d2afd5f3ba9e02da1f1320f0f97a7e5	multi_cast_data_streamer.h
100644 blob b55b22d1a587208a9f31a256e33f195201347e28	nested_loop_join_build_operator.cpp
100644 blob 265a8767b3ec1cbc0d5c67a53131303913ee8584	nested_loop_join_build_operator.h
100644 blob 7a3be55cbb1988b6a55c067bf98e76e3b4d9cc0a	nested_loop_join_probe_operator.cpp
100644 blob aea6972f428becb71300005bbbae51cb7f884b53	nested_loop_join_probe_operator.h
100644 blob 5edcd3a43986289020d10d9100627e30338830c2	olap_scan_operator.cpp
100644 blob 04df02fec80fed13b96b8b38f1d9c6df2e08bb8c	olap_scan_operator.h
100644 blob e8261daf46bc9d7054d0541040359e30254999bb	olap_table_sink_operator.h
100644 blob 358cb4c10e2a7fa75d3d57e2d8cb9ec9308fe6a6	olap_table_sink_v2_operator.h
100644 blob 96f7933d5d52744afd9ce44adb0641e58542b334	operator.cpp
100644 blob d4b09a4aed3bb536a11cd3a2ef303a34b2b9ae1a	operator.h
100644 blob 76695b8ee3240c305417abd639d72db4f4816f1d	partition_sort_sink_operator.cpp
100644 blob 48b709d3f1f0cda4cdaf6e685d2dde5ac2468c51	partition_sort_sink_operator.h
100644 blob 3db89fb4cd292d59270602aed92ba6484488e4f6	partition_sort_source_operator.cpp
100644 blob 82bf052f1c06c833f7422f41d68bd598e4d5a04d	partition_sort_source_operator.h
100644 blob 07c96959d9834437815e5bc0a586350c07c4af38	partitioned_aggregation_sink_operator.cpp
100644 blob 56834757bd35a9b0e917d019fc54fee33e2ebd7d	partitioned_aggregation_sink_operator.h
100644 blob 6425cb3b92847bce3e0b19c8139e0039fe7ac0c9	partitioned_aggregation_source_operator.cpp
100644 blob 3e631d7c10c6fa0f99447e877436ad62108dfc3b	partitioned_aggregation_source_operator.h
100644 blob 56e80cee3f8ac20afd7d81de7996093e2a1954b7	partitioned_hash_join_probe_operator.cpp
100644 blob 15767504d85982d671b069acc7b0b3eb95d44f7a	partitioned_hash_join_probe_operator.h
100644 blob 4a0d4d0f42e63b5d62ee1fc1e2a2195b94c1d4e6	partitioned_hash_join_sink_operator.cpp
100644 blob c6dc2cdfb947684b96334e7f3f8bbadbbd8a36c6	partitioned_hash_join_sink_operator.h
100644 blob b8d1dfc52933c8aaf569ac226b5afab2ddceb71b	rec_cte_anchor_sink_operator.cpp
100644 blob 42661ee41813765eaf810025b174f35be691ec52	rec_cte_anchor_sink_operator.h
100644 blob adea08c4188b8710efa357e679dbbe09340137a7	rec_cte_scan_operator.h
100644 blob df26996e3eba6800ab9a0980cf9fc9ab6bc95bc7	rec_cte_sink_operator.cpp
100644 blob a071cf55761147de4e8de45857230a8cf77a9b76	rec_cte_sink_operator.h
100644 blob 1c32983b22a106750766ff07ba30505a909d0c40	rec_cte_source_operator.cpp
100644 blob 83e55937998e8b3c0a86807683094704436dffe9	rec_cte_source_operator.h
100644 blob 82ffa633056a413fb053fa0d9c4c0516eb23045d	repeat_operator.cpp
100644 blob 43348d2fc5a591d03531b4d27f882238f19e43dc	repeat_operator.h
100644 blob edc12412fce2d297fc88133a7ec5ece5b570ba5a	result_file_sink_operator.cpp
100644 blob 8c759456b8ed7ff7d4618c7a15630a982365c21c	result_file_sink_operator.h
100644 blob 2384a2e5f604213a7692cf6a78d876a7f15a5d7f	result_sink_operator.cpp
100644 blob b3a7c504a5d7ccc4bcddbfd7bcd5a679cfa5b11b	result_sink_operator.h
100644 blob 7f72b4be146afe755d3c974636dbfdd6769295e3	scan_operator.cpp
100644 blob f2ba87d4291412eb830aa4b63c1f83af74f54dfb	scan_operator.h
100644 blob 030e49b54d48c0327f06b59e0db48e999c7d9fd5	schema_scan_operator.cpp
100644 blob 49729cabf33624c2e0baf4b7539b171a3bf8b1b8	schema_scan_operator.h
100644 blob 9c4fa8af1bcfb24e7abca424f8a904ed57d1a597	select_operator.h
100644 blob 6954c93ee655e0866d92484ede5581b201e98882	set_probe_sink_operator.cpp
100644 blob c736e2af2296ef83bda7e43ce7a631eb3170e36b	set_probe_sink_operator.h
100644 blob 608bd8c1b69e58aea36e2e7929097ca89fc153df	set_sink_operator.cpp
100644 blob e1c937f147189193cb41e1110aa66167332674bb	set_sink_operator.h
100644 blob a314f4113110694b0272263dc348cc57ec320f34	set_source_operator.cpp
100644 blob 40887f35fab3f1f399469e1406a906bcc9c89870	set_source_operator.h
100644 blob 9b045da6d8c39255da38811ab596655e43e92207	sort_sink_operator.cpp
100644 blob eda5bb31b53b1a00916c7f2325a12d905fd3e5d9	sort_sink_operator.h
100644 blob 681411d46ef346de8b9076d81b3e9b6917bc022d	sort_source_operator.cpp
100644 blob c2a63b82ccd607f100d29f6718cad56907b2a2f8	sort_source_operator.h
100644 blob 13a04271f542ee9f5fe7f20d89d7f8282f32896b	spill_counters.h
100644 blob 8d2a2041ea9922cd12944e00135051cbcba47180	spill_iceberg_table_sink_operator.cpp
100644 blob b754e9988961979efb571ddd21e5162606bed49a	spill_iceberg_table_sink_operator.h
100644 blob f88774d3190d0b2c372d8769eb4ef3a4027f95a7	spill_sort_sink_operator.cpp
100644 blob 19cfa1b927425bee3f9788795296783b5968ba67	spill_sort_sink_operator.h
100644 blob a745bf2858d45b97cedcf193f4f72e92791d2170	spill_sort_source_operator.cpp
100644 blob 196ab6474b20062a64ca7c3e6f152502628a6cb7	spill_sort_source_operator.h
100644 blob 131c1c9b8b78e27b21667bda0da136059fa86ad6	spill_utils.h
100644 blob df2acc66ec81c7298567e377cc8594591bc16651	streaming_agg_min_reduction.h
100644 blob 5744b288a4487e2aaacb01c2fe5e51068b77ca27	streaming_aggregation_operator.cpp
100644 blob 40a8de2824446a01af2820dada7e157397e4b526	streaming_aggregation_operator.h
100644 blob 09e74f580dd1c2f4272e30cb2d4023433ef55976	table_function_operator.cpp
100644 blob 0a55c0905960353c58245146ab43bee16e17b235	table_function_operator.h
100644 blob c4a497c2f6514cdb9d1886edb889aeb4fd22d9ce	tvf_table_sink_operator.cpp
100644 blob 7c20f3c482e5e3b0cd06d2ff28838a64f255941d	tvf_table_sink_operator.h
100644 blob dc6fb2e0d9a1e34e31c86ffa87032378f92f86ac	union_sink_operator.cpp
100644 blob 4842ab6b2439037a2d21ebbec6ead0722ccb8ccb	union_sink_operator.h
100644 blob a484f1e4a324ba49fec0b35b00d5bea0cdd6297a	union_source_operator.cpp
100644 blob 748c9a48e60c558834907a365cfc84434b970c4d	union_source_operator.h