100644 blob 4adaecec6a9950244d2a2a39a36d651351acc827	aggregation_sink_operator.cpp
100644 blob 4d103d54119f822b0389cdcd935957f13532b1d0	aggregation_sink_operator.h
100644 blob 945fb24abe8cb64d98b373ba851ab2c3a74df2e7	aggregation_source_operator.cpp
100644 blob 090f493ae28ab464f92604b141e7bc4bd5aaf92f	aggregation_source_operator.h
100644 blob c7f2e42a57bb72ee37acf200f7986ad6ac88bbd2	analytic_sink_operator.cpp
100644 blob 31acbb80edd086b9b39d594fc968f126c82ece30	analytic_sink_operator.h
100644 blob d3bb0de39759090a2e906953372a0e9a1da102df	analytic_source_operator.cpp
100644 blob 72273ebd98a68ba1e95ee910887e8e0b47b6e7ed	analytic_source_operator.h
100644 blob 290ed763ed62f82a1b10f723796b9bd5747e8dbd	assert_num_rows_operator.cpp
100644 blob 29da76e8a964f5237164eb2dc3e8de4cdcee811c	assert_num_rows_operator.h
100644 blob e8daabec852261a43d8684e6d3adb504546e447d	blackhole_sink_operator.cpp
100644 blob 8bb32e3d4f7d22a7e5a70175775c34f8782849de	blackhole_sink_operator.h
100644 blob aee32541c5a5da9d15553c4532522be8f089a4a9	bucketed_aggregation_sink_operator.cpp
100644 blob 4f2abe0a96a6312d607774eacfd226752baab17d	bucketed_aggregation_sink_operator.h
100644 blob ac571248b5d128160dec9210dc95d2a43534eba7	bucketed_aggregation_source_operator.cpp
100644 blob 454b6f067a2d468fb7044a7929c9072f87066dce	bucketed_aggregation_source_operator.h
100644 blob 97c42b99c252c7501fa03c974ccee3ce0d9a0550	cache_sink_operator.cpp
100644 blob 6204b20eb950d6fa6423ed793994941850a34705	cache_sink_operator.h
100644 blob ec7d947680a6f8b052d5543c211e7b1df62105e1	cache_source_operator.cpp
100644 blob 3a68bd337fc5b73df195a0dff3b83574c4746dd7	cache_source_operator.h
100644 blob 752e972c3e642fa9311defd6a30d50becda3709b	data_queue.cpp
100644 blob 1443e2ed5205bc7f8912db364eb7be7cfbc4c49d	data_queue.h
100644 blob a9e0003c779391ff6078093b58f3925a673a8cdb	datagen_operator.cpp
100644 blob 7b2a5d4f69c4b8af03c920218d5d9fb054716467	datagen_operator.h
100644 blob 8f8a5a13685bb4029a50893fe385680c4053d185	dict_sink_operator.cpp
100644 blob 23747a996011bc8cb72e5657c77666277a9aad3e	dict_sink_operator.h
100644 blob e6a26904913500a93685db2aef57ce0c291d8e65	distinct_streaming_aggregation_operator.cpp
100644 blob 4ae652d498c65c832a5a9e4dbc120c98ba92bb96	distinct_streaming_aggregation_operator.h
100644 blob 72c91997f4c56444119f5e7bedbc20ecc3118c57	empty_set_operator.cpp
100644 blob 0f16236373ce008de683225e2a1f819c9c29c9cd	empty_set_operator.h
100644 blob 2c564891da02f7e6d4902d1af1ff5298b9ec0175	exchange_sink_buffer.cpp
100644 blob 7478c63f4e8f12f02e1ebece5f3269a9466345d8	exchange_sink_buffer.h
100644 blob 2011a44d2ca6c6e29950e81067b3af3f63ed0de1	exchange_sink_operator.cpp
100644 blob 10351154d1d8cd10be493dbed29753b6d06ba2bc	exchange_sink_operator.h
100644 blob 1e4d24de8e86c297a7747f4283ae90cce7a1bdf6	exchange_source_operator.cpp
100644 blob 0c4aa1e43ebf44aa4aefe9ed0f5c9c61eb4aab42	exchange_source_operator.h
100644 blob 2a87f413a15bd69d728f5c79ca6a9138d4214996	file_scan_operator.cpp
100644 blob d4e31195a4459a846ad5c1c16c8ae1e3bc8a2026	file_scan_operator.h
100644 blob 38ea6d3c18a3440f771139f4047b924ca98ae551	group_commit_block_sink_operator.cpp
100644 blob 854f2f3cc1d2688b525672f28de203640a014c15	group_commit_block_sink_operator.h
100644 blob 209481d86bf213f80abb542546d7b605b4795456	group_commit_scan_operator.cpp
100644 blob 679b46b11258a443691ab56bfa72466c377538d9	group_commit_scan_operator.h
100644 blob ebd90a462ece4635c13262e0961277ba0fdbe07b	hashjoin_build_sink.cpp
100644 blob dda24cef91b373ac367ce30561694e49a744de86	hashjoin_build_sink.h
100644 blob 80543c55e4ec4ad51c86d50921471d95f2ff04a0	hashjoin_probe_operator.cpp
100644 blob da60e8b52313c5c880859b0d5030d0f7b065fa74	hashjoin_probe_operator.h
100644 blob d40c90c71cc360deeea460c9aab45c0af8c2c574	hive_table_sink_operator.cpp
100644 blob 51161809e6846147276c59f66483d07b194cc329	hive_table_sink_operator.h
100644 blob f4f8e0d926e1545032d7d386d327ded145796dc9	iceberg_delete_sink_operator.cpp
100644 blob 12f93bfc8b60e52719b978138c205b6d87f44bee	iceberg_delete_sink_operator.h
100644 blob bc0ea96466e3579fed9f5bd9fea025a45f8c835f	iceberg_merge_sink_operator.cpp
100644 blob 0cf64681c1d58fe257aa8901dd8be3b1f94f9b52	iceberg_merge_sink_operator.h
100644 blob 8d2074e3a49f689b07e75247bf0ec73d65e2ac8e	iceberg_table_sink_operator.cpp
100644 blob 0dec306edebdde802e35c60caba9806380697d21	iceberg_table_sink_operator.h
100644 blob 5e1c8e97899fff774337b8b3e8e68ab4525fc8a4	jdbc_scan_operator.cpp
100644 blob feb11ff331a129e29243a2ae63be1ac1449c9617	jdbc_scan_operator.h
100644 blob 9ee8828714dad739ea70d76f606fc214454378f0	jdbc_table_sink_operator.cpp
100644 blob a557ec80a8dad246d4b7e558cdde07ca35d15b1e	jdbc_table_sink_operator.h
040000 tree 6b53e867862a6365cd097630e1cdd46e20fb8629	join
100644 blob 719b33fab2e7b848fb0a4b070ba7f2ce16e32187	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 dc3bf09d7f8f5e8ea6239b6aa59f1a8b0c04f789	local_merge_sort_source_operator.cpp
100644 blob b22193c3686bcc3f2234cb4b8c579d6dda54000c	local_merge_sort_source_operator.h
100644 blob 7ceeae0f261f23d39aa9fd051f580a3ca5cd3579	materialization_opertor.cpp
100644 blob 5cf2bf1ee9ee1b72c300b2eb64a3d5cfeabcbb48	materialization_opertor.h
100644 blob b364d2f461ae7e44612d4d045fbb65d210731a5e	maxcompute_table_sink_operator.cpp
100644 blob 3332143080bb4b6dfe0f05be4dbf1f948511eb2e	maxcompute_table_sink_operator.h
100644 blob 5635a65168fb8d4d31a00d8c17a45c348f387464	memory_scratch_sink_operator.cpp
100644 blob f12e118e75ed0ba27f498e36eaca25a4a25d13ec	memory_scratch_sink_operator.h
100644 blob c94c7e213de8eb71454799d46a26771d85b3b66c	meta_scan_operator.cpp
100644 blob 05829c76a19dc2301cdb8b79ef7ae79966a6d475	meta_scan_operator.h
100644 blob 3c8d133def4156e038843b501dc110d5eb3da897	mock_operator.h
100644 blob 3eaa78366a8e465bd1f4d4b49ab69437c3194b70	mock_scan_operator.h
100644 blob 7a13a05eaebe279fd13c68036add6da01ff26106	multi_cast_data_stream_sink.cpp
100644 blob 0b0dc7ca5372802b80e077a2aabdc6a8c0c0f9a2	multi_cast_data_stream_sink.h
100644 blob 2b9e663ce07cc81179c24411c911493f946511d8	multi_cast_data_stream_source.cpp
100644 blob 31488df78dac8166d28c792d8f0ab6aedaa1164d	multi_cast_data_stream_source.h
100644 blob 34b09bc712d8606c1389b842b32fc9a281537e66	multi_cast_data_streamer.cpp
100644 blob 01264301b775df81baae1099f31f0d58c25eca08	multi_cast_data_streamer.h
100644 blob 5c62e974cf8b301cc5c4ae081e1c07bb84be1609	nested_loop_join_build_operator.cpp
100644 blob 818d914972d4cb6e8ae4ff0c1f69aa1c24b336a5	nested_loop_join_build_operator.h
100644 blob fd80d5471cea73dbec5fa70e4ffc2dab4e736be7	nested_loop_join_probe_operator.cpp
100644 blob 2bbe6794cdf3cccf437130be9451aab68cc90236	nested_loop_join_probe_operator.h
100644 blob 92dfbaaeae02d97d8bc4ea429ecc9cad4a1cca03	olap_scan_operator.cpp
100644 blob d22aac75052ff274952e9fedb262dcc46823457f	olap_scan_operator.h
100644 blob 9567b82e082197583f6422c1840ed8aa5c722761	olap_table_sink_operator.h
100644 blob 038484c83eef9dd6e109413f3d1e5aa8d267f8da	olap_table_sink_v2_operator.h
100644 blob 60f199b2b4977933b4bae77c605a4920b6671432	operator.cpp
100644 blob 8585f0be741bb657d4c2277fb7586d4bfc74b2cc	operator.h
100644 blob 0f358fb70ada6976f71154adf70a94260354d749	partition_sort_sink_operator.cpp
100644 blob 68a698dff8f37836abb4d6a9b588f7ed2244c34a	partition_sort_sink_operator.h
100644 blob 7e07cd9d307d461b558976db3d3aedfde48e802e	partition_sort_source_operator.cpp
100644 blob def4cab8ea0eeabe760b517aa733f9c72377d04f	partition_sort_source_operator.h
100644 blob 677077f4766a3a7090a899805a8dc5f980bcfcfe	partitioned_aggregation_sink_operator.cpp
100644 blob b7916f755c4a399acc2a8a91a1ce79e79c479b1d	partitioned_aggregation_sink_operator.h
100644 blob 14acb7270527216fa126c3d4d91919a7b94d83d0	partitioned_aggregation_source_operator.cpp
100644 blob 540b60064bb54facd9a7591f6f39f62dabdad19b	partitioned_aggregation_source_operator.h
100644 blob 561f0873adc478d2d767a32242a03218f04e6da7	partitioned_hash_join_probe_operator.cpp
100644 blob 01787014c8d12f4ff9c0b2b19ce43de52571001a	partitioned_hash_join_probe_operator.h
100644 blob acd69a2ef24457403fdd929556f4efaec634c813	partitioned_hash_join_sink_operator.cpp
100644 blob f48fe8f71373468c20fee5dc6b9fc8d3c668f540	partitioned_hash_join_sink_operator.h
100644 blob b8d1dfc52933c8aaf569ac226b5afab2ddceb71b	rec_cte_anchor_sink_operator.cpp
100644 blob 4e8596497adcd176303f3d5bba0eb7492ee660e2	rec_cte_anchor_sink_operator.h
100644 blob c374fe509ca3fc32d940544df8d25ddc45eb53f5	rec_cte_scan_operator.h
100644 blob df26996e3eba6800ab9a0980cf9fc9ab6bc95bc7	rec_cte_sink_operator.cpp
100644 blob a351effb34adb5fefc2be048de12c0a1567b5493	rec_cte_sink_operator.h
100644 blob 1c32983b22a106750766ff07ba30505a909d0c40	rec_cte_source_operator.cpp
100644 blob 07f1c2c39a6946b5bf8d5ec1d878e6db8756ea22	rec_cte_source_operator.h
100644 blob b659052187b17a4b33ddbb84a77ab0865b93d0af	repeat_operator.cpp
100644 blob 43348d2fc5a591d03531b4d27f882238f19e43dc	repeat_operator.h
100644 blob 7207a0dc503175799e1c854903ba1fa80ae93bf3	result_file_sink_operator.cpp
100644 blob 6151918df9bb4c393cd7c34aa4caf3e62c6592f9	result_file_sink_operator.h
100644 blob 021ffb60983180bdca363c06ec07736e333c45dd	result_sink_operator.cpp
100644 blob 4ead2985d8516261bea1a8d36196ea17b20b6548	result_sink_operator.h
100644 blob f661244d39adbd4325382ca15eeb4578d1e9a679	scan_operator.cpp
100644 blob e20262eb85fcf70a8ad79f10a79b797d893fc1eb	scan_operator.h
100644 blob 95ee374824c38a431fe33823d624b4d9df00503c	schema_scan_operator.cpp
100644 blob fc7c79067d964230e5db856a85dc48d4b22d5ad9	schema_scan_operator.h
100644 blob 9c4fa8af1bcfb24e7abca424f8a904ed57d1a597	select_operator.h
100644 blob c3fb08a3725efcd9e63e09b35003eca2ef85dd24	set_probe_sink_operator.cpp
100644 blob 7c294fe72541ce04cc14d7dbbff32cbf8f847c96	set_probe_sink_operator.h
100644 blob 614a45afbc87700b9265ce0c05f4b037222f0905	set_sink_operator.cpp
100644 blob 5ac71634cd8f057398cd2746666319a1eebfa33f	set_sink_operator.h
100644 blob 63afdae0814f81beac3587d462ae1115e32141bf	set_source_operator.cpp
100644 blob cacfd6a335f8a391f5a411a9e4cfa2ce1a79d614	set_source_operator.h
100644 blob 9c77b52bd0236d9715cf9289e6d727553b71ec1b	sort_sink_operator.cpp
100644 blob b0c66483b9be7cbb01fc5533d66d5851e2fc36d4	sort_sink_operator.h
100644 blob 88ab9261b4a9b69c68946ccc1c6345592cbe9892	sort_source_operator.cpp
100644 blob 79e59f635e0b72d8e815fcf159f8925c2087a9c4	sort_source_operator.h
100644 blob 13a04271f542ee9f5fe7f20d89d7f8282f32896b	spill_counters.h
100644 blob cf7c8e6e1a15380dd646790b710f8c896b4cb74c	spill_iceberg_table_sink_operator.cpp
100644 blob 6da926ae20fb91f9c29472de7784eb2f71382196	spill_iceberg_table_sink_operator.h
100644 blob 87098451e261b8ca2ed1a7f6e882026eeff5083d	spill_sort_sink_operator.cpp
100644 blob cf27bd3765b18f1c42f60eaf8e45d382c344946e	spill_sort_sink_operator.h
100644 blob 40f15832cfe10b0895b3ca6d7bd519f5a319d7a1	spill_sort_source_operator.cpp
100644 blob 25fdd306b4b5f8cf6284bf8e481c6cae11e53f78	spill_sort_source_operator.h
100644 blob dff39d5212feda4f3f527644b527d2e7c302efe3	spill_utils.h
100644 blob df2acc66ec81c7298567e377cc8594591bc16651	streaming_agg_min_reduction.h
100644 blob b3e789e6e0f8a2547cc5da240fc3bc93e7a22c44	streaming_aggregation_operator.cpp
100644 blob 007da4188651f1fd20298b27c781fb65c9eecab6	streaming_aggregation_operator.h
100644 blob 4cf3a3642c50080a1ac237a6f148923a72ebc56e	table_function_operator.cpp
100644 blob 0a55c0905960353c58245146ab43bee16e17b235	table_function_operator.h
100644 blob c4a497c2f6514cdb9d1886edb889aeb4fd22d9ce	tvf_table_sink_operator.cpp
100644 blob e1a06e675c9485a061e4e73fbcb7540f79e693f8	tvf_table_sink_operator.h
100644 blob b0f7cf619a8ee1176150c05e74e27844a57cd91a	union_sink_operator.cpp
100644 blob 4da532b9f0b55fe3ce3d194d466973f993041651	union_sink_operator.h
100644 blob 6cc39ebb7ce935e5d6d871bb6a709089e40490e7	union_source_operator.cpp
100644 blob 01de0cbb05bf69ba265e5fcb4e78d3b008e2a33b	union_source_operator.h