feat: support schedule/reschedule resource group #19955

shanicky · 2024-12-27T16:26:30Z

I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

This PR adds support for resource groups for database (although it is not enabled), and provides specific resource group support for the materialized views that will be used for serverless backfill.

At the same time, scaling also supports resource groups.

This PR also adds support for altering resource groups (only for materialized views).

Since altering resource groups is also a form of rescheduling, I have unified the logic with the previous alter parallelism and changed most of the existing alter logic for parallelism to reschedule streaming jobs, making it more consistent.

This PR still needs some testing, including simulations with madsim.
Currently, the manual invocation of the alter command is working fine.

dev=> create table t(v int);
CREATE_TABLE
dev=> create materialized view m1 as select count(*) from t;
CREATE_MATERIALIZED_VIEW
dev=> create materialized view m2 as select * from m1;
CREATE_MATERIALIZED_VIEW
dev=> alter materialized view m1 set resource_group to test;
ERROR:  Failed to run the query

Caused by these errors (recent errors listed first):
  1: gRPC request to meta service failed: Internal error
  2: Cannot resize streaming_job 7 to empty worker set

# add new worker with `test` resource group

dev=> alter materialized view m1 set resource_group to test;
ALTER_MATERIALIZED_VIEW
dev=> alter materialized view m2 set resource_group to test;
ALTER_MATERIALIZED_VIEW
dev=> alter materialized view m1 reset resource_group;
ALTER_MATERIALIZED_VIEW
dev=> alter materialized view m2 reset resource_group;
ALTER_MATERIALIZED_VIEW

Checklist

I have written necessary rustdoc comments.
I have added necessary unit tests and integration tests.
I have added test labels as necessary.
I have added fuzzing tests or opened an issue to track them.
My PR contains breaking changes.
My PR changes performance-critical code, so I will run (micro) benchmarks and present the results.
My PR contains critical fixes that are necessary to be merged into the latest release.

Documentation

My PR needs documentation updates.

Release note

Signed-off-by: Shanicky Chen <[email protected]> Add schedulable workers with label filtering; update cluster info retrieval and actor graph prep. Enhance worker parallelism in `StreamingClusterInfo` with job label support; add filtering helper. Refactor system for resource group management; replace job labels with resource groups across codebase. Refactor: Improve code formatting, remove unused imports, update function signatures Signed-off-by: Shanicky Chen <[email protected]> Replace node_label with resource_group, update related code Signed-off-by: Shanicky Chen <[email protected]> Remove commented code for resource groups in CatalogController Signed-off-by: Shanicky Chen <[email protected]>

…use `DEFAULT_RESOURCE_GROUP`. Refactor scaling: JobReschedulePlan with parallelism and resource group updates Signed-off-by: Shanicky Chen <[email protected]> Perf improvements, code cleanup, simplify recovery logic, update String conversions Signed-off-by: Shanicky Chen <[email protected]> Add AlterResourceGroup RPC and support for altering resource groups in views Signed-off-by: Shanicky Chen <[email protected]> Refactor job rescheduling: add parallelism/resource group targets, update handlers Signed-off-by: Shanicky Chen <[email protected]> Implement resource group alteration and cleanup unused code (100 chars) Signed-off-by: Shanicky Chen <[email protected]> tmp Signed-off-by: Shanicky Chen <[email protected]>

…e-group

shanicky · 2024-12-27T16:27:33Z

Cargo.toml

@@ -315,7 +315,7 @@ redundant_explicit_links = "allow"
 lto = "off"
 # use parallel frontend to speed up build
 # TODO: may consider applying to release/production profile as well
-rustflags = ["-Z", "threads=8"]
+#rustflags = ["-Z", "threads=8"]


will be reverted once approved

…t comments.

