-
Notifications
You must be signed in to change notification settings - Fork 797
Open
Labels
C-refactoringCategory: refactorCategory: refactor
Description
Summary
transforms/
├── filters/ # Filter transformations
│ ├── mod.rs # New: Export module contents
│ ├── filter_predicate.rs # Source: transform_filter.rs
│ └── filter_limit.rs # Source: transform_limit.rs
│
├── blocks/ # Block operations
│ ├── mod.rs # New: Export module contents
│ └── block_merge.rs # Source: transform_merge_block.rs
│
├── columns/ # Column operations
│ ├── mod.rs # New: Export module contents
│ ├── column_add_computed.rs # Source: transform_add_computed_columns.rs
│ ├── column_add_const.rs # Source: transform_add_const_columns.rs
│ ├── column_add_internal.rs # Source: transform_add_internal_columns.rs
│ ├── column_add_stream.rs # Source: transform_add_stream_columns.rs
│ ├── column_cast.rs # Source: transform_cast_schema.rs
│ └── column_nullif.rs # Source: transform_null_if.rs
│
├── aggregates/ # Aggregation operations
│ ├── mod.rs # New: Export module contents
│ ├── agg_partial.rs # Source: aggregator/transform_aggregate_partial.rs
│ ├── agg_final.rs # Source: aggregator/transform_aggregate_final.rs
│ ├── agg_expand.rs # Source: aggregator/transform_aggregate_expand.rs
│ ├── agg_single_key.rs # Source: aggregator/transform_single_key.rs
│ ├── agg_meta.rs # Source: aggregator/aggregate_meta.rs
│ ├── agg_params.rs # Source: aggregator/aggregator_params.rs
│ ├── agg_injector.rs # Source: aggregator/aggregate_exchange_injector.rs
│ ├── agg_bucket.rs # Source: aggregator/new_transform_partition_bucket.rs
│ └── serde/ # Aggregation serialization
│ ├── mod.rs # Source: aggregator/serde/mod.rs
│ ├── agg_serializer.rs # Source: aggregator/serde/transform_aggregate_serializer.rs
│ ├── agg_deserializer.rs # Source: aggregator/serde/transform_aggregate_deserializer.rs
│ ├── agg_spill_writer.rs # Source: aggregator/serde/transform_aggregate_spill_writer.rs
│ └── agg_exchange.rs # Source: aggregator/serde/transform_exchange_aggregate_serializer.rs
│
├── joins/ # Join operations
│ ├── mod.rs # New: Export module contents
│ ├── hash/ # Hash joins
│ │ ├── mod.rs # Source: hash_join/mod.rs
│ │ ├── join_hash_build.rs # Source: hash_join/transform_hash_join_build.rs
│ │ ├── join_hash_probe.rs # Source: hash_join/transform_hash_join_probe.rs
│ │ ├── join_hash_state.rs # Source: hash_join/hash_join_build_state.rs
│ │ ├── join_hash_desc.rs # Source: hash_join/desc.rs
│ │ ├── join_hash_common.rs # Source: hash_join/common.rs
│ │ ├── join_hash_util.rs # Source: hash_join/util.rs
│ │ └── probe_join/ # Source: hash_join/probe_join/ (maintain existing structure)
│ └── range/ # Range joins
│ ├── mod.rs # Source: range_join/mod.rs
│ ├── join_range_transform.rs # Source: range_join/transform_range_join.rs
│ ├── join_range_state.rs # Source: range_join/range_join_state.rs
│ ├── join_range_ie_state.rs # Source: range_join/ie_join_state.rs
│ ├── join_range_filter.rs # Source: range_join/filter_block.rs
│ └── join_range_match.rs # Source: range_join/order_match.rs
│
├── sorts/ # Sort operations
│ ├── mod.rs # New: Export module contents
│ ├── merge/ # Merge sort
│ │ ├── mod.rs # New: Export merge sort components
│ │ ├── sort_merge_transform.rs # Source: transform_merge_sort.rs
│ │ ├── sort_merge_builder.rs # Source: transform_merge_sort/builder.rs
│ │ └── sort_merge_spill.rs # Source: transform_merge_sort/sort_spill.rs
│ └── resort/ # Resort operations
│ ├── mod.rs # New: Export resort components
│ ├── sort_resort_addon.rs # Source: transform_resort_addon.rs
│ └── sort_resort_noschema.rs # Source: transform_resort_addon_without_source_schema.rs
│
├── scans/ # Scan operations
│ ├── mod.rs # New: Export module contents
│ ├── scan_cache.rs # Source: transform_cache_scan.rs
│ ├── scan_expression.rs # Source: transform_expression_scan.rs
│ ├── scan_cte.rs # Source: transform_recursive_cte_scan.rs
│ └── scan_cte_source.rs # Source: transform_recursive_cte_source.rs
│
├── functions/ # Function operations
│ ├── mod.rs # New: Export module contents
│ ├── func_async.rs # Source: transform_async_function.rs
│ ├── func_udf_script.rs # Source: transform_udf_script.rs
│ ├── func_udf_server.rs # Source: transform_udf_server.rs
│ └── func_table.rs # Source: transform_srf.rs
│
├── dictionaries/ # Dictionary operations
│ ├── mod.rs # New: Export module contents
│ └── dict_ops.rs # Source: transform_dictionary.rs
│
├── sets/ # Set operations
│ ├── mod.rs # New: Export module contents
│ └── set_create.rs # Source: transform_create_sets.rs
│
├── windows/ # Window functions
│ ├── mod.rs # Source: window/mod.rs
│ ├── window_transform.rs # Source: window/transform_window.rs
│ ├── window_state.rs # Source: window/window_state.rs
│ ├── window_frame.rs # Source: window/window_frame.rs
│ ├── window_function.rs # Source: window/window_function.rs
│ └── [other files] # Source: Other files in window/ directory
│
├── runtimes/ # Runtime utilities
│ ├── mod.rs # New: Export module contents
│ └── runtime_pool.rs # Source: runtime_pool.rs
│
└── mod.rs # Update: Main module file, re-exports all public components
wubx
Metadata
Metadata
Assignees
Labels
C-refactoringCategory: refactorCategory: refactor