This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/avatica.version-1.25.0
in repository https://gitbox.apache.org/repos/asf/druid.git
discard 1abd1c83326 Bump avatica.version from 1.23.0 to 1.25.0
add 6974498d983 Improve error message when task fails before becoming
ready (#16286)
add 4285a5e2c6c Update documentation for exceptions to subquery limit.
(#16295)
add 960a674442a Corrected Strict NON NULL return type checks (#16279)
add 79e48c6b45a Fix NPE while loading lookups from empty JDBC source
(#16307)
add ad5701e8914 new SCALAR_IN_ARRAY function analogous to DRUID_IN (#16306)
add 3e42ebbaead Web console: Fix the supervisor offset reset dialog.
(#16298)
add cff5d1e3695 Add method Supervisor.computeLagForAutoScaler (#16314)
add b9bbde5c0a1 Fix deadlock that can occur while merging group by results
(#15420)
add 173a206829e Fix incorrect check of InvalidFieldException to
InvalidFieldFault while generating MSQ Error Report (#16273)
add 08b5a8b88e9 Ignore append locks for compaction when using concurrent
locks (#16316)
add 65412f80ab9 remove additional column marks (#16319)
add f1d24c868f2 [CVE Fixes] Update version of Nimbus.jose.jwt (#16320)
add 4bdc1890f7d Improve worst-case performance of LIKE filters by 20x
(#16153)
add 1dabb028430 Fix `ForkingTaskRunnerTest` (#16323)
add 274ccbfd85c Reset buffer aggregators when resetting Groupers. (#16296)
add 080476f9ea3 WINDOWING - Fix 2 nodes with same digest causing mapping
issue (#16301)
add e30790e0139 Introduce Segment Schema Publishing and Polling for
Efficient Datasource Schema Building (#15817)
add 6bca406d310 Grouping on complex columns aka unifying GroupBy
strategies (#16068)
add ceb6646dec1 Add supervisor actions (#16276)
add e74da6a6b6d Add new metrics for prometheus emitter (#16329)
add 8a5cc976a93 ArrayOfDoublesSketchBuildAggregator: Fix NPE in get() for
empty sketch. (#16330)
add 77333e56fa2 Docs: Add missing kafka emitter config (#16332)
add 9c0bd56f5bf Make QueryComponentSupliers independent from test classes
(#16275)
add 50615075414 pacj4: add UserProfile attributes to AuthenticationResult
context (#16109)
add 31eee7d51ef Check for handoff of upgraded segments (#16162)
add 68d6e682e86 Fix TimeBoundary planning when filters require virtual
columns. (#16337)
add 4b6748bdc95 Update default value of useMaxMemoryEstimates for Hadoop
jobs (#16280)
add 126a0c219a8 Surface lock revocation exceptions in task status (#16325)
add 9a2d7c28bce Prepare master branch for 31.0.0 release (#16333)
add 64a6fc8fc02 JSONFlattenerMaker: Speed up charsetFix. (#16212)
add 365cd7e8e7e INSERT/REPLACE can omit clustering when catalog has
default (#16260)
add 4e3cb9c2519 change ownership of /opt/shared to druid (#16253)
add 9cd18908556 Fix log count (#16341)
add db82adcdfde SCALAR_IN_ARRAY: Optimization and behavioral follow-ups.
(#16311)
add 9aef8e02ef8 Expend coverage for default mapping (#16340)
add 9d2cae40c3f Add support for selective loading of lookups in the task
layer (#16328)
add 89ec0da5c59 Disable upload of coverage report to codecov.io (#16347)
add f8015eb02a9 Add config lagAggregate to LagBasedAutoScalerConfig
(#16334)
add 1d7595f3f78 Support for filters in the Druid Delta Lake connector
(#16288)
add aa463149715 Remove usage of skife from DruidCoordinatorConfig (#15705)
add 736a2ab7c13 update code style for task type (#16343)
add fb63520de91 Add tests for ProcessorManager (#16327)
add 26d63e7b65b Prevent joining on nested arrays and complex types (#16349)
add e695e52d3fa Improve code flow in the First/Last vector aggregators and
unify the numeric aggregators with the String implementations (#16230)
add 42e99bf9120 Add new index on datasource and task_allocator_id for
pending segments (#16355)
add 834b0eddeb8 web-console: ACE editor refactoring (#16359)
add 51104e8bb31 Docs: Remove references to Zk-based segment loading
(#16360)
add 5d1950d4512 MSQ controller: Support in-memory shuffles; towards JVM
reuse. (#16168)
add 2d0e86cbdcb Use quidem to run tests (#16249)
add e5b40b0b8c3 Miscellaneous cleanup of load queue references (#16367)
add b7ae78296a7 Allow different timechunk lock types to coexist in a task
group (#16369)
add 39ada8b9ade Web console: surface more info on the supervisor view
(#16318)
add 3717554e161 Web console changes for
https://github.com/apache/druid/pull/16288 (#16379)
add b16401323b1 update dependencies to address CVEs (#16374)
add 5fae20d2878 Do not allocate ids conflicting with existing segment ids
(#16380)
add c61c3785a0c Followup changes to 15817 (Segment schema publishing and
polling) (#16368)
add 4d62c4a917b Web console: concat data when doing a durable storage
download (#16375)
add fb7c84fb5d8 Catalog clustering keys fixes (#16351)
add 1b107ff6953 QueryableIndex: Close columns after failed vector cursor
setup. (#16365)
add 588d4424220 Add native filter conversion for SCALAR_IN_ARRAY. (#16312)
add 2a638d77d93 Remove stale references to coordinator dynamic config
killAllDataSources. (#16387)
add b713a517f12 Fix the bug in Immutable RTree object strategy (#16389)
add 92fb0ff718c upgrade mysql:mysql-connector-java to 8.2.0 (#16024)
add a2223ce821e Bump org.scala-lang:scala-library from 2.13.11 to 2.13.14
(#16364)
add b50e341a115 Bump avatica.version from 1.23.0 to 1.25.0
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1abd1c83326)
\
N -- N -- N refs/heads/dependabot/maven/avatica.version-1.25.0
(b50e341a115)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/scripts/unit_tests_script.sh | 6 +-
.github/workflows/standard-its.yml | 4 +-
.gitignore | 1 +
benchmarks/pom.xml | 27 +-
.../DruidSchemaInternRowSignatureBenchmark.java | 4 +-
.../benchmark/GroupByTypeInterfaceBenchmark.java | 7 +-
.../druid/benchmark/LikeFilterBenchmark.java | 142 ++-
.../query/CachingClusteredClientBenchmark.java | 9 +-
.../druid/benchmark/query/GroupByBenchmark.java | 7 +-
.../druid/benchmark/query/SqlGroupByBenchmark.java | 385 ++++++
.../resources/META-INF/services/java.sql.Driver | 2 +
cloud/aws-common/pom.xml | 2 +-
cloud/gcp-common/pom.xml | 2 +-
distribution/docker/Dockerfile | 2 +-
distribution/docker/Dockerfile.mysql | 8 +-
distribution/docker/docker-compose.yml | 10 +-
distribution/pom.xml | 2 +-
docs/api-reference/supervisor-api.md | 13 +-
docs/assets/supervisor-actions.png | Bin 0 -> 77894 bytes
docs/configuration/index.md | 46 +-
docs/design/zookeeper.md | 18 +-
docs/development/extensions-contrib/delta-lake.md | 10 +-
.../extensions-contrib/kafka-emitter.md | 2 +
docs/development/extensions-core/kubernetes.md | 3 +-
docs/development/extensions-core/mysql.md | 4 +-
docs/ingestion/input-sources.md | 114 +-
docs/ingestion/supervisor.md | 85 +-
docs/operations/metrics.md | 20 +-
docs/operations/use_sbt_to_build_fat_jar.md | 2 +-
docs/querying/math-expr.md | 1 +
docs/querying/query-execution.md | 6 +-
docs/querying/sql-array-functions.md | 5 +-
docs/querying/sql-functions.md | 15 +-
docs/tutorials/tutorial-sql-null.md | 2 +-
extensions-contrib/aliyun-oss-extensions/pom.xml | 2 +-
extensions-contrib/ambari-metrics-emitter/pom.xml | 2 +-
extensions-contrib/cassandra-storage/pom.xml | 2 +-
extensions-contrib/cloudfiles-extensions/pom.xml | 2 +-
extensions-contrib/compressed-bigdecimal/pom.xml | 2 +-
.../CompressedBigDecimalSqlAggregatorTestBase.java | 119 +-
extensions-contrib/ddsketch/pom.xml | 2 +-
extensions-contrib/distinctcount/pom.xml | 2 +-
.../DistinctCountGroupByQueryTest.java | 4 +-
extensions-contrib/dropwizard-emitter/pom.xml | 2 +-
.../druid-deltalake-extensions/pom.xml | 28 +-
.../apache/druid/delta/filter/DeltaAndFilter.java | 67 +
.../druid/delta/filter/DeltaEqualsFilter.java | 66 +
.../org/apache/druid/delta/filter/DeltaFilter.java | 54 +
.../druid/delta/filter/DeltaFilterUtils.java | 92 ++
.../druid/delta/filter/DeltaGreaterThanFilter.java | 66 +
.../filter/DeltaGreaterThanOrEqualsFilter.java | 66 +
.../druid/delta/filter/DeltaLessThanFilter.java | 66 +
.../delta/filter/DeltaLessThanOrEqualsFilter.java | 66 +
.../apache/druid/delta/filter/DeltaNotFilter.java | 55 +
.../apache/druid/delta/filter/DeltaOrFilter.java | 67 +
.../apache/druid/delta/input/DeltaInputSource.java | 70 +-
.../druid/delta/input/DeltaInputSourceReader.java | 4 +-
.../druid/delta/filter/DeltaAndFilterTest.java | 110 ++
.../druid/delta/filter/DeltaEqualsFilterTest.java | 103 ++
.../delta/filter/DeltaGreaterThanFilterTest.java | 56 +
.../filter/DeltaGreaterThanOrEqualsFilterTest.java | 57 +
.../delta/filter/DeltaLessThanFilterTest.java | 56 +
.../filter/DeltaLessThanOrEqualsFilterTest.java | 75 ++
.../druid/delta/filter/DeltaNotFilterTest.java | 111 ++
.../druid/delta/filter/DeltaOrFilterTest.java | 110 ++
.../druid/delta/input/DeltaInputRowTest.java | 58 +-
.../delta/input/DeltaInputSourceSerdeTest.java | 142 +++
.../druid/delta/input/DeltaInputSourceTest.java | 429 +++++--
.../apache/druid/delta/input/DeltaTestUtils.java | 285 +----
.../delta/input/NonPartitionedDeltaTable.java | 306 +++++
.../druid/delta/input/PartitionedDeltaTable.java | 258 ++++
.../org/apache/druid/delta/input/RowSerdeTest.java | 23 +-
.../src/test/resources/README.md | 38 +-
.../src/test/resources/create_delta_table.py | 23 +-
.../_delta_log/.00000000000000000000.json.crc | Bin 0 -> 44 bytes
.../_delta_log/.00000000000000000001.json.crc | Bin 0 -> 40 bytes
.../_delta_log/.00000000000000000002.json.crc | Bin 0 -> 40 bytes
.../_delta_log/00000000000000000000.json | 8 +
.../_delta_log/00000000000000000001.json | 6 +
.../_delta_log/00000000000000000002.json | 6 +
...-4065-9c4e-d5fa896dcefe.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4378-936e-34132f176203.c000.snappy.parquet.crc | Bin 0 -> 24 bytes
...-47ef-ac1a-b8decc09e05a.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...6d69-4065-9c4e-d5fa896dcefe.c000.snappy.parquet | Bin 0 -> 2049 bytes
...348f-4378-936e-34132f176203.c000.snappy.parquet | Bin 0 -> 2034 bytes
...eb13-47ef-ac1a-b8decc09e05a.c000.snappy.parquet | Bin 0 -> 2187 bytes
...-4b24-8962-03543375d133.c000.snappy.parquet.crc | Bin 0 -> 24 bytes
...-4794-97b3-faa0f302984a.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4b70-91ec-9f398300c083.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...1943-4b24-8962-03543375d133.c000.snappy.parquet | Bin 0 -> 2033 bytes
...1c53-4794-97b3-faa0f302984a.c000.snappy.parquet | Bin 0 -> 2187 bytes
...f361-4b70-91ec-9f398300c083.c000.snappy.parquet | Bin 0 -> 2186 bytes
...-407e-8ecf-03add4ee14b8.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-47a3-9eac-c09a3802cd78.c000.snappy.parquet.crc | Bin 0 -> 24 bytes
...-4a50-90d3-96f00b1b2e22.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...7ebf-407e-8ecf-03add4ee14b8.c000.snappy.parquet | Bin 0 -> 2187 bytes
...3abc-47a3-9eac-c09a3802cd78.c000.snappy.parquet | Bin 0 -> 2034 bytes
...d3a8-4a50-90d3-96f00b1b2e22.c000.snappy.parquet | Bin 0 -> 2049 bytes
...-4e92-b21c-84d385a8218a.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4bd1-8dd2-1ed5e561f801.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4c31-8340-58cb6d797963.c000.snappy.parquet.crc | Bin 0 -> 24 bytes
...d1e1-4e92-b21c-84d385a8218a.c000.snappy.parquet | Bin 0 -> 2049 bytes
...cb41-4bd1-8dd2-1ed5e561f801.c000.snappy.parquet | Bin 0 -> 2049 bytes
...2bb0-4c31-8340-58cb6d797963.c000.snappy.parquet | Bin 0 -> 2033 bytes
...-434f-a816-c73420234b25.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4d68-89ee-195b76453643.c000.snappy.parquet.crc | Bin 0 -> 24 bytes
...-4a37-9283-f2bff0c0dfad.c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...dd8d-434f-a816-c73420234b25.c000.snappy.parquet | Bin 0 -> 2049 bytes
...b0e9-4d68-89ee-195b76453643.c000.snappy.parquet | Bin 0 -> 2034 bytes
...6cfd-4a37-9283-f2bff0c0dfad.c000.snappy.parquet | Bin 0 -> 2187 bytes
.../src/test/resources/requirements.txt | 3 +-
.../druid-iceberg-extensions/pom.xml | 2 +-
extensions-contrib/gce-extensions/pom.xml | 2 +-
extensions-contrib/graphite-emitter/pom.xml | 2 +-
extensions-contrib/influx-extensions/pom.xml | 2 +-
extensions-contrib/influxdb-emitter/pom.xml | 2 +-
extensions-contrib/kafka-emitter/pom.xml | 2 +-
.../kubernetes-overlord-extensions/pom.xml | 2 +-
.../materialized-view-maintenance/pom.xml | 2 +-
.../MaterializedViewSupervisor.java | 6 -
.../MaterializedViewSupervisorSpec.java | 1 +
.../MaterializedViewSupervisorSpecTest.java | 2 -
.../MaterializedViewSupervisorTest.java | 27 +-
.../materialized-view-selection/pom.xml | 2 +-
.../MaterializedViewQueryQueryToolChest.java | 25 +-
.../materializedview/DatasourceOptimizerTest.java | 18 +-
.../MaterializedViewQueryQueryToolChestTest.java | 6 +-
extensions-contrib/momentsketch/pom.xml | 2 +-
extensions-contrib/moving-average-query/pom.xml | 2 +-
extensions-contrib/opentelemetry-emitter/pom.xml | 2 +-
extensions-contrib/opentsdb-emitter/pom.xml | 2 +-
extensions-contrib/prometheus-emitter/pom.xml | 2 +-
.../src/main/resources/defaultMetrics.json | 187 ++-
.../rabbit-stream-indexing-service/pom.xml | 2 +-
extensions-contrib/redis-cache/pom.xml | 2 +-
extensions-contrib/spectator-histogram/pom.xml | 2 +-
.../sqlserver-metadata-storage/pom.xml | 2 +-
.../storage/sqlserver/SQLServerConnector.java | 9 +-
.../storage/sqlserver/SQLServerConnectorTest.java | 7 +-
extensions-contrib/statsd-emitter/pom.xml | 2 +-
extensions-contrib/tdigestsketch/pom.xml | 2 +-
.../sql/TDigestSketchSqlAggregatorTest.java | 104 +-
extensions-contrib/thrift-extensions/pom.xml | 2 +-
extensions-contrib/time-min-max/pom.xml | 2 +-
extensions-contrib/virtual-columns/pom.xml | 2 +-
.../druid/segment/MapVirtualColumnGroupByTest.java | 15 +-
extensions-core/avro-extensions/pom.xml | 2 +-
extensions-core/azure-extensions/pom.xml | 4 +-
extensions-core/datasketches/pom.xml | 2 +-
.../hll/HllSketchMergeBufferAggregator.java | 2 +-
.../hll/HllSketchMergeBufferAggregatorHelper.java | 2 +-
.../hll/HllSketchMergeVectorAggregator.java | 2 +-
.../datasketches/theta/SketchBufferAggregator.java | 2 +-
.../theta/SketchBufferAggregatorHelper.java | 4 +-
.../datasketches/theta/SketchVectorAggregator.java | 2 +-
.../tuple/ArrayOfDoublesSketchBuildAggregator.java | 24 +-
.../ArrayOfDoublesSketchBuildBufferAggregator.java | 6 +-
.../hll/sql/HllSketchSqlAggregatorTest.java | 118 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 99 +-
.../theta/sql/ThetaSketchSqlAggregatorTest.java | 123 +-
.../sql/ArrayOfDoublesSketchSqlAggregatorTest.java | 143 ++-
extensions-core/druid-aws-rds-extensions/pom.xml | 2 +-
extensions-core/druid-basic-security/pom.xml | 2 +-
extensions-core/druid-bloom-filter/pom.xml | 2 +-
.../bloom/BloomFilterAggregatorTest.java | 1 +
.../bloom/sql/BloomFilterSqlAggregatorTest.java | 91 +-
.../query/filter/sql/BloomDimFilterSqlTest.java | 22 +-
extensions-core/druid-catalog/pom.xml | 2 +-
.../druid/catalog/sql/CatalogInsertTest.java | 102 +-
.../apache/druid/catalog/sql/CatalogQueryTest.java | 92 +-
.../druid/catalog/sql/CatalogReplaceTest.java | 114 +-
.../druid/server/http/catalog/EditorTest.java | 37 +-
extensions-core/druid-kerberos/pom.xml | 2 +-
extensions-core/druid-pac4j/pom.xml | 4 +-
.../apache/druid/security/pac4j/Pac4jFilter.java | 10 +-
extensions-core/druid-ranger-security/pom.xml | 2 +-
extensions-core/ec2-extensions/pom.xml | 2 +-
extensions-core/google-extensions/pom.xml | 2 +-
extensions-core/hdfs-storage/pom.xml | 2 +-
extensions-core/histogram/pom.xml | 2 +-
.../ApproximateHistogramGroupByQueryTest.java | 6 +-
.../FixedBucketsHistogramGroupByQueryTest.java | 6 +-
...dBucketsHistogramQuantileSqlAggregatorTest.java | 105 +-
.../histogram/sql/QuantileSqlAggregatorTest.java | 106 +-
extensions-core/kafka-extraction-namespace/pom.xml | 2 +-
extensions-core/kafka-indexing-service/pom.xml | 2 +-
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../kinesis/supervisor/KinesisSupervisor.java | 7 -
extensions-core/kubernetes-extensions/pom.xml | 2 +-
extensions-core/lookups-cached-global/pom.xml | 6 +-
.../lookup/namespace/JdbcCacheGenerator.java | 22 +-
.../JdbcExtractionNamespaceUrlCheckTest.java | 40 -
.../namespace/NamespacedExtractorModuleTest.java | 2 +-
.../cache/JdbcExtractionNamespaceTest.java | 30 +
extensions-core/lookups-cached-single/pom.xml | 6 +-
.../lookup/jdbc/JdbcDataFetcherUrlCheckTest.java | 35 -
extensions-core/multi-stage-query/pom.xml | 14 +-
.../org/apache/druid/guice/annotations/MSQ.java | 40 -
.../java/org/apache/druid/msq/exec/Controller.java | 68 +-
.../apache/druid/msq/exec/ControllerClient.java | 16 +
.../apache/druid/msq/exec/ControllerContext.java | 63 +-
.../org/apache/druid/msq/exec/ControllerImpl.java | 1329 +++++++++-----------
.../druid/msq/exec/ControllerMemoryParameters.java | 109 ++
.../msq/exec/ControllerQueryResultsReader.java | 158 +++
.../msq/exec/ExceptionWrappingWorkerClient.java | 10 +-
.../java/org/apache/druid/msq/exec/Limits.java | 7 +-
.../apache/druid/msq/exec/MemoryIntrospector.java | 65 +
.../druid/msq/exec/MemoryIntrospectorImpl.java | 140 +++
.../apache/druid/msq/exec/OutputChannelMode.java | 92 ++
.../org/apache/druid/msq/exec/QueryListener.java | 71 ++
.../org/apache/druid/msq/exec/ResultsContext.java | 86 ++
.../druid/msq/exec/RetryCapableWorkerManager.java | 45 +
.../druid/msq/exec/SegmentLoadStatusFetcher.java | 6 +-
.../org/apache/druid/msq/exec/WorkerClient.java | 41 +-
.../druid/msq/exec/WorkerFailureListener.java | 34 +
.../org/apache/druid/msq/exec/WorkerManager.java | 92 ++
.../druid/msq/exec/WorkerMemoryParameters.java | 17 +-
.../apache/druid/msq/exec/WorkerSketchFetcher.java | 48 +-
.../org/apache/druid/msq/exec/WorkerStats.java | 105 ++
.../msq/guice/IndexerMemoryManagementModule.java | 78 ++
.../apache/druid/msq/guice/MSQIndexingModule.java | 20 -
.../org/apache/druid/msq/guice/MSQSqlModule.java | 5 +-
.../apache/druid/msq/guice/MultiStageQuery.java | 3 +
.../msq/guice/PeonMemoryManagementModule.java | 85 ++
.../org/apache/druid/msq/guice/SqlTaskModule.java | 10 -
.../msq/indexing/IndexerControllerContext.java | 199 ++-
.../indexing/IndexerResourcePermissionMapper.java | 55 +
.../druid/msq/indexing/MSQControllerTask.java | 44 +-
.../apache/druid/msq/indexing/MSQWorkerTask.java | 10 +-
.../druid/msq/indexing/MSQWorkerTaskLauncher.java | 231 ++--
.../org/apache/druid/msq/indexing/RetryTask.java | 33 -
.../msq/indexing/TaskReportQueryListener.java | 214 ++++
.../msq/indexing/client/ControllerChatHandler.java | 175 +--
.../indexing/client/IndexerControllerClient.java | 16 +
.../msq/indexing/client/IndexerWorkerClient.java | 252 +---
.../destination/DataSourceMSQDestination.java | 12 +
.../destination/DurableStorageMSQDestination.java | 13 +
.../indexing/destination/ExportMSQDestination.java | 12 +
.../msq/indexing/destination/MSQDestination.java | 26 +
.../indexing/destination/MSQSelectDestination.java | 31 +-
.../destination/TaskReportMSQDestination.java | 12 +
.../msq/indexing/error/NotEnoughMemoryFault.java | 5 +-
.../SegmentGeneratorFrameProcessorFactory.java | 5 +-
.../msq/indexing/report/MSQResultsReport.java | 76 +-
.../druid/msq/indexing/report/MSQStagesReport.java | 29 +-
.../druid/msq/indexing/report/MSQStatusReport.java | 29 +-
.../msq/indexing/report/MSQTaskReportPayload.java | 13 +-
.../apache/druid/msq/input/InputSpecSlicer.java | 3 +-
.../druid/msq/input/InputSpecSlicerFactory.java | 6 +-
.../druid/msq/input/stage/StageInputSlice.java | 25 +-
.../msq/input/stage/StageInputSpecSlicer.java | 25 +-
.../msq/input/table/TableInputSpecSlicer.java | 121 +-
.../msq/kernel/GlobalSortMaxCountShuffleSpec.java | 6 +-
.../druid/msq/kernel/GlobalSortShuffleSpec.java | 6 +
.../apache/druid/msq/kernel/HashShuffleSpec.java | 7 +-
.../apache/druid/msq/kernel/MixShuffleSpec.java | 6 -
.../apache/druid/msq/kernel/QueryDefinition.java | 6 +-
.../druid/msq/kernel/QueryDefinitionBuilder.java | 15 +-
.../org/apache/druid/msq/kernel/ShuffleKind.java | 35 +-
.../org/apache/druid/msq/kernel/ShuffleSpec.java | 12 +-
.../apache/druid/msq/kernel/StageDefinition.java | 2 +-
.../java/org/apache/druid/msq/kernel/StageId.java | 8 +-
.../org/apache/druid/msq/kernel/WorkOrder.java | 72 +-
.../druid/msq/kernel/WorkerAssignmentStrategy.java | 6 +-
.../kernel/controller/ControllerQueryKernel.java | 536 ++++----
.../controller/ControllerQueryKernelConfig.java | 260 ++++
.../controller/ControllerQueryKernelUtils.java | 406 ++++++
.../kernel/controller/ControllerStagePhase.java | 124 +-
.../kernel/controller/ControllerStageTracker.java | 99 +-
.../controller/ControllerWorkerStagePhase.java | 3 +-
.../druid/msq/kernel/controller/StageGroup.java | 133 ++
.../querykit/BaseLeafFrameProcessorFactory.java | 3 +-
.../msq/querykit/ChainedProcessorManager.java | 2 +-
.../apache/druid/msq/querykit/DataSourcePlan.java | 6 +-
.../druid/msq/querykit/ShuffleSpecFactory.java | 3 +-
.../druid/msq/querykit/WindowOperatorQueryKit.java | 4 +-
.../msq/querykit/groupby/GroupByQueryKit.java | 4 +-
.../druid/msq/querykit/scan/ScanQueryKit.java | 2 +-
.../apache/druid/msq/rpc/BaseWorkerClientImpl.java | 270 ++++
.../apache/druid/msq/rpc/ControllerResource.java | 196 +++
.../org/apache/druid/msq/rpc/MSQResourceUtils.java | 50 +
.../druid/msq/rpc/ResourcePermissionMapper.java | 33 +
.../input/DurableStorageInputChannelFactory.java | 6 +-
.../msq/sql/resources/SqlStatementResource.java | 45 +-
.../druid/msq/sql/resources/SqlTaskResource.java | 4 +-
.../PartialKeyStatisticsInformation.java | 32 +
.../druid/msq/util/MultiStageQueryContext.java | 19 +
.../druid/msq/util/SqlStatementResourceHelper.java | 46 +-
.../org.apache.druid.initialization.DruidModule | 4 +-
.../src/main/resources/log4j2.xml | 3 +
.../apache/druid/msq/exec/ControllerImplTest.java | 12 +-
.../msq/exec/ControllerMemoryParametersTest.java | 121 ++
.../org/apache/druid/msq/exec/MSQFaultsTest.java | 12 +-
.../org/apache/druid/msq/exec/MSQInsertTest.java | 2 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 24 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 7 +-
.../org/apache/druid/msq/exec/MSQTasksTest.java | 74 +-
.../org/apache/druid/msq/exec/MSQWindowTest.java | 32 +
.../apache/druid/msq/exec/QueryValidatorTest.java | 5 +-
.../druid/msq/exec/WorkerSketchFetcherTest.java | 39 +-
.../druid/msq/indexing/MSQControllerTaskTest.java | 100 +-
.../msq/indexing/MSQWorkerTaskLauncherTest.java | 4 +-
.../druid/msq/indexing/MSQWorkerTaskTest.java | 8 -
.../msq/indexing/TaskReportQueryListenerTest.java | 206 +++
.../druid/msq/indexing/WorkerChatHandlerTest.java | 20 +-
.../indexing/client/ControllerChatHandlerTest.java | 17 +-
.../msq/indexing/report/MSQTaskReportTest.java | 20 +-
.../druid/msq/input/stage/StageInputSliceTest.java | 4 +-
.../msq/input/stage/StageInputSpecSlicerTest.java | 29 +-
.../msq/input/table/TableInputSpecSlicerTest.java | 45 +-
.../druid/msq/kernel/QueryDefinitionTest.java | 4 +-
.../controller/BaseControllerQueryKernelTest.java | 65 +-
.../controller/ControllerQueryKernelTest.java | 248 +++-
.../controller/ControllerQueryKernelUtilsTest.java | 551 ++++++++
.../controller/MockQueryDefinitionBuilder.java | 117 +-
.../NonShufflingWorkersWithRetryKernelTest.java | 16 +-
.../ShufflingWorkersWithRetryKernelTest.java | 17 +-
.../msq/kernel/controller/WorkerInputsTest.java | 16 +-
.../msq/querykit/ChainedProcessorManagerTest.java | 337 +++++
.../querykit/NonFailingWritableFrameChannel.java | 66 +
.../sql/resources/SqlStatementResourceTest.java | 11 +-
...ndPartialKeyStatisticsInformationSerdeTest.java | 62 +
.../druid/msq/test/CalciteArraysQueryMSQTest.java | 74 +-
.../druid/msq/test/CalciteMSQTestsHelper.java | 2 +
.../msq/test/CalciteSelectJoinQueryMSQTest.java | 72 +-
.../druid/msq/test/CalciteSelectQueryMSQTest.java | 71 +-
.../druid/msq/test/CalciteUnionQueryMSQTest.java | 74 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 96 +-
.../druid/msq/test/MSQTestControllerClient.java | 6 +
.../druid/msq/test/MSQTestControllerContext.java | 159 ++-
.../msq/test/MSQTestOverlordServiceClient.java | 141 ++-
.../apache/druid/msq/test/MSQTestWorkerClient.java | 25 +-
.../druid/msq/test/MSQTestWorkerContext.java | 17 +-
.../apache/druid/msq/test/NoopQueryListener.java | 61 +
.../msq/util/SqlStatementResourceHelperTest.java | 25 +-
extensions-core/mysql-metadata-storage/pom.xml | 6 +-
.../metadata/storage/mysql/MySQLConnector.java | 10 +-
.../sql/MySQLFirehoseDatabaseConnectorTest.java | 24 -
.../metadata/storage/mysql/MySQLConnectorTest.java | 47 +-
extensions-core/orc-extensions/pom.xml | 2 +-
extensions-core/parquet-extensions/pom.xml | 2 +-
.../postgresql-metadata-storage/pom.xml | 2 +-
.../storage/postgresql/PostgreSQLConnector.java | 6 +-
.../postgresql/PostgreSQLConnectorTest.java | 30 +-
extensions-core/protobuf-extensions/pom.xml | 2 +-
extensions-core/s3-extensions/pom.xml | 2 +-
extensions-core/simple-client-sslcontext/pom.xml | 2 +-
extensions-core/stats/pom.xml | 2 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 111 +-
extensions-core/testing-tools/pom.xml | 2 +-
.../org/apache/druid/query/sql/SleepSqlTest.java | 21 +-
indexing-hadoop/pom.xml | 2 +-
.../apache/druid/indexer/HadoopTuningConfig.java | 74 +-
.../apache/druid/indexer/IndexGeneratorJob.java | 1 +
.../updater/MetadataStorageUpdaterJobSpec.java | 1 +
.../druid/indexer/BatchDeltaIngestionTest.java | 1 +
.../indexer/DetermineHashedPartitionsJobTest.java | 1 +
.../druid/indexer/DeterminePartitionsJobTest.java | 1 +
.../indexer/DetermineRangePartitionsJobTest.java | 2 +-
.../indexer/HadoopDruidIndexerConfigTest.java | 1 +
.../druid/indexer/HadoopTuningConfigTest.java | 1 +
.../druid/indexer/IndexGeneratorJobTest.java | 1 +
.../org/apache/druid/indexer/JobHelperTest.java | 1 +
.../indexer/path/GranularityPathSpecTest.java | 1 +
indexing-service/pom.xml | 2 +-
.../common/MultipleFileTaskReportFileWriter.java | 36 +-
.../org/apache/druid/indexing/common/TaskLock.java | 15 +
.../apache/druid/indexing/common/TaskToolbox.java | 2 +-
.../common/actions/SegmentInsertAction.java | 18 +-
.../actions/SegmentTransactionalAppendAction.java | 29 +-
.../actions/SegmentTransactionalInsertAction.java | 36 +-
.../actions/SegmentTransactionalReplaceAction.java | 74 +-
.../common/task/AbstractBatchIndexTask.java | 21 +-
.../common/task/AbstractFixedIntervalTask.java | 5 +-
.../task/AppenderatorDriverRealtimeIndexTask.java | 10 +-
.../druid/indexing/common/task/ArchiveTask.java | 3 +-
.../indexing/common/task/BatchAppenderators.java | 10 +-
.../druid/indexing/common/task/CompactionTask.java | 3 +-
.../indexing/common/task/HadoopIndexTask.java | 13 +-
.../druid/indexing/common/task/IndexTask.java | 15 +-
.../indexing/common/task/InputSourceProcessor.java | 10 +-
.../common/task/KillUnusedSegmentsTask.java | 7 +
.../druid/indexing/common/task/MoveTask.java | 3 +-
.../druid/indexing/common/task/NoopTask.java | 3 +-
.../indexing/common/task/RealtimeIndexTask.java | 16 +-
.../druid/indexing/common/task/RestoreTask.java | 3 +-
.../apache/druid/indexing/common/task/Task.java | 26 +-
.../parallel/ParallelIndexSupervisorTask.java | 24 +-
...GenericSegmentMergeParallelIndexTaskRunner.java | 14 +-
.../parallel/PartialGenericSegmentMergeTask.java | 20 +-
.../batch/parallel/PartialSegmentGenerateTask.java | 6 +-
.../batch/parallel/PartialSegmentMergeTask.java | 52 +-
.../task/batch/parallel/PushedSegmentsReport.java | 17 +-
.../SinglePhaseParallelIndexTaskRunner.java | 11 +-
.../task/batch/parallel/SinglePhaseSubTask.java | 31 +-
.../druid/indexing/overlord/ForkingTaskRunner.java | 32 +-
.../druid/indexing/overlord/TaskLockbox.java | 36 +-
.../apache/druid/indexing/overlord/TaskQueue.java | 11 +-
.../overlord/supervisor/SupervisorManager.java | 21 +-
.../seekablestream/PendingSegmentVersions.java | 56 -
.../SeekableStreamIndexTaskClient.java | 11 +-
.../SeekableStreamIndexTaskClientAsyncImpl.java | 7 +-
.../SeekableStreamIndexTaskRunner.java | 18 +-
.../indexing/seekablestream/SequenceMetadata.java | 16 +-
.../supervisor/SeekableStreamSupervisor.java | 57 +-
.../supervisor/autoscaler/LagBasedAutoScaler.java | 13 +-
.../autoscaler/LagBasedAutoScalerConfig.java | 14 +-
.../MultipleFileTaskReportFileWriterTest.java | 64 +
.../common/SingleFileTaskReportFileWriterTest.java | 61 +
.../druid/indexing/common/TestIndexTask.java | 15 +
.../common/actions/LocalTaskActionClientTest.java | 2 +-
.../actions/RetrieveSegmentsActionsTest.java | 4 +-
.../common/actions/SegmentAllocateActionTest.java | 74 +-
.../common/actions/SegmentInsertActionTest.java | 4 +-
.../SegmentTransactionalInsertActionTest.java | 12 +-
.../indexing/common/actions/TaskActionTestKit.java | 16 +-
.../AppenderatorDriverRealtimeIndexTaskTest.java | 24 +-
.../indexing/common/task/AppenderatorsTest.java | 10 +-
.../common/task/BatchAppenderatorsTest.java | 2 +
.../common/task/CompactionTaskParallelRunTest.java | 67 +-
.../common/task/CompactionTaskRunTest.java | 268 ++--
.../indexing/common/task/CompactionTaskTest.java | 6 +-
.../druid/indexing/common/task/IndexTaskTest.java | 203 ++-
.../indexing/common/task/IngestionTestBase.java | 68 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 39 +-
.../common/task/NoopTestTaskReportFileWriter.java | 10 +
.../common/task/TestAppenderatorsManager.java | 18 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 10 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 15 +-
...ashPartitionAdjustingCorePartitionSizeTest.java | 4 +-
...ashPartitionMultiPhaseParallelIndexingTest.java | 12 +-
...ltiPhaseParallelIndexingWithNullColumnTest.java | 8 +-
.../ParallelIndexSupervisorTaskKillTest.java | 4 +-
.../ParallelIndexSupervisorTaskResourceTest.java | 7 +-
.../task/batch/parallel/PartialCompactionTest.java | 45 +-
.../PartialGenericSegmentMergeTaskTest.java | 9 +-
...ngePartitionAdjustingCorePartitionSizeTest.java | 4 +-
...ngePartitionMultiPhaseParallelIndexingTest.java | 44 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 26 +-
.../common/task/concurrent/ActionsTestTask.java | 10 +-
.../concurrent/ConcurrentReplaceAndAppendTest.java | 7 +-
.../ConcurrentReplaceAndStreamingAppendTest.java | 63 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 5 +-
.../druid/indexing/overlord/RealtimeishTask.java | 6 +-
.../indexing/overlord/RemoteTaskRunnerTest.java | 47 +
.../druid/indexing/overlord/TaskLifecycleTest.java | 12 +-
.../overlord/TaskLockBoxConcurrencyTest.java | 12 +-
.../druid/indexing/overlord/TaskLockboxTest.java | 116 +-
.../indexing/overlord/TaskQueueScaleTest.java | 9 +-
.../druid/indexing/overlord/TaskQueueTest.java | 5 +-
.../indexing/overlord/TestTaskToolboxFactory.java | 3 +-
.../overlord/supervisor/SupervisorManagerTest.java | 51 +
.../SeekableStreamIndexTaskTestBase.java | 8 +-
.../seekablestream/SequenceMetadataTest.java | 79 +-
.../SeekableStreamSupervisorStateTest.java | 64 +-
.../TestIndexerMetadataStorageCoordinator.java | 32 +-
integration-tests-ex/cases/pom.xml | 8 +-
.../druid/testsEx/msq/ITMultiStageQuery.java | 6 +-
integration-tests-ex/image/docker/Dockerfile | 2 +-
integration-tests-ex/image/pom.xml | 10 +-
integration-tests-ex/tools/pom.xml | 2 +-
integration-tests/docker/Dockerfile | 6 +-
...ose.cds-coordinator-metadata-query-disabled.yml | 110 ++
...er-compose.cds-task-schema-publish-disabled.yml | 111 ++
...ocker-compose.centralized-datasource-schema.yml | 6 +-
integration-tests/docker/druid.sh | 2 +-
.../docker/environment-configs/common | 2 +-
.../docker/environment-configs/common-ldap | 2 +-
...inator-metadata-query-disabled-sample-data.sql} | 0
...s-task-schema-publish-disabled-sample-data.sql} | 0
integration-tests/k8s/tiny-cluster.yaml | 1 -
integration-tests/pom.xml | 2 +-
integration-tests/script/docker_compose_args.sh | 8 +
.../apache/druid/testing/utils/ITRetryUtil.java | 9 +-
.../druid/testing/utils/MsqTestQueryHelper.java | 6 +-
integration-tests/src/main/resources/log4j2.xml | 9 +
.../java/org/apache/druid/tests/TestNGGroup.java | 4 +
.../tests/indexer/ITAppendBatchIndexTest.java | 2 +-
.../ITAppenderatorDriverRealtimeIndexTaskTest.java | 2 +-
.../ITBestEffortRollupParallelIndexTest.java | 2 +-
.../ITCombiningInputSourceParallelIndexTest.java | 2 +-
.../indexer/ITCompactionSparseColumnTest.java | 2 +-
.../druid/tests/indexer/ITCompactionTaskTest.java | 2 +-
.../druid/tests/indexer/ITHttpInputSourceTest.java | 2 +-
.../apache/druid/tests/indexer/ITIndexerTest.java | 2 +-
...exingServiceNonTransactionalSerializedTest.java | 2 +-
...IndexingServiceTransactionalSerializedTest.java | 2 +-
.../ITLocalInputSourceAllInputFormatTest.java | 2 +-
.../tests/indexer/ITOverwriteBatchIndexTest.java | 2 +-
.../indexer/ITPerfectRollupParallelIndexTest.java | 2 +-
.../tests/indexer/ITRealtimeIndexTaskTest.java | 2 +-
.../indexer/ITSystemTableBatchIndexTaskTest.java | 2 +-
licenses.yaml | 54 +-
pom.xml | 24 +-
processing/pom.xml | 6 +-
.../apache/druid/common/config/NullHandling.java | 27 +
.../druid/frame/util/DurableStorageUtils.java | 6 +-
.../apache/druid/frame/write/FrameWriterUtils.java | 5 -
.../druid/frame/write/InvalidFieldException.java | 23 +
.../java/org/apache/druid/indexer/TaskStatus.java | 8 +-
.../report/SingleFileTaskReportFileWriter.java | 25 +-
.../druid/indexer/report/TaskReportFileWriter.java | 5 +
.../apache/druid/jackson/AggregatorsModule.java | 20 +-
.../util/common/parsers/JSONFlattenerMaker.java | 44 +-
.../java/org/apache/druid/math/expr/Function.java | 128 +-
.../druid/metadata/MetadataStorageConnector.java | 5 +
.../metadata/MetadataStorageTablesConfig.java | 14 +-
.../org/apache/druid/query/FluentQueryRunner.java | 9 +-
.../java/org/apache/druid/query/QueryContext.java | 4 +
.../java/org/apache/druid/query/QueryContexts.java | 4 +-
.../org/apache/druid/query/QueryResourceId.java | 119 ++
.../org/apache/druid/query/QueryToolChest.java | 24 +
.../query/aggregation/AggregatorAdapters.java | 20 +-
.../druid/query/aggregation/BufferAggregator.java | 6 +-
.../druid/query/aggregation/VectorAggregator.java | 6 +-
.../any/StringAnyAggregatorFactory.java | 2 +-
...ityAggregatorColumnSelectorStrategyFactory.java | 9 +-
.../aggregation/first/DoubleFirstAggregator.java | 72 --
.../first/DoubleFirstAggregatorFactory.java | 317 -----
.../first/DoubleFirstBufferAggregator.java | 81 --
.../first/DoubleFirstVectorAggregator.java | 67 -
.../query/aggregation/first/FirstLastUtils.java | 69 -
.../aggregation/first/FloatFirstAggregator.java | 76 --
.../first/FloatFirstAggregatorFactory.java | 310 -----
.../first/FloatFirstBufferAggregator.java | 81 --
.../first/FloatFirstVectorAggregator.java | 66 -
.../first/GenericFirstAggregateCombiner.java | 66 -
.../aggregation/first/LongFirstAggregator.java | 71 --
.../first/LongFirstAggregatorFactory.java | 310 -----
.../first/LongFirstBufferAggregator.java | 77 --
.../first/LongFirstVectorAggregator.java | 64 -
.../aggregation/first/NumericFirstAggregator.java | 105 --
.../first/NumericFirstBufferAggregator.java | 143 ---
.../first/NumericFirstVectorAggregator.java | 225 ----
...SingleStringFirstDimensionVectorAggregator.java | 125 --
.../aggregation/first/StringFirstAggregator.java | 114 --
.../first/StringFirstAggregatorFactory.java | 371 ------
.../first/StringFirstBufferAggregator.java | 141 ---
.../first/StringFirstFoldingAggregatorFactory.java | 41 -
.../aggregation/first/StringFirstLastUtils.java | 134 --
.../first/StringFirstVectorAggregator.java | 184 ---
.../firstlast/DoubleFirstLastVectorAggregator.java | 123 ++
.../aggregation/firstlast/FirstLastUtils.java | 155 +++
.../firstlast/FirstLastVectorAggregator.java | 266 ++++
.../firstlast/FloatFirstLastVectorAggregator.java | 122 ++
.../firstlast/LongFirstLastVectorAggregator.java | 121 ++
.../aggregation/firstlast/SelectionPredicate.java | 70 ++
...leStringFirstLastDimensionVectorAggregator.java | 185 +++
.../firstlast/StringFirstLastUtils.java | 136 ++
.../firstlast/StringFirstLastVectorAggregator.java | 110 ++
.../firstlast/first/DoubleFirstAggregator.java | 72 ++
.../first/DoubleFirstAggregatorFactory.java | 318 +++++
.../first/DoubleFirstBufferAggregator.java | 81 ++
.../first/DoubleFirstVectorAggregator.java | 39 +
.../firstlast/first/FloatFirstAggregator.java | 76 ++
.../first/FloatFirstAggregatorFactory.java | 311 +++++
.../first/FloatFirstBufferAggregator.java | 81 ++
.../first/FloatFirstVectorAggregator.java | 39 +
.../first/GenericFirstAggregateCombiner.java | 66 +
.../firstlast/first/LongFirstAggregator.java | 71 ++
.../first/LongFirstAggregatorFactory.java | 311 +++++
.../firstlast/first/LongFirstBufferAggregator.java | 77 ++
.../firstlast/first/LongFirstVectorAggregator.java | 38 +
.../firstlast/first/NumericFirstAggregator.java | 105 ++
.../first/NumericFirstBufferAggregator.java | 143 +++
...SingleStringFirstDimensionVectorAggregator.java | 38 +
.../firstlast/first/StringFirstAggregator.java | 115 ++
.../first/StringFirstAggregatorFactory.java | 373 ++++++
.../first/StringFirstBufferAggregator.java | 142 +++
.../first/StringFirstFoldingAggregatorFactory.java | 41 +
.../first/StringFirstVectorAggregator.java | 39 +
.../firstlast/last/DoubleLastAggregator.java | 71 ++
.../last/DoubleLastAggregatorFactory.java | 312 +++++
.../firstlast/last/DoubleLastBufferAggregator.java | 81 ++
.../firstlast/last/DoubleLastVectorAggregator.java | 39 +
.../firstlast/last/FloatLastAggregator.java | 72 ++
.../firstlast/last/FloatLastAggregatorFactory.java | 309 +++++
.../firstlast/last/FloatLastBufferAggregator.java | 82 ++
.../firstlast/last/FloatLastVectorAggregator.java | 39 +
.../last/GenericLastAggregateCombiner.java | 66 +
.../firstlast/last/LongLastAggregator.java | 71 ++
.../firstlast/last/LongLastAggregatorFactory.java | 307 +++++
.../firstlast/last/LongLastBufferAggregator.java | 77 ++
.../firstlast/last/LongLastVectorAggregator.java | 38 +
.../firstlast/last/NumericLastAggregator.java | 105 ++
.../last/NumericLastBufferAggregator.java | 147 +++
.../SingleStringLastDimensionVectorAggregator.java | 38 +
.../firstlast/last/StringLastAggregator.java | 115 ++
.../last/StringLastAggregatorFactory.java | 340 +++++
.../firstlast/last/StringLastBufferAggregator.java | 142 +++
.../last/StringLastFoldingAggregatorFactory.java | 41 +
.../firstlast/last/StringLastVectorAggregator.java | 39 +
.../aggregation/last/DoubleLastAggregator.java | 71 --
.../last/DoubleLastAggregatorFactory.java | 312 -----
.../last/DoubleLastBufferAggregator.java | 81 --
.../last/DoubleLastVectorAggregator.java | 70 --
.../aggregation/last/FloatLastAggregator.java | 72 --
.../last/FloatLastAggregatorFactory.java | 309 -----
.../last/FloatLastBufferAggregator.java | 82 --
.../last/FloatLastVectorAggregator.java | 71 --
.../last/GenericLastAggregateCombiner.java | 66 -
.../query/aggregation/last/LongLastAggregator.java | 71 --
.../last/LongLastAggregatorFactory.java | 309 -----
.../aggregation/last/LongLastBufferAggregator.java | 77 --
.../aggregation/last/LongLastVectorAggregator.java | 72 --
.../aggregation/last/NumericLastAggregator.java | 105 --
.../last/NumericLastBufferAggregator.java | 147 ---
.../last/NumericLastVectorAggregator.java | 228 ----
.../SingleStringLastDimensionVectorAggregator.java | 124 --
.../aggregation/last/StringLastAggregator.java | 115 --
.../last/StringLastAggregatorFactory.java | 336 -----
.../last/StringLastBufferAggregator.java | 142 ---
.../last/StringLastFoldingAggregatorFactory.java | 41 -
.../last/StringLastVectorAggregator.java | 200 ---
.../dimension/ColumnSelectorStrategyFactory.java | 8 +-
.../query/filter/ArrayContainsElementFilter.java | 11 +-
.../apache/druid/query/filter/LikeDimFilter.java | 67 +-
.../apache/druid/query/groupby/GroupByQuery.java | 17 +-
.../query/groupby/GroupByQueryQueryToolChest.java | 51 +-
.../druid/query/groupby/GroupByQueryResources.java | 119 +-
.../query/groupby/GroupByQueryRunnerFactory.java | 3 +
.../groupby/GroupByResourcesReservationPool.java | 141 +++
.../apache/druid/query/groupby/GroupingEngine.java | 61 +-
.../epinephelinae/AbstractBufferHashGrouper.java | 2 +-
.../groupby/epinephelinae/BufferArrayGrouper.java | 3 +-
.../groupby/epinephelinae/BufferHashGrouper.java | 1 +
.../groupby/epinephelinae/DictionaryBuilding.java | 106 --
.../epinephelinae/DictionaryBuildingUtils.java | 71 ++
.../GroupByColumnSelectorStrategyFactory.java | 118 ++
.../epinephelinae/GroupByMergingQueryRunner.java | 78 +-
.../groupby/epinephelinae/GroupByQueryEngine.java | 71 +-
.../groupby/epinephelinae/GroupByRowProcessor.java | 2 +-
.../groupby/epinephelinae/HashVectorGrouper.java | 3 +-
.../epinephelinae/LimitedBufferHashGrouper.java | 1 +
.../epinephelinae/RowBasedGrouperHelper.java | 263 ++--
.../ArrayDoubleGroupByColumnSelectorStrategy.java | 58 -
.../ArrayLongGroupByColumnSelectorStrategy.java | 56 -
.../ArrayNumericGroupByColumnSelectorStrategy.java | 196 ---
.../ArrayStringGroupByColumnSelectorStrategy.java | 272 ----
...onaryBuildingGroupByColumnSelectorStrategy.java | 264 ++++
...uildingStringGroupByColumnSelectorStrategy.java | 152 ---
.../epinephelinae/column/DimensionIdCodec.java | 58 +
.../DoubleGroupByColumnSelectorStrategy.java | 112 --
.../FixedWidthGroupByColumnSelectorStrategy.java | 200 +++
.../column/FloatGroupByColumnSelectorStrategy.java | 116 --
.../column/GroupByColumnSelectorStrategy.java | 11 +-
.../KeyMappingGroupByColumnSelectorStrategy.java | 229 ++++
...ingMultiValueGroupByColumnSelectorStrategy.java | 303 +++++
.../column/LongGroupByColumnSelectorStrategy.java | 116 --
.../epinephelinae/column/MemoryFootprint.java | 46 +
...llableNumericGroupByColumnSelectorStrategy.java | 151 ---
.../StringGroupByColumnSelectorStrategy.java | 188 ---
...ngleValueStringGroupByVectorColumnSelector.java | 7 +-
.../epinephelinae/vector/VectorGroupByEngine.java | 4 +-
.../query/groupby/orderby/DefaultLimitSpec.java | 19 +-
.../druid/query/search/SearchQueryRunner.java | 9 +-
.../query/timeseries/TimeseriesQueryEngine.java | 6 +-
.../apache/druid/query/topn/BaseTopNAlgorithm.java | 6 +-
.../druid/query/topn/HeapBasedTopNAlgorithm.java | 2 +-
.../druid/query/topn/PooledTopNAlgorithm.java | 2 +-
.../query/topn/TimeExtractionTopNAlgorithm.java | 2 +-
.../TopNColumnAggregatesProcessorFactory.java | 9 +-
.../druid/segment/DataSegmentWithMetadata.java | 57 +
.../druid/segment/DataSegmentsWithSchemas.java | 91 ++
.../druid/segment/DimensionHandlerUtils.java | 42 +-
.../QueryableIndexCursorSequenceBuilder.java | 110 +-
.../org/apache/druid/segment/SchemaPayload.java | 97 ++
.../apache/druid/segment/SchemaPayloadPlus.java | 85 ++
.../org/apache/druid/segment/SegmentMetadata.java | 87 ++
.../apache/druid/segment/SegmentSchemaMapping.java | 141 +++
.../druid/segment/column/NullableTypeStrategy.java | 26 +-
.../column/ObjectStrategyComplexTypeStrategy.java | 41 +-
.../druid/segment/column/TypeStrategies.java | 120 ++
.../apache/druid/segment/column/TypeStrategy.java | 30 +-
.../druid/segment/data/ComparableIntArray.java | 118 --
.../segment/data/ImmutableRTreeObjectStrategy.java | 6 +-
.../segment/generator/GeneratorBasicSchemas.java | 45 +
.../incremental/AppendableIndexBuilder.java | 2 +-
.../segment/incremental/AppendableIndexSpec.java | 10 +-
.../segment/join/table/RowBasedIndexBuilder.java | 6 +
.../segment/nested/NestedDataComplexTypeSerde.java | 26 +
.../druid/segment/nested/StructuredData.java | 7 +
.../org/apache/druid/utils/ConnectionUriUtils.java | 74 +-
.../collections/spatial/ImmutableRTreeTest.java | 34 +
.../processor/FrameProcessorExecutorTest.java | 2 +-
.../manager/SequenceProcessorManagerTest.java | 4 +-
.../test/SimpleReturningFrameProcessor.java | 45 +
.../test/SingleChannelFrameProcessor.java | 84 ++
.../test/SingleRowWritingFrameProcessor.java | 46 +
.../processor/test/TestFrameProcessorUtils.java | 84 ++
.../druid/frame/write/RowBasedFrameWriterTest.java | 74 ++
.../guice/MetadataStorageTablesConfigTest.java | 15 +
.../org/apache/druid/indexer/TaskStatusTest.java | 33 +
.../common/parsers/JSONFlattenerMakerTest.java | 15 +
.../org/apache/druid/math/expr/FunctionTest.java | 24 +
.../metadata/TestMetadataStorageConnector.java | 6 +
.../metadata/TestMetadataStorageTablesConfig.java | 1 +
.../apache/druid/query/QueryResourceIdTest.java | 55 +
.../apache/druid/query/QueryRunnerTestHelper.java | 4 +-
.../query/aggregation/AggregationTestHelper.java | 10 +-
.../query/aggregation/AggregatorFactoryTest.java | 16 +-
.../first/DoubleFirstAggregationTest.java | 296 -----
.../first/DoubleFirstVectorAggregationTest.java | 294 -----
.../first/FloatFirstAggregationTest.java | 283 -----
.../first/FloatFirstVectorAggregationTest.java | 343 -----
.../first/LongFirstAggregationTest.java | 280 -----
.../first/LongFirstVectorAggregationTest.java | 305 -----
.../first/StringFirstAggregationTest.java | 268 ----
.../first/StringFirstBufferAggregatorTest.java | 195 ---
.../first/StringFirstLastUtilsTest.java | 59 -
.../first/StringFirstTimeseriesQueryTest.java | 154 ---
.../first/StringFirstVectorAggregatorTest.java | 362 ------
.../first/DoubleFirstAggregationTest.java | 296 +++++
.../first/DoubleFirstVectorAggregatorTest.java | 316 +++++
.../firstlast/first/FloatFirstAggregationTest.java | 283 +++++
.../first/FloatFirstVectorAggregatorTest.java | 345 +++++
.../firstlast/first/LongFirstAggregationTest.java | 280 +++++
.../first/LongFirstVectorAggregatorTest.java | 307 +++++
.../first/StringFirstAggregationTest.java | 268 ++++
.../first/StringFirstBufferAggregatorTest.java | 195 +++
.../firstlast/first/StringFirstLastUtilsTest.java | 60 +
.../first/StringFirstTimeseriesQueryTest.java | 154 +++
.../first/StringFirstVectorAggregatorTest.java | 363 ++++++
.../firstlast/last/DoubleLastAggregationTest.java | 287 +++++
.../last/DoubleLastVectorAggregatorTest.java | 316 +++++
.../firstlast/last/FloatLastAggregationTest.java | 286 +++++
.../last/FloatLastVectorAggregatorTest.java | 311 +++++
.../firstlast/last/LongLastAggregationTest.java | 282 +++++
.../last/LongLastVectorAggregatorTest.java | 368 ++++++
.../firstlast/last/StringLastAggregationTest.java | 270 ++++
.../last/StringLastBufferAggregatorTest.java | 197 +++
.../last/StringLastTimeseriesQueryTest.java | 158 +++
.../last/StringLastVectorAggregatorTest.java | 470 +++++++
.../last/DoubleLastAggregationTest.java | 287 -----
.../last/DoubleLastVectorAggregatorTest.java | 294 -----
.../aggregation/last/FloatLastAggregationTest.java | 286 -----
.../last/FloatLastVectorAggregatorTest.java | 308 -----
.../aggregation/last/LongLastAggregationTest.java | 282 -----
.../last/LongLastVectorAggregatorTest.java | 304 -----
.../last/StringLastAggregationTest.java | 270 ----
.../last/StringLastBufferAggregatorTest.java | 197 ---
.../last/StringLastTimeseriesQueryTest.java | 158 ---
.../last/StringLastVectorAggregatorTest.java | 469 -------
.../FinalizingFieldAccessPostAggregatorTest.java | 2 +-
.../druid/query/context/ResponseContextTest.java | 4 +-
.../druid/query/filter/LikeDimFilterTest.java | 188 +++
...GroupByLimitPushDownInsufficientBufferTest.java | 83 +-
.../GroupByLimitPushDownMultiNodeMergeTest.java | 174 ++-
.../query/groupby/GroupByMultiSegmentTest.java | 17 +-
.../query/groupby/GroupByQueryMergeBufferTest.java | 25 +-
.../groupby/GroupByQueryQueryToolChestTest.java | 118 +-
.../groupby/GroupByQueryRunnerFactoryTest.java | 15 +-
.../groupby/GroupByQueryRunnerFailureTest.java | 14 +-
.../query/groupby/GroupByQueryRunnerTest.java | 247 ++--
.../groupby/GroupByQueryRunnerTestHelper.java | 22 +-
.../groupby/GroupByTimeseriesQueryRunnerTest.java | 1 +
.../query/groupby/NestedQueryPushDownTest.java | 68 +-
.../groupby/UnnestGroupByQueryRunnerTest.java | 7 +-
.../epinephelinae/HashVectorGrouperTest.java | 2 +-
...rayDoubleGroupByColumnSelectorStrategyTest.java | 159 ---
...ArrayLongGroupByColumnSelectorStrategyTest.java | 163 ---
...rayStringGroupByColumnSelectorStrategyTest.java | 168 ---
...ixedWidthGroupByColumnSelectorStrategyTest.java | 506 ++++++++
...tedColumnGroupByColumnSelectorStrategyTest.java | 183 +++
.../StringGroupByColumnSelectorStrategyTest.java | 109 --
.../druid/query/search/SearchQueryRunnerTest.java | 2 +-
.../TimeseriesQueryQueryToolChestTest.java | 2 +-
.../timeseries/TimeseriesQueryRunnerTest.java | 4 +-
.../query/topn/TopNQueryQueryToolChestTest.java | 8 +-
.../druid/query/topn/TopNQueryRunnerTest.java | 10 +-
.../query/topn/UnnestTopNQueryRunnerTest.java | 2 +-
.../druid/segment/IndexMergerRollupTest.java | 16 +-
.../column/DataSegmentsWithSchemasTest.java | 110 ++
.../segment/column/SchemaPayloadPlusTest.java | 58 +
.../druid/segment/column/SchemaPayloadTest.java | 62 +
.../segment/column/SegmentSchemaMappingTest.java | 110 ++
.../druid/segment/column/TypeStrategiesTest.java | 12 +
.../druid/segment/data/ComparableIntArrayTest.java | 70 --
.../apache/druid/utils/ConnectionUriUtilsTest.java | 11 +-
.../src/test/resources/test.runtime.properties | 1 +
quidem | 46 +
server/pom.xml | 2 +-
.../druid/catalog/model/table/DatasourceDefn.java | 34 +-
.../apache/druid/guice/BrokerProcessingModule.java | 13 +
.../apache/druid/guice/DruidProcessingModule.java | 13 +
.../apache/druid/guice/RouterProcessingModule.java | 16 +
.../indexing/overlord/DataSourceMetadata.java | 3 +-
.../IndexerMetadataStorageCoordinator.java | 44 +-
.../indexing/overlord/SegmentPublishResult.java | 31 +
.../overlord/supervisor/NoopSupervisorSpec.java | 7 -
.../indexing/overlord/supervisor/Supervisor.java | 15 -
.../supervisor/autoscaler/AggregateFunction.java | 27 +
.../overlord/supervisor/autoscaler/LagMetric.java | 27 -
.../overlord/supervisor/autoscaler/LagStats.java | 30 +-
.../IndexerSQLMetadataStorageCoordinator.java | 506 ++++++--
.../druid/metadata/PendingSegmentRecord.java | 18 +-
.../druid/metadata/SQLMetadataConnector.java | 171 ++-
.../druid/metadata/SqlSegmentsMetadataManager.java | 165 ++-
.../SqlSegmentsMetadataManagerProvider.java | 15 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 103 +-
.../metadata/storage/derby/DerbyConnector.java | 11 +-
.../lookup/LookupListeningAnnouncerConfig.java | 6 +
.../query/lookup/LookupReferencesManager.java | 27 +-
.../java/org/apache/druid/rpc/RequestBuilder.java | 48 +-
.../java/org/apache/druid/rpc/ServiceLocation.java | 58 +-
.../metadata/AbstractSegmentMetadataCache.java | 317 ++---
.../CentralizedDatasourceSchemaConfig.java | 48 +-
.../metadata/CoordinatorSegmentMetadataCache.java | 380 +++++-
.../segment/metadata/FingerprintGenerator.java | 83 ++
.../metadata/SegmentMetadataCacheConfig.java | 14 +
.../metadata/SegmentSchemaBackFillQueue.java | 195 +++
.../druid/segment/metadata/SegmentSchemaCache.java | 361 ++++++
.../segment/metadata/SegmentSchemaManager.java | 432 +++++++
.../realtime/appenderator/AppenderatorImpl.java | 58 +-
.../realtime/appenderator/Appenderators.java | 18 +-
.../appenderator/AppenderatorsManager.java | 9 +-
.../appenderator/BaseAppenderatorDriver.java | 29 +-
.../realtime/appenderator/BatchAppenderator.java | 59 +-
.../appenderator/BatchAppenderatorDriver.java | 7 +-
.../DefaultOfflineAppenderatorFactory.java | 18 +-
.../DummyForInjectionAppenderatorsManager.java | 9 +-
.../appenderator/PeonAppenderatorsManager.java | 18 +-
.../appenderator/SegmentsAndCommitMetadata.java | 62 +-
.../appenderator/SinkQuerySegmentWalker.java | 34 +-
.../realtime/appenderator/StreamAppenderator.java | 239 ++--
.../appenderator/StreamAppenderatorDriver.java | 27 +-
.../appenderator/TaskSegmentSchemaUtil.java | 56 +
.../TransactionalSegmentPublisher.java | 10 +-
.../UnifiedIndexerAppenderatorsManager.java | 18 +-
.../druid/server/ClientQuerySegmentWalker.java | 43 +-
.../druid/server/LocalQuerySegmentWalker.java | 2 +-
.../druid/server/QuerySwappingQueryRunner.java | 62 +
.../server/ResourceIdPopulatingQueryRunner.java | 68 +
.../coordination/DataSegmentChangeResponse.java | 64 +
.../server/coordination/SegmentChangeStatus.java | 82 ++
.../coordination/SegmentLoadDropHandler.java | 148 +--
.../druid/server/coordination/ServerManager.java | 36 +-
.../coordinator/CoordinatorDynamicConfig.java | 6 -
.../druid/server/coordinator/DruidCoordinator.java | 60 +-
.../server/coordinator/DruidCoordinatorConfig.java | 170 ---
.../druid/server/coordinator/MetadataManager.java | 11 +-
.../coordinator/config/CoordinatorKillConfigs.java | 157 +++
.../config/CoordinatorPeriodConfig.java | 57 +
.../coordinator/config/CoordinatorRunConfig.java | 54 +
.../coordinator/config/DruidCoordinatorConfig.java | 157 +++
.../config/HttpLoadQueuePeonConfig.java | 71 ++
.../config/KillUnusedSegmentsConfig.java | 125 ++
.../coordinator/config/MetadataCleanupConfig.java | 89 ++
.../server/coordinator/duty/KillAuditLog.java | 14 +-
.../coordinator/duty/KillCompactionConfig.java | 15 +-
.../coordinator/duty/KillDatasourceMetadata.java | 14 +-
.../druid/server/coordinator/duty/KillRules.java | 14 +-
.../server/coordinator/duty/KillSupervisors.java | 14 +-
.../duty/KillSupervisorsCustomDuty.java | 36 +-
.../duty/KillUnreferencedSegmentSchema.java | 85 ++
.../coordinator/duty/KillUnusedSegments.java | 58 +-
.../coordinator/duty/MetadataCleanupDuty.java | 62 +-
.../coordinator/loading/CuratorLoadQueuePeon.java | 19 +-
.../coordinator/loading/HttpLoadQueuePeon.java | 49 +-
.../server/coordinator/loading/LoadQueuePeon.java | 3 +-
.../coordinator/loading/LoadQueueTaskMaster.java | 35 +-
.../coordinator/stats/CoordinatorRunStats.java | 27 -
.../druid/server/coordinator/stats/Stats.java | 2 +
.../apache/druid/server/http/DataSegmentPlus.java | 33 +-
.../apache/druid/server/http/MetadataResource.java | 61 +-
.../druid/server/http/SegmentListerResource.java | 7 +-
.../initialization/JdbcAccessSecurityConfig.java | 2 +-
.../server/lookup/cache/LookupLoadingSpec.java | 91 ++
.../server/metrics/DataSourceTaskIdHolder.java | 14 +
.../server/metrics/HistoricalMetricsMonitor.java | 2 +-
.../catalog/model/table/DatasourceTableTest.java | 25 +
.../druid/client/CachingClusteredClientTest.java | 5 +-
.../druid/discovery/DataServerClientTest.java | 2 +-
.../indexing/overlord/supervisor/LagStatsTest.java | 17 +-
.../IndexerSQLMetadataStorageCoordinatorTest.java | 933 ++++----------
...ataStorageCoordinatorSchemaPersistenceTest.java | 476 +++++++
...dexerSqlMetadataStorageCoordinatorTestBase.java | 563 +++++++++
.../SQLMetadataConnectorSchemaPersistenceTest.java | 145 +++
.../druid/metadata/SQLMetadataConnectorTest.java | 129 +-
.../druid/metadata/SQLMetadataRuleManagerTest.java | 1 +
.../SqlSegmentsMetadataManagerProviderTest.java | 9 +-
.../SqlSegmentsMetadataManagerSchemaPollTest.java | 270 ++++
.../metadata/SqlSegmentsMetadataManagerTest.java | 28 +-
.../SqlSegmentsMetadataManagerTestBase.java | 82 ++
.../apache/druid/metadata/TestDerbyConnector.java | 31 +-
.../lookup/LookupListeningAnnouncerConfigTest.java | 17 +
.../query/lookup/LookupReferencesManagerTest.java | 78 ++
...CoordinatorSegmentDataCacheConcurrencyTest.java | 74 +-
.../CoordinatorSegmentMetadataCacheCommon.java | 79 --
.../CoordinatorSegmentMetadataCacheTest.java | 489 +++++--
.../CoordinatorSegmentMetadataCacheTestBase.java | 122 ++
.../segment/metadata/FingerprintGeneratorTest.java | 128 ++
.../metadata/SegmentMetadataCacheCommon.java | 329 -----
.../metadata/SegmentMetadataCacheTestBase.java | 329 +++++
.../metadata/SegmentSchemaBackFillQueueTest.java | 129 ++
.../segment/metadata/SegmentSchemaCacheTest.java | 112 ++
.../segment/metadata/SegmentSchemaManagerTest.java | 243 ++++
.../segment/metadata/SegmentSchemaTestUtils.java | 272 ++++
.../metadata/TestSegmentMetadataQueryWalker.java | 4 +-
.../ClosedSegmensSinksBatchAppenderatorTester.java | 4 +-
...edSegmentsSinksBatchAppenderatorDriverTest.java | 6 +-
.../OpenAndClosedSegmentsAppenderatorTester.java | 7 +-
...dClosedSegmentsBatchAppenderatorDriverTest.java | 6 +-
...OpenAndClosedSegmentsBatchAppenderatorTest.java | 1 -
.../StreamAppenderatorDriverFailTest.java | 10 +-
.../appenderator/StreamAppenderatorDriverTest.java | 79 +-
.../UnifiedIndexerAppenderatorsManagerTest.java | 4 +-
.../plumber/CustomVersioningPolicyTest.java | 8 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 61 +-
.../apache/druid/server/QuerySchedulerTest.java | 7 +-
.../org/apache/druid/server/QueryStackTests.java | 3 +-
.../org/apache/druid/server/ServerTestHelper.java | 38 -
.../server/SpecificSegmentsQuerySegmentWalker.java | 14 +-
.../server/TestClusterQuerySegmentWalker.java | 33 +-
.../coordination/SegmentLoadDropHandlerTest.java | 37 +-
.../server/coordination/ServerManagerTest.java | 2 +-
.../server/coordination/ZkCoordinatorTest.java | 6 +-
.../coordinator/CoordinatorRunStatsTest.java | 31 -
.../coordinator/CuratorDruidCoordinatorTest.java | 11 +-
.../coordinator/DruidCoordinatorConfigTest.java | 552 +++++++-
.../server/coordinator/DruidCoordinatorTest.java | 57 +-
.../coordinator/TestDruidCoordinatorConfig.java | 525 --------
.../coordinator/duty/CompactSegmentsTest.java | 2 +-
.../server/coordinator/duty/KillAuditLogTest.java | 66 +-
.../coordinator/duty/KillCompactionConfigTest.java | 68 +-
.../duty/KillDatasourceMetadataTest.java | 85 +-
.../server/coordinator/duty/KillRulesTest.java | 65 +-
.../duty/KillSupervisorsCustomDutyTest.java | 48 +-
.../coordinator/duty/KillSupervisorsTest.java | 66 +-
.../duty/KillUnreferencedSegmentSchemaTest.java | 418 ++++++
.../coordinator/duty/KillUnusedSegmentsTest.java | 102 +-
.../loading/CuratorLoadQueuePeonTest.java | 401 ++++++
.../coordinator/loading/HttpLoadQueuePeonTest.java | 30 +-
.../coordinator/loading/LoadQueuePeonTest.java | 413 ------
.../simulate/CoordinatorSimulationBuilder.java | 110 +-
.../simulate/TestSegmentLoadingHttpClient.java | 16 +-
.../server/http/CoordinatorDynamicConfigTest.java | 60 +-
.../druid/server/http/DataSegmentPlusTest.java | 4 +-
.../druid/server/http/MetadataResourceTest.java | 2 +-
.../server/lookup/cache/LookupLoadingSpecTest.java | 62 +
.../metrics/HistoricalMetricsMonitorTest.java | 2 +-
services/pom.xml | 6 +-
.../main/java/org/apache/druid/cli/CliBroker.java | 2 +
.../java/org/apache/druid/cli/CliCoordinator.java | 74 +-
.../main/java/org/apache/druid/cli/CliIndexer.java | 6 +
.../org/apache/druid/cli/CliMiddleManager.java | 2 +
.../java/org/apache/druid/cli/CliOverlord.java | 13 +
.../main/java/org/apache/druid/cli/CliPeon.java | 37 +-
.../java/org/apache/druid/cli/CreateTables.java | 1 +
.../java/org/apache/druid/cli/DumpSegment.java | 5 +-
.../java/org/apache/druid/cli/ServerRunnable.java | 34 +
.../java/org/apache/druid/cli/DumpSegmentTest.java | 2 +
...ompatibleCentralizedDatasourceSchemaConfig.java | 71 ++
sql/pom.xml | 18 +-
sql/src/main/codegen/includes/insert.ftl | 6 +-
sql/src/main/codegen/includes/replace.ftl | 6 +-
.../org/apache/druid/sql/avatica/DruidMeta.java | 2 +-
.../builtin/EarliestLatestAnySqlAggregator.java | 16 +-
.../sql/calcite/expression/DruidExpression.java | 16 +
.../druid/sql/calcite/expression/DruidLiteral.java | 70 ++
.../druid/sql/calcite/expression/Expressions.java | 94 +-
.../builtin/ArrayOverlapOperatorConversion.java | 31 +-
.../builtin/ContainsOperatorConversion.java | 2 +-
.../builtin/RegexpLikeOperatorConversion.java | 2 +-
.../builtin/ScalarInArrayOperatorConversion.java | 153 +++
.../builtin/SubstringOperatorConversion.java | 3 +-
.../builtin/TimeArithmeticOperatorConversion.java | 3 +-
.../druid/sql/calcite/planner/CalcitePlanner.java | 2 +
.../sql/calcite/planner/CalcitePlannerModule.java | 2 +
.../sql/calcite/planner/CalciteRulesManager.java | 17 +
.../sql/calcite/planner/DruidOperatorTable.java | 2 +
.../sql/calcite/planner/DruidSqlValidator.java | 102 ++
.../druid/sql/calcite/planner/PlannerContext.java | 12 +-
.../druid/sql/calcite/planner/QueryHandler.java | 3 +
.../planner/SqlResourceCollectorShuttle.java | 2 +-
.../TimeInIntervalConvertletFactory.java | 4 +-
.../apache/druid/sql/calcite/rel/DruidQuery.java | 28 +-
.../apache/druid/sql/calcite/rel/Windowing.java | 13 +-
.../calcite/schema/BrokerSegmentMetadataCache.java | 55 +-
.../schema/BrokerSegmentMetadataCacheConfig.java | 10 -
.../druid/quidem/DruidAvaticaDriverTest.java | 56 +
.../druid/quidem/DruidAvaticaTestDriver.java | 419 ++++++
.../apache/druid/quidem/DruidConnectionExtras.java | 43 +
.../druid/quidem/DruidQuidemCommandHandler.java | 203 +++
.../druid/quidem/DruidQuidemConnectionFactory.java | 52 +
.../apache/druid/quidem/DruidQuidemTestBase.java | 214 ++++
.../org/apache/druid/quidem/DynamicComposite.java | 61 +
.../apache/druid/quidem/DynamicCompositeTest.java | 47 +
.../apache/druid/quidem/MapToInterfaceHandler.java | 75 ++
.../org/apache/druid/quidem/ProjectPathUtils.java | 49 +
.../org/apache/druid/quidem/SqlQuidemTest.java | 46 +
.../druid/sql/calcite/BaseCalciteQueryTest.java | 131 +-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 147 ++-
.../calcite/CalciteCatalogIngestionDmlTest.java | 763 ++++++++---
.../druid/sql/calcite/CalciteExportTest.java | 81 +-
.../druid/sql/calcite/CalciteGroupByQueryTest.java | 24 +
.../druid/sql/calcite/CalciteIngestionDmlTest.java | 119 +-
.../druid/sql/calcite/CalciteInsertDmlTest.java | 2 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 659 ++++++----
.../apache/druid/sql/calcite/CalciteQueryTest.java | 97 +-
.../sql/calcite/CalciteScanSignatureTest.java | 121 +-
.../druid/sql/calcite/CalciteSimpleQueryTest.java | 4 +-
.../druid/sql/calcite/CalciteStrictInsertTest.java | 29 +-
.../sql/calcite/CalciteTimeBoundaryQueryTest.java | 63 +-
.../druid/sql/calcite/CalciteWindowQueryTest.java | 21 +
.../druid/sql/calcite/DecoupledExtension.java | 71 ++
.../DecoupledPlanningCalciteJoinQueryTest.java | 36 +-
.../calcite/DecoupledPlanningCalciteQueryTest.java | 38 +-
.../DecoupledPlanningCalciteUnionQueryTest.java | 38 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 296 ++---
.../apache/druid/sql/calcite/NotYetSupported.java | 1 -
.../druid/sql/calcite/SqlTestFrameworkConfig.java | 144 ++-
.../sql/calcite/SqlTestFrameworkConfigTest.java | 34 +
.../apache/druid/sql/calcite/TempDirProducer.java | 68 +
.../calcite/expression/DruidExpressionTest.java | 125 +-
.../sql/calcite/expression/ExpressionsTest.java | 228 +++-
.../schema/BrokerSegmentMetadataCacheCommon.java | 100 --
.../BrokerSegmentMetadataCacheConcurrencyTest.java | 9 +-
.../schema/BrokerSegmentMetadataCacheTest.java | 31 +-
.../schema/BrokerSegmentMetadataCacheTestBase.java | 100 ++
.../calcite/schema/DruidSchemaNoDataInitTest.java | 4 +-
.../druid/sql/calcite/schema/SystemSchemaTest.java | 4 +-
.../druid/sql/calcite/util/CalciteTestBase.java | 1 -
.../sql/calcite/util/QueryFrameworkUtils.java | 4 +-
.../druid/sql/calcite/util/QueryLogHook.java | 7 +
.../druid/sql/calcite/util/SqlTestFramework.java | 65 +-
.../druid/sql/calcite/util/TestDataBuilder.java | 14 +-
.../decoupled.iq | 96 ++
.../org.apache.druid.quidem.SqlQuidemTest/join.iq | 131 ++
.../numMerge.iq | 82 ++
.../simple.iq | 60 +
web-console/lib/sql-docs.d.ts | 2 +-
web-console/package-lock.json | 4 +-
web-console/package.json | 2 +-
web-console/pom.xml | 2 +-
.../__snapshots__/make-doc-html.spec.ts.snap | 8 +
web-console/src/ace-modes/dsql.js | 146 ---
web-console/src/ace-modes/dsql.ts | 195 +++
web-console/src/ace-modes/hjson.js | 300 -----
web-console/src/ace-modes/hjson.ts | 302 +++++
web-console/src/ace-modes/make-doc-html.spec.ts | 31 +
web-console/src/ace-modes/make-doc-html.ts | 32 +
.../src/components/header-bar/header-bar.scss | 5 +
.../__snapshots__/json-input.spec.tsx.snap | 4 +-
.../query-error-pane/query-error-pane.tsx | 1 +
.../table-column-selector.spec.tsx | 2 +-
.../table-column-selector.tsx | 43 +-
.../__snapshots__/timed-button.spec.tsx.snap | 2 +-
.../src/components/timed-button/timed-button.tsx | 4 +-
web-console/src/console-application.tsx | 4 +-
.../compaction-history-dialog.tsx | 4 +-
.../kill-datasource-dialog.tsx | 7 +-
.../__snapshots__/spec-dialog.spec.tsx.snap | 4 +-
.../supervisor-reset-offsets-dialog.scss | 4 +-
.../supervisor-reset-offsets-dialog.tsx | 194 ++-
.../supervisor-table-action-dialog.spec.tsx.snap | 4 +-
.../supervisor-statistics-table.spec.tsx.snap | 57 +-
.../supervisor-statistics-table.spec.tsx | 6 +-
.../supervisor-statistics-table.tsx | 91 +-
.../supervisor-table-action-dialog.tsx | 14 +-
.../task-table-action-dialog.spec.tsx.snap | 22 +-
.../task-table-action-dialog.tsx | 40 +-
.../coordinator-dynamic-config.tsx | 1 -
web-console/src/druid-models/index.ts | 1 +
.../druid-models/ingestion-spec/ingestion-spec.tsx | 21 +
.../src/druid-models/input-source/input-source.tsx | 24 +-
.../supervisor-status/supervisor-status.ts | 135 ++
web-console/src/setup-tests.ts | 1 +
web-console/src/utils/basic-action.tsx | 13 +-
web-console/src/utils/druid-query.ts | 9 +-
web-console/src/utils/general.tsx | 17 +
.../src/utils/local-storage-backed-visibility.tsx | 4 +-
web-console/src/utils/table-helpers.ts | 19 +
.../__snapshots__/datasources-view.spec.tsx.snap | 3 +-
.../views/datasources-view/datasources-view.tsx | 10 +-
.../src/views/load-data-view/info-messages.tsx | 6 +-
.../src/views/load-data-view/load-data-view.tsx | 30 +-
.../__snapshots__/lookups-view.spec.tsx.snap | 3 +-
.../src/views/lookups-view/lookups-view.tsx | 3 +-
.../__snapshots__/segments-view.spec.tsx.snap | 2 +-
.../src/views/segments-view/segments-view.tsx | 46 +-
.../__snapshots__/services-view.spec.tsx.snap | 2 +-
.../src/views/services-view/services-view.tsx | 5 +-
.../__snapshots__/supervisors-view.spec.tsx.snap | 148 ++-
.../views/supervisors-view/supervisors-view.scss | 13 +
.../views/supervisors-view/supervisors-view.tsx | 455 +++++--
.../__snapshots__/tasks-view.spec.tsx.snap | 3 +-
web-console/src/views/tasks-view/tasks-view.tsx | 9 +-
.../destination-pages-pane.tsx | 21 +-
.../__snapshots__/explain-dialog.spec.tsx.snap | 6 +-
.../explain-dialog/explain-dialog.tsx | 2 +-
.../flexible-query-input.spec.tsx.snap | 11 +-
.../flexible-query-input.spec.tsx | 10 -
.../flexible-query-input/flexible-query-input.tsx | 148 +--
.../max-tasks-button/max-tasks-button.tsx | 11 +-
.../workbench-history-dialog.tsx | 2 +-
.../src/views/workbench-view/workbench-view.tsx | 18 +-
web-console/unified-console.html | 2 +-
website/.spelling | 2 +
1099 files changed, 49442 insertions(+), 26793 deletions(-)
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/query/SqlGroupByBenchmark.java
create mode 100644
benchmarks/src/test/resources/META-INF/services/java.sql.Driver
create mode 100644 docs/assets/supervisor-actions.png
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaAndFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaEqualsFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaFilterUtils.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaGreaterThanFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaGreaterThanOrEqualsFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaLessThanFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaLessThanOrEqualsFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaNotFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/filter/DeltaOrFilter.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaAndFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaEqualsFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaGreaterThanFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaGreaterThanOrEqualsFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaLessThanFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaLessThanOrEqualsFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaNotFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/filter/DeltaOrFilterTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/DeltaInputSourceSerdeTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/NonPartitionedDeltaTable.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/PartitionedDeltaTable.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/.00000000000000000000.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/.00000000000000000001.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/.00000000000000000002.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/00000000000000000000.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/00000000000000000001.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/_delta_log/00000000000000000002.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/.part-00001-1b911f24-6d69-4065-9c4e-d5fa896dcefe.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/.part-00001-4f11e631-348f-4378-936e-34132f176203.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/.part-00001-615707f3-eb13-47ef-ac1a-b8decc09e05a.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/part-00001-1b911f24-6d69-4065-9c4e-d5fa896dcefe.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/part-00001-4f11e631-348f-4378-936e-34132f176203.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee1/part-00001-615707f3-eb13-47ef-ac1a-b8decc09e05a.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/.part-00003-07285317-1943-4b24-8962-03543375d133.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/.part-00003-090fd396-1c53-4794-97b3-faa0f302984a.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/.part-00003-62ce8217-f361-4b70-91ec-9f398300c083.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/part-00003-07285317-1943-4b24-8962-03543375d133.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/part-00003-090fd396-1c53-4794-97b3-faa0f302984a.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee2/part-00003-62ce8217-f361-4b70-91ec-9f398300c083.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/.part-00005-32e5492c-7ebf-407e-8ecf-03add4ee14b8.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/.part-00005-ac0ede62-3abc-47a3-9eac-c09a3802cd78.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/.part-00005-c33dc31c-d3a8-4a50-90d3-96f00b1b2e22.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/part-00005-32e5492c-7ebf-407e-8ecf-03add4ee14b8.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/part-00005-ac0ede62-3abc-47a3-9eac-c09a3802cd78.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee3/part-00005-c33dc31c-d3a8-4a50-90d3-96f00b1b2e22.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/.part-00007-45c2fd36-d1e1-4e92-b21c-84d385a8218a.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/.part-00007-b6e49fa4-cb41-4bd1-8dd2-1ed5e561f801.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/.part-00007-d88803d4-2bb0-4c31-8340-58cb6d797963.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/part-00007-45c2fd36-d1e1-4e92-b21c-84d385a8218a.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/part-00007-b6e49fa4-cb41-4bd1-8dd2-1ed5e561f801.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee4/part-00007-d88803d4-2bb0-4c31-8340-58cb6d797963.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/.part-00009-079ed08f-dd8d-434f-a816-c73420234b25.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/.part-00009-b8de3a44-b0e9-4d68-89ee-195b76453643.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/.part-00009-f87803c3-6cfd-4a37-9283-f2bff0c0dfad.c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/part-00009-079ed08f-dd8d-434f-a816-c73420234b25.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/part-00009-b8de3a44-b0e9-4d68-89ee-195b76453643.c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table-partitioned-name/name=Employee5/part-00009-f87803c3-6cfd-4a37-9283-f2bff0c0dfad.c000.snappy.parquet
delete mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/guice/annotations/MSQ.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerMemoryParameters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerQueryResultsReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MemoryIntrospector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MemoryIntrospectorImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/OutputChannelMode.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/QueryListener.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ResultsContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/RetryCapableWorkerManager.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerFailureListener.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerManager.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerStats.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/IndexerMemoryManagementModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/PeonMemoryManagementModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerResourcePermissionMapper.java
delete mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/RetryTask.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/TaskReportQueryListener.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelConfig.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/StageGroup.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/BaseWorkerClientImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/ControllerResource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/MSQResourceUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/ResourcePermissionMapper.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/ControllerMemoryParametersTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/TaskReportQueryListenerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelUtilsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/ChainedProcessorManagerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/NonFailingWritableFrameChannel.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/SendPartialKeyStatisticsInformationSerdeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/NoopQueryListener.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/PendingSegmentVersions.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/MultipleFileTaskReportFileWriterTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/SingleFileTaskReportFileWriterTest.java
create mode 100644
integration-tests/docker/docker-compose.cds-coordinator-metadata-query-disabled.yml
create mode 100644
integration-tests/docker/docker-compose.cds-task-schema-publish-disabled.yml
copy
integration-tests/docker/test-data/{centralized-datasource-schema-sample-data.sql
=> cds-coordinator-metadata-query-disabled-sample-data.sql} (100%)
copy
integration-tests/docker/test-data/{centralized-datasource-schema-sample-data.sql
=> cds-task-schema-publish-disabled-sample-data.sql} (100%)
create mode 100644
processing/src/main/java/org/apache/druid/query/QueryResourceId.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/DoubleFirstAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/DoubleFirstAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/DoubleFirstBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/DoubleFirstVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/FirstLastUtils.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/FloatFirstAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/FloatFirstAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/FloatFirstBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/FloatFirstVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/GenericFirstAggregateCombiner.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/LongFirstAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/LongFirstAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/LongFirstBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/LongFirstVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/NumericFirstAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/NumericFirstBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/NumericFirstVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/SingleStringFirstDimensionVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstFoldingAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstLastUtils.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/DoubleFirstLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/FirstLastUtils.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/FirstLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/FloatFirstLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/LongFirstLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/SelectionPredicate.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/SingleStringFirstLastDimensionVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/StringFirstLastUtils.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/StringFirstLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/GenericFirstAggregateCombiner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/NumericFirstAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/NumericFirstBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/SingleStringFirstDimensionVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstFoldingAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/GenericLastAggregateCombiner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/LongLastAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/LongLastAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/LongLastBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/LongLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/NumericLastAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/NumericLastBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/SingleStringLastDimensionVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/StringLastAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/StringLastAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/StringLastBufferAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/StringLastFoldingAggregatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/firstlast/last/StringLastVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/DoubleLastAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/DoubleLastAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/DoubleLastBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/DoubleLastVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/FloatLastAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/FloatLastAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/FloatLastBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/FloatLastVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/GenericLastAggregateCombiner.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/LongLastAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/LongLastAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/LongLastBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/LongLastVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/NumericLastAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/NumericLastBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/NumericLastVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/SingleStringLastDimensionVectorAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/StringLastAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/StringLastAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/StringLastBufferAggregator.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/StringLastFoldingAggregatorFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/last/StringLastVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/GroupByResourcesReservationPool.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/DictionaryBuilding.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/DictionaryBuildingUtils.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/GroupByColumnSelectorStrategyFactory.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayDoubleGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayLongGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayNumericGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayStringGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/DictionaryBuildingGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/DictionaryBuildingStringGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/DimensionIdCodec.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/DoubleGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/FixedWidthGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/FloatGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/KeyMappingGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/KeyMappingMultiValueGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/LongGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/MemoryFootprint.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/NullableNumericGroupByColumnSelectorStrategy.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/column/StringGroupByColumnSelectorStrategy.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/DataSegmentWithMetadata.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/DataSegmentsWithSchemas.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/SchemaPayload.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/SchemaPayloadPlus.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/SegmentMetadata.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/SegmentSchemaMapping.java
delete mode 100644
processing/src/main/java/org/apache/druid/segment/data/ComparableIntArray.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/test/SimpleReturningFrameProcessor.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/test/SingleChannelFrameProcessor.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/test/SingleRowWritingFrameProcessor.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/test/TestFrameProcessorUtils.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/write/RowBasedFrameWriterTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/QueryResourceIdTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/DoubleFirstAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/DoubleFirstVectorAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/FloatFirstAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/FloatFirstVectorAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/LongFirstAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/LongFirstVectorAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/StringFirstAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/StringFirstBufferAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/StringFirstLastUtilsTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/StringFirstTimeseriesQueryTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/first/StringFirstVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/DoubleFirstVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/FloatFirstVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/LongFirstVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstBufferAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstLastUtilsTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstTimeseriesQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/first/StringFirstVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/DoubleLastVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/FloatLastVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/LongLastAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/LongLastVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/StringLastAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/StringLastBufferAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/StringLastTimeseriesQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/firstlast/last/StringLastVectorAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/DoubleLastAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/DoubleLastVectorAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/FloatLastAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/FloatLastVectorAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/LongLastAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/LongLastVectorAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/StringLastAggregationTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/StringLastBufferAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/StringLastTimeseriesQueryTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/last/StringLastVectorAggregatorTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayDoubleGroupByColumnSelectorStrategyTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayLongGroupByColumnSelectorStrategyTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/ArrayStringGroupByColumnSelectorStrategyTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/FixedWidthGroupByColumnSelectorStrategyTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/NestedColumnGroupByColumnSelectorStrategyTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/column/StringGroupByColumnSelectorStrategyTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/DataSegmentsWithSchemasTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/SchemaPayloadPlusTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/SchemaPayloadTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/SegmentSchemaMappingTest.java
delete mode 100644
processing/src/test/java/org/apache/druid/segment/data/ComparableIntArrayTest.java
create mode 100755 quidem
create mode 100644
server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/AggregateFunction.java
delete mode 100644
server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/LagMetric.java
create mode 100644
server/src/main/java/org/apache/druid/segment/metadata/FingerprintGenerator.java
create mode 100644
server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaBackFillQueue.java
create mode 100644
server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaCache.java
create mode 100644
server/src/main/java/org/apache/druid/segment/metadata/SegmentSchemaManager.java
create mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/TaskSegmentSchemaUtil.java
create mode 100644
server/src/main/java/org/apache/druid/server/QuerySwappingQueryRunner.java
create mode 100644
server/src/main/java/org/apache/druid/server/ResourceIdPopulatingQueryRunner.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordination/DataSegmentChangeResponse.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordination/SegmentChangeStatus.java
delete mode 100644
server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorKillConfigs.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorPeriodConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/CoordinatorRunConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/DruidCoordinatorConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/HttpLoadQueuePeonConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/KillUnusedSegmentsConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/MetadataCleanupConfig.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/duty/KillUnreferencedSegmentSchema.java
create mode 100644
server/src/main/java/org/apache/druid/server/lookup/cache/LookupLoadingSpec.java
create mode 100644
server/src/test/java/org/apache/druid/metadata/IndexerSqlMetadataStorageCoordinatorSchemaPersistenceTest.java
create mode 100644
server/src/test/java/org/apache/druid/metadata/IndexerSqlMetadataStorageCoordinatorTestBase.java
create mode 100644
server/src/test/java/org/apache/druid/metadata/SQLMetadataConnectorSchemaPersistenceTest.java
create mode 100644
server/src/test/java/org/apache/druid/metadata/SqlSegmentsMetadataManagerSchemaPollTest.java
create mode 100644
server/src/test/java/org/apache/druid/metadata/SqlSegmentsMetadataManagerTestBase.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/metadata/CoordinatorSegmentMetadataCacheCommon.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/CoordinatorSegmentMetadataCacheTestBase.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/FingerprintGeneratorTest.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentMetadataCacheCommon.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentMetadataCacheTestBase.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentSchemaBackFillQueueTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentSchemaCacheTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentSchemaManagerTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/metadata/SegmentSchemaTestUtils.java
delete mode 100644
server/src/test/java/org/apache/druid/server/ServerTestHelper.java
delete mode 100644
server/src/test/java/org/apache/druid/server/coordinator/TestDruidCoordinatorConfig.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/duty/KillUnreferencedSegmentSchemaTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/loading/CuratorLoadQueuePeonTest.java
delete mode 100644
server/src/test/java/org/apache/druid/server/coordinator/loading/LoadQueuePeonTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/lookup/cache/LookupLoadingSpecTest.java
create mode 100644
services/src/test/java/org/apache/druid/cli/TestValidateIncompatibleCentralizedDatasourceSchemaConfig.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/expression/DruidLiteral.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/expression/builtin/ScalarInArrayOperatorConversion.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidAvaticaDriverTest.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidAvaticaTestDriver.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidConnectionExtras.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidQuidemCommandHandler.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidQuidemConnectionFactory.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DruidQuidemTestBase.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DynamicComposite.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/DynamicCompositeTest.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/MapToInterfaceHandler.java
create mode 100644
sql/src/test/java/org/apache/druid/quidem/ProjectPathUtils.java
create mode 100644 sql/src/test/java/org/apache/druid/quidem/SqlQuidemTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteGroupByQueryTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/DecoupledExtension.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/SqlTestFrameworkConfigTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/TempDirProducer.java
delete mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/schema/BrokerSegmentMetadataCacheCommon.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/schema/BrokerSegmentMetadataCacheTestBase.java
create mode 100644
sql/src/test/quidem/org.apache.druid.quidem.SqlQuidemTest/decoupled.iq
create mode 100644
sql/src/test/quidem/org.apache.druid.quidem.SqlQuidemTest/join.iq
create mode 100644
sql/src/test/quidem/org.apache.druid.quidem.SqlQuidemTest/numMerge.iq
create mode 100644
sql/src/test/quidem/org.apache.druid.quidem.SqlQuidemTest/simple.iq
create mode 100644
web-console/src/ace-modes/__snapshots__/make-doc-html.spec.ts.snap
delete mode 100644 web-console/src/ace-modes/dsql.js
create mode 100644 web-console/src/ace-modes/dsql.ts
delete mode 100644 web-console/src/ace-modes/hjson.js
create mode 100644 web-console/src/ace-modes/hjson.ts
create mode 100644 web-console/src/ace-modes/make-doc-html.spec.ts
create mode 100644 web-console/src/ace-modes/make-doc-html.ts
create mode 100644
web-console/src/druid-models/supervisor-status/supervisor-status.ts
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