…e_group.rs` with `.to_owned()`

…e-group

github-actions

license-eye has checked 5532 files.

Valid	Invalid	Ignored	Fixed
0	2334	3198	0

Click to see the invalid file list

dashboard/hook/useErrorToast.ts
dashboard/lib/algo.ts
dashboard/lib/api/api.ts
dashboard/lib/api/cluster.ts
dashboard/lib/api/fetch.ts
dashboard/lib/api/metric.ts
dashboard/lib/api/streaming.ts
dashboard/lib/extractInfo.ts
dashboard/lib/layout.ts
dashboard/lib/util.js
dashboard/mock-server.js
dashboard/next.config.js
java/common-utils/src/main/java/com/risingwave/java/utils/MetaClient.java
java/common-utils/src/main/java/com/risingwave/java/utils/ObjectSerde.java
java/common-utils/src/main/java/com/risingwave/java/utils/UrlParser.java
java/common-utils/src/main/java/com/risingwave/java/utils/VnodeHelper.java
java/common-utils/src/test/java/com/risingwave/connector/utils/VnodeHelperTest.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/TestUtils.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/ColumnDesc.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/Monitor.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/PkComparator.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/TableSchema.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/ArraySinkRow.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/CloseableIterable.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/CommonSinkConfig.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/Deserializer.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkCoordinator.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkFactory.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkRow.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkWriter.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkWriterBase.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/SinkWriterV1.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/sink/TrivialCloseIterable.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/source/CdcEngine.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/source/CdcEngineRunner.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/source/SourceConfig.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/source/SourceHandler.java
java/connector-node/connector-api/src/main/java/com/risingwave/connector/api/source/SourceTypeE.java
java/connector-node/python-client/integration_tests.py
java/connector-node/python-client/proto/init.py
java/connector-node/python-client/pyspark-util.py
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/ConnectorService.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/ConnectorServiceImpl.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/FileSink.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/FileSinkConfig.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/FileSinkFactory.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkCoordinatorHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkCoordinatorResponseObserver.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkValidationHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/JniSinkWriterResponseObserver.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkCoordinatorStreamObserver.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkUtils.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkValidationHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/SinkWriterStreamObserver.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/deserializer/StreamChunkDeserializer.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/JniSourceValidateHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/SourceRequestHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/CdcConnectorException.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/CitusValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DatabaseValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzConnectorConfig.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/DbzSourceUtils.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/MongoDbValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/MySqlValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/PostgresValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/SqlServerValidator.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/common/ValidatorUtils.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEngine.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzCdcEngineRunner.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzChangeEventConsumer.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzJsonConverter.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/DbzSourceHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/JniDbzSourceHandler.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/JniDbzSourceRegistry.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/core/SourceHandlerFactory.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/metrics/ConnectorNodeMetrics.java
java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/metrics/MonitoredRowIterable.java
java/connector-node/risingwave-connector-service/src/test/java/com/risingwave/connector/sink/FileSinkTest.java
java/connector-node/risingwave-connector-service/src/test/java/com/risingwave/connector/sink/SinkStreamObserverTest.java
java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraConfig.java
java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraFactory.java
java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraSink.java
java/connector-node/risingwave-sink-cassandra/src/main/java/com/risingwave/connector/CassandraUtil.java
java/connector-node/risingwave-sink-deltalake-test/src/test/java/com/risingwave/connector/sink/deltalake/DeltaLakeLocalSinkTest.java
java/connector-node/risingwave-sink-deltalake-test/src/test/java/com/risingwave/connector/sink/deltalake/DeltaLakeSinkFactoryTest.java
java/connector-node/risingwave-sink-deltalake/src/main/java/com/risingwave/connector/DeltaLakeSink.java
java/connector-node/risingwave-sink-deltalake/src/main/java/com/risingwave/connector/DeltaLakeSinkConfig.java
java/connector-node/risingwave-sink-deltalake/src/main/java/com/risingwave/connector/DeltaLakeSinkFactory.java
java/connector-node/risingwave-sink-deltalake/src/main/java/com/risingwave/connector/DeltaLakeSinkUtil.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/BulkListener.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/BulkProcessorAdapter.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/ElasticBulkProcessorAdapter.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/ElasticRestHighLevelClientAdapter.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/EsSink.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/EsSinkConfig.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/EsSinkFactory.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/OpensearchBulkProcessorAdapter.java
java/connector-node/risingwave-sink-es-7/src/main/java/com/risingwave/connector/OpensearchRestHighLevelClientAdapter.java
java/connector-node/risingwave-sink-es-7/src/test/java/com/risingwave/connector/sink/elasticsearch/EsSinkTest.java
java/connector-node/risingwave-sink-iceberg/src/main/java/com/risingwave/connector/catalog/GlueCredentialProvider.java
java/connector-node/risingwave-sink-iceberg/src/main/java/com/risingwave/connector/catalog/JniCatalogWrapper.java
java/connector-node/risingwave-sink-iceberg/src/main/java/com/risingwave/connector/catalog/RESTObjectMapper.java
java/connector-node/risingwave-sink-iceberg/src/test/java/com/risingwave/connector/catalog/JniCatalogWrapperTest.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSink.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSinkConfig.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JDBCSinkFactory.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/JdbcDialect.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/JdbcDialectFactory.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/MySqlDialect.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/MySqlDialectFactory.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/PostgresDialect.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/PostgresDialectFactory.java
java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/jdbc/SchemaTableName.java
java/connector-node/risingwave-sink-jdbc/src/test/java/com/risingwave/connector/sink/jdbc/JDBCSinkTest.java
java/connector-node/risingwave-source-cdc-test/src/test/java/com/risingwave/connector/source/MongoDbSourceTest.java
java/connector-node/risingwave-source-cdc-test/src/test/java/com/risingwave/connector/source/MongoDbValidatorTest.java
java/connector-node/risingwave-source-cdc-test/src/test/java/com/risingwave/connector/source/MySQLSourceTest.java
java/connector-node/risingwave-source-cdc-test/src/test/java/com/risingwave/connector/source/PostgresSourceTest.java
java/connector-node/risingwave-source-cdc-test/src/test/java/com/risingwave/connector/source/SourceTestClient.java
java/connector-node/risingwave-source-cdc/src/main/java/com/risingwave/connector/cdc/debezium/converters/DatetimeTypeConverter.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/PostgresSchema.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/connection/ReplicationStream.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/embedded/EmbeddedEngineChangeEventProxy.java
java/connector-node/s3-common/src/main/java/com/risingwave/connector/common/S3Config.java
java/connector-node/s3-common/src/main/java/com/risingwave/connector/common/S3Utils.java
java/connector-node/tracing/src/main/java/com/risingwave/tracing/TracingSlf4jAdapter.java
java/connector-node/tracing/src/main/java/com/risingwave/tracing/TracingSlf4jImpl.java
java/connector-node/tracing/src/main/java/com/risingwave/tracing/TracingSlf4jLoggerFactory.java
java/connector-node/tracing/src/main/java/com/risingwave/tracing/TracingSlf4jServiceProvider.java
java/java-binding-benchmark/src/main/java/com/risingwave/java/binding/ArrayListBenchmark.java
java/java-binding-benchmark/src/main/java/com/risingwave/java/binding/BenchmarkRunner.java
java/java-binding-benchmark/src/main/java/com/risingwave/java/binding/StreamchunkBenchmark.java
java/java-binding-integration-test/src/main/java/com/risingwave/java/binding/HummockReadDemo.java
java/java-binding-integration-test/src/main/java/com/risingwave/java/binding/StreamChunkDemo.java
java/java-binding-integration-test/src/main/java/com/risingwave/java/binding/Utils.java
java/java-binding/src/main/java/com/risingwave/java/binding/BaseRow.java
java/java-binding/src/main/java/com/risingwave/java/binding/Binding.java
java/java-binding/src/main/java/com/risingwave/java/binding/HummockIterator.java
java/java-binding/src/main/java/com/risingwave/java/binding/JniSinkWriterStreamRequest.java
java/java-binding/src/main/java/com/risingwave/java/binding/KeyedRow.java
java/java-binding/src/main/java/com/risingwave/java/binding/StreamChunk.java
java/java-binding/src/main/java/com/risingwave/java/binding/StreamChunkIterator.java
java/java-binding/src/main/java/com/risingwave/java/binding/StreamChunkRow.java
src/batch/executors/benches/expand.rs
src/batch/executors/benches/filter.rs
src/batch/executors/benches/hash_agg.rs
src/batch/executors/benches/hash_join.rs
src/batch/executors/benches/limit.rs
src/batch/executors/benches/nested_loop_join.rs
src/batch/executors/benches/sort.rs
src/batch/executors/benches/top_n.rs
src/batch/executors/benches/utils/mod.rs
src/batch/executors/src/executor.rs
src/batch/executors/src/executor/aggregation/distinct.rs
src/batch/executors/src/executor/aggregation/filter.rs
src/batch/executors/src/executor/aggregation/mod.rs
src/batch/executors/src/executor/aggregation/orderby.rs
src/batch/executors/src/executor/aggregation/projection.rs
src/batch/executors/src/executor/delete.rs
src/batch/executors/src/executor/expand.rs
src/batch/executors/src/executor/filter.rs
src/batch/executors/src/executor/generic_exchange.rs
src/batch/executors/src/executor/group_top_n.rs
src/batch/executors/src/executor/hash_agg.rs
src/batch/executors/src/executor/hop_window.rs
src/batch/executors/src/executor/iceberg_scan.rs
src/batch/executors/src/executor/insert.rs
src/batch/executors/src/executor/join/chunked_data.rs
src/batch/executors/src/executor/join/distributed_lookup_join.rs
src/batch/executors/src/executor/join/hash_join.rs
src/batch/executors/src/executor/join/local_lookup_join.rs
src/batch/executors/src/executor/join/lookup_join_base.rs
src/batch/executors/src/executor/join/mod.rs
src/batch/executors/src/executor/join/nested_loop_join.rs
src/batch/executors/src/executor/limit.rs
src/batch/executors/src/executor/log_row_seq_scan.rs
src/batch/executors/src/executor/max_one_row.rs
src/batch/executors/src/executor/merge_sort.rs
src/batch/executors/src/executor/merge_sort_exchange.rs
src/batch/executors/src/executor/mysql_query.rs
src/batch/executors/src/executor/order_by.rs
src/batch/executors/src/executor/postgres_query.rs
src/batch/executors/src/executor/project.rs
src/batch/executors/src/executor/project_set.rs
src/batch/executors/src/executor/row_seq_scan.rs
src/batch/executors/src/executor/s3_file_scan.rs
src/batch/executors/src/executor/sort_agg.rs
src/batch/executors/src/executor/sort_over_window.rs
src/batch/executors/src/executor/source.rs
src/batch/executors/src/executor/sys_row_seq_scan.rs
src/batch/executors/src/executor/table_function.rs
src/batch/executors/src/executor/test_utils.rs
src/batch/executors/src/executor/top_n.rs
src/batch/executors/src/executor/union.rs
src/batch/executors/src/executor/update.rs
src/batch/executors/src/executor/utils.rs
src/batch/executors/src/executor/values.rs
src/batch/executors/src/lib.rs
src/batch/src/error.rs
src/batch/src/exchange_source.rs
src/batch/src/execution/grpc_exchange.rs
src/batch/src/execution/local_exchange.rs
src/batch/src/execution/mod.rs
src/batch/src/executor/managed.rs
src/batch/src/executor/mod.rs
src/batch/src/executor/test_utils.rs
src/batch/src/lib.rs
src/batch/src/monitor/mod.rs
src/batch/src/monitor/stats.rs
src/batch/src/rpc/mod.rs
src/batch/src/rpc/service/exchange.rs
src/batch/src/rpc/service/mod.rs
src/batch/src/rpc/service/task_service.rs
src/batch/src/spill/mod.rs
src/batch/src/spill/spill_op.rs
src/batch/src/task/broadcast_channel.rs
src/batch/src/task/channel.rs
src/batch/src/task/consistent_hash_shuffle_channel.rs
src/batch/src/task/context.rs
src/batch/src/task/data_chunk_in_channel.rs
src/batch/src/task/env.rs
src/batch/src/task/fifo_channel.rs
src/batch/src/task/hash_shuffle_channel.rs
src/batch/src/task/mod.rs
src/batch/src/task/task_execution.rs
src/batch/src/task/task_manager.rs
src/batch/src/worker_manager/mod.rs
src/batch/src/worker_manager/worker_node_manager.rs
src/bench/sink_bench/main.rs
src/cmd/src/bin/ctl.rs
src/cmd/src/lib.rs
src/cmd_all/build.rs
src/cmd_all/src/bin/risingwave.rs
src/cmd_all/src/common.rs
src/cmd_all/src/lib.rs
src/cmd_all/src/single_node.rs
src/cmd_all/src/standalone.rs
src/common/benches/bench_array.rs
src/common/benches/bench_column_aware_row_encoding.rs
src/common/benches/bench_data_chunk_compact.rs
src/common/benches/bench_data_chunk_encoding.rs
src/common/benches/bench_encoding.rs
src/common/benches/bench_hash_key_encoding.rs
src/common/benches/bench_lru.rs
src/common/benches/bench_sequencer.rs
src/common/benches/bitmap.rs
src/common/common_service/src/lib.rs
src/common/common_service/src/metrics_manager.rs
src/common/common_service/src/observer_manager.rs
src/common/common_service/src/tracing.rs
src/common/estimate_size/src/collections/btreemap.rs
src/common/estimate_size/src/collections/hashmap.rs
src/common/estimate_size/src/collections/hashset.rs
src/common/estimate_size/src/collections/mod.rs
src/common/estimate_size/src/collections/vec.rs
src/common/estimate_size/src/collections/vecdeque.rs
src/common/estimate_size/src/lib.rs
src/common/fields-derive/src/lib.rs
src/common/heap_profiling/src/jeprof.rs
src/common/heap_profiling/src/lib.rs
src/common/heap_profiling/src/profiler.rs
src/common/metrics/src/error_metrics.rs
src/common/metrics/src/gauge_ext.rs
src/common/metrics/src/guarded_metrics.rs
src/common/metrics/src/lib.rs
src/common/metrics/src/metrics.rs
src/common/metrics/src/monitor/connection.rs
src/common/metrics/src/monitor/mod.rs
src/common/metrics/src/monitor/process.rs
src/common/metrics/src/monitor/rwlock.rs
src/common/metrics/src/relabeled_metric.rs
src/common/proc_macro/src/config.rs
src/common/proc_macro/src/config_doc.rs
src/common/proc_macro/src/estimate_size.rs
src/common/proc_macro/src/lib.rs
src/common/proc_macro/src/session_config.rs
src/common/secret/src/encryption.rs
src/common/secret/src/error.rs
src/common/secret/src/lib.rs
src/common/secret/src/secret_manager.rs
src/common/src/acl/mod.rs
src/common/src/array/arrow/arrow_52.rs
src/common/src/array/arrow/arrow_53.rs
src/common/src/array/arrow/arrow_deltalake.rs
src/common/src/array/arrow/arrow_iceberg.rs
src/common/src/array/arrow/arrow_impl.rs
src/common/src/array/arrow/arrow_udf.rs
src/common/src/array/arrow/mod.rs
src/common/src/array/bool_array.rs
src/common/src/array/bytes_array.rs
src/common/src/array/chrono_array.rs
src/common/src/array/data_chunk.rs
src/common/src/array/data_chunk_iter.rs
src/common/src/array/decimal_array.rs
src/common/src/array/error.rs
src/common/src/array/interval_array.rs
src/common/src/array/iterator.rs
src/common/src/array/jsonb_array.rs
src/common/src/array/list_array.rs
src/common/src/array/map_array.rs
src/common/src/array/mod.rs
src/common/src/array/num256_array.rs
src/common/src/array/primitive_array.rs
src/common/src/array/proto_reader.rs
src/common/src/array/stream_chunk.rs
src/common/src/array/stream_chunk_builder.rs
src/common/src/array/stream_chunk_iter.rs
src/common/src/array/stream_record.rs
src/common/src/array/struct_array.rs
src/common/src/array/utf8_array.rs
src/common/src/bitmap.rs
src/common/src/cache.rs
src/common/src/cast/mod.rs
src/common/src/catalog/column.rs
src/common/src/catalog/external_table.rs
src/common/src/catalog/internal_table.rs
src/common/src/catalog/mod.rs
src/common/src/catalog/physical_table.rs
src/common/src/catalog/schema.rs
src/common/src/catalog/test_utils.rs
src/common/src/config.rs
src/common/src/constants.rs
src/common/src/error.rs
src/common/src/field_generator/mod.rs
src/common/src/field_generator/numeric.rs
src/common/src/field_generator/timestamp.rs
src/common/src/field_generator/varchar.rs
src/common/src/hash/consistent_hash/bitmap.rs
src/common/src/hash/consistent_hash/mapping.rs
src/common/src/hash/consistent_hash/mod.rs
src/common/src/hash/consistent_hash/vnode.rs
src/common/src/hash/consistent_hash/vnode_count.rs
src/common/src/hash/dispatcher.rs
src/common/src/hash/key.rs
src/common/src/hash/key_v2.rs
src/common/src/hash/mod.rs
src/common/src/hash/table_distribution.rs
src/common/src/jemalloc.rs
src/common/src/lib.rs
src/common/src/log.rs
src/common/src/lru.rs
src/common/src/memory/alloc.rs
src/common/src/memory/mem_context.rs
src/common/src/memory/mod.rs
src/common/src/memory/monitored_heap.rs
src/common/src/opts.rs
src/common/src/range.rs
src/common/src/row/chain.rs
src/common/src/row/compacted_row.rs
src/common/src/row/empty.rs
src/common/src/row/mod.rs
src/common/src/row/once.rs
src/common/src/row/ordered.rs
src/common/src/row/owned_row.rs
src/common/src/row/project.rs
src/common/src/row/repeat_n.rs
src/common/src/row/slice.rs
src/common/src/sequence.rs
src/common/src/session_config/mod.rs
src/common/src/session_config/non_zero64.rs
src/common/src/session_config/over_window.rs
src/common/src/session_config/query_mode.rs
src/common/src/session_config/search_path.rs
src/common/src/session_config/sink_decouple.rs
src/common/src/session_config/transaction_isolation_level.rs
src/common/src/session_config/visibility_mode.rs
src/common/src/system_param/common.rs
src/common/src/system_param/diff.rs
src/common/src/system_param/local_manager.rs
src/common/src/system_param/mod.rs
src/common/src/system_param/reader.rs
src/common/src/telemetry/manager.rs
src/common/src/telemetry/mod.rs
src/common/src/telemetry/pb_compatible.rs
src/common/src/telemetry/report.rs
src/common/src/test_utils/mod.rs
src/common/src/test_utils/rand_array.rs
src/common/src/test_utils/rand_bitmap.rs
src/common/src/test_utils/rand_chunk.rs
src/common/src/test_utils/rand_stream_chunk.rs
src/common/src/test_utils/test_stream_chunk.rs
src/common/src/transaction/mod.rs
src/common/src/transaction/transaction_id.rs
src/common/src/transaction/transaction_message.rs
src/common/src/types/cow.rs
src/common/src/types/datetime.rs
src/common/src/types/decimal.rs
src/common/src/types/fields.rs
src/common/src/types/from_sql.rs
src/common/src/types/interval.rs
src/common/src/types/jsonb.rs
src/common/src/types/macros.rs
src/common/src/types/map_type.rs
src/common/src/types/mod.rs
src/common/src/types/native_type.rs
src/common/src/types/num256.rs
src/common/src/types/ops.rs
src/common/src/types/ordered.rs
src/common/src/types/ordered_float.rs
src/common/src/types/postgres_type.rs
src/common/src/types/scalar_impl.rs
src/common/src/types/sentinel.rs
src/common/src/types/serial.rs
src/common/src/types/struct_type.rs
src/common/src/types/successor.rs
src/common/src/types/timestamptz.rs
src/common/src/types/to_binary.rs
src/common/src/types/to_sql.rs
src/common/src/types/to_text.rs
src/common/src/types/with_data_type.rs
src/common/src/util/addr.rs
src/common/src/util/chunk_coalesce.rs
src/common/src/util/cluster_limit.rs
src/common/src/util/column_index_mapping.rs
src/common/src/util/compress.rs
src/common/src/util/deployment.rs
src/common/src/util/env_var.rs
src/common/src/util/epoch.rs
src/common/src/util/hash_util.rs
src/common/src/util/memcmp_encoding.rs
src/common/src/util/meta_addr.rs
src/common/src/util/mod.rs
src/common/src/util/panic.rs
src/common/src/util/pretty_bytes.rs
src/common/src/util/prost.rs
src/common/src/util/query_log.rs
src/common/src/util/recursive.rs
src/common/src/util/row_id.rs
src/common/src/util/row_serde.rs
src/common/src/util/runtime.rs
src/common/src/util/scan_range.rs
src/common/src/util/schema_check.rs
src/common/src/util/sort_util.rs
src/common/src/util/stream_graph_visitor.rs
src/common/src/util/tracing.rs
src/common/src/util/tracing/layer.rs
src/common/src/util/value_encoding/column_aware_row_encoding.rs
src/common/src/util/value_encoding/error.rs
src/common/src/util/value_encoding/mod.rs
src/common/src/util/worker_util.rs
src/common/src/vnode_mapping/mod.rs
src/common/src/vnode_mapping/vnode_placement.rs
src/common/telemetry_event/src/lib.rs
src/common/telemetry_event/src/util.rs
src/compute/src/lib.rs
src/compute/src/memory/config.rs
src/compute/src/memory/controller.rs
src/compute/src/memory/manager.rs
src/compute/src/memory/mod.rs
src/compute/src/observer/mod.rs
src/compute/src/observer/observer_manager.rs
src/compute/src/rpc/mod.rs
src/compute/src/rpc/service/config_service.rs
src/compute/src/rpc/service/exchange_metrics.rs
src/compute/src/rpc/service/exchange_service.rs
src/compute/src/rpc/service/health_service.rs
src/compute/src/rpc/service/mod.rs
src/compute/src/rpc/service/monitor_service.rs
src/compute/src/rpc/service/stream_service.rs
src/compute/src/server.rs
src/compute/src/telemetry.rs
src/compute/tests/cdc_tests.rs
src/compute/tests/integration_tests.rs
src/connector/benches/debezium_json_parser.rs
src/connector/benches/json_common/mod.rs
src/connector/benches/json_parser_case_insensitive.rs
src/connector/benches/json_vs_plain_parser.rs
src/connector/benches/nexmark_integration.rs
src/connector/codec/build.rs
src/connector/codec/src/common/mod.rs
src/connector/codec/src/common/protobuf/compiler.rs
src/connector/codec/src/common/protobuf/mod.rs
src/connector/codec/src/decoder/avro/mod.rs
src/connector/codec/src/decoder/avro/schema.rs
src/connector/codec/src/decoder/json/mod.rs
src/connector/codec/src/decoder/mod.rs
src/connector/codec/src/decoder/protobuf/mod.rs
src/connector/codec/src/decoder/protobuf/parser.rs
src/connector/codec/src/decoder/utils.rs
src/connector/codec/src/lib.rs
src/connector/codec/tests/integration_tests/avro.rs
src/connector/codec/tests/integration_tests/main.rs
src/connector/codec/tests/integration_tests/protobuf.rs
src/connector/codec/tests/integration_tests/utils.rs
src/connector/src/aws_utils.rs
src/connector/src/connector_common/common.rs
src/connector/src/connector_common/connection.rs
src/connector/src/connector_common/iceberg/jni_catalog.rs
src/connector/src/connector_common/iceberg/mock_catalog.rs
src/connector/src/connector_common/iceberg/mod.rs
src/connector/src/connector_common/iceberg/storage_catalog.rs
src/connector/src/connector_common/maybe_tls_connector.rs
src/connector/src/connector_common/mod.rs
src/connector/src/connector_common/mqtt_common.rs
src/connector/src/connector_common/postgres.rs
src/connector/src/error.rs
src/connector/src/lib.rs
src/connector/src/macros.rs
src/connector/src/parser/access_builder.rs
src/connector/src/parser/additional_columns.rs
src/connector/src/parser/avro/confluent_resolver.rs
src/connector/src/parser/avro/glue_resolver.rs
src/connector/src/parser/avro/mod.rs
src/connector/src/parser/avro/parser.rs
src/connector/src/parser/bytes_parser.rs
src/connector/src/parser/canal/mod.rs
src/connector/src/parser/canal/operators.rs
src/connector/src/parser/canal/simd_json_parser.rs
src/connector/src/parser/chunk_builder.rs
src/connector/src/parser/config.rs
src/connector/src/parser/csv_parser.rs
src/connector/src/parser/debezium/avro_parser.rs
src/connector/src/parser/debezium/debezium_parser.rs
src/connector/src/parser/debezium/mod.rs
src/connector/src/parser/debezium/mongo_json_parser.rs
src/connector/src/parser/debezium/schema_change.rs
src/connector/src/parser/debezium/simd_json_parser.rs
src/connector/src/parser/json_parser.rs
src/connector/src/parser/maxwell/maxwell_parser.rs
src/connector/src/parser/maxwell/mod.rs
src/connector/src/parser/maxwell/simd_json_parser.rs
src/connector/src/parser/mod.rs
src/connector/src/parser/mysql.rs
src/connector/src/parser/parquet_parser.rs
src/connector/src/parser/plain_parser.rs
src/connector/src/parser/postgres.rs
src/connector/src/parser/protobuf/mod.rs
src/connector/src/parser/protobuf/parser.rs
src/connector/src/parser/scalar_adapter.rs
src/connector/src/parser/sql_server.rs
src/connector/src/parser/unified/bytes.rs
src/connector/src/parser/unified/debezium.rs
src/connector/src/parser/unified/json.rs
src/connector/src/parser/unified/kv_event.rs
src/connector/src/parser/unified/maxwell.rs
src/connector/src/parser/unified/mod.rs
src/connector/src/parser/unified/util.rs
src/connector/src/parser/upsert_parser.rs
src/connector/src/parser/utils.rs
src/connector/src/schema/avro.rs
src/connector/src/schema/loader.rs
src/connector/src/schema/mod.rs
src/connector/src/schema/protobuf.rs
src/connector/src/schema/schema_registry/client.rs
src/connector/src/schema/schema_registry/mod.rs
src/connector/src/schema/schema_registry/util.rs
src/connector/src/sink/big_query.rs
src/connector/src/sink/boxed.rs
src/connector/src/sink/catalog/desc.rs
src/connector/src/sink/catalog/mod.rs
src/connector/src/sink/clickhouse.rs
src/connector/src/sink/coordinate.rs
src/connector/src/sink/decouple_checkpoint_log_sink.rs
src/connector/src/sink/deltalake.rs
src/connector/src/sink/doris.rs
src/connector/src/sink/doris_starrocks_connector.rs
src/connector/src/sink/dynamodb.rs
src/connector/src/sink/elasticsearch_opensearch/elasticsearch.rs
src/connector/src/sink/elasticsearch_opensearch/elasticsearch_converter.rs
src/connector/src/sink/elasticsearch_opensearch/elasticsearch_opensearch_client.rs
src/connector/src/sink/elasticsearch_opensearch/elasticsearch_opensearch_config.rs
src/connector/src/sink/elasticsearch_opensearch/elasticsearch_opensearch_formatter.rs
src/connector/src/sink/elasticsearch_opensearch/mod.rs
src/connector/src/sink/elasticsearch_opensearch/opensearch.rs
src/connector/src/sink/encoder/avro.rs
src/connector/src/sink/encoder/bson.rs
src/connector/src/sink/encoder/bytes.rs
src/connector/src/sink/encoder/json.rs
src/connector/src/sink/encoder/mod.rs
src/connector/src/sink/encoder/proto.rs
src/connector/src/sink/encoder/template.rs
src/connector/src/sink/encoder/text.rs
src/connector/src/sink/file_sink/azblob.rs
src/connector/src/sink/file_sink/batching_log_sink.rs
src/connector/src/sink/file_sink/fs.rs
src/connector/src/sink/file_sink/gcs.rs
src/connector/src/sink/file_sink/mod.rs
src/connector/src/sink/file_sink/opendal_sink.rs
src/connector/src/sink/file_sink/s3.rs
src/connector/src/sink/file_sink/webhdfs.rs
src/connector/src/sink/formatter/append_only.rs
src/connector/src/sink/formatter/debezium_json.rs
src/connector/src/sink/formatter/mod.rs
src/connector/src/sink/formatter/upsert.rs
src/connector/src/sink/google_pubsub.rs
src/connector/src/sink/iceberg/mod.rs
src/connector/src/sink/iceberg/prometheus/mod.rs
src/connector/src/sink/iceberg/prometheus/monitored_general_writer.rs
src/connector/src/sink/iceberg/prometheus/monitored_partition_writer.rs
src/connector/src/sink/iceberg/prometheus/monitored_position_delete_writer.rs
src/connector/src/sink/kafka.rs
src/connector/src/sink/kinesis.rs
src/connector/src/sink/log_store.rs
src/connector/src/sink/mock_coordination_client.rs
src/connector/src/sink/mod.rs
src/connector/src/sink/mongodb.rs
src/connector/src/sink/mqtt.rs
src/connector/src/sink/nats.rs
src/connector/src/sink/postgres.rs
src/connector/src/sink/pulsar.rs
src/connector/src/sink/redis.rs
src/connector/src/sink/remote.rs
src/connector/src/sink/sqlserver.rs
src/connector/src/sink/starrocks.rs
src/connector/src/sink/test_sink.rs
src/connector/src/sink/trivial.rs
src/connector/src/sink/utils.rs
src/connector/src/sink/writer.rs
src/connector/src/source/base.rs
src/connector/src/source/cdc/enumerator/mod.rs
src/connector/src/source/cdc/external/mock_external_table.rs
src/connector/src/source/cdc/external/mod.rs
src/connector/src/source/cdc/external/mysql.rs
src/connector/src/source/cdc/external/postgres.rs
src/connector/src/source/cdc/external/sql_server.rs
src/connector/src/source/cdc/jni_source.rs
src/connector/src/source/cdc/mod.rs
src/connector/src/source/cdc/source/message.rs
src/connector/src/source/cdc/source/mod.rs
src/connector/src/source/cdc/source/reader.rs
src/connector/src/source/cdc/split.rs
src/connector/src/source/common.rs
src/connector/src/source/data_gen_util.rs
src/connector/src/source/datagen/enumerator/mod.rs
src/connector/src/source/datagen/mod.rs
src/connector/src/source/datagen/source/generator.rs
src/connector/src/source/datagen/source/mod.rs
src/connector/src/source/datagen/source/reader.rs
src/connector/src/source/datagen/split.rs
src/connector/src/source/filesystem/file_common.rs
src/connector/src/source/filesystem/mod.rs
src/connector/src/source/filesystem/nd_streaming.rs
src/connector/src/source/filesystem/opendal_source/azblob_source.rs
src/connector/src/source/filesystem/opendal_source/gcs_source.rs
src/connector/src/source/filesystem/opendal_source/mod.rs
src/connector/src/source/filesystem/opendal_source/opendal_enumerator.rs
src/connector/src/source/filesystem/opendal_source/opendal_reader.rs
src/connector/src/source/filesystem/opendal_source/posix_fs_source.rs
src/connector/src/source/filesystem/opendal_source/s3_source.rs
src/connector/src/source/filesystem/s3/enumerator.rs
src/connector/src/source/filesystem/s3/mod.rs
src/connector/src/source/filesystem/s3/source/mod.rs
src/connector/src/source/filesystem/s3/source/reader.rs
src/connector/src/source/filesystem/s3/source/split_stream.rs
src/connector/src/source/filesystem/s3_v2/lister.rs
src/connector/src/source/filesystem/s3_v2/mod.rs
src/connector/src/source/google_pubsub/enumerator/client.rs
src/connector/src/source/google_pubsub/enumerator/mod.rs
src/connector/src/source/google_pubsub/mod.rs
src/connector/src/source/google_pubsub/source/message.rs
src/connector/src/source/google_pubsub/source/mod.rs
src/connector/src/source/google_pubsub/source/reader.rs
src/connector/src/source/google_pubsub/split.rs
src/connector/src/source/iceberg/mod.rs
src/connector/src/source/iceberg/parquet_file_handler.rs
src/connector/src/source/kafka/client_context.rs
src/connector/src/source/kafka/enumerator/client.rs
src/connector/src/source/kafka/enumerator/mod.rs
src/connector/src/source/kafka/mod.rs
src/connector/src/source/kafka/private_link.rs
src/connector/src/source/kafka/source/message.rs
src/connector/src/source/kafka/source/mod.rs
src/connector/src/source/kafka/source/reader.rs
src/connector/src/source/kafka/split.rs
src/connector/src/source/kafka/stats.rs
src/connector/src/source/kinesis/enumerator/client.rs
src/connector/src/source/kinesis/enumerator/mod.rs
src/connector/src/source/kinesis/mod.rs
src/connector/src/source/kinesis/source/message.rs
src/connector/src/source/kinesis/source/mod.rs
src/connector/src/source/kinesis/source/reader.rs
src/connector/src/source/kinesis/split.rs
src/connector/src/source/manager.rs
src/connector/src/source/mod.rs
src/connector/src/source/monitor/metrics.rs
src/connector/src/source/monitor/mod.rs
src/connector/src/source/mqtt/enumerator/mod.rs
src/connector/src/source/mqtt/mod.rs
src/connector/src/source/mqtt/source/message.rs
src/connector/src/source/mqtt/source/mod.rs
src/connector/src/source/mqtt/source/reader.rs
src/connector/src/source/mqtt/split.rs
src/connector/src/source/nats/enumerator/mod.rs
src/connector/src/source/nats/mod.rs
src/connector/src/source/nats/source/message.rs
src/connector/src/source/nats/source/mod.rs
src/connector/src/source/nats/source/reader.rs
src/connector/src/source/nats/split.rs
src/connector/src/source/nexmark/enumerator/mod.rs
src/connector/src/source/nexmark/mod.rs
src/connector/src/source/nexmark/source/combined_event.rs
src/connector/src/source/nexmark/source/message.rs
src/connector/src/source/nexmark/source/mod.rs
src/connector/src/source/nexmark/source/reader.rs
src/connector/src/source/nexmark/split.rs
src/connector/src/source/pulsar/enumerator/client.rs
src/connector/src/source/pulsar/enumerator/mod.rs
src/connector/src/source/pulsar/mod.rs
src/connector/src/source/pulsar/source/message.rs
src/connector/src/source/pulsar/source/mod.rs
src/connector/src/source/pulsar/source/reader.rs
src/connector/src/source/pulsar/split.rs
src/connector/src/source/pulsar/topic.rs
src/connector/src/source/reader/desc.rs
src/connector/src/source/reader/fs_reader.rs
src/connector/src/source/reader/mod.rs
src/connector/src/source/reader/reader.rs
src/connector/src/source/test_source.rs
src/connector/src/source/util.rs
src/connector/src/with_options.rs
src/connector/src/with_options_test.rs
src/connector/with_options/src/lib.rs
src/ctl/src/cmd_impl.rs
src/ctl/src/cmd_impl/await_tree.rs
src/ctl/src/cmd_impl/bench.rs
src/ctl/src/cmd_impl/compute.rs
src/ctl/src/cmd_impl/hummock.rs
src/ctl/src/cmd_impl/hummock/compaction_group.rs
src/ctl/src/cmd_impl/hummock/list_kv.rs
src/ctl/src/cmd_impl/hummock/list_version.rs
src/ctl/src/cmd_impl/hummock/list_version_deltas.rs
src/ctl/src/cmd_impl/hummock/migrate_legacy_object.rs
src/ctl/src/cmd_impl/hummock/pause_resume.rs
src/ctl/src/cmd_impl/hummock/resize_cache.rs
src/ctl/src/cmd_impl/hummock/sst_dump.rs
src/ctl/src/cmd_impl/hummock/tiered_cache_tracing.rs
src/ctl/src/cmd_impl/hummock/trigger_full_gc.rs
src/ctl/src/cmd_impl/hummock/trigger_manual_compaction.rs
src/ctl/src/cmd_impl/hummock/validate_version.rs
src/ctl/src/cmd_impl/meta.rs
src/ctl/src/cmd_impl/meta/backup_meta.rs
src/ctl/src/cmd_impl/meta/check.rs
src/ctl/src/cmd_impl/meta/cluster_info.rs
src/ctl/src/cmd_impl/meta/connection.rs
src/ctl/src/cmd_impl/meta/pause_resume.rs
src/ctl/src/cmd_impl/meta/reschedule.rs
src/ctl/src/cmd_impl/meta/serving.rs
src/ctl/src/cmd_impl/profile.rs
src/ctl/src/cmd_impl/scale.rs
src/ctl/src/cmd_impl/scale/resize.rs
src/ctl/src/cmd_impl/table.rs
src/ctl/src/cmd_impl/table/list.rs
src/ctl/src/cmd_impl/table/scan.rs
src/ctl/src/cmd_impl/throttle.rs
src/ctl/src/common.rs
src/ctl/src/common/context.rs
src/ctl/src/common/hummock_service.rs
src/ctl/src/common/meta_service.rs
src/ctl/src/lib.rs
src/dml/src/dml_manager.rs
src/dml/src/error.rs
src/dml/src/lib.rs
src/dml/src/table.rs
src/dml/src/txn_channel.rs
src/error/src/anyhow.rs
src/error/src/common.rs
src/error/src/lib.rs
src/error/src/macros.rs
src/error/src/tonic.rs
src/error/src/tonic/extra.rs
src/expr/core/src/aggregate/def.rs
src/expr/core/src/aggregate/mod.rs
src/expr/core/src/aggregate/scalar_wrapper.rs
src/expr/core/src/aggregate/user_defined.rs
src/expr/core/src/codegen.rs
src/expr/core/src/error.rs
src/expr/core/src/expr/and_or.rs
src/expr/core/src/expr/build.rs
src/expr/core/src/expr/expr_input_ref.rs
src/expr/core/src/expr/expr_literal.rs
src/expr/core/src/expr/expr_some_all.rs
src/expr/core/src/expr/expr_udf.rs
src/expr/core/src/expr/mod.rs
src/expr/core/src/expr/test_utils.rs
src/expr/core/src/expr/value.rs
src/expr/core/src/expr/wrapper/checked.rs
src/expr/core/src/expr/wrapper/mod.rs
src/expr/core/src/expr/wrapper/non_strict.rs
src/expr/core/src/expr/wrapper/strict.rs
src/expr/core/src/expr_context.rs
src/expr/core/src/lib.rs
src/expr/core/src/scalar/like.rs
src/expr/core/src/scalar/mod.rs
src/expr/core/src/sig/mod.rs
src/expr/core/src/sig/udf.rs
src/expr/core/src/table_function/empty.rs
src/expr/core/src/table_function/mod.rs
src/expr/core/src/table_function/repeat.rs
src/expr/core/src/table_function/user_defined.rs
src/expr/core/src/window_function/call.rs
src/expr/core/src/window_function/kind.rs
src/expr/core/src/window_function/mod.rs
src/expr/core/src/window_function/range.rs
src/expr/core/src/window_function/rows.rs
src/expr/core/src/window_function/session.rs
src/expr/core/src/window_function/state.rs
src/expr/core/src/window_function/states.rs
src/expr/impl/benches/expr.rs
src/expr/impl/src/aggregate/approx_count_distinct/append_only.rs
src/expr/impl/src/aggregate/approx_count_distinct/mod.rs
src/expr/impl/src/aggregate/approx_count_distinct/updatable.rs
src/expr/impl/src/aggregate/approx_percentile.rs
src/expr/impl/src/aggregate/array_agg.rs
src/expr/impl/src/aggregate/bit_and.rs
src/expr/impl/src/aggregate/bit_or.rs
src/expr/impl/src/aggregate/bit_xor.rs
src/expr/impl/src/aggregate/bool_and.rs
src/expr/impl/src/aggregate/bool_or.rs
src/expr/impl/src/aggregate/first_last_value.rs
src/expr/impl/src/aggregate/general.rs
src/expr/impl/src/aggregate/jsonb_agg.rs
src/expr/impl/src/aggregate/mod.rs
src/expr/impl/src/aggregate/mode.rs
src/expr/impl/src/aggregate/percentile_cont.rs
src/expr/impl/src/aggregate/percentile_disc.rs
src/expr/impl/src/aggregate/string_agg.rs
src/expr/impl/src/lib.rs
src/expr/impl/src/scalar/arithmetic_op.rs
src/expr/impl/src/scalar/array.rs
src/expr/impl/src/scalar/array_access.rs
src/expr/impl/src/scalar/array_concat.rs
src/expr/impl/src/scalar/array_contain.rs
src/expr/impl/src/scalar/array_distinct.rs
src/expr/impl/src/scalar/array_length.rs
src/expr/impl/src/scalar/array_min_max.rs
src/expr/impl/src/scalar/array_positions.rs
src/expr/impl/src/scalar/array_range_access.rs
src/expr/impl/src/scalar/array_remove.rs
src/expr/impl/src/scalar/array_replace.rs
src/expr/impl/src/scalar/array_sort.rs
src/expr/impl/src/scalar/array_sum.rs
src/expr/impl/src/scalar/array_to_string.rs
src/expr/impl/src/scalar/array_transform.rs
src/expr/impl/src/scalar/ascii.rs
src/expr/impl/src/scalar/bitwise_op.rs
src/expr/impl/src/scalar/cardinality.rs
src/expr/impl/src/scalar/case.rs
src/expr/impl/src/scalar/cast.rs
src/expr/impl/src/scalar/cmp.rs
src/expr/impl/src/scalar/coalesce.rs
src/expr/impl/src/scalar/concat.rs
src/expr/impl/src/scalar/concat_op.rs
src/expr/impl/src/scalar/concat_ws.rs
src/expr/impl/src/scalar/conjunction.rs
src/expr/impl/src/scalar/date_trunc.rs
src/expr/impl/src/scalar/delay.rs
src/expr/impl/src/scalar/encdec.rs
src/expr/impl/src/scalar/encrypt.rs
src/expr/impl/src/scalar/exp.rs
src/expr/impl/src/scalar/external/iceberg.rs
src/expr/impl/src/scalar/external/mod.rs
src/expr/impl/src/scalar/extract.rs
src/expr/impl/src/scalar/field.rs
src/expr/impl/src/scalar/format.rs
src/expr/impl/src/scalar/format_type.rs
src/expr/impl/src/scalar/hmac.rs
src/expr/impl/src/scalar/in_.rs
src/expr/impl/src/scalar/inet.rs
src/expr/impl/src/scalar/int256.rs
src/expr/impl/src/scalar/jsonb_access.rs
src/expr/impl/src/scalar/jsonb_build.rs
src/expr/impl/src/scalar/jsonb_concat.rs
src/expr/impl/src/scalar/jsonb_contains.rs
src/expr/impl/src/scalar/jsonb_delete.rs
src/expr/impl/src/scalar/jsonb_info.rs
src/expr/impl/src/scalar/jsonb_object.rs
src/expr/impl/src/scalar/jsonb_path.rs
src/expr/impl/src/scalar/jsonb_record.rs
src/expr/impl/src/scalar/jsonb_set.rs
src/expr/impl/src/scalar/length.rs
src/expr/impl/src/scalar/lower.rs
src/expr/impl/src/scalar/make_time.rs
src/expr/impl/src/scalar/md5.rs
src/expr/impl/src/scalar/mod.rs
src/expr/impl/src/scalar/overlay.rs
src/expr/impl/src/scalar/position.rs
src/expr/impl/src/scalar/proctime.rs
src/expr/impl/src/scalar/regexp.rs
src/expr/impl/src/scalar/repeat.rs
src/expr/impl/src/scalar/replace.rs
src/expr/impl/src/scalar/round.rs
src/expr/impl/src/scalar/sha.rs
src/expr/impl/src/scalar/similar_to_escape.rs
src/expr/impl/src/scalar/split_part.rs
src/expr/impl/src/scalar/string.rs
src/expr/impl/src/scalar/string_to_array.rs
src/expr/impl/src/scalar/substr.rs
src/expr/impl/src/scalar/test_license.rs
src/expr/impl/src/scalar/timestamptz.rs
src/expr/impl/src/scalar/to_char.rs
src/expr/impl/src/scalar/to_jsonb.rs
src/expr/impl/src/scalar/to_timestamp.rs
src/expr/impl/src/scalar/translate.rs
src/expr/impl/src/scalar/trigonometric.rs
src/expr/impl/src/scalar/trim.rs
src/expr/impl/src/scalar/trim_array.rs
src/expr/impl/src/scalar/tumble.rs
src/expr/impl/src/scalar/upper.rs
src/expr/impl/src/scalar/vnode.rs
src/expr/impl/src/table_function/generate_series.rs
src/expr/impl/src/table_function/generate_subscripts.rs
src/expr/impl/src/table_function/jsonb.rs
src/expr/impl/src/table_function/mod.rs
src/expr/impl/src/table_function/pg_expandarray.rs
src/expr/impl/src/table_function/pg_get_keywords.rs
src/expr/impl/src/table_function/regexp_matches.rs
src/expr/impl/src/table_function/unnest.rs
src/expr/impl/src/udf/external.rs
src/expr/impl/src/udf/mod.rs
src/expr/impl/src/udf/python.rs
src/expr/impl/src/udf/quickjs.rs
src/expr/impl/src/udf/wasm.rs
src/expr/impl/src/window_function/aggregate.rs
src/expr/impl/src/window_function/buffer.rs
src/expr/impl/src/window_function/mod.rs
src/expr/impl/src/window_function/range_utils.rs
src/expr/impl/src/window_function/rank.rs
src/expr/impl/tests/sig.rs
src/expr/macro/src/context.rs
src/expr/macro/src/gen.rs
src/expr/macro/src/lib.rs
src/expr/macro/src/parse.rs
src/expr/macro/src/types.rs
src/expr/macro/src/utils.rs
src/frontend/macro/src/lib.rs
src/frontend/planner_test/src/lib.rs
src/frontend/planner_test/src/resolve_id.rs
src/frontend/planner_test/tests/planner_test_runner.rs
src/frontend/src/binder/bind_context.rs
src/frontend/src/binder/bind_param.rs
src/frontend/src/binder/create.rs
src/frontend/src/binder/create_view.rs
src/frontend/src/binder/declare_cursor.rs
src/frontend/src/binder/delete.rs
src/frontend/src/binder/expr/binary_op.rs
src/frontend/src/binder/expr/column.rs
src/frontend/src/binder/expr/function/aggregate.rs
src/frontend/src/binder/expr/function/builtin_scalar.rs
src/frontend/src/binder/expr/function/mod.rs
src/frontend/src/binder/expr/function/window.rs
src/frontend/src/binder/expr/mod.rs
src/frontend/src/binder/expr/order_by.rs
src/frontend/src/binder/expr/subquery.rs
src/frontend/src/binder/expr/value.rs
src/frontend/src/binder/fetch_cursor.rs
src/frontend/src/binder/for_system.rs
src/frontend/src/binder/insert.rs
src/frontend/src/binder/mod.rs
src/frontend/src/binder/query.rs
src/frontend/src/binder/relation/cte_ref.rs
src/frontend/src/binder/relation/join.rs
src/frontend/src/binder/relation/mod.rs
src/frontend/src/binder/relation/share.rs
src/frontend/src/binder/relation/subquery.rs
src/frontend/src/binder/relation/table_function.rs
src/frontend/src/binder/relation/table_or_source.rs
src/frontend/src/binder/relation/watermark.rs
src/frontend/src/binder/relation/window_table_function.rs
src/frontend/src/binder/select.rs
src/frontend/src/binder/set_expr.rs
src/frontend/src/binder/statement.rs
src/frontend/src/binder/struct_field.rs
src/frontend/src/binder/update.rs
src/frontend/src/binder/values.rs
src/frontend/src/catalog/catalog_service.rs
src/frontend/src/catalog/connection_catalog.rs
src/frontend/src/catalog/database_catalog.rs
src/frontend/src/catalog/function_catalog.rs
src/frontend/src/catalog/index_catalog.rs
src/frontend/src/catalog/mod.rs
src/frontend/src/catalog/root_catalog.rs
src/frontend/src/catalog/schema_catalog.rs
src/frontend/src/catalog/secret_catalog.rs
src/frontend/src/catalog/source_catalog.rs
src/frontend/src/catalog/subscription_catalog.rs
src/frontend/src/catalog/system_catalog/information_schema/columns.rs
src/frontend/src/catalog/system_catalog/information_schema/key_column_usage.rs
src/frontend/src/catalog/system_catalog/information_schema/mod.rs
src/frontend/src/catalog/system_catalog/information_schema/schemata.rs
src/frontend/src/catalog/system_catalog/information_schema/table_constraints.rs
src/frontend/src/catalog/system_catalog/information_schema/tables.rs
src/frontend/src/catalog/system_catalog/information_schema/views.rs
src/frontend/src/catalog/system_catalog/mod.rs
src/frontend/src/catalog/system_catalog/pg_catalog/mod.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_am.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_attrdef.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_attribute.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_auth_members.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_cast.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_class.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_collation.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_constraint.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_conversion.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_database.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_depend.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_description.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_enum.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_extension.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_index.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_indexes.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_inherits.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_language.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_locks.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_matviews.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_namespace.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_opclass.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_operator.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_partitioned_table.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_proc.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_range.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_rewrite.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_roles.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_sequence.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_sequences.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_settings.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_shadow.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_shdescription.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_stat_activity.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_stat_user_tables.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_tables.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_tablespace.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_trigger.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_type.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_user.rs
src/frontend/src/catalog/system_catalog/pg_catalog/pg_views.rs
src/frontend/src/catalog/system_catalog/rw_catalog/mod.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_actor_id_to_ddl.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_actor_infos.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_actor_splits.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_actors.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_columns.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_connections.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_databases.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_ddl_progress.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_depend.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_description.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_event_logs.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_fragment_id_to_ddl.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_fragment_parallelism.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_fragments.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_functions.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_branched_objects.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_compact_task_assignment.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_compact_task_progress.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_compaction_group_configs.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_meta_configs.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_pinned_versions.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_version.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_hummock_version_deltas.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_iceberg_all_files.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_iceberg_files.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_iceberg_snapshots.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_indexes.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_internal_table_info.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_internal_tables.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_materialized_views.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_meta_snapshot.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_rate_limit.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_relation_info.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_relations.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_schemas.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_secrets.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_sinks.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_sources.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_streaming_parallelism.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_subscriptions.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_system_tables.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_table_fragments.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_table_stats.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_tables.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_types.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_user_secrets.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_users.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_views.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_worker_actor_count.rs
src/frontend/src/catalog/system_catalog/rw_catalog/rw_worker_nodes.rs
src/frontend/src/catalog/table_catalog.rs
src/frontend/src/catalog/view_catalog.rs
src/frontend/src/error.rs
src/frontend/src/expr/agg_call.rs
src/frontend/src/expr/correlated_input_ref.rs
src/frontend/src/expr/expr_mutator.rs
src/frontend/src/expr/expr_rewriter.rs
src/frontend/src/expr/expr_visitor.rs
src/frontend/src/expr/function_call.rs
src/frontend/src/expr/function_call_with_lambda.rs
src/frontend/src/expr/function_impl/cast_regclass.rs
src/frontend/src/expr/function_impl/col_description.rs
src/frontend/src/expr/function_impl/context.rs
src/frontend/src/expr/function_impl/has_privilege.rs
src/frontend/src/expr/function_impl/mod.rs
src/frontend/src/expr/function_impl/pg_get_indexdef.rs
src/frontend/src/expr/function_impl/pg_get_userbyid.rs
src/frontend/src/expr/function_impl/pg_get_viewdef.rs
src/frontend/src/expr/function_impl/pg_index_column_has_property.rs
src/frontend/src/expr/function_impl/pg_indexes_size.rs
src/frontend/src/expr/function_impl/pg_relation_size.rs
src/frontend/src/expr/function_impl/rw_epoch_to_ts.rs
src/frontend/src/expr/function_impl/rw_recovery_status.rs
src/frontend/src/expr/input_ref.rs
src/frontend/src/expr/literal.rs
src/frontend/src/expr/mod.rs
src/frontend/src/expr/now.rs
src/frontend/src/expr/order_by_expr.rs
src/frontend/src/expr/parameter.rs
src/frontend/src/expr/pure.rs
src/frontend/src/expr/session_timezone.rs
src/frontend/src/expr/subquery.rs
src/frontend/src/expr/table_function.rs
src/frontend/src/expr/type_inference/cast.rs
src/frontend/src/expr/type_inference/func.rs
src/frontend/src/expr/type_inference/mod.rs
src/frontend/src/expr/user_defined_function.rs
src/frontend/src/expr/utils.rs
src/frontend/src/expr/window_function.rs
src/frontend/src/handler/alter_owner.rs
src/frontend/src/handler/alter_parallelism.rs
src/frontend/src/handler/alter_rename.rs
src/frontend/src/handler/alter_resource_group.rs
src/frontend/src/handler/alter_secret.rs
src/frontend/src/handler/alter_set_schema.rs
src/frontend/src/handler/alter_source_column.rs
src/frontend/src/handler/alter_source_with_sr.rs
src/frontend/src/handler/alter_streaming_rate_limit.rs
src/frontend/src/handler/alter_swap_rename.rs
src/frontend/src/handler/alter_system.rs
src/frontend/src/handler/alter_table_column.rs
src/frontend/src/handler/alter_table_with_sr.rs
src/frontend/src/handler/alter_user.rs
src/frontend/src/handler/cancel_job.rs
src/frontend/src/handler/close_cursor.rs
src/frontend/src/handler/comment.rs
src/frontend/src/handler/create_aggregate.rs
src/frontend/src/handler/create_connection.rs
src/frontend/src/handler/create_database.rs
src/frontend/src/handler/create_function.rs
src/frontend/src/handler/create_index.rs
src/frontend/src/handler/create_mv.rs
src/frontend/src/handler/create_schema.rs
src/frontend/src/handler/create_secret.rs
src/frontend/src/handler/create_sink.rs
src/frontend/src/handler/create_source.rs
src/frontend/src/handler/create_source/additional_column.rs
src/frontend/src/handler/create_source/external_schema.rs
src/frontend/src/handler/create_source/external_schema/avro.rs
src/frontend/src/handler/create_source/external_schema/debezium.rs
src/frontend/src/handler/create_source/external_schema/iceberg.rs
src/frontend/src/handler/create_source/external_schema/json.rs
src/frontend/src/handler/create_source/external_schema/nexmark.rs
src/frontend/src/handler/create_source/external_schema/protobuf.rs
src/frontend/src/handler/create_source/validate.rs
src/frontend/src/handler/create_sql_function.rs
src/frontend/src/handler/create_subscription.rs
src/frontend/src/handler/create_table.rs
src/frontend/src/handler/create_table_as.rs
src/frontend/src/handler/create_user.rs
src/frontend/src/handler/create_view.rs
src/frontend/src/handler/declare_cursor.rs
src/frontend/src/handler/describe.rs
src/frontend/src/handler/discard.rs
src/frontend/src/handler/drop_connection.rs
src/frontend/src/handler/drop_database.rs
src/frontend/src/handler/drop_function.rs
src/frontend/src/handler/drop_index.rs
src/frontend/src/handler/drop_mv.rs
src/frontend/src/handler/drop_schema.rs
src/frontend/src/handler/drop_secret.rs
src/frontend/src/handler/drop_sink.rs
src/frontend/src/handler/drop_source.rs
src/frontend/src/handler/drop_subscription.rs
src/frontend/src/handler/drop_table.rs
src/frontend/src/handler/drop_user.rs
src/frontend/src/handler/drop_view.rs
src/frontend/src/handler/explain.rs
src/frontend/src/handler/extended_handle.rs
src/frontend/src/handler/fetch_cursor.rs
src/frontend/src/handler/flush.rs
src/frontend/src/handler/handle_privilege.rs
src/frontend/src/handler/kill_process.rs
src/frontend/src/handler/mod.rs
src/frontend/src/handler/privilege.rs
src/frontend/src/handler/query.rs
src/frontend/src/handler/recover.rs
src/frontend/src/handler/show.rs
src/frontend/src/handler/transaction.rs
src/frontend/src/handler/use_db.rs
src/frontend/src/handler/util.rs
src/frontend/src/handler/variable.rs
src/frontend/src/handler/wait.rs
src/frontend/src/health_service.rs
src/frontend/src/lib.rs
src/frontend/src/meta_client.rs
src/frontend/src/monitor/mod.rs
src/frontend/src/monitor/stats.rs
src/frontend/src/observer/mod.rs
src/frontend/src/observer/observer_manager.rs
src/frontend/src/optimizer/delta_join_solver.rs
src/frontend/src/optimizer/heuristic_optimizer.rs
src/frontend/src/optimizer/logical_optimization.rs
src/frontend/src/optimizer/mod.rs
src/frontend/src/optimizer/optimizer_context.rs
src/frontend/src/optimizer/plan_expr_rewriter/const_eval_rewriter.rs
src/frontend/src/optimizer/plan_expr_rewriter/cse_rewriter.rs
src/frontend/src/optimizer/plan_expr_rewriter/mod.rs
src/frontend/src/optimizer/plan_expr_visitor/expr_counter.rs
src/frontend/src/optimizer/plan_expr_visitor/input_ref_counter.rs
src/frontend/src/optimizer/plan_expr_visitor/mod.rs
src/frontend/src/optimizer/plan_expr_visitor/strong.rs
src/frontend/src/optimizer/plan_node/batch.rs
src/frontend/src/optimizer/plan_node/batch_delete.rs
src/frontend/src/optimizer/plan_node/batch_exchange.rs
src/frontend/src/optimizer/plan_node/batch_expand.rs
src/frontend/src/optimizer/plan_node/batch_file_scan.rs
src/frontend/src/optimizer/plan_node/batch_filter.rs
src/frontend/src/optimizer/plan_node/batch_group_topn.rs
src/frontend/src/optimizer/plan_node/batch_hash_agg.rs
src/frontend/src/optimizer/plan_node/batch_hash_join.rs
src/frontend/src/optimizer/plan_node/batch_hop_window.rs
src/frontend/src/optimizer/plan_node/batch_iceberg_scan.rs
src/frontend/src/optimizer/plan_node/batch_insert.rs
src/frontend/src/optimizer/plan_node/batch_kafka_scan.rs
src/frontend/src/optimizer/plan_node/batch_limit.rs
src/frontend/src/optimizer/plan_node/batch_log_seq_scan.rs
src/frontend/src/optimizer/plan_node/batch_lookup_join.rs
src/frontend/src/optimizer/plan_node/batch_max_one_row.rs
src/frontend/src/optimizer/plan_node/batch_mysql_query.rs
src/frontend/src/optimizer/plan_node/batch_nested_loop_join.rs
src/frontend/src/optimizer/plan_node/batch_over_window.rs
src/frontend/src/optimizer/plan_node/batch_postgres_query.rs
src/frontend/src/optimizer/plan_node/batch_project.rs
src/frontend/src/optimizer/plan_node/batch_project_set.rs
src/frontend/src/optimizer/plan_node/batch_seq_scan.rs
src/frontend/src/optimizer/plan_node/batch_simple_agg.rs
src/frontend/src/optimizer/plan_node/batch_sort.rs
src/frontend/src/optimizer/plan_node/batch_sort_agg.rs
src/frontend/src/optimizer/plan_node/batch_source.rs
src/frontend/src/optimizer/plan_node/batch_sys_seq_scan.rs
src/frontend/src/optimizer/plan_node/batch_table_function.rs
src/frontend/src/optimizer/plan_node/batch_topn.rs
src/frontend/src/optimizer/plan_node/batch_union.rs
src/frontend/src/optimizer/plan_node/batch_update.rs
src/frontend/src/optimizer/plan_node/batch_values.rs
src/frontend/src/optimizer/plan_node/col_pruning.rs
src/frontend/src/optimizer/plan_node/convert.rs
src/frontend/src/optimizer/plan_node/derive.rs
src/frontend/src/optimizer/plan_node/eq_join_predicate.rs
src/frontend/src/optimizer/plan_node/expr_rewritable.rs
src/frontend/src/optimizer/plan_node/expr_visitable.rs
src/frontend/src/optimizer/plan_node/generic/agg.rs
src/frontend/src/optimizer/plan_node/generic/cdc_scan.rs
src/frontend/src/optimizer/plan_node/generic/changelog.rs
src/frontend/src/optimizer/plan_node/generic/cte_ref.rs
src/frontend/src/optimizer/plan_node/generic/dedup.rs
src/frontend/src/optimizer/plan_node/generic/delete.rs
src/frontend/src/optimizer/plan_node/generic/dynamic_filter.rs
src/frontend/src/optimizer/plan_node/generic/except.rs
src/frontend/src/optimizer/plan_node/generic/expand.rs
src/frontend/src/optimizer/plan_node/generic/file_scan.rs
src/frontend/src/optimizer/plan_node/generic/filter.rs
src/frontend/src/optimizer/plan_node/generic/hop_window.rs
src/frontend/src/optimizer/plan_node/generic/insert.rs
src/frontend/src/optimizer/plan_node/generic/intersect.rs
src/frontend/src/optimizer/plan_node/generic/join.rs
src/frontend/src/optimizer/plan_node/generic/limit.rs
src/frontend/src/optimizer/plan_node/generic/log_scan.rs
src/frontend/src/optimizer/plan_node/generic/max_one_row.rs
src/frontend/src/optimizer/plan_node/generic/mod.rs
src/frontend/src/optimizer/plan_node/generic/mysql_query.rs
src/frontend/src/optimizer/plan_node/generic/now.rs
src/frontend/src/optimizer/plan_node/generic/over_window.rs
src/frontend/src/optimizer/plan_node/generic/postgres_query.rs
src/frontend/src/optimizer/plan_node/generic/project.rs
src/frontend/src/optimizer/plan_node/generic/project_set.rs
src/frontend/src/optimizer/plan_node/generic/recursive_union.rs
src/frontend/src/optimizer/plan_node/generic/share.rs
src/frontend/src/optimizer/plan_node/generic/source.rs
src/frontend/src/optimizer/plan_node/generic/sys_scan.rs
src/frontend/src/optimizer/plan_node/generic/table_scan.rs
src/frontend/src/optimizer/plan_node/generic/top_n.rs
src/frontend/src/optimizer/plan_node/generic/union.rs
src/frontend/src/optimizer/plan_node/generic/update.rs
src/frontend/src/optimizer/plan_node/logical_agg.rs
src/frontend/src/optimizer/plan_node/logical_apply.rs
src/frontend/src/optimizer/plan_node/logical_cdc_scan.rs
src/frontend/src/optimizer/plan_node/logical_changelog.rs
src/frontend/src/optimizer/plan_node/logical_cte_ref.rs
src/frontend/src/optimizer/plan_node/logical_dedup.rs
src/frontend/src/optimizer/plan_node/logical_delete.rs
src/frontend/src/optimizer/plan_node/logical_except.rs
src/frontend/src/optimizer/plan_node/logical_expand.rs
src/frontend/src/optimizer/plan_node/logical_file_scan.rs
src/frontend/src/optimizer/plan_node/logical_filter.rs
src/frontend/src/optimizer/plan_node/logical_hop_window.rs
src/frontend/src/optimizer/plan_node/logical_iceberg_scan.rs
src/frontend/src/optimizer/plan_node/logical_insert.rs
src/frontend/src/optimizer/plan_node/logical_intersect.rs
src/frontend/src/optimizer/plan_node/logical_join.rs
src/frontend/src/optimizer/plan_node/logical_kafka_scan.rs
src/frontend/src/optimizer/plan_node/logical_limit.rs
src/frontend/src/optimizer/plan_node/logical_max_one_row.rs
src/frontend/src/optimizer/plan_node/logical_multi_join.rs
src/frontend/src/optimizer/plan_node/logical_mysql_query.rs
src/frontend/src/optimizer/plan_node/logical_now.rs
src/frontend/src/optimizer/plan_node/logical_over_window.rs
src/frontend/src/optimizer/plan_node/logical_postgres_query.rs
src/frontend/src/optimizer/plan_node/logical_project.rs
src/frontend/src/optimizer/plan_node/logical_project_set.rs
src/frontend/src/optimizer/plan_node/logical_recursive_union.rs
src/frontend/src/optimizer/plan_node/logical_scan.rs
src/frontend/src/optimizer/plan_node/logical_share.rs
src/frontend/src/optimizer/plan_node/logical_source.rs
src/frontend/src/optimizer/plan_node/logical_sys_scan.rs
src/frontend/src/optimizer/plan_node/logical_table_function.rs
src/frontend/src/optimizer/plan_node/logical_topn.rs
src/frontend/src/optimizer/plan_node/logical_union.rs
src/frontend/src/optimizer/plan_node/logical_update.rs
src/frontend/src/optimizer/plan_node/logical_values.rs
src/frontend/src/optimizer/plan_node/merge_eq_nodes.rs
src/frontend/src/optimizer/plan_node/mod.rs
src/frontend/src/optimizer/plan_node/plan_base.rs
src/frontend/src/optimizer/plan_node/plan_tree_node.rs
src/frontend/src/optimizer/plan_node/predicate_pushdown.rs
src/frontend/src/optimizer/plan_node/stream.rs
src/frontend/src/optimizer/plan_node/stream_asof_join.rs
src/frontend/src/optimizer/plan_node/stream_cdc_table_scan.rs
src/frontend/src/optimizer/plan_node/stream_changelog.rs
src/frontend/src/optimizer/plan_node/stream_dedup.rs
src/frontend/src/optimizer/plan_node/stream_delta_join.rs
src/frontend/src/optimizer/plan_node/stream_dml.rs
src/frontend/src/optimizer/plan_node/stream_dynamic_filter.rs
src/frontend/src/optimizer/plan_node/stream_eowc_over_window.rs
src/frontend/src/optimizer/plan_node/stream_exchange.rs
src/frontend/src/optimizer/plan_node/stream_expand.rs
src/frontend/src/optimizer/plan_node/stream_filter.rs
src/frontend/src/optimizer/plan_node/stream_fs_fetch.rs
src/frontend/src/optimizer/plan_node/stream_global_approx_percentile.rs
src/frontend/src/optimizer/plan_node/stream_group_topn.rs
src/frontend/src/optimizer/plan_node/stream_hash_agg.rs
src/frontend/src/optimizer/plan_node/stream_hash_join.rs
src/frontend/src/optimizer/plan_node/stream_hop_window.rs
src/frontend/src/optimizer/plan_node/stream_join_common.rs
src/frontend/src/optimizer/plan_node/stream_local_approx_percentile.rs
src/frontend/src/optimizer/plan_node/stream_materialize.rs
src/frontend/src/optimizer/plan_node/stream_now.rs
src/frontend/src/optimizer/plan_node/stream_over_window.rs
src/frontend/src/optimizer/plan_node/stream_project.rs
src/frontend/src/optimizer/plan_node/stream_project_set.rs
src/frontend/src/optimizer/plan_node/stream_row_id_gen.rs
src/frontend/src/optimizer/plan_node/stream_row_merge.rs
src/frontend/src/optimizer/plan_node/stream_share.rs
src/frontend/src/optimizer/plan_node/stream_simple_agg.rs
src/frontend/src/optimizer/plan_node/stream_sink.rs
src/frontend/src/optimizer/plan_node/stream_sort.rs
src/frontend/src/optimizer/plan_node/stream_source.rs
src/frontend/src/optimizer/plan_node/stream_source_scan.rs
src/frontend/src/optimizer/plan_node/stream_stateless_simple_agg.rs
src/frontend/src/optimizer/plan_node/stream_table_scan.rs
src/frontend/src/optimizer/plan_node/stream_temporal_join.rs
src/frontend/src/optimizer/plan_node/stream_topn.rs
src/frontend/src/optimizer/plan_node/stream_union.rs
src/frontend/src/optimizer/plan_node/stream_values.rs
src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs
src/frontend/src/optimizer/plan_node/to_prost.rs
src/frontend/src/optimizer/plan_node/utils.rs
src/frontend/src/optimizer/plan_rewriter/mod.rs
src/frontend/src/optimizer/plan_rewriter/plan_cloner.rs
src/frontend/src/optimizer/plan_rewriter/share_source_rewriter.rs
src/frontend/src/optimizer/plan_visitor/apply_visitor.rs
src/frontend/src/optimizer/plan_visitor/cardinality_visitor.rs
src/frontend/src/optimizer/plan_visitor/distributed_dml_visitor.rs
src/frontend/src/optimizer/plan_visitor/execution_mode_decider.rs
src/frontend/src/optimizer/plan_visitor/input_ref_validator.rs
src/frontend/src/optimizer/plan_visitor/jsonb_stream_key_checker.rs
src/frontend/src/optimizer/plan_visitor/mod.rs
src/frontend/src/optimizer/plan_visitor/plan_correlated_id_finder.rs
src/frontend/src/optimizer/plan_visitor/read_storage_table_visitor.rs
src/frontend/src/optimizer/plan_visitor/relation_collector_visitor.rs
src/frontend/src/optimizer/plan_visitor/rw_timestamp_validator.rs
src/frontend/src/optimizer/plan_visitor/share_parent_counter.rs
src/frontend/src/optimizer/plan_visitor/side_effect_visitor.rs
src/frontend/src/optimizer/plan_visitor/sys_table_visitor.rs
src/frontend/src/optimizer/plan_visitor/temporal_join_validator.rs
src/frontend/src/optimizer/property/cardinality.rs
src/frontend/src/optimizer/property/distribution.rs
src/frontend/src/optimizer/property/func_dep.rs
src/frontend/src/optimizer/property/mod.rs
src/frontend/src/optimizer/property/monotonicity.rs
src/frontend/src/optimizer/property/order.rs
src/frontend/src/optimizer/rule/agg_call_merge_rule.rs
src/frontend/src/optimizer/rule/agg_group_by_simplify_rule.rs
src/frontend/src/optimizer/rule/agg_project_merge_rule.rs
src/frontend/src/optimizer/rule/always_false_filter_rule.rs
src/frontend/src/optimizer/rule/apply_agg_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_dedup_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_eliminate_rule.rs
src/frontend/src/optimizer/rule/apply_expand_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_filter_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_hop_window_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_join_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_limit_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_offset_rewriter.rs
src/frontend/src/optimizer/rule/apply_over_window_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_project_set_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_project_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_share_eliminate_rule.rs
src/frontend/src/optimizer/rule/apply_to_join_rule.rs
src/frontend/src/optimizer/rule/apply_topn_transpose_rule.rs
src/frontend/src/optimizer/rule/apply_union_transpose_rule.rs
src/frontend/src/optimizer/rule/batch/batch_iceberg_predicate_pushdown.rs
src/frontend/src/optimizer/rule/batch/batch_project_merge_rule.rs
src/frontend/src/optimizer/rule/batch/batch_push_limit_to_scan_rule.rs
src/frontend/src/optimizer/rule/batch/mod.rs
src/frontend/src/optimizer/rule/common_sub_expr_extract_rule.rs
src/frontend/src/optimizer/rule/cross_join_eliminate_rule.rs
src/frontend/src/optimizer/rule/dag_to_tree_rule.rs
src/frontend/src/optimizer/rule/distinct_agg_rule.rs
src/frontend/src/optimizer/rule/except_merge_rule.rs
src/frontend/src/optimizer/rule/except_to_anti_join_rule.rs
src/frontend/src/optimizer/rule/expand_to_project_rule.rs
src/frontend/src/optimizer/rule/grouping_sets_to_expand_rule.rs
src/frontend/src/optimizer/rule/index_delta_join_rule.rs
src/frontend/src/optimizer/rule/index_selection_rule.rs
src/frontend/src/optimizer/rule/intersect_merge_rule.rs
src/frontend/src/optimizer/rule/intersect_to_semi_join_rule.rs
src/frontend/src/optimizer/rule/join_commute_rule.rs
src/frontend/src/optimizer/rule/join_project_transpose_rule.rs
src/frontend/src/optimizer/rule/left_deep_tree_join_ordering_rule.rs
src/frontend/src/optimizer/rule/limit_push_down_rule.rs
src/frontend/src/optimizer/rule/logical_filter_expression_simplify_rule.rs
src/frontend/src/optimizer/rule/max_one_row_eliminate_rule.rs
src/frontend/src/optimizer/rule/merge_multijoin_rule.rs
src/frontend/src/optimizer/rule/min_max_on_index_rule.rs
src/frontend/src/optimizer/rule/mod.rs
src/frontend/src/optimizer/rule/over_window_merge_rule.rs
src/frontend/src/optimizer/rule/over_window_split_rule.rs
src/frontend/src/optimizer/rule/over_window_to_agg_and_join_rule.rs
src/frontend/src/optimizer/rule/over_window_to_topn_rule.rs
src/frontend/src/optimizer/rule/project_eliminate_rule.rs
src/frontend/src/optimizer/rule/project_join_merge_rule.rs
src/frontend/src/optimizer/rule/project_join_separate_rule.rs
src/frontend/src/optimizer/rule/project_merge_rule.rs
src/frontend/src/optimizer/rule/pull_up_correlated_predicate_agg_rule.rs
src/frontend/src/optimizer/rule/pull_up_correlated_predicate_rule.rs
src/frontend/src/optimizer/rule/pull_up_hop_rule.rs
src/frontend/src/optimizer/rule/push_calculation_of_join_rule.rs
src/frontend/src/optimizer/rule/rewrite_like_expr_rule.rs
src/frontend/src/optimizer/rule/source_to_iceberg_scan_rule.rs
src/frontend/src/optimizer/rule/source_to_kafka_scan_rule.rs
src/frontend/src/optimizer/rule/stream/bushy_tree_join_ordering_rule.rs
src/frontend/src/optimizer/rule/stream/filter_with_now_to_join_rule.rs
src/frontend/src/optimizer/rule/stream/generate_series_with_now_rule.rs
src/frontend/src/optimizer/rule/stream/mod.rs
src/frontend/src/optimizer/rule/stream/split_now_and_rule.rs
src/frontend/src/optimizer/rule/stream/split_now_or_rule.rs
src/frontend/src/optimizer/rule/stream/stream_project_merge_rule.rs
src/frontend/src/optimizer/rule/table_function_to_file_scan_rule.rs
src/frontend/src/optimizer/rule/table_function_to_mysql_query_rule.rs
src/frontend/src/optimizer/rule/table_function_to_postgres_query_rule.rs
src/frontend/src/optimizer/rule/table_function_to_project_set_rule.rs
src/frontend/src/optimizer/rule/top_n_on_index_rule.rs
src/frontend/src/optimizer/rule/translate_apply_rule.rs
src/frontend/src/optimizer/rule/trivial_project_to_values_rule.rs
src/frontend/src/optimizer/rule/union_input_values_merge_rule.rs
src/frontend/src/optimizer/rule/union_merge_rule.rs
src/frontend/src/optimizer/rule/union_to_distinct_rule.rs
src/frontend/src/optimizer/rule/values_extract_project_rule.rs
src/frontend/src/planner/changelog.rs
src/frontend/src/planner/delete.rs
src/frontend/src/planner/insert.rs
src/frontend/src/planner/mod.rs
src/frontend/src/planner/query.rs
src/frontend/src/planner/recursive_union.rs
src/frontend/src/planner/relation.rs
src/frontend/src/planner/select.rs
src/frontend/src/planner/set_expr.rs
src/frontend/src/planner/set_operation.rs
src/frontend/src/planner/statement.rs
src/frontend/src/planner/update.rs
src/frontend/src/planner/values.rs
src/frontend/src/rpc/mod.rs
src/frontend/src/scheduler/distributed/mod.rs
src/frontend/src/scheduler/distributed/query.rs
src/frontend/src/scheduler/distributed/query_manager.rs
src/frontend/src/scheduler/distributed/stage.rs
src/frontend/src/scheduler/distributed/stats.rs
src/frontend/src/scheduler/error.rs
src/frontend/src/scheduler/local.rs
src/frontend/src/scheduler/mod.rs
src/frontend/src/scheduler/plan_fragmenter.rs
src/frontend/src/scheduler/snapshot.rs
src/frontend/src/scheduler/streaming_manager.rs
src/frontend/src/scheduler/task_context.rs
src/frontend/src/session.rs
src/frontend/src/session/current.rs
src/frontend/src/session/cursor_manager.rs
src/frontend/src/session/transaction.rs
src/frontend/src/stream_fragmenter/graph/fragment_graph.rs
src/frontend/src/stream_fragmenter/graph/mod.rs
src/frontend/src/stream_fragmenter/mod.rs
src/frontend/src/stream_fragmenter/rewrite/delta_join.rs
src/frontend/src/stream_fragmenter/rewrite/mod.rs
src/frontend/src/telemetry.rs
src/frontend/src/test_utils.rs
src/frontend/src/user/mod.rs
src/frontend/src/user/user_authentication.rs
src/frontend/src/user/user_catalog.rs
src/frontend/src/user/user_manager.rs
src/frontend/src/user/user_privilege.rs
src/frontend/src/user/user_service.rs
src/frontend/src/utils/column_index_mapping.rs
src/frontend/src/utils/condition.rs
src/frontend/src/utils/connected_components.rs
src/frontend/src/utils/group_by.rs
src/frontend/src/utils/index_set.rs
src/frontend/src/utils/mod.rs
src/frontend/src/utils/overwrite_options.rs
src/frontend/src/utils/pretty_serde.rs
src/frontend/src/utils/rewrite_index.rs
src/frontend/src/utils/stream_graph_formatter.rs
src/frontend/src/utils/with_options.rs
src/frontend/src/webhook/mod.rs
src/frontend/src/webhook/utils.rs
src/java_binding/gen-demo-insert-data.py
src/java_binding/src/bin/data-chunk-payload-convert-generator.rs
src/java_binding/src/bin/data-chunk-payload-generator.rs
src/java_binding/src/hummock_iterator.rs
src/java_binding/src/lib.rs
src/jni_core/src/jvm_runtime.rs
src/jni_core/src/lib.rs
src/jni_core/src/macros.rs
src/jni_core/src/tracing_slf4j.rs
src/license/src/cpu.rs
src/license/src/feature.rs
src/license/src/key.rs
src/license/src/lib.rs
src/license/src/manager.rs
src/meta/dashboard/build.rs
src/meta/dashboard/examples/serve.rs
src/meta/dashboard/src/embed.rs
src/meta/dashboard/src/lib.rs
src/meta/dashboard/src/proxy.rs
src/meta/model/src/actor.rs
src/meta/model/src/actor_dispatcher.rs
src/meta/model/src/catalog_version.rs
src/meta/model/src/cluster.rs
src/meta/model/src/compaction_config.rs
src/meta/model/src/compaction_status.rs
src/meta/model/src/compaction_task.rs
src/meta/model/src/connection.rs
src/meta/model/src/database.rs
src/meta/model/src/fragment.rs
src/meta/model/src/function.rs
src/meta/model/src/hummock_epoch_to_version.rs
src/meta/model/src/hummock_gc_history.rs
src/meta/model/src/hummock_pinned_snapshot.rs
src/meta/model/src/hummock_pinned_version.rs
src/meta/model/src/hummock_sequence.rs
src/meta/model/src/hummock_sstable_info.rs
src/meta/model/src/hummock_time_travel_delta.rs
src/meta/model/src/hummock_time_travel_version.rs
src/meta/model/src/hummock_version_delta.rs
src/meta/model/src/hummock_version_stats.rs
src/meta/model/src/index.rs
src/meta/model/src/lib.rs
src/meta/model/src/object.rs
src/meta/model/src/object_dependency.rs
src/meta/model/src/prelude.rs
src/meta/model/src/schema.rs
src/meta/model/src/secret.rs
src/meta/model/src/serde_seaql_migration.rs
src/meta/model/src/session_parameter.rs
src/meta/model/src/sink.rs
src/meta/model/src/source.rs
src/meta/model/src/streaming_job.rs
src/meta/model/src/subscription.rs
src/meta/model/src/system_parameter.rs
src/meta/model/src/table.rs
src/meta/model/src/user.rs
src/meta/model/src/user_privilege.rs
src/meta/model/src/view.rs
src/meta/model/src/worker.rs
src/meta/model/src/worker_property.rs
src/meta/node/src/lib.rs
src/meta/node/src/server.rs
src/meta/service/src/backup_service.rs
src/meta/service/src/cloud_service.rs
src/meta/service/src/cluster_limit_service.rs
src/meta/service/src/cluster_service.rs
src/meta/service/src/ddl_service.rs
src/meta/service/src/event_log_service.rs
src/meta/service/src/health_service.rs
src/meta/service/src/heartbeat_service.rs
src/meta/service/src/hummock_service.rs
src/meta/service/src/lib.rs
src/meta/service/src/meta_member_service.rs
src/meta/service/src/notification_service.rs
src/meta/service/src/scale_service.rs
src/meta/service/src/serving_service.rs
src/meta/service/src/session_config.rs
src/meta/service/src/sink_coordination_service.rs
src/meta/service/src/stream_service.rs
src/meta/service/src/system_params_service.rs
src/meta/service/src/telemetry_service.rs
src/meta/service/src/user_service.rs
src/meta/src/backup_restore/backup_manager.rs
src/meta/src/backup_restore/error.rs
src/meta/src/backup_restore/meta_snapshot_builder.rs
src/meta/src/backup_restore/metrics.rs
src/meta/src/backup_restore/mod.rs
src/meta/src/backup_restore/restore.rs
src/meta/src/backup_restore/restore_impl/mod.rs
src/meta/src/backup_restore/restore_impl/v2.rs
src/meta/src/backup_restore/utils.rs
src/meta/src/barrier/checkpoint/control.rs
src/meta/src/barrier/checkpoint/creating_job/barrier_control.rs
src/meta/src/barrier/checkpoint/creating_job/mod.rs
src/meta/src/barrier/checkpoint/creating_job/status.rs
src/meta/src/barrier/checkpoint/mod.rs
src/meta/src/barrier/checkpoint/recovery.rs
src/meta/src/barrier/checkpoint/state.rs
src/meta/src/barrier/command.rs
src/meta/src/barrier/complete_task.rs
src/meta/src/barrier/context/context_impl.rs
src/meta/src/barrier/context/mod.rs
src/meta/src/barrier/context/recovery.rs
src/meta/src/barrier/info.rs
src/meta/src/barrier/manager.rs
src/meta/src/barrier/mod.rs
src/meta/src/barrier/notifier.rs
src/meta/src/barrier/progress.rs
src/meta/src/barrier/rpc.rs
src/meta/src/barrier/schedule.rs
src/meta/src/barrier/trace.rs
src/meta/src/barrier/utils.rs
src/meta/src/barrier/worker.rs
src/meta/src/controller/catalog/alter_op.rs
src/meta/src/controller/catalog/create_op.rs
src/meta/src/controller/catalog/drop_op.rs
src/meta/src/controller/catalog/get_op.rs
src/meta/src/controller/catalog/list_op.rs
src/meta/src/controller/catalog/mod.rs
src/meta/src/controller/catalog/test.rs
src/meta/src/controller/catalog/util.rs
src/meta/src/controller/cluster.rs
src/meta/src/controller/fragment.rs
src/meta/src/controller/id.rs
src/meta/src/controller/mod.rs
src/meta/src/controller/rename.rs
src/meta/src/controller/scale.rs
src/meta/src/controller/session_params.rs
src/meta/src/controller/streaming_job.rs
src/meta/src/controller/system_param.rs
src/meta/src/controller/user.rs
src/meta/src/controller/utils.rs
src/meta/src/dashboard/mod.rs
src/meta/src/dashboard/prometheus.rs
src/meta/src/error.rs
src/meta/src/hummock/compaction/compaction_config.rs
src/meta/src/hummock/compaction/mod.rs
src/meta/src/hummock/compaction/overlap_strategy.rs
src/meta/src/hummock/compaction/picker/base_level_compaction_picker.rs
src/meta/src/hummock/compaction/picker/compaction_task_validator.rs
src/meta/src/hummock/compaction/picker/emergency_compaction_picker.rs
src/meta/src/hummock/compaction/picker/intra_compaction_picker.rs
src/meta/src/hummock/compaction/picker/manual_compaction_picker.rs
src/meta/src/hummock/compaction/picker/min_overlap_compaction_picker.rs
src/meta/src/hummock/compaction/picker/mod.rs
src/meta/src/hummock/compaction/picker/space_reclaim_compaction_picker.rs
src/meta/src/hummock/compaction/picker/tier_compaction_picker.rs
src/meta/src/hummock/compaction/picker/tombstone_reclaim_compaction_picker.rs
src/meta/src/hummock/compaction/picker/trivial_move_compaction_picker.rs
src/meta/src/hummock/compaction/picker/ttl_reclaim_compaction_picker.rs
src/meta/src/hummock/compaction/picker/vnode_watermark_picker.rs
src/meta/src/hummock/compaction/selector/emergency_selector.rs
src/meta/src/hummock/compaction/selector/level_selector.rs
src/meta/src/hummock/compaction/selector/manual_selector.rs
src/meta/src/hummock/compaction/selector/mod.rs
src/meta/src/hummock/compaction/selector/space_reclaim_selector.rs
src/meta/src/hummock/compaction/selector/tombstone_compaction_selector.rs
src/meta/src/hummock/compaction/selector/ttl_selector.rs
src/meta/src/hummock/compaction/selector/vnode_watermark_selector.rs
src/meta/src/hummock/compactor_manager.rs
src/meta/src/hummock/error.rs
src/meta/src/hummock/level_handler.rs
src/meta/src/hummock/manager/checkpoint.rs
src/meta/src/hummock/manager/commit_epoch.rs
src/meta/src/hummock/manager/compaction/compaction_group_manager.rs
src/meta/src/hummock/manager/compaction/compaction_group_schedule.rs
src/meta/src/hummock/manager/compaction/mod.rs
src/meta/src/hummock/manager/context.rs
src/meta/src/hummock/manager/gc.rs
src/meta/src/hummock/manager/mod.rs
src/meta/src/hummock/manager/sequence.rs
src/meta/src/hummock/manager/table_write_throughput_statistic.rs
src/meta/src/hummock/manager/tests.rs
src/meta/src/hummock/manager/time_travel.rs
src/meta/src/hummock/manager/timer_task.rs
src/meta/src/hummock/manager/transaction.rs
src/meta/src/hummock/manager/utils.rs
src/meta/src/hummock/manager/versioning.rs
src/meta/src/hummock/manager/worker.rs
src/meta/src/hummock/metrics_utils.rs
src/meta/src/hummock/mock_hummock_meta_client.rs
src/meta/src/hummock/mod.rs
src/meta/src/hummock/model/compaction_group_config.rs
src/meta/src/hummock/model/compaction_status.rs
src/meta/src/hummock/model/ext/hummock.rs
src/meta/src/hummock/model/ext/mod.rs
src/meta/src/hummock/model/mod.rs
src/meta/src/hummock/test_utils.rs
src/meta/src/hummock/utils.rs
src/meta/src/lib.rs
src/meta/src/manager/diagnose.rs
src/meta/src/manager/env.rs
src/meta/src/manager/event_log.rs
src/meta/src/manager/idle.rs
src/meta/src/manager/license.rs
src/meta/src/manager/metadata.rs
src/meta/src/manager/mod.rs
src/meta/src/manager/notification.rs
src/meta/src/manager/notification_version.rs
src/meta/src/manager/sink_coordination/coordinator_worker.rs
src/meta/src/manager/sink_coordination/handle.rs
src/meta/src/manager/sink_coordination/manager.rs
src/meta/src/manager/sink_coordination/mod.rs
src/meta/src/manager/streaming_job.rs
src/meta/src/model/error.rs
src/meta/src/model/mod.rs
src/meta/src/model/stream.rs
src/meta/src/rpc/ddl_controller.rs
src/meta/src/rpc/election/dummy.rs
src/meta/src/rpc/election/mod.rs
src/meta/src/rpc/election/sql.rs
src/meta/src/rpc/intercept.rs
src/meta/src/rpc/metrics.rs
src/meta/src/rpc/mod.rs
src/meta/src/serving/mod.rs
src/meta/src/storage/mod.rs
src/meta/src/storage/transaction.rs
src/meta/src/stream/mod.rs
src/meta/src/stream/scale.rs
src/meta/src/stream/sink.rs
src/meta/src/stream/source_manager.rs
src/meta/src/stream/stream_graph.rs
src/meta/src/stream/stream_graph/actor.rs
src/meta/src/stream/stream_graph/fragment.rs
src/meta/src/stream/stream_graph/id.rs
src/meta/src/stream/stream_graph/schedule.rs
src/meta/src/stream/stream_manager.rs
src/meta/src/stream/test_fragmenter.rs
src/meta/src/stream/test_scale.rs
src/meta/src/telemetry.rs
src/object_store/src/lib.rs
src/object_store/src/object/error.rs
src/object_store/src/object/mem.rs
src/object_store/src/object/mod.rs
src/object_store/src/object/object_metrics.rs
src/object_store/src/object/opendal_engine/azblob.rs
src/object_store/src/object/opendal_engine/fs.rs
src/object_store/src/object/opendal_engine/gcs.rs
src/object_store/src/object/opendal_engine/hdfs.rs
src/object_store/src/object/opendal_engine/mod.rs
src/object_store/src/object/opendal_engine/obs.rs
src/object_store/src/object/opendal_engine/opendal_object_store.rs
src/object_store/src/object/opendal_engine/opendal_s3.rs
src/object_store/src/object/opendal_engine/oss.rs
src/object_store/src/object/opendal_engine/webhdfs.rs
src/object_store/src/object/prefix.rs
src/object_store/src/object/s3.rs
src/object_store/src/object/sim/client.rs
src/object_store/src/object/sim/error.rs
src/object_store/src/object/sim/mod.rs
src/object_store/src/object/sim/rpc_server.rs
src/object_store/src/object/sim/service.rs
src/prost/build.rs
src/prost/helpers/src/generate.rs
src/prost/helpers/src/lib.rs
src/prost/src/lib.rs
src/risedevtool/config/src/main.rs
src/risedevtool/src/bin/risedev-compose.rs
src/risedevtool/src/bin/risedev-dev.rs
src/risedevtool/src/bin/risedev-docslt.rs
src/risedevtool/src/compose.rs
src/risedevtool/src/compose_deploy.rs
src/risedevtool/src/config.rs
src/risedevtool/src/config/dollar_expander.rs
src/risedevtool/src/config/id_expander.rs
src/risedevtool/src/config/provide_expander.rs
src/risedevtool/src/config/use_expander.rs
src/risedevtool/src/config_gen.rs
src/risedevtool/src/config_gen/grafana_gen.rs
src/risedevtool/src/config_gen/prometheus_gen.rs
src/risedevtool/src/config_gen/tempo_gen.rs
src/risedevtool/src/lib.rs
src/risedevtool/src/preflight_check.rs
src/risedevtool/src/risedev_env.rs
src/risedevtool/src/service_config.rs
src/risedevtool/src/task.rs
src/risedevtool/src/task/compactor_service.rs
src/risedevtool/src/task/compute_node_service.rs
src/risedevtool/src/task/configure_tmux_service.rs
src/risedevtool/src/task/docker_service.rs
src/risedevtool/src/task/dummy_service.rs
src/risedevtool/src/task/ensure_stop_service.rs
src/risedevtool/src/task/frontend_service.rs
src/risedevtool/src/task/grafana_service.rs
src/risedevtool/src/task/kafka_service.rs
src/risedevtool/src/task/meta_node_service.rs
src/risedevtool/src/task/minio_service.rs
src/risedevtool/src/task/mysql_service.rs
src/risedevtool/src/task/postgres_service.rs
src/risedevtool/src/task/prometheus_service.rs
src/risedevtool/src/task/pubsub_service.rs
src/risedevtool/src/task/redis_service.rs
src/risedevtool/src/task/schema_registry_service.rs
src/risedevtool/src/task/sql_server_service.rs
src/risedevtool/src/task/task_configure_minio.rs
src/risedevtool/src/task/task_kafka_ready_check.rs
src/risedevtool/src/task/task_log_ready_check.rs
src/risedevtool/src/task/task_pubsub_emu_ready_check.rs
src/risedevtool/src/task/task_redis_ready_check.rs
src/risedevtool/src/task/task_tcp_ready_check.rs
src/risedevtool/src/task/tempo_service.rs
src/risedevtool/src/task/utils.rs
src/risedevtool/src/util.rs
src/risedevtool/src/wait.rs
src/rpc_client/src/channel.rs
src/rpc_client/src/compactor_client.rs
src/rpc_client/src/compute_client.rs
src/rpc_client/src/connector_client.rs
src/rpc_client/src/error.rs
src/rpc_client/src/frontend_client.rs
src/rpc_client/src/hummock_meta_client.rs
src/rpc_client/src/lib.rs
src/rpc_client/src/meta_client.rs
src/rpc_client/src/sink_coordinate_client.rs
src/rpc_client/src/stream_client.rs
src/storage/backup/src/error.rs
src/storage/backup/src/lib.rs
src/storage/backup/src/meta_snapshot.rs
src/storage/backup/src/meta_snapshot_v1.rs
src/storage/backup/src/meta_snapshot_v2.rs
src/storage/backup/src/storage.rs
src/storage/benches/bench_block_cache.rs
src/storage/benches/bench_block_iter.rs
src/storage/benches/bench_compactor.rs
src/storage/benches/bench_compression.rs
src/storage/benches/bench_fs_operation.rs
src/storage/benches/bench_imm_compact.rs
src/storage/benches/bench_merge_iter.rs
src/storage/benches/bench_multi_builder.rs
src/storage/benches/bench_row.rs
src/storage/benches/bench_table_watermarks.rs
src/storage/compactor/src/compactor_observer/mod.rs
src/storage/compactor/src/compactor_observer/observer_manager.rs
src/storage/compactor/src/lib.rs
src/storage/compactor/src/rpc.rs
src/storage/compactor/src/server.rs
src/storage/compactor/src/telemetry.rs
src/storage/hummock_sdk/src/change_log.rs
src/storage/hummock_sdk/src/compact.rs
src/storage/hummock_sdk/src/compact_task.rs
src/storage/hummock_sdk/src/compaction_group/hummock_version_ext.rs
src/storage/hummock_sdk/src/compaction_group/mod.rs
src/storage/hummock_sdk/src/frontend_version.rs
src/storage/hummock_sdk/src/key.rs
src/storage/hummock_sdk/src/key_cmp.rs
src/storage/hummock_sdk/src/key_range.rs
src/storage/hummock_sdk/src/level.rs
src/storage/hummock_sdk/src/lib.rs
src/storage/hummock_sdk/src/prost_key_range.rs
src/storage/hummock_sdk/src/sstable_info.rs
src/storage/hummock_sdk/src/state_table_info.rs
src/storage/hummock_sdk/src/table_stats.rs
src/storage/hummock_sdk/src/table_watermark.rs
src/storage/hummock_sdk/src/time_travel.rs
src/storage/hummock_sdk/src/version.rs
src/storage/hummock_test/benches/bench_hummock_iter.rs
src/storage/hummock_test/src/bin/replay/main.rs
src/storage/hummock_test/src/bin/replay/replay_impl.rs
src/storage/hummock_test/src/compactor_tests.rs
src/storage/hummock_test/src/failpoint_tests.rs
src/storage/hummock_test/src/hummock_read_version_tests.rs
src/storage/hummock_test/src/hummock_storage_tests.rs
src/storage/hummock_test/src/lib.rs
src/storage/hummock_test/src/local_state_store_test_utils.rs
src/storage/hummock_test/src/mock_notification_client.rs
src/storage/hummock_test/src/snapshot_tests.rs
src/storage/hummock_test/src/state_store_tests.rs
src/storage/hummock_test/src/sync_point_tests.rs
src/storage/hummock_test/src/test_utils.rs
src/storage/hummock_trace/src/collector.rs
src/storage/hummock_trace/src/error.rs
src/storage/hummock_trace/src/lib.rs
src/storage/hummock_trace/src/opts.rs
src/storage/hummock_trace/src/read.rs
src/storage/hummock_trace/src/record.rs
src/storage/hummock_trace/src/replay/mod.rs
src/storage/hummock_trace/src/replay/runner.rs
src/storage/hummock_trace/src/replay/worker.rs
src/storage/hummock_trace/src/write.rs
src/storage/src/compaction_catalog_manager.rs
src/storage/src/error.rs
src/storage/src/hummock/backup_reader.rs
src/storage/src/hummock/block_cache.rs
src/storage/src/hummock/block_stream.rs
src/storage/src/hummock/compactor/compaction_executor.rs
src/storage/src/hummock/compactor/compaction_filter.rs
src/storage/src/hummock/compactor/compaction_utils.rs
src/storage/src/hummock/compactor/compactor_runner.rs
src/storage/src/hummock/compactor/context.rs
src/storage/src/hummock/compactor/fast_compactor_runner.rs
src/storage/src/hummock/compactor/iterator.rs
src/storage/src/hummock/compactor/mod.rs
src/storage/src/hummock/compactor/shared_buffer_compact.rs
src/storage/src/hummock/compactor/task_progress.rs
src/storage/src/hummock/error.rs
src/storage/src/hummock/event_handler/hummock_event_handler.rs
src/storage/src/hummock/event_handler/mod.rs
src/storage/src/hummock/event_handler/refiller.rs
src/storage/src/hummock/event_handler/uploader/mod.rs
src/storage/src/hummock/event_handler/uploader/spiller.rs
src/storage/src/hummock/event_handler/uploader/task_manager.rs
src/storage/src/hummock/event_handler/uploader/test_utils.rs
src/storage/src/hummock/hummock_meta_client.rs
src/storage/src/hummock/iterator/backward_concat.rs
src/storage/src/hummock/iterator/backward_merge.rs
src/storage/src/hummock/iterator/backward_user.rs
src/storage/src/hummock/iterator/change_log.rs
src/storage/src/hummock/iterator/concat_inner.rs
src/storage/src/hummock/iterator/forward_concat.rs
src/storage/src/hummock/iterator/forward_merge.rs
src/storage/src/hummock/iterator/forward_user.rs
src/storage/src/hummock/iterator/merge_inner.rs
src/storage/src/hummock/iterator/mod.rs
src/storage/src/hummock/iterator/skip_watermark.rs
src/storage/src/hummock/iterator/test_utils.rs
src/storage/src/hummock/local_version/mod.rs
src/storage/src/hummock/local_version/pinned_version.rs
src/storage/src/hummock/local_version/recent_versions.rs
src/storage/src/hummock/mod.rs
src/storage/src/hummock/observer_manager.rs
src/storage/src/hummock/recent_filter.rs
src/storage/src/hummock/shared_buffer/mod.rs
src/storage/src/hummock/shared_buffer/shared_buffer_batch.rs
src/storage/src/hummock/sstable/backward_sstable_iterator.rs
src/storage/src/hummock/sstable/block.rs
src/storage/src/hummock/sstable/block_iterator.rs
src/storage/src/hummock/sstable/bloom.rs
src/storage/src/hummock/sstable/builder.rs
src/storage/src/hummock/sstable/filter.rs
src/storage/src/hummock/sstable/forward_sstable_iterator.rs
src/storage/src/hummock/sstable/mod.rs
src/storage/src/hummock/sstable/multi_builder.rs
src/storage/src/hummock/sstable/sstable_object_id_manager.rs
src/storage/src/hummock/sstable/utils.rs
src/storage/src/hummock/sstable/writer.rs
src/storage/src/hummock/sstable/xor_filter.rs
src/storage/src/hummock/sstable_store.rs
src/storage/src/hummock/store/hummock_storage.rs
src/storage/src/hummock/store/local_hummock_storage.rs
src/storage/src/hummock/store/mod.rs
src/storage/src/hummock/store/version.rs
src/storage/src/hummock/test_utils.rs
src/storage/src/hummock/time_travel_version_cache.rs
src/storage/src/hummock/utils.rs
src/storage/src/hummock/validator.rs
src/storage/src/hummock/value.rs
src/storage/src/hummock/write_limiter.rs
src/storage/src/lib.rs
src/storage/src/mem_table.rs
src/storage/src/memory.rs
src/storage/src/monitor/compactor_metrics.rs
src/storage/src/monitor/hitmap.rs
src/storage/src/monitor/hummock_metrics.rs
src/storage/src/monitor/hummock_state_store_metrics.rs
src/storage/src/monitor/local_metrics.rs
src/storage/src/monitor/mod.rs
src/storage/src/monitor/monitored_storage_metrics.rs
src/storage/src/monitor/monitored_store.rs
src/storage/src/monitor/traced_store.rs
src/storage/src/opts.rs
src/storage/src/panic_store.rs
src/storage/src/row_serde/mod.rs
src/storage/src/row_serde/row_serde_util.rs
src/storage/src/row_serde/value_serde.rs
src/storage/src/storage_failpoints/mod.rs
src/storage/src/storage_failpoints/test_iterator.rs
src/storage/src/storage_failpoints/test_sstable.rs
src/storage/src/storage_value.rs
src/storage/src/store.rs
src/storage/src/store_impl.rs
src/storage/src/table/batch_table/mod.rs
src/storage/src/table/batch_table/storage_table.rs
src/storage/src/table/merge_sort.rs
src/storage/src/table/mod.rs
src/stream/benches/bench_state_table.rs
src/stream/benches/stream_hash_agg.rs
src/stream/benches/stream_hash_join.py
src/stream/benches/stream_hash_join_mem.rs
src/stream/benches/stream_hash_join_rt.rs
src/stream/spill_test/src/lib.rs
src/stream/spill_test/src/test_mem_table.rs
src/stream/src/cache/managed_lru.rs
src/stream/src/cache/mod.rs
src/stream/src/common/builder.rs
src/stream/src/common/column_mapping.rs
src/stream/src/common/compact_chunk.rs
src/stream/src/common/log_store_impl/in_mem.rs
src/stream/src/common/log_store_impl/kv_log_store/buffer.rs
src/stream/src/common/log_store_impl/kv_log_store/mod.rs
src/stream/src/common/log_store_impl/kv_log_store/reader.rs
src/stream/src/common/log_store_impl/kv_log_store/serde.rs
src/stream/src/common/log_store_impl/kv_log_store/test_utils.rs
src/stream/src/common/log_store_impl/kv_log_store/writer.rs
src/stream/src/common/log_store_impl/mod.rs
src/stream/src/common/metrics.rs
src/stream/src/common/mod.rs
src/stream/src/common/rate_limit.rs
src/stream/src/common/state_cache/mod.rs
src/stream/src/common/state_cache/ordered.rs
src/stream/src/common/state_cache/top_n.rs
src/stream/src/common/table/mod.rs
src/stream/src/common/table/state_table.rs
src/stream/src/common/table/state_table_cache.rs
src/stream/src/common/table/test_state_table.rs
src/stream/src/common/table/test_storage_table.rs
src/stream/src/common/table/test_utils.rs
src/stream/src/error.rs
src/stream/src/executor/actor.rs
src/stream/src/executor/agg_common.rs
src/stream/src/executor/aggregation/agg_group.rs
src/stream/src/executor/aggregation/agg_state.rs
src/stream/src/executor/aggregation/agg_state_cache.rs
src/stream/src/executor/aggregation/distinct.rs
src/stream/src/executor/aggregation/minput.rs
src/stream/src/executor/aggregation/mod.rs
src/stream/src/executor/approx_percentile/global.rs
src/stream/src/executor/approx_percentile/global_state.rs
src/stream/src/executor/approx_percentile/local.rs
src/stream/src/executor/approx_percentile/mod.rs
src/stream/src/executor/asof_join.rs
src/stream/src/executor/backfill/arrangement_backfill.rs
src/stream/src/executor/backfill/cdc/cdc_backfill.rs
src/stream/src/executor/backfill/cdc/mod.rs
src/stream/src/executor/backfill/cdc/state.rs
src/stream/src/executor/backfill/cdc/upstream_table/external.rs
src/stream/src/executor/backfill/cdc/upstream_table/mod.rs
src/stream/src/executor/backfill/cdc/upstream_table/snapshot.rs
src/stream/src/executor/backfill/mod.rs
src/stream/src/executor/backfill/no_shuffle_backfill.rs
src/stream/src/executor/backfill/snapshot_backfill/executor.rs
src/stream/src/executor/backfill/snapshot_backfill/mod.rs
src/stream/src/executor/backfill/snapshot_backfill/vnode_stream.rs
src/stream/src/executor/backfill/utils.rs
src/stream/src/executor/barrier_align.rs
src/stream/src/executor/barrier_recv.rs
src/stream/src/executor/batch_query.rs
src/stream/src/executor/chain.rs
src/stream/src/executor/changelog.rs
src/stream/src/executor/dedup/append_only_dedup.rs
src/stream/src/executor/dedup/cache.rs
src/stream/src/executor/dedup/mod.rs
src/stream/src/executor/dispatch.rs
src/stream/src/executor/dml.rs
src/stream/src/executor/dynamic_filter.rs
src/stream/src/executor/error.rs
src/stream/src/executor/exchange/error.rs
src/stream/src/executor/exchange/input.rs
src/stream/src/executor/exchange/mod.rs
src/stream/src/executor/exchange/output.rs
src/stream/src/executor/exchange/permit.rs
src/stream/src/executor/expand.rs
src/stream/src/executor/filter.rs
src/stream/src/executor/hash_agg.rs
src/stream/src/executor/hash_join.rs
src/stream/src/executor/hop_window.rs
src/stream/src/executor/integration_tests.rs
src/stream/src/executor/join/builder.rs
src/stream/src/executor/join/hash_join.rs
src/stream/src/executor/join/join_row_set.rs
src/stream/src/executor/join/mod.rs
src/stream/src/executor/join/row.rs
src/stream/src/executor/lookup.rs
src/stream/src/executor/lookup/cache.rs
src/stream/src/executor/lookup/impl_.rs
src/stream/src/executor/lookup/sides.rs
src/stream/src/executor/lookup/tests.rs
src/stream/src/executor/lookup_union.rs
src/stream/src/executor/merge.rs
src/stream/src/executor/mod.rs
src/stream/src/executor/monitor/mod.rs
src/stream/src/executor/monitor/streaming_stats.rs
src/stream/src/executor/mview/materialize.rs
src/stream/src/executor/mview/mod.rs
src/stream/src/executor/mview/test_utils.rs
src/stream/src/executor/nested_loop_temporal_join.rs
src/stream/src/executor/no_op.rs
src/stream/src/executor/now.rs
src/stream/src/executor/over_window/eowc.rs
src/stream/src/executor/over_window/frame_finder.rs
src/stream/src/executor/over_window/general.rs
src/stream/src/executor/over_window/mod.rs
src/stream/src/executor/over_window/over_partition.rs
src/stream/src/executor/prelude.rs
src/stream/src/executor/project.rs
src/stream/src/executor/project_set.rs
src/stream/src/executor/rearranged_chain.rs
src/stream/src/executor/receiver.rs
src/stream/src/executor/row_id_gen.rs
src/stream/src/executor/row_merge.rs
src/stream/src/executor/simple_agg.rs
src/stream/src/executor/sink.rs
src/stream/src/executor/sort.rs
src/stream/src/executor/sort_buffer.rs
src/stream/src/executor/source/executor_core.rs
src/stream/src/executor/source/fetch_executor.rs
src/stream/src/executor/source/fs_source_executor.rs
src/stream/src/executor/source/list_executor.rs
src/stream/src/executor/source/mod.rs
src/stream/src/executor/source/source_backfill_executor.rs
src/stream/src/executor/source/source_backfill_state_table.rs
src/stream/src/executor/source/source_executor.rs
src/stream/src/executor/source/state_table_handler.rs
src/stream/src/executor/stateless_simple_agg.rs
src/stream/src/executor/stream_reader.rs
src/stream/src/executor/subtask.rs
src/stream/src/executor/temporal_join.rs
src/stream/src/executor/test_utils.rs
src/stream/src/executor/top_n/group_top_n.rs
src/stream/src/executor/top_n/group_top_n_appendonly.rs
src/stream/src/executor/top_n/mod.rs
src/stream/src/executor/top_n/top_n_appendonly.rs
src/stream/src/executor/top_n/top_n_cache.rs
src/stream/src/executor/top_n/top_n_plain.rs
src/stream/src/executor/top_n/top_n_state.rs
src/stream/src/executor/top_n/utils.rs
src/stream/src/executor/troublemaker.rs
src/stream/src/executor/union.rs
src/stream/src/executor/utils.rs
src/stream/src/executor/values.rs
src/stream/src/executor/watermark/mod.rs
src/stream/src/executor/watermark_filter.rs
src/stream/src/executor/wrapper.rs
src/stream/src/executor/wrapper/epoch_check.rs
src/stream/src/executor/wrapper/epoch_provide.rs
src/stream/src/executor/wrapper/schema_check.rs
src/stream/src/executor/wrapper/trace.rs
src/stream/src/executor/wrapper/update_check.rs
src/stream/src/from_proto/agg_common.rs
src/stream/src/from_proto/append_only_dedup.rs
src/stream/src/from_proto/approx_percentile/global.rs
src/stream/src/from_proto/approx_percentile/local.rs
src/stream/src/from_proto/approx_percentile/mod.rs
src/stream/src/from_proto/asof_join.rs
src/stream/src/from_proto/barrier_recv.rs
src/stream/src/from_proto/batch_query.rs
src/stream/src/from_proto/cdc_filter.rs
src/stream/src/from_proto/changelog.rs
src/stream/src/from_proto/dml.rs
src/stream/src/from_proto/dynamic_filter.rs
src/stream/src/from_proto/eowc_over_window.rs
src/stream/src/from_proto/expand.rs
src/stream/src/from_proto/filter.rs
src/stream/src/from_proto/group_top_n.rs
src/stream/src/from_proto/hash_agg.rs
src/stream/src/from_proto/hash_join.rs
src/stream/src/from_proto/hop_window.rs
src/stream/src/from_proto/lookup.rs
src/stream/src/from_proto/lookup_union.rs
src/stream/src/from_proto/merge.rs
src/stream/src/from_proto/mod.rs
src/stream/src/from_proto/mview.rs
src/stream/src/from_proto/no_op.rs
src/stream/src/from_proto/now.rs
src/stream/src/from_proto/over_window.rs
src/stream/src/from_proto/project.rs
src/stream/src/from_proto/project_set.rs
src/stream/src/from_proto/row_id_gen.rs
src/stream/src/from_proto/row_merge.rs
src/stream/src/from_proto/simple_agg.rs
src/stream/src/from_proto/sink.rs
src/stream/src/from_proto/sort.rs
src/stream/src/from_proto/source/fs_fetch.rs
src/stream/src/from_proto/source/mod.rs
src/stream/src/from_proto/source/trad_source.rs
src/stream/src/from_proto/source_backfill.rs
src/stream/src/from_proto/stateless_simple_agg.rs
src/stream/src/from_proto/stream_cdc_scan.rs
src/stream/src/from_proto/stream_scan.rs
src/stream/src/from_proto/temporal_join.rs
src/stream/src/from_proto/top_n.rs
src/stream/src/from_proto/union.rs
src/stream/src/from_proto/values.rs
src/stream/src/from_proto/watermark_filter.rs
src/stream/src/lib.rs
src/stream/src/task/barrier_manager.rs
src/stream/src/task/barrier_manager/managed_state.rs
src/stream/src/task/barrier_manager/progress.rs
src/stream/src/task/barrier_manager/tests.rs
src/stream/src/task/env.rs
src/stream/src/task/mod.rs
src/stream/src/task/stream_manager.rs
src/stream/src/telemetry.rs
src/stream/tests/integration_tests/eowc_over_window.rs
src/stream/tests/integration_tests/hash_agg.rs
src/stream/tests/integration_tests/hop_window.rs
src/stream/tests/integration_tests/main.rs
src/stream/tests/integration_tests/over_window.rs
src/stream/tests/integration_tests/project_set.rs
src/stream/tests/integration_tests/snapshot.rs
src/test_runner/src/lib.rs
src/test_runner/src/test_runner.rs
src/tests/compaction_test/src/bin/compaction.rs
src/tests/compaction_test/src/compaction_test_runner.rs
src/tests/compaction_test/src/lib.rs
src/tests/e2e_extended_mode/src/lib.rs
src/tests/e2e_extended_mode/src/main.rs
src/tests/e2e_extended_mode/src/opts.rs
src/tests/e2e_extended_mode/src/test.rs
src/tests/libpq_test/src/main.rs
src/tests/regress/src/bin/main.rs
src/tests/regress/src/env.rs
src/tests/regress/src/file.rs
src/tests/regress/src/lib.rs
src/tests/regress/src/opts.rs
src/tests/regress/src/psql.rs
src/tests/regress/src/schedule.rs
src/tests/simulation/src/client.rs
src/tests/simulation/src/cluster.rs
src/tests/simulation/src/ctl_ext.rs
src/tests/simulation/src/kafka.rs
src/tests/simulation/src/lib.rs
src/tests/simulation/src/main.rs
src/tests/simulation/src/nexmark.rs
src/tests/simulation/src/slt.rs
src/tests/simulation/src/utils/assert_result.rs
src/tests/simulation/src/utils/mod.rs
src/tests/simulation/src/utils/timed_future.rs
src/tests/simulation/tests/integration_tests/backfill_tests.rs
src/tests/simulation/tests/integration_tests/batch/mod.rs
src/tests/simulation/tests/integration_tests/compaction/mod.rs
src/tests/simulation/tests/integration_tests/main.rs
src/tests/simulation/tests/integration_tests/recovery/backfill.rs
src/tests/simulation/tests/integration_tests/recovery/background_ddl.rs
src/tests/simulation/tests/integration_tests/recovery/event_log.rs
src/tests/simulation/tests/integration_tests/recovery/mod.rs
src/tests/simulation/tests/integration_tests/recovery/nexmark_recovery.rs
src/tests/simulation/tests/integration_tests/recovery/pause_on_bootstrap.rs
src/tests/simulation/tests/integration_tests/scale/auto_parallelism.rs
src/tests/simulation/tests/integration_tests/scale/cascade_materialized_view.rs
src/tests/simulation/tests/integration_tests/scale/dynamic_filter.rs
src/tests/simulation/tests/integration_tests/scale/mod.rs
src/tests/simulation/tests/integration_tests/scale/nexmark_chaos.rs
src/tests/simulation/tests/integration_tests/scale/nexmark_q4.rs
src/tests/simulation/tests/integration_tests/scale/nexmark_source.rs
src/tests/simulation/tests/integration_tests/scale/no_shuffle.rs
src/tests/simulation/tests/integration_tests/scale/resource_group.rs
src/tests/simulation/tests/integration_tests/scale/schedulability.rs
src/tests/simulation/tests/integration_tests/scale/shared_source.rs
src/tests/simulation/tests/integration_tests/scale/singleton_migration.rs
src/tests/simulation/tests/integration_tests/scale/sink.rs
src/tests/simulation/tests/integration_tests/scale/streaming_parallelism.rs
src/tests/simulation/tests/integration_tests/scale/table.rs
src/tests/simulation/tests/integration_tests/sink/basic.rs
src/tests/simulation/tests/integration_tests/sink/err_isolation.rs
src/tests/simulation/tests/integration_tests/sink/mod.rs
src/tests/simulation/tests/integration_tests/sink/rate_limit.rs
src/tests/simulation/tests/integration_tests/sink/recovery.rs
src/tests/simulation/tests/integration_tests/sink/scale.rs
src/tests/simulation/tests/integration_tests/sink/utils.rs
src/tests/simulation/tests/integration_tests/storage.rs
src/tests/simulation/tests/integration_tests/throttle.rs
src/tests/simulation/tests/integration_tests/utils.rs
src/tests/sqlsmith/src/bin/main.rs
src/tests/sqlsmith/src/bin/reducer.rs
src/tests/sqlsmith/src/lib.rs
src/tests/sqlsmith/src/reducer.rs
src/tests/sqlsmith/src/sql_gen/agg.rs
src/tests/sqlsmith/src/sql_gen/cast.rs
src/tests/sqlsmith/src/sql_gen/dml.rs
src/tests/sqlsmith/src/sql_gen/expr.rs
src/tests/sqlsmith/src/sql_gen/functions.rs
src/tests/sqlsmith/src/sql_gen/mod.rs
src/tests/sqlsmith/src/sql_gen/query.rs
src/tests/sqlsmith/src/sql_gen/relation.rs
src/tests/sqlsmith/src/sql_gen/scalar.rs
src/tests/sqlsmith/src/sql_gen/time_window.rs
src/tests/sqlsmith/src/sql_gen/types.rs
src/tests/sqlsmith/src/sql_gen/utils.rs
src/tests/sqlsmith/src/test_runners/diff.rs
src/tests/sqlsmith/src/test_runners/fuzzing.rs
src/tests/sqlsmith/src/test_runners/mod.rs
src/tests/sqlsmith/src/test_runners/utils.rs
src/tests/sqlsmith/src/utils.rs
src/tests/sqlsmith/src/validation.rs
src/tests/sqlsmith/tests/frontend/mod.rs
src/tests/sqlsmith/tests/test_runner.rs
src/tests/state_cleaning_test/src/bin/main.rs
src/utils/delta_btree_map/src/lib.rs
src/utils/futures_util/src/buffered_with_fence.rs
src/utils/futures_util/src/lib.rs
src/utils/futures_util/src/misc.rs
src/utils/futures_util/src/pausable.rs
src/utils/iter_util/src/lib.rs
src/utils/local_stats_alloc/src/lib.rs
src/utils/pgwire/src/error.rs
src/utils/pgwire/src/error_or_notice.rs
src/utils/pgwire/src/lib.rs
src/utils/pgwire/src/net.rs
src/utils/pgwire/src/pg_extended.rs
src/utils/pgwire/src/pg_field_descriptor.rs
src/utils/pgwire/src/pg_message.rs
src/utils/pgwire/src/pg_protocol.rs
src/utils/pgwire/src/pg_response.rs
src/utils/pgwire/src/pg_server.rs
src/utils/pgwire/src/types.rs
src/utils/resource_util/src/lib.rs
src/utils/runtime/src/deadlock.rs
src/utils/runtime/src/lib.rs
src/utils/runtime/src/logger.rs
src/utils/runtime/src/panic_hook.rs
src/utils/runtime/src/prof.rs
src/utils/sync-point/src/lib.rs
src/utils/variables/src/lib.rs
src/utils/workspace-config/src/lib.rs
src/workspace-hack/build.rs
src/workspace-hack/src/lib.rs

Use this command to fix any missing license headers

```bash

docker run -it --rm -v $(pwd):/github/workspace apache/skywalking-eyes header fix

</details>

shanicky added 3 commits December 27, 2024 23:53

Merge remote-tracking branch 'origin/main' into peng/schedule-resourc…

5b62d2d

…e-group

github-actions bot added type/feature ci/run-e2e-single-node-tests ci/run-e2e-test-other-backends labels Dec 27, 2024

shanicky commented Dec 27, 2024

View reviewed changes

shanicky added 2 commits December 28, 2024 00:39

Clean up Rust test: remove unused imports, debug prints, and redundan…

6e69c23

…t comments.

Refactor scale.rs for clarity; optimize string handling in `resourc…

2cf6546

…e_group.rs` with `.to_owned()`

graphite-app bot requested a review from a team December 27, 2024 17:25

shanicky requested a review from yezizp2012 December 30, 2024 05:42

Merge remote-tracking branch 'origin/main' into peng/schedule-resourc…

7b4f5e1

…e-group

github-actions bot reviewed Jan 2, 2025

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: support schedule/reschedule resource group #19955

feat: support schedule/reschedule resource group #19955

shanicky commented Dec 27, 2024

shanicky Dec 27, 2024

github-actions bot left a comment

feat: support schedule/reschedule resource group #19955

Are you sure you want to change the base?

feat: support schedule/reschedule resource group #19955

Conversation

shanicky commented Dec 27, 2024

What's changed and what's your intention?

Checklist

Documentation

shanicky Dec 27, 2024

Choose a reason for hiding this comment

github-actions bot left a comment

Choose a reason for hiding this comment