This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a change to branch
dependabot/maven/org.asynchttpclient-async-http-client-3.0.10
in repository https://gitbox.apache.org/repos/asf/druid.git
discard 0d7b3ca8b0c build(deps): bump org.asynchttpclient:async-http-client
add 375dfd128cd minor: Web console: improve and fix supervisor view
(#19475)
add b04b349bef3 bump bouncy castle due to CVE-2026-5588 (#19473)
add 8308a662874 perf: Streamline s3 backend (#19394)
add 1001b6f5d4b fix: ensure sequence metadata list accesses are threadsafe
in task runner (#19467)
add 577dd6a6fcf Bump postgres dep due to high vuln (#19474)
add 4628e43081b perf: Optimize HLL sketch merge by avoiding unnecessary
HLL_8 to HLL_4 conversion (#19482)
add a1181533931 fix: web console services card omits most service types
without SQL (#19481)
add 781aba64000 perf: Optimize SpillingGrouper to avoid unnecessary disk
I/O for small spill runs (#19439)
add 1d87a74ed7d fix: add rel="noopener noreferrer" to web console links
opening in a new tab (#19483)
add 6e2f4726167 refactor: clean up min/max task count limits in streaming
task autoscaler (#19369)
add 953b505d57e refactor: add ColumnFormat implementation for string
columns (#19410)
add e2af6647c43 docs: use {{DRUIDVERSION}} template in docker tutorial
port link (#19485)
add f357a4b86af fix: Peon metrics emit same value (#19484)
add 111e7338113 feat: add realtimeSegmentsMode query context param (#19486)
add c822ac8f04c docs: fix off-by-one line anchor in docker tutorial
DRUID_LOG4J link (#19487)
add 5938d27a3db fix: invalid ISO 8601 start_time placeholder in services
view fallback (#19488)
add d2736411784 minor: Jump to the last ever derby version (#19492)
add 791a071452d feat: Multi-cluster Kubernetes Task Runner (#19433)
add 520978e94e2 feat: Extension point for MSQ InputSpecs. (#19479)
add a9469502238 feat: consolidate S3 client creation and enable ARN role
for MSQ export (#19317)
add e5e31b7d962 fix: chat handler response parsing (#19495)
add f0ea14b2f39 perf: Hoist config check in acquireSegment. (#19503)
add 983c0c37db2 minor: Get StorageMonitor metrics from StorageLocations.
(#19494)
add 47925aa0998 fix: Close exposure to potential NPE in S3Utils.useHttps
(#19504)
add b3b1ff255ba docs: Stop Referring to MSQ as an extension (#19507)
add 50ce46501f2 refactor: remove deprecated zookeeper-based task runner
(#19500)
add f0d06c45ada ci: fix unit tests, bump actions-timeline (#19509)
add 215f415e5a2 feat: partial segment cache infrastructure (#19496)
add 06ef24c1e09 feat: ingest support for numeric typed
ExpressionLambdaAggregatorFactory (#19508)
add 177cada0f34 fix: OrcInputFormat concurrent FileSystem init race
condition (#19491) (#19497)
add ab12df66fbe feat: add getDimensionRangeSet support to LikeDimFilter
for equality and prefix cases (#19524)
add 7bdbc2d6b81 Remove raw types in ChainedExecutionQueryRunner (#19529)
add 5ba191be9f6 perf: disable processing thread renaming by default
(#19518)
add 2f35573537a build(deps): Bump jackson to `2.21.3` (#19528)
add cf275580199 feat: resetOffsetsAndBackfill using bounded stream
supervisor (#19477)
add efa6ed49339 Bump caffeine to 3.2.4 and errorprone to 2.49.0 (#19527)
add 530a30a7502 feat: Web console support for resetToLatestAndBackfill
(#19533)
add 120be6e11c5 refactor: adjust diskNormalized strategy to scale cost
exponentially with disk utilization (#19422)
add e61fddc3dbe feat: add simd add/sub/mul expressions (#19512)
add b876851c68a refactor: remove deprecated curator ServiceAnnouncer stuff
(#19523)
add b210c99149c minor: scale AWSClientConfig default maxConnections with
available processors (#19536)
add fd6befe010b Fix a small typo in bin/start-druid (#19544)
add 11b0b591822 feat: Include supervisorId in Kafka consumer metrics.
(#19525)
add 03ab4e2b1e3 feat: Background fetching of files for SQL EXTERN. (#19539)
add 9d82a0ec9a6 fix: Retain exception that triggered Dart query
cancellation. (#19553)
add 4f83cee078f fix: Track load completion in
StorageLocationVirtualStorageManager. (#19555)
add 7426949b213 fix: thrownAway reason incorrectly defaulting to null for
streaming tasks (#19540)
add d06aa83cd80 fix: retry transient AWS credential resolution failures
(#19558)
add 7bbfa039403 feat: Make segmentLoadAheadCount able to be configured at
worker task level in addition to context (#19559)
add ca51d780bf3 feat: clustered segments pt.1 (#19460)
add 2f1f0b770ac feat: S3 SegmentRangeReader for partial segment downloads
(#19560)
add 80d7700f55c fix: flaky Consul embedded test startup (#19564)
add 38f8b4cfe50 fix: empty loads for asymmetric cluster-group partial-load
matchers (#19565)
add ce74072496f feat: Prunable shard specs for streaming published
segments (#19571)
add 0565ddcaa8f refactor: split out RowCountInspector,
PhysicalSegmentColumnInspector from PhysicalSegmentInspector (#19577)
add 1ce8a309071 test: Fix row-count race in EmbeddedKafkaSupervisorTest
(#19581)
add 3d573004ebb fix: zstd + v10 segment metadata decompression for large
metadata (#19578)
add ed63f731e13 test: Hoist latch-timeout override to
StreamIndexFaultToleranceTest to reduce flakiness (#19580)
add a4d221e21ca fix: Raise `start-druid` middleManager memory to 256m
(#19582)
add 0e991fd1bdc feat: add OpenLineage request logger extension (#19107)
add fd59f41a110 ci: bump outdated GitHub Actions (#19587)
add d00dd4ad50e feat: clustered segments pt.2 (write side support) (#19579)
add 2e61c7120a5 refactor: enforce 1 tierAlias mapping per distinct tier.
add tierAlias dim to some metrics (#19595)
add 633ccd409e9 feat: on-demand partial segment loading in
SegmentLocalCacheManager (#19535)
add 3228e3ec05c fix(delta): drain all batches per scan file in
DeltaInputSourceIterator (#19592)
add b90c6c525f5 docs: complete druid.broker.balancer.type description
(#19590)
add 96df2030e90 feat: clustered segments + MSQ compaction (#19597)
add f45747d84e2 test: KafkaBoundedSupervisorTest flaky test (#19543)
add b5d84044721 feat: add maxValuesPerDimension cap to
streamingPartitionsSpec (#19596)
add 43278bce1b6 build(deps): Update Netty to 4.2.15.Final to address
multiple CVEs (#19566)
add e02b9af07d7 feat: support aggregate projections on clustered segments
(#19599)
add a289901680c fix: preserve DimensionValueSetShardSpec on upgraded
append segments (#19615)
add b8e11706e61 test: Fix flaky `BasicAuthMSQTest` (#19593)
add 4bc6a13d640 fix: retry S3 segment reads on transient SSLException (TLS
"Tag mismatch")
add 68ffc462d98 docs: update to docusaurus 3.10 (#19522)
add c010e42988c feat: Add "Convert to SQL" option for streaming
supervisors (#19547)
add 9cdedcddc52 feat: partial load for clustered segments (#19620)
add 24b90ebb765 test: switch tests to use CompactionState builder (#19626)
add 6687229e0e4 minor: add debug logs for diagnosing projection match
failures (#19613)
add 2c634fc05b8 feat: clustered segment benchmark and fix (#19623)
add 60e34876ef3 feat: unnest and join makeCursorHolderAsync (#19600)
add 4e6f930ed9b fix: fix broker segment metadata cache refresh (#19625)
add d4afc1f7244 feat: enhance U-shape idle prediction for scale-down
scenarios (#19562)
add 14df9842a2d fix: Terminate connection on closing the stream from the
DirectDruidClient (#19607)
add 9c26bb75430 minor: Add metrics to costBased auto-scaler (#19631)
add 6bed96efcb9 feat: introduce processing rate to max ratio as
poll-idle-ratio replacement (#19622)
add 1a05649d005 build(deps): Update Jackson to 2.21.4 to address multiple
CVEs (#19618)
add 51aa8962a64 minor: bump Log4j dep to 2.26 and make JsonTemplateLayout
available to operators in their custom log4j configs (#19629)
add d9b6c4e4727 feat: add auth metrics emission (#19552)
add fb90a5edcc5 fix: partial segment bootstrap (#19630)
add b20f29c34bb minor: improve partial load metrics (#19632)
add c2d15dfc55d docs: updated isolation.level description (#19628)
add 4e517615b82 feat: add query/segments/count metric to data nodes
(#19624)
add 29eaed52c6c fix: adjust docs for query/segments/count metric (#19639)
add 77b4284940e fix: Perform best effort cleanup of intermediary data in
ParallelIndexSupervisorTask (#19647)
add a2105da7cfa feat: rebalance cost-based autoscaler for best throughput
(#19646)
add a5f1488617b test(delta): add embedded e2e ingestion test for Delta
Lake input source (#19611)
add d70bf3a5c4d feat: SIMD sum vector aggregators (Long/Double/Float)
(#19561)
add f813306c603 feat: Weighted Query Laning Strategy (#19225)
add cdb50b65f06 fix: bugfix in MSQ code path for extern ingest (#19656)
add b6a5fabd04a fix: update milestone pr script (#19664)
add 9b45e5b7a78 fix: projections on base table columns result in failed
indexing when using unzipped segments (#19662)
add 31019ad3a02 refactor: switch diskNormalized strategy to be more
tune-able (#19663)
add e787535df06 add tierAlias to coordinator tier capacity metrics for
statsd and prometheus emitters (#19667)
add 9fca068da23 minor: Fix metric values of costBased auto-scaler (#19641)
add 79c272183c0 fix: Fix for flaky embedded test QueryVirtualStorageTest
add c326986ac2c docs: added registered trademarks to mentions of Apache
Druid and Kafka (#19653)
add 71b5e329d27 test: convert tests in druid-processing to junit5 pt. 9
(#19601)
add 6fb885e055c docs: Update tutorials to not use bin/post-index-task
(#19637)
add 9c3e58e0c97 feat: ensure statusCode is included in router logs (#19668)
add 60420e3dd75 feat: wire up partial load rules to segment cache (#19671)
add f6b4c708ae9 minor: Add logs and metrics observability to the segment
upgrade path that fires while using concurrent locking (#19651)
add f7543426da6 fix: constant columns for clustered segment (#19675)
add 5f0d65d06ba Upgrade Kafka to 4.3.0 (#19584)
add bb9924e59fd perf: speed-up coordinator segment metadata cache delta
syncs (#19672)
add 2c2a1c1d681 fix: Try register upgraded pending segment on all
supervisors for datasource (#19679)
add 7cc704d88a3 minor: Add `segment/allocated/count` metric (#19674)
add 4bf97a82b5f feat: simd min/max vector aggregators (#19660)
add 5b4755e942b perf: add SIMD acceleration for doubleMean aggregator
(#19681)
add af0e764ee6d feat: optimize partial loads by coalescing (or splitting)
range reads (#19683)
add 355a9b83d40 refactor: make supervisor diff+restart algorithm smarter
on submission (#19541)
add 90563dc3b61 feat: partial load rule announcement (#19682)
add 5487eda462f Adding query which matches the index (#19685)
add 3e59af12048 docs: update IntelliJ settings (#19661)
add e44c2166880 feat: support redis TLS (#19666)
add 12116521c88 fix: Limit number of unused segment rows scanned (#19690)
add 148a728bb7b feat: Configurable per-threshold weighted laning (#19665)
add 87943a1ebfd feat: simd division expression (#19686)
add 6513113034a refactor: remove id from query/priority metric (#19696)
add b55666ff684 docs: added registered trademark symbol to mentions of
external software (#19684)
add 07b11189fa3 Upgrade RoaringBitmap to 1.6.14 (#19688)
add 2812445723d feat: Add remote address tracking for JDBC/Avatica SQL
queries (#19231)
add 0971e423682 perf: optimize coordinator HistoricalManagement duty
runtime (#19532)
add 4caa5ce4c44 minor: Add config and metrics to CostBasedAutoScaler
(#19697)
add aedca205992 feat: PartialSegmentFileMapper no longer lazy loads
(#19693)
add 072103e83df release: Prepare master for next version 39.0.0-SNAPSHOT
add d58381a806c build(deps): Upgrade to latest SpotBugs (#19576)
add 66124609fb1 fix: delegate row/vector id inspectors for clustered
selector factories (#19702)
add f0d8c616cc5 feat: rework `requireRestart` to `getActionOnUpdateTo` to
control restart/task-disruption behavior (#19700)
add 3e8da56c809 fix: dedicated ephemeral storage loading pool for tasks
(#19658)
add 34049ff8389 fix: better query manager and allow setting cookie for dev
forward (#19692)
add 48647470fec minor: reduce flakiness in CI (#19706)
add cec7f0cf0b3 feat: Add endpoint to fetch configured peon pod template
names (#19712)
add 704baa25471 feat: upgrade to JDK 25 compiler (#19707)
add 3ee535bbcd1 minor: [JDK upgrade] Update forking task runner to use
bin/run-java (#19709)
add 543256bd422 fix: loading pool callers decide when to permit (#19717)
add 1ebdf5ff7f9 feat: simd negate and abs (#19703)
add 4a4c8838da5 minor: Add QOS filtering for coordinator endpoints (#19271)
add 15e50434614 perf: add datasource filter pushdown for sys.segments
table (#19718)
add a85d64c4cbd refactor: Make shard spec collector an interface for
extensibility (#19689)
add 4c0f5240c1a fix: Fix undesireable load rule behavior for clustered
segments with conforming shape but no matched groups (#19728)
add dbe1d23ee03 fix: ensure supervisor worker threadpool is reapable
(#19738)
add 80ae6bc7d0f feat: support time ordered cursor for clustered segments
when possible (#19726)
add f46ee871953 feat: simd sqrt (#19742)
add 1e510ab555e feat: catalog + clustered segments (#19711)
add 004f8eb9f40 test: Fixes for flaky StreamIndexFaultToleranceTest tests.
(#19749)
add 13f2f583e2c feat: restrict virtual column usage in clustered segments,
allow remapping them at query time (#19659)
add 67aa25cef0d fix: Avoid sleep on stop in K8sDruidNodeDiscoveryProvider.
(#19748)
add be1863f0bfe feat: Always allow scaling during task rollover in
costBased auto-scaler (#19750)
add ff7584596d8 fix: Stop kill task if segment IDs that share load spec of
killable segment could not be determined (#19737)
add 957121248f3 feat: clustered segment time ordering for realtime queries
(#19753)
add 40d02713f90 build(deps): bump org.asynchttpclient:async-http-client
add b197e534016 Align JetBrains annotations with async-http-client
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 (0d7b3ca8b0c)
\
N -- N -- N
refs/heads/dependabot/maven/org.asynchttpclient-async-http-client-3.0.10
(b197e534016)
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/workflows/ci.yml | 2 +-
.github/workflows/codeql.yml | 2 +-
.github/workflows/cron-job-its.yml | 2 +-
.github/workflows/docker-tests.yml | 4 +-
.github/workflows/pr-checks.yml | 2 +-
.github/workflows/stale.yml | 2 +-
.github/workflows/static-checks.yml | 2 +-
.../unit-and-integration-tests-unified.yml | 2 +-
README.md | 4 +-
README.template | 2 +-
benchmarks/pom.xml | 27 +-
.../druid/benchmark/DataSketchesHllBenchmark.java | 36 +
.../DoubleMeanVectorAggregatorBenchmark.java | 179 +
.../benchmark/SinkQuerySegmentWalkerBenchmark.java | 358 +-
.../druid/benchmark/query/SqlBaseBenchmark.java | 52 +-
.../benchmark/query/SqlBenchmarkDatasets.java | 166 +-
.../query/SqlClusteredSegmentsBenchmark.java | 127 +
.../benchmark/query/SqlExpressionBenchmark.java | 128 +-
.../coordinator/ComputePlacementCostBenchmark.java | 141 +
.../MarkOvershadowedSegmentsAsUnusedBenchmark.java | 142 +
.../calcite/schema/SysSegmentsTableBenchmark.java | 286 +
cloud/aws-common/pom.xml | 2 +-
.../apache/druid/common/aws/AWSClientConfig.java | 28 +-
.../org/apache/druid/common/aws/AWSClientUtil.java | 14 +-
.../druid/common/aws/AWSClientConfigTest.java | 53 +-
.../apache/druid/common/aws/AWSClientUtilTest.java | 27 +
cloud/gcp-common/pom.xml | 2 +-
codestyle/spotbugs-exclude.xml | 25 +
dev/intellij-sdk-config.jpg | Bin 885115 -> 0 bytes
dev/intellij-sdk-config.png | Bin 0 -> 365252 bytes
dev/intellij-setup.md | 18 +-
distribution/bin/check-licenses.py | 3 +
distribution/bin/get-milestone-prs.py | 2 +-
distribution/docker/Dockerfile | 6 +-
distribution/docker/docker-compose.yml | 10 +-
distribution/pom.xml | 4 +-
docs/api-reference/api-reference.md | 2 +-
docs/api-reference/automatic-compaction-api.md | 2 +-
docs/api-reference/data-management-api.md | 2 +-
docs/api-reference/dynamic-configuration-api.md | 2 +-
docs/api-reference/json-querying-api.md | 2 +-
docs/api-reference/legacy-metadata-api.md | 2 +-
docs/api-reference/lookups-api.md | 2 +-
docs/api-reference/retention-rules-api.md | 2 +-
docs/api-reference/service-status-api.md | 34 +-
docs/api-reference/sql-api.md | 2 +-
docs/api-reference/sql-ingestion-api.md | 7 +-
docs/api-reference/sql-jdbc.md | 2 +-
docs/api-reference/supervisor-api.md | 107 +-
docs/api-reference/tasks-api.md | 2 +-
docs/configuration/extensions.md | 12 +-
docs/configuration/index.md | 92 +-
docs/data-management/automatic-compaction.md | 2 +-
docs/data-management/compaction.md | 2 +-
docs/data-management/delete.md | 10 +-
docs/data-management/index.md | 2 +-
docs/data-management/manual-compaction.md | 2 +-
docs/data-management/schema-changes.md | 2 +-
docs/data-management/update.md | 2 +-
docs/design/architecture.md | 2 +-
docs/design/broker.md | 2 +-
docs/design/coordinator.md | 4 +-
docs/design/deep-storage.md | 2 +-
docs/design/historical.md | 2 +-
docs/design/index.md | 2 +-
docs/design/indexer.md | 4 +-
docs/design/indexing-service.md | 2 +-
docs/design/metadata-storage.md | 2 +-
docs/design/middlemanager.md | 2 +-
docs/design/overlord.md | 2 +-
docs/design/peons.md | 2 +-
docs/design/router.md | 2 +-
docs/design/segments.md | 2 +-
docs/design/zookeeper.md | 5 +-
docs/development/build.md | 4 +-
docs/development/docs-contribute.md | 2 +-
docs/development/extensions-contrib/consul.md | 2 +-
.../extensions-contrib/druid-ranger-security.md | 2 +-
docs/development/extensions-contrib/iceberg.md | 2 +-
.../extensions-contrib/openlineage-emitter.md | 98 +
docs/development/extensions-contrib/redis-cache.md | 2 +
docs/development/extensions-contrib/sqlserver.md | 2 +-
.../extensions-core/approximate-histograms.md | 2 +-
docs/development/extensions-core/avro.md | 2 +-
docs/development/extensions-core/azure.md | 2 +-
docs/development/extensions-core/bloom-filter.md | 2 +-
.../extensions-core/datasketches-extension.md | 2 +-
.../extensions-core/datasketches-hll.md | 2 +-
.../extensions-core/datasketches-kll.md | 2 +-
.../extensions-core/datasketches-quantiles.md | 2 +-
.../extensions-core/datasketches-theta.md | 2 +-
.../extensions-core/datasketches-tuple.md | 2 +-
.../extensions-core/druid-basic-security.md | 2 +-
docs/development/extensions-core/druid-kerberos.md | 2 +-
docs/development/extensions-core/druid-lookups.md | 2 +-
docs/development/extensions-core/druid-pac4j.md | 2 +-
docs/development/extensions-core/examples.md | 2 +-
docs/development/extensions-core/google.md | 2 +-
docs/development/extensions-core/hdfs.md | 2 +-
docs/development/extensions-core/k8s-jobs.md | 208 +-
docs/development/extensions-core/kubernetes.md | 2 +-
docs/development/extensions-core/mysql.md | 2 +-
docs/development/extensions-core/orc.md | 2 +-
docs/development/extensions-core/parquet.md | 4 +-
docs/development/extensions-core/postgresql.md | 2 +-
docs/development/extensions-core/protobuf.md | 2 +-
docs/development/extensions-core/s3.md | 2 +-
.../extensions-core/simple-client-sslcontext.md | 2 +-
docs/development/extensions-core/stats.md | 2 +-
docs/development/extensions-core/test-stats.md | 2 +-
docs/development/javascript.md | 2 +-
docs/ingestion/data-formats.md | 2 +-
docs/ingestion/hadoop.md | 4 +-
docs/ingestion/index.md | 2 +-
docs/ingestion/ingestion-spec.md | 2 +-
docs/ingestion/input-sources.md | 2 +-
docs/ingestion/kafka-ingestion.md | 55 +-
docs/ingestion/kinesis-ingestion.md | 2 +-
docs/ingestion/native-batch.md | 6 +-
docs/ingestion/standalone-realtime.md | 2 +-
docs/ingestion/streaming.md | 4 +-
docs/ingestion/supervisor.md | 6 +-
docs/multi-stage-query/index.md | 2 +-
docs/multi-stage-query/reference.md | 9 +-
docs/multi-stage-query/security.md | 7 +-
docs/operations/alerts.md | 2 +-
docs/operations/auth-ldap.md | 2 +-
docs/operations/auth.md | 2 +-
docs/operations/basic-cluster-tuning.md | 2 +-
docs/operations/clean-metadata-store.md | 2 +-
docs/operations/dump-segment.md | 2 +-
docs/operations/high-availability.md | 4 +-
docs/operations/http-compression.md | 2 +-
docs/operations/insert-segment-to-db.md | 2 +-
docs/operations/java.md | 22 +-
docs/operations/kubernetes.md | 4 +-
docs/operations/metrics.md | 47 +-
docs/operations/mixed-workloads.md | 2 +-
docs/operations/password-provider.md | 2 +-
docs/operations/pull-deps.md | 2 +-
docs/operations/request-logging.md | 2 +-
docs/operations/reset-cluster.md | 2 +-
docs/operations/rolling-updates.md | 2 +-
docs/operations/rule-configuration.md | 2 +-
docs/operations/security-overview.md | 4 +-
docs/operations/segment-optimization.md | 2 +-
docs/operations/tls-support.md | 2 +-
docs/operations/web-console.md | 2 +-
docs/querying/aggregations.md | 10 +-
docs/querying/arrays.md | 4 +-
docs/querying/caching.md | 4 +-
docs/querying/dart.md | 1 +
docs/querying/datasource.md | 2 +-
docs/querying/datasourcemetadataquery.md | 4 +-
docs/querying/dimensionspecs.md | 4 +-
docs/querying/filters.md | 4 +-
docs/querying/geo.md | 4 +-
docs/querying/granularities.md | 4 +-
docs/querying/groupbyquery.md | 4 +-
docs/querying/having.md | 4 +-
docs/querying/hll-old.md | 2 +-
docs/querying/joins.md | 2 +-
docs/querying/kafka-extraction-namespace.md | 4 +-
docs/querying/limitspec.md | 2 +-
docs/querying/lookups-cached-global.md | 2 +-
docs/querying/lookups.md | 2 +-
docs/querying/math-expr.md | 2 +-
docs/querying/multi-value-dimensions.md | 4 +-
docs/querying/multitenancy.md | 2 +-
docs/querying/nested-columns.md | 2 +-
docs/querying/post-aggregations.md | 4 +-
docs/querying/query-context-reference.md | 8 +-
docs/querying/query-context.md | 2 +-
docs/querying/query-processing.md | 2 +-
docs/querying/querying.md | 2 +-
docs/querying/scan-query.md | 4 +-
docs/querying/searchquery.md | 4 +-
docs/querying/segmentmetadataquery.md | 4 +-
docs/querying/select-query.md | 2 +-
docs/querying/sorting-orders.md | 2 +-
docs/querying/sql-aggregations.md | 2 +-
docs/querying/sql-array-functions.md | 2 +-
docs/querying/sql-data-types.md | 2 +-
docs/querying/sql-functions.md | 4 +-
docs/querying/sql-metadata-tables.md | 2 +-
docs/querying/sql-multivalue-string-functions.md | 2 +-
docs/querying/sql-operators.md | 2 +-
docs/querying/sql-query-context.md | 4 +-
docs/querying/sql-scalar.md | 2 +-
docs/querying/sql-translation.md | 2 +-
docs/querying/sql-window-functions.md | 4 +-
docs/querying/sql.md | 4 +-
docs/querying/timeboundaryquery.md | 4 +-
docs/querying/timeseriesquery.md | 4 +-
docs/querying/tips-good-queries.md | 2 +-
docs/querying/topnmetricspec.md | 4 +-
docs/querying/topnquery.md | 4 +-
docs/querying/virtual-columns.md | 4 +-
docs/release-info/migr-ansi-sql-null.md | 2 +-
docs/release-info/migr-front-coded-dict.md | 2 +-
docs/release-info/migration-guide.md | 2 +-
docs/release-info/upgrade-notes.md | 2 +-
docs/tutorials/cluster.md | 4 +-
docs/tutorials/docker.md | 6 +-
docs/tutorials/index.md | 6 +-
docs/tutorials/tutorial-append-data.md | 6 +-
docs/tutorials/tutorial-batch-native.md | 2 +-
docs/tutorials/tutorial-batch.md | 48 +-
docs/tutorials/tutorial-compaction.md | 18 +-
docs/tutorials/tutorial-delete-data.md | 8 +-
docs/tutorials/tutorial-extern.md | 4 +-
docs/tutorials/tutorial-ingestion-spec.md | 12 +-
docs/tutorials/tutorial-kafka.md | 6 +-
docs/tutorials/tutorial-latest-by.md | 2 +-
docs/tutorials/tutorial-msq-convert-spec.md | 5 +-
docs/tutorials/tutorial-msq-extern.md | 5 +-
docs/tutorials/tutorial-query.md | 2 +-
docs/tutorials/tutorial-retention.md | 8 +-
docs/tutorials/tutorial-rollup.md | 2 +-
docs/tutorials/tutorial-sketches-theta.md | 2 +-
docs/tutorials/tutorial-sql-null.md | 2 +-
docs/tutorials/tutorial-sql-query-view.md | 2 +-
docs/tutorials/tutorial-transform.md | 2 +-
docs/tutorials/tutorial-update-data.md | 6 +-
embedded-tests/pom.xml | 15 +-
.../testing/embedded/auth/BasicAuthMSQTest.java | 122 +-
.../catalog/CatalogIngestAndQueryTest.java | 137 +-
.../testing/embedded/catalog/CatalogTestBase.java | 5 +-
.../embedded/compact/CompactionTaskTest.java | 90 +
.../embedded/consul/ConsulClusterResource.java | 125 +
.../embedded/consul/ConsulClusterResourceTest.java | 58 +
.../DeltaLakeInputSourceIngestionTest.java | 132 +
.../IngestionBackwardCompatibilityDockerTest.java | 8 +
.../embedded/indexing/IngestionSmokeTest.java | 45 +-
.../indexing/KafkaBoundedSupervisorTest.java | 56 +-
.../indexing/StreamIndexFaultToleranceTest.java | 23 +
.../embedded/indexing/StreamIndexTestBase.java | 68 +-
.../CostBasedAutoScalerIntegrationTest.java | 70 +-
.../kinesis/KinesisFaultToleranceTest.java | 7 -
.../testing/embedded/msq/EmbeddedMSQApis.java | 94 +-
.../msq/EmbeddedMSQParquetIngestionTest.java | 162 +
.../embedded/msq/EmbeddedMSQRealtimeQueryTest.java | 30 +-
.../testing/embedded/msq/S3ExternQueryTest.java | 215 +
.../query/ClusteredSegmentProjectionQueryTest.java | 294 +
.../query/PartialProjectionLoadRuleQueryTest.java | 425 +
.../embedded/query/QueryVirtualStorageTest.java | 88 +-
.../query/ServerManagerForQueryErrorTest.java | 3 +-
...-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc | Bin 0 -> 152 bytes
...-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc | Bin 0 -> 152 bytes
.../_delta_log/.00000000000000000000.json.crc | Bin 0 -> 20 bytes
.../_delta_log/00000000000000000000.json | 5 +
...104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet | Bin 0 -> 18078 bytes
...2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet | Bin 0 -> 18185 bytes
examples/bin/run-java | 1 +
examples/bin/start-druid | 2 +-
examples/bin/start-druid-main.py | 2 +-
examples/bin/verify-java | 8 +-
extensions-contrib/aliyun-oss-extensions/pom.xml | 2 +-
extensions-contrib/ambari-metrics-emitter/pom.xml | 2 +-
.../src/main/resources/defaultWhiteListMap.json | 4 +
extensions-contrib/cassandra-storage/pom.xml | 2 +-
extensions-contrib/cloudfiles-extensions/pom.xml | 2 +-
extensions-contrib/compressed-bigdecimal/pom.xml | 2 +-
extensions-contrib/consul-extensions/pom.xml | 2 +-
.../consul/discovery/ConsulDruidNodeAnnouncer.java | 32 +-
.../discovery/ConsulDruidNodeAnnouncerTest.java | 27 +
extensions-contrib/ddsketch/pom.xml | 2 +-
extensions-contrib/distinctcount/pom.xml | 2 +-
extensions-contrib/dropwizard-emitter/pom.xml | 2 +-
.../main/resources/defaultMetricDimensions.json | 63 +-
.../druid-deltalake-extensions/pom.xml | 2 +-
.../druid/delta/input/DeltaInputSourceReader.java | 45 +-
.../druid/delta/input/DeltaInputSourceTest.java | 40 +
.../druid/delta/input/LargeRowGroupDeltaTable.java | 54 +
...-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc | Bin 0 -> 152 bytes
...-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc | Bin 0 -> 152 bytes
.../_delta_log/.00000000000000000000.json.crc | Bin 0 -> 20 bytes
.../_delta_log/00000000000000000000.json | 5 +
...104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet | Bin 0 -> 18078 bytes
...2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet | Bin 0 -> 18185 bytes
.../druid-exact-count-bitmap/pom.xml | 2 +-
.../Bitmap64ExactCountMergeAggregatorTest.java | 23 +
.../druid-iceberg-extensions/pom.xml | 2 +-
extensions-contrib/druid-ranger-security/pom.xml | 2 +-
extensions-contrib/gce-extensions/pom.xml | 2 +-
extensions-contrib/graphite-emitter/pom.xml | 2 +-
.../src/main/resources/defaultWhiteListMap.json | 4 +
extensions-contrib/grpc-query/pom.xml | 2 +-
extensions-contrib/influx-extensions/pom.xml | 2 +-
extensions-contrib/influxdb-emitter/pom.xml | 2 +-
extensions-contrib/kafka-emitter/pom.xml | 2 +-
extensions-contrib/momentsketch/pom.xml | 2 +-
extensions-contrib/moving-average-query/pom.xml | 2 +-
.../pom.xml | 103 +-
.../openlineage/OpenLineageRequestLogger.java | 575 +
.../OpenLineageRequestLoggerModule.java | 31 +-
.../OpenLineageRequestLoggerProvider.java | 171 +
.../org.apache.druid.initialization.DruidModule | 16 +
.../DruidQueryContextRunFacet.json | 29 +
.../DruidQueryStatisticsRunFacet.json | 28 +
.../openlineage/OpenLineageRequestLoggerTest.java | 597 +
extensions-contrib/opentelemetry-emitter/pom.xml | 2 +-
extensions-contrib/opentsdb-emitter/pom.xml | 2 +-
.../src/main/resources/defaultMetrics.json | 36 +
extensions-contrib/prometheus-emitter/pom.xml | 2 +-
.../src/main/resources/defaultMetrics.json | 15 +-
.../rabbit-stream-indexing-service/pom.xml | 2 +-
.../RabbitStreamIndexTaskTuningConfig.java | 25 +
.../supervisor/RabbitStreamIOConfigBuilder.java | 69 +-
.../supervisor/RabbitStreamSupervisor.java | 6 +-
.../supervisor/RabbitStreamSupervisorIOConfig.java | 28 +
.../supervisor/RabbitStreamSupervisorSpec.java | 88 +
.../RabbitStreamSupervisorTuningConfig.java | 24 +
.../RabbitStreamIndexTaskTuningConfigTest.java | 17 +
.../RabbitStreamSupervisorIOConfigTest.java | 72 +
.../supervisor/RabbitStreamSupervisorTest.java | 139 +-
.../RabbitStreamSupervisorTuningConfigTest.java | 84 +
extensions-contrib/redis-cache/pom.xml | 2 +-
.../druid/client/cache/RedisCacheConfig.java | 23 +
.../druid/client/cache/RedisCacheFactory.java | 57 +-
.../druid/client/cache/RedisCacheConfigTest.java | 91 +
extensions-contrib/spectator-histogram/pom.xml | 2 +-
.../sqlserver-metadata-storage/pom.xml | 2 +-
.../storage/sqlserver/SQLServerConnector.java | 7 +
extensions-contrib/statsd-emitter/pom.xml | 2 +-
.../main/resources/defaultMetricDimensions.json | 16 +-
extensions-contrib/tdigestsketch/pom.xml | 2 +-
extensions-contrib/thrift-extensions/pom.xml | 2 +-
extensions-contrib/time-min-max/pom.xml | 2 +-
extensions-contrib/virtual-columns/pom.xml | 2 +-
extensions-core/avro-extensions/pom.xml | 2 +-
extensions-core/azure-extensions/pom.xml | 2 +-
extensions-core/datasketches/pom.xml | 2 +-
.../datasketches/hll/HllSketchHolder.java | 11 +-
.../datasketches/hll/HllSketchHolderTest.java | 139 +
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 +-
extensions-core/druid-catalog/pom.xml | 2 +-
.../druid/catalog/sql/CatalogInsertTest.java | 4 +
.../druid/catalog/sql/CatalogReplaceTest.java | 4 +
.../apache/druid/catalog/storage/CatalogTests.java | 6 +-
extensions-core/druid-kerberos/pom.xml | 2 +-
extensions-core/druid-pac4j/pom.xml | 2 +-
extensions-core/druid-testcontainers/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 +-
extensions-core/kafka-extraction-namespace/pom.xml | 2 +-
.../query/lookup/TestKafkaExtractionCluster.java | 2 +-
extensions-core/kafka-indexing-service/pom.xml | 2 +-
.../druid/indexing/kafka/KafkaConsumerMonitor.java | 21 +-
.../druid/indexing/kafka/KafkaIndexTask.java | 9 +-
.../indexing/kafka/KafkaIndexTaskTuningConfig.java | 17 +-
.../druid/indexing/kafka/KafkaRecordSupplier.java | 17 +-
.../druid/indexing/kafka/KafkaSamplerSpec.java | 8 +-
.../kafka/supervisor/KafkaIOConfigBuilder.java | 45 +-
.../indexing/kafka/supervisor/KafkaSupervisor.java | 13 +-
.../kafka/supervisor/KafkaSupervisorIOConfig.java | 39 +
.../kafka/supervisor/KafkaSupervisorSpec.java | 92 +
.../supervisor/KafkaSupervisorTuningConfig.java | 35 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 7 +-
.../kafka/KafkaIndexTaskTuningConfigTest.java | 135 +-
.../indexing/kafka/KafkaRecordSupplierTest.java | 51 +-
.../EmbeddedDimensionValueSetShardSpecTest.java | 1171 +
.../simulate/EmbeddedKafkaSupervisorTest.java | 13 +-
.../indexing/kafka/simulate/KafkaResource.java | 2 +-
.../supervisor/KafkaSupervisorIOConfigTest.java | 83 +
.../kafka/supervisor/KafkaSupervisorSpecTest.java | 33 +
.../kafka/supervisor/KafkaSupervisorTest.java | 243 +-
.../kafka/supervisor/KafkaTuningConfigBuilder.java | 11 +-
.../indexing/kafka/test/EmbeddedKafkaBroker.java | 2 +-
.../TestModifiedKafkaIndexTaskTuningConfig.java | 1 +
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../kinesis/supervisor/KinesisIOConfigBuilder.java | 125 +
.../kinesis/supervisor/KinesisSupervisor.java | 4 +-
.../supervisor/KinesisSupervisorIOConfig.java | 39 +
.../kinesis/supervisor/KinesisSupervisorSpec.java | 101 +
.../supervisor/KinesisSupervisorTuningConfig.java | 35 +
.../kinesis/KinesisIndexTaskSerdeTest.java | 3 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 5 +-
.../indexing/kinesis/KinesisSamplerSpecTest.java | 61 +-
.../supervisor/KinesisSupervisorIOConfigTest.java | 73 +
.../kinesis/supervisor/KinesisSupervisorTest.java | 371 +-
extensions-core/kubernetes-extensions/pom.xml | 2 +-
.../discovery/K8sDruidNodeDiscoveryProvider.java | 18 +-
.../K8sDruidNodeDiscoveryProviderTest.java | 94 +
.../kubernetes-overlord-extensions/pom.xml | 6 +-
.../overlord/AutoscalableThreadPoolExecutor.java | 122 +
.../KubernetesAndWorkerTaskRunnerConfig.java | 9 +-
.../k8s/overlord/KubernetesOverlordModule.java | 21 +-
.../druid/k8s/overlord/KubernetesTaskRunner.java | 69 +-
.../k8s/overlord/MultipleKubernetesTaskRunner.java | 441 +
.../MultipleKubernetesTaskRunnerConfig.java | 316 +
.../MultipleKubernetesTaskRunnerDelegate.java | 114 +
.../MultipleKubernetesTaskRunnerFactory.java | 473 +
.../DefaultKubernetesTaskRunnerDynamicConfig.java | 2 +
.../KubernetesTaskRunnerPodTemplateResource.java | 77 +
.../DynamicConfigPodTemplateSelector.java | 11 +
.../k8s/overlord/taskadapter/K8sTaskAdapter.java | 54 +-
.../taskadapter/MultiContainerTaskAdapter.java | 25 +
.../overlord/taskadapter/PodTemplateSelector.java | 8 +
.../taskadapter/PodTemplateTaskAdapter.java | 5 +
.../taskadapter/SingleContainerTaskAdapter.java | 25 +
.../AutoscalableThreadPoolExecutorTest.java | 102 +
.../KubernetesAndWorkerTaskRunnerConfigTest.java | 2 +-
.../k8s/overlord/KubernetesOverlordModuleTest.java | 59 +-
.../k8s/overlord/KubernetesTaskRunnerTest.java | 104 +-
.../MultipleKubernetesTaskRunnerConfigTest.java | 304 +
.../MultipleKubernetesTaskRunnerFactoryTest.java | 294 +
.../overlord/MultipleKubernetesTaskRunnerTest.java | 1340 +
...ubernetesTaskRunnerPodTemplateResourceTest.java | 62 +
.../DynamicConfigPodTemplateSelectorTest.java | 21 +
.../overlord/taskadapter/K8sTaskAdapterTest.java | 86 +
.../taskadapter/TestPodTemplateSelector.java | 9 +
.../kubernetesAndWorkerTaskRunnerConfig.json | 4 +-
extensions-core/lookups-cached-global/pom.xml | 2 +-
extensions-core/lookups-cached-single/pom.xml | 2 +-
extensions-core/mysql-metadata-storage/pom.xml | 2 +-
.../metadata/storage/mysql/MySQLConnector.java | 7 +
extensions-core/orc-extensions/pom.xml | 2 +-
.../druid/data/input/orc/OrcInputFormat.java | 19 +-
.../druid/data/input/orc/OrcInputFormatTest.java | 1 +
extensions-core/parquet-extensions/pom.xml | 2 +-
.../postgresql-metadata-storage/pom.xml | 2 +-
extensions-core/protobuf-extensions/pom.xml | 2 +-
extensions-core/s3-extensions/pom.xml | 12 +-
.../apache/druid/data/input/s3/S3InputSource.java | 151 +-
.../druid/storage/s3/S3DataSegmentMover.java | 125 +-
.../druid/storage/s3/S3DataSegmentPuller.java | 23 +-
.../druid/storage/s3/S3DataSegmentPusher.java | 29 +-
.../org/apache/druid/storage/s3/S3LoadSpec.java | 43 +-
.../druid/storage/s3/S3SegmentRangeReader.java | 151 +
.../druid/storage/s3/S3StorageDruidModule.java | 86 +-
.../java/org/apache/druid/storage/s3/S3Utils.java | 27 +-
.../storage/s3/ServerSideEncryptingAmazonS3.java | 207 +
.../storage/s3/output/S3ExportStorageProvider.java | 72 +-
.../druid/data/input/s3/S3InputSourceTest.java | 137 +-
.../druid/storage/s3/S3DataSegmentMoverTest.java | 52 +
.../druid/storage/s3/S3DataSegmentPullerTest.java | 9 -
.../druid/storage/s3/S3DataSegmentPusherTest.java | 145 +-
.../apache/druid/storage/s3/S3LoadSpecTest.java | 79 +
.../druid/storage/s3/S3SegmentRangeReaderTest.java | 240 +
.../druid/storage/s3/S3StorageDruidModuleTest.java | 17 +-
.../apache/druid/storage/s3/S3TaskLogsTest.java | 19 +-
.../org/apache/druid/storage/s3/S3UtilsTest.java | 87 +
.../s3/output/S3ExportStorageProviderTest.java | 2 +-
extensions-core/simple-client-sslcontext/pom.xml | 2 +-
extensions-core/stats/pom.xml | 2 +-
extensions-core/testing-tools/pom.xml | 2 +-
.../druid/guice/ClusterTestingModuleTest.java | 2 +-
indexing-service/pom.xml | 14 +-
.../druid/guice/IndexingServiceModuleHelper.java | 4 -
.../common/SegmentCacheManagerFactory.java | 57 +-
.../indexing/common/SegmentUpgradeMetrics.java | 64 +
.../druid/indexing/common/TaskToolboxFactory.java | 2 +-
.../common/actions/SegmentAllocateAction.java | 5 +-
.../common/actions/SegmentAllocationQueue.java | 1 +
.../actions/SegmentTransactionalReplaceAction.java | 90 +-
.../common/task/AbstractBatchIndexTask.java | 2 +
.../druid/indexing/common/task/CompactionTask.java | 57 +-
.../druid/indexing/common/task/IndexTask.java | 2 +-
.../druid/indexing/common/task/IndexTaskUtils.java | 37 +
.../common/task/KillUnusedSegmentsTask.java | 162 +-
.../common/task/NativeCompactionRunner.java | 6 +
.../parallel/ParallelIndexSupervisorTask.java | 5 +-
.../task/batch/parallel/SinglePhaseSubTask.java | 2 +-
.../compact/CascadingReindexingTemplate.java | 8 +
.../indexing/compact/ReindexingConfigBuilder.java | 4 +
.../druid/indexing/input/DruidInputSource.java | 3 +-
.../indexing/input/DruidSegmentInputEntity.java | 2 +-
.../druid/indexing/overlord/DruidOverlord.java | 19 +-
.../druid/indexing/overlord/ForkingTaskRunner.java | 33 +-
.../indexing/overlord/ImmutableWorkerInfo.java | 3 +-
.../druid/indexing/overlord/RemoteTaskRunner.java | 1686 -
.../indexing/overlord/RemoteTaskRunnerFactory.java | 99 -
.../druid/indexing/overlord/TaskRunnerUtils.java | 43 +
.../apache/druid/indexing/overlord/ZkWorker.java | 271 -
.../overlord/config/ForkingTaskRunnerConfig.java | 17 +-
.../config/HttpRemoteTaskRunnerConfig.java | 77 +-
.../overlord/config/RemoteTaskRunnerConfig.java | 202 -
.../overlord/duty/UnusedSegmentsKiller.java | 27 +-
.../overlord/hrtr/HttpRemoteTaskRunner.java | 111 +-
.../overlord/hrtr/HttpRemoteTaskRunnerFactory.java | 23 -
.../overlord/setup/WorkerSelectStrategy.java | 3 +-
.../supervisor/CompactionSupervisorManager.java | 5 +-
.../overlord/supervisor/SupervisorManager.java | 327 +-
.../overlord/supervisor/SupervisorResource.java | 89 +-
.../supervisor/SupervisorSpecUpdateResult.java | 32 +-
.../scheduledbatch/ScheduledBatchTaskManager.java | 8 +
.../seekablestream/DimensionValueSetCollector.java | 191 +
.../DimensionValueSetPartitionsSpec.java | 127 +
.../SeekableStreamIndexTaskRunner.java | 484 +-
.../SeekableStreamIndexTaskTuningConfig.java | 77 +-
.../seekablestream/SettableByteEntity.java | 2 +-
.../seekablestream/SettableByteEntityReader.java | 8 +-
.../indexing/seekablestream/StreamChunkReader.java | 13 +-
.../seekablestream/StreamingPartitionsSpec.java | 61 +
.../StreamingShardSpecCollector.java | 75 +
.../seekablestream/supervisor/IdleConfig.java | 20 +
.../seekablestream/supervisor/LagAggregator.java | 23 +
.../supervisor/SeekableStreamSupervisor.java | 168 +-
.../SeekableStreamSupervisorIOConfig.java | 59 +
.../SeekableStreamSupervisorIngestionSpec.java | 23 +
.../supervisor/SeekableStreamSupervisorSpec.java | 139 +
.../supervisor/SupervisorIOConfigBuilder.java | 99 +-
.../supervisor/autoscaler/CostBasedAutoScaler.java | 202 +-
.../autoscaler/CostBasedAutoScalerConfig.java | 164 +-
.../supervisor/autoscaler/CostMetrics.java | 35 +-
.../supervisor/autoscaler/LagBasedAutoScaler.java | 95 +-
.../autoscaler/WeightedCostFunction.java | 60 +-
.../indexing/worker/WorkerCuratorCoordinator.java | 226 -
.../druid/indexing/worker/WorkerTaskManager.java | 28 +-
.../druid/indexing/worker/WorkerTaskMonitor.java | 226 -
.../druid/indexing/worker/http/WorkerResource.java | 37 +-
.../server/initialization/IndexerZkConfig.java | 136 -
.../common/SegmentCacheManagerFactoryTest.java | 109 +
.../druid/indexing/common/TaskToolboxTest.java | 4 +-
.../apache/druid/indexing/common/TestUtils.java | 3 +-
.../SegmentTransactionalInsertActionTest.java | 2 +-
.../SegmentTransactionalReplaceActionTest.java | 180 +
.../indexing/common/actions/TaskActionTestKit.java | 36 +
.../task/ClientCompactionTaskQuerySerdeTest.java | 47 +-
.../common/task/CompactionTaskParallelRunTest.java | 424 +-
.../common/task/CompactionTaskRunBase.java | 80 +-
.../indexing/common/task/CompactionTaskTest.java | 36 +-
.../druid/indexing/common/task/IndexTaskTest.java | 2 +
.../indexing/common/task/IngestionTestBase.java | 12 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 150 +-
.../druid/indexing/common/task/TaskBuilder.java | 3 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 7 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 7 +-
.../concurrent/ConcurrentReplaceAndAppendTest.java | 61 +-
.../ConcurrentReplaceAndStreamingAppendTest.java | 8 +-
.../compact/CascadingReindexingTemplateTest.java | 25 +-
.../compact/OverlordCompactionSchedulerTest.java | 4 +-
.../compact/ReindexingConfigBuilderTest.java | 65 +
.../ReindexingDeletionRuleOptimizerTest.java | 38 +-
.../indexing/input/DruidSegmentReaderTest.java | 4 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 47 +
.../overlord/OverlordBlinkLeadershipTest.java | 93 -
.../overlord/RemoteTaskRunnerFactoryTest.java | 72 -
...teTaskRunnerRunPendingTasksConcurrencyTest.java | 179 -
.../indexing/overlord/RemoteTaskRunnerTest.java | 1250 -
.../overlord/RemoteTaskRunnerTestUtils.java | 307 -
.../overlord/SingleTaskBackgroundRunnerTest.java | 6 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 8 +-
.../indexing/overlord/TaskLockConfigTest.java | 3 +-
.../druid/indexing/overlord/TaskQueueTest.java | 5 -
.../indexing/overlord/TaskRunnerUtilsTest.java | 100 +
.../overlord/TestRemoteTaskRunnerConfig.java | 84 -
.../indexing/overlord/TestTaskToolboxFactory.java | 2 +-
.../druid/indexing/overlord/ZkWorkerTest.java | 148 -
.../PendingTaskBasedProvisioningStrategyTest.java | 178 +-
.../SimpleProvisioningStrategyTest.java | 116 +-
.../config/RemoteTaskRunnerConfigTest.java | 880 -
.../duty/KillUnreferencedIndexingStateTest.java | 10 +-
.../overlord/duty/UnusedSegmentsKillerTest.java | 32 +-
.../overlord/hrtr/HttpRemoteTaskRunnerTest.java | 173 +-
.../http/OverlordCompactionResourceTest.java | 10 +-
.../overlord/http/OverlordResourceTest.java | 2 +-
.../druid/indexing/overlord/http/OverlordTest.java | 7 -
.../security/SupervisorResourceFilterTest.java | 9 +-
.../sampler/InputSourceSamplerDiscoveryTest.java | 2 +-
.../overlord/sampler/SamplerResourceTest.java | 2 +-
...butionWithAffinityWorkerSelectStrategyTest.java | 16 +-
...onWithCategorySpecWorkerSelectStrategyTest.java | 10 +-
.../EqualDistributionWorkerSelectStrategyTest.java | 22 +-
...pacityWithAffinityWorkerSelectStrategyTest.java | 16 +-
...tyWithCategorySpecWorkerSelectStrategyTest.java | 10 +-
.../setup/JavaScriptWorkerSelectStrategyTest.java | 19 +-
.../overlord/supervisor/SupervisorManagerTest.java | 589 +-
.../supervisor/SupervisorResourceTest.java | 174 +-
.../SeekableStreamIndexTaskRunnerAuthTest.java | 1 +
.../SeekableStreamIndexTaskRunnerTest.java | 1005 +-
.../SeekableStreamIndexTaskTestBase.java | 6 +-
.../SeekableStreamSamplerSpecTest.java | 7 +
.../seekablestream/StreamChunkReaderTest.java | 125 +
.../SeekableStreamSupervisorIOConfigTest.java | 147 +-
.../SeekableStreamSupervisorSpecTest.java | 377 +-
.../SeekableStreamSupervisorStateTest.java | 528 +-
.../SeekableStreamSupervisorTestBase.java | 98 +-
.../autoscaler/CostBasedAutoScalerConfigTest.java | 120 +-
.../autoscaler/CostBasedAutoScalerMockTest.java | 132 +-
.../autoscaler/CostBasedAutoScalerTest.java | 254 +-
.../autoscaler/LagBasedAutoScalerTest.java | 14 +-
.../autoscaler/WeightedCostFunctionTest.java | 215 +-
.../TestIndexerMetadataStorageCoordinator.java | 4 +-
.../indexing/worker/WorkerTaskManagerTest.java | 19 +-
.../indexing/worker/WorkerTaskMonitorTest.java | 406 -
.../indexing/worker/http/WorkerResourceTest.java | 115 +-
.../server/initialization/IndexerZkConfigTest.java | 278 -
licenses.yaml | 122 +-
multi-stage-query/README.md | 4 +-
multi-stage-query/pom.xml | 2 +-
.../apache/druid/msq/counters/ChannelCounters.java | 13 +-
.../msq/dart/controller/DartControllerContext.java | 21 +-
.../DartControllerContextFactoryImpl.java | 9 +
.../DartTableInputSpecSlicerProvider.java | 55 +
.../msq/dart/controller/sql/DartQueryMaker.java | 9 +-
.../msq/dart/controller/sql/DartSqlEngine.java | 2 +-
.../druid/msq/dart/guice/DartControllerModule.java | 6 +
.../druid/msq/dart/guice/DartWorkerConfig.java | 24 +
.../druid/msq/dart/guice/DartWorkerModule.java | 7 +
.../druid/msq/dart/worker/DartFrameContext.java | 10 +
.../DartSegmentsInputSliceReaderProvider.java | 33 +-
.../druid/msq/dart/worker/DartWorkerContext.java | 61 +-
.../dart/worker/DartWorkerContextFactoryImpl.java | 26 +-
.../java/org/apache/druid/msq/exec/Controller.java | 2 +-
.../apache/druid/msq/exec/ControllerContext.java | 11 +-
.../apache/druid/msq/exec/ControllerHolder.java | 8 +-
.../org/apache/druid/msq/exec/ControllerImpl.java | 106 +-
.../msq/exec/DataServerQueryHandlerUtils.java | 12 +-
.../apache/druid/msq/exec/ExecutionContext.java | 7 +
.../druid/msq/exec/ExecutionContextImpl.java | 9 +
.../org/apache/druid/msq/exec/FrameContext.java | 6 +
.../org/apache/druid/msq/exec/RunWorkOrder.java | 34 +-
.../org/apache/druid/msq/exec/WorkerContext.java | 26 +
.../org/apache/druid/msq/guice/MSQBinders.java | 34 +
.../apache/druid/msq/guice/MSQIndexingModule.java | 13 +
.../msq/indexing/IndexerControllerContext.java | 22 +-
.../druid/msq/indexing/IndexerFrameContext.java | 10 +
.../IndexerSegmentsInputSliceReaderProvider.java | 47 +
.../IndexerTableInputSpecSlicerProvider.java | 73 +
.../druid/msq/indexing/IndexerWorkerContext.java | 49 +-
.../druid/msq/indexing/MSQCompactionRunner.java | 13 +
.../druid/msq/indexing/MSQControllerTask.java | 2 +-
.../destination/DataSourceMSQDestination.java | 51 +-
.../destination/SegmentGenerationUtils.java | 44 +-
.../druid/msq/input/AdaptedLoadableSegment.java | 127 +-
.../druid/msq/input/InputSliceReaderProvider.java | 28 +-
.../druid/msq/input/InputSpecSlicerProvider.java | 49 +-
.../apache/druid/msq/input/LoadableSegment.java | 32 +-
.../druid/msq/input/LoadableSegmentUtils.java | 83 +
.../druid/msq/input/RegularLoadableSegment.java | 39 +-
.../input/external/ExternalInputSliceReader.java | 186 +-
.../druid/msq/input/external/ExternalSegment.java | 52 +-
.../msq/input/inline/InlineInputSliceReader.java | 5 +-
.../msq/input/lookup/LookupInputSliceReader.java | 5 +-
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 29 -
.../druid/msq/querykit/BaseLeafStageProcessor.java | 25 +-
.../druid/msq/querykit/ReadableInputQueue.java | 23 +-
.../druid/msq/querykit/SegmentReferenceHolder.java | 14 -
.../groupby/GroupByPreShuffleStageProcessor.java | 15 +
.../msq/querykit/scan/ScanQueryStageProcessor.java | 17 +
.../apache/druid/msq/rpc/ControllerResource.java | 4 +-
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 42 +-
.../druid/msq/util/MultiStageQueryContext.java | 13 +-
.../dart/controller/DartControllerContextTest.java | 13 +-
.../msq/dart/worker/DartFrameContextTest.java | 1 +
.../DartWorkerContextSegmentLoadAheadTest.java | 79 +
.../druid/msq/exec/ControllerHolderTest.java | 59 +-
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 40 +-
.../org/apache/druid/msq/exec/MSQInsertTest.java | 163 +
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 17 +-
.../apache/druid/msq/exec/TestMSQSqlModule.java | 9 +
.../msq/indexing/IndexerFrameContextTest.java | 1 +
.../msq/indexing/MSQCompactionRunnerTest.java | 72 +-
.../indexing/MSQWorkerTaskLauncherRetryTest.java | 6 +
.../destination/DataSourceMSQDestinationTest.java | 42 +
.../msq/input/RegularLoadableSegmentTest.java | 32 +-
.../input/table/DataSegmentWithLocationTest.java | 42 +-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 2 -
.../druid/msq/sql/MSQTaskQueryMakerTest.java | 9 +-
.../msq/test/AbstractDartComponentSupplier.java | 3 -
.../test/AbstractMSQComponentSupplierDelegate.java | 7 +-
.../druid/msq/test/CalciteMSQTestsHelper.java | 4 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 67 +-
.../druid/msq/test/MSQTestControllerContext.java | 14 +-
.../msq/test/MSQTestOverlordServiceClient.java | 2 +-
.../druid/msq/test/MSQTestWorkerContext.java | 14 +-
.../test/TestDartControllerContextFactoryImpl.java | 16 +-
owasp-dependency-check-suppressions.xml | 4 +-
pom.xml | 75 +-
processing/pom.xml | 7 +-
.../druid/common/asyncresource/AsyncResource.java | 143 +
.../druid/common/asyncresource/AsyncResources.java | 192 +
.../common/asyncresource/CollectAsyncResource.java | 98 +
.../common/asyncresource/RecoverAsyncResource.java | 124 +
.../asyncresource/SettableAsyncResource.java | 335 +
.../asyncresource/TransformAsyncResource.java | 86 +
.../druid/data/input/BytesCountingInputEntity.java | 6 +
.../org/apache/druid/data/input/InputEntity.java | 13 +-
.../apache/druid/data/input/InputFilePointer.java | 27 +-
.../org/apache/druid/data/input/InputSource.java | 10 +
.../druid/data/input/RetryingInputEntity.java | 12 +-
.../input/impl/AdaptedBaseTableProjectionSpec.java | 160 +
.../data/input/impl/BaseTableProjectionSpec.java | 102 +
.../apache/druid/data/input/impl/ByteEntity.java | 2 +-
.../data/input/impl/CloudObjectInputSource.java | 63 +
...lusteredValueGroupsBaseTableProjectionSpec.java | 527 +
.../druid/data/input/impl/DimensionSchema.java | 7 +-
.../apache/druid/data/input/impl/FileEntity.java | 14 +-
.../druid/data/input/impl/LocalInputSource.java | 10 +
.../data/input/impl/StringDimensionSchema.java | 2 +-
.../columnar/ColumnarFrameCursorFactory.java | 3 +-
.../frame/segment/row/RowFrameCursorFactory.java | 3 +-
.../druid/guice/GuiceAnnotationIntrospector.java | 18 +-
.../apache/druid/guice/StartupInjectorBuilder.java | 23 +
.../guice/annotations/EphemeralStorageLoading.java | 7 +-
.../granularity/SegmentGranularitySpec.java | 102 +
.../java/org/apache/druid/io/FilePopulator.java | 29 +-
.../apache/druid/java/util/common/FileUtils.java | 33 +
.../util/common/concurrent/ScheduledExecutors.java | 10 +-
.../java/util/http/client/NettyHttpClient.java | 35 +-
.../http/client/response/HttpResponseHandler.java | 8 +
.../druid/math/expr/ExpressionProcessing.java | 22 +-
.../math/expr/ExpressionProcessingConfig.java | 13 +-
.../java/org/apache/druid/math/expr/Function.java | 1 -
.../SimpleVectorMathBivariateProcessorFactory.java | 55 +
...VectorMathUnivariateDoubleProcessorFactory.java | 29 +-
...SimpleVectorMathUnivariateProcessorFactory.java | 29 +-
.../math/expr/vector/VectorMathProcessors.java | 25 +-
.../expr/vector/simd/SimdDoubleAbsProcessor.java | 57 +
.../vector/simd/SimdDoubleDoubleAddProcessor.java | 93 +
.../vector/simd/SimdDoubleDoubleDivProcessor.java | 95 +
.../vector/simd/SimdDoubleDoubleMulProcessor.java | 93 +
.../vector/simd/SimdDoubleDoubleProcessor.java | 95 +
.../vector/simd/SimdDoubleDoubleSubProcessor.java | 93 +
.../vector/simd/SimdDoubleLongAddProcessor.java | 96 +
.../vector/simd/SimdDoubleLongDivProcessor.java | 96 +
.../vector/simd/SimdDoubleLongMulProcessor.java | 96 +
.../expr/vector/simd/SimdDoubleLongProcessor.java | 98 +
.../vector/simd/SimdDoubleLongSubProcessor.java | 96 +
.../expr/vector/simd/SimdDoubleNegProcessor.java | 57 +
.../expr/vector/simd/SimdDoubleSqrtProcessor.java | 59 +
.../expr/vector/simd/SimdDoubleUnaryProcessor.java | 79 +
.../expr/vector/simd/SimdLongAbsProcessor.java | 57 +
.../vector/simd/SimdLongDoubleAddProcessor.java | 96 +
.../vector/simd/SimdLongDoubleDivProcessor.java | 96 +
.../vector/simd/SimdLongDoubleMulProcessor.java | 96 +
.../expr/vector/simd/SimdLongDoubleProcessor.java | 98 +
.../vector/simd/SimdLongDoubleSubProcessor.java | 96 +
.../expr/vector/simd/SimdLongLongAddProcessor.java | 93 +
.../expr/vector/simd/SimdLongLongMulProcessor.java | 93 +
.../expr/vector/simd/SimdLongLongProcessor.java | 96 +
.../expr/vector/simd/SimdLongLongSubProcessor.java | 93 +
.../expr/vector/simd/SimdLongNegProcessor.java | 57 +
.../vector/simd/SimdLongToDoubleSqrtProcessor.java | 63 +
.../simd/SimdLongToDoubleUnaryProcessor.java | 82 +
.../expr/vector/simd/SimdLongUnaryProcessor.java | 80 +
.../math/expr/vector/simd/SimdProcessors.java | 144 +
.../expr/vector/simd/SimdSupportedBinaryOp.java | 58 +
.../expr/vector/simd/SimdSupportedUnaryOp.java | 17 +-
.../druid/query/ChainedExecutionQueryRunner.java | 4 +-
.../apache/druid/query/DefaultQueryMetrics.java | 1 +
.../java/org/apache/druid/query/DruidMetrics.java | 1 +
.../java/org/apache/druid/query/QueryContext.java | 43 +-
.../java/org/apache/druid/query/QueryContexts.java | 42 +
.../java/org/apache/druid/query/QueryMetrics.java | 11 +-
.../aggregation/DoubleMaxAggregatorFactory.java | 5 +
.../aggregation/DoubleMinAggregatorFactory.java | 5 +
.../aggregation/DoubleSumAggregatorFactory.java | 5 +
.../ExpressionLambdaAggregatorFactory.java | 82 +
.../aggregation/FloatMaxAggregatorFactory.java | 5 +
.../aggregation/FloatMinAggregatorFactory.java | 5 +
.../aggregation/FloatSumAggregatorFactory.java | 5 +
.../aggregation/LongMaxAggregatorFactory.java | 5 +
.../aggregation/LongMinAggregatorFactory.java | 5 +
.../aggregation/LongSumAggregatorFactory.java | 5 +
.../aggregation/NullAwareVectorAggregator.java | 46 +
.../NullableNumericVectorAggregator.java | 13 +-
.../mean/DoubleMeanAggregatorFactory.java | 9 +-
.../query/aggregation/mean/DoubleMeanHolder.java | 6 +
.../simd/SimdDoubleMaxVectorAggregator.java | 97 +
.../simd/SimdDoubleMeanVectorAggregator.java | 114 +
.../simd/SimdDoubleMinVectorAggregator.java | 97 +
.../simd/SimdDoubleSumVectorAggregator.java | 98 +
.../simd/SimdFloatMaxVectorAggregator.java | 97 +
.../simd/SimdFloatMinVectorAggregator.java | 97 +
.../simd/SimdFloatSumVectorAggregator.java | 98 +
.../simd/SimdLongMaxVectorAggregator.java | 97 +
.../simd/SimdLongMinVectorAggregator.java | 97 +
.../simd/SimdLongSumVectorAggregator.java | 98 +
.../druid/query/filter/DruidPredicateMatch.java | 5 +-
.../apache/druid/query/filter/LikeDimFilter.java | 53 +
.../groupby/epinephelinae/SpillOutputStream.java | 127 +
.../groupby/epinephelinae/SpillingGrouper.java | 31 +-
.../druid/query/metadata/SegmentAnalyzer.java | 25 +-
.../SegmentMetadataQueryRunnerFactory.java | 7 +-
.../apache/druid/query/search/SearchStrategy.java | 4 +-
.../query/spec/SpecificSegmentQueryRunner.java | 3 +-
.../apache/druid/segment/AsyncCursorHolder.java | 254 +-
.../apache/druid/segment/ConcatenatingCursor.java | 157 +
.../org/apache/druid/segment/CursorFactory.java | 17 +-
.../druid/segment/DefaultColumnFormatConfig.java | 2 +-
.../segment/DictionaryEncodedColumnMerger.java | 11 +-
.../apache/druid/segment/EmptyCursorHolder.java | 216 +
.../druid/segment/FilteredCursorFactory.java | 9 +
.../druid/segment/IncrementalIndexSegment.java | 5 +-
.../java/org/apache/druid/segment/IndexIO.java | 155 +-
.../org/apache/druid/segment/IndexMergerBase.java | 2 +-
.../org/apache/druid/segment/IndexMergerV10.java | 493 +-
.../org/apache/druid/segment/IndexMergerV9.java | 12 +
.../org/apache/druid/segment/IndexableAdapter.java | 10 +
.../druid/segment/MergingClusterGroupCursor.java | 294 +
.../java/org/apache/druid/segment/Metadata.java | 55 +-
.../druid/segment/NestedDataColumnSchema.java | 11 +-
.../druid/segment/PartialBundleAcquirer.java | 51 +
.../druid/segment/PartialQueryableIndex.java | 710 +-
.../PartialQueryableIndexCursorFactory.java | 482 +
.../segment/PartialQueryableIndexSegment.java | 114 +
...or.java => PhysicalSegmentColumnInspector.java} | 18 +-
.../druid/segment/PhysicalSegmentInspector.java | 35 +-
.../org/apache/druid/segment/QueryableIndex.java | 39 +
.../druid/segment/QueryableIndexCursorFactory.java | 429 +-
.../druid/segment/QueryableIndexCursorHolder.java | 50 +-
.../segment/QueryableIndexIndexableAdapter.java | 22 +
.../QueryableIndexPhysicalSegmentInspector.java | 16 +
.../druid/segment/QueryableIndexSegment.java | 6 +-
.../segment/ReferenceCountedSegmentProvider.java | 28 +-
.../druid/segment/ResidentCursorFactory.java | 39 +-
.../druid/segment/RestrictedCursorFactory.java | 6 +
.../druid/segment/RowBasedCursorFactory.java | 2 +-
.../apache/druid/segment/RowCountInspector.java | 23 +-
.../java/org/apache/druid/segment/Segment.java | 19 +-
.../apache/druid/segment/SimpleQueryableIndex.java | 150 +-
.../druid/segment/SortedDimensionDictionary.java | 10 +
.../druid/segment/StringDimensionHandler.java | 23 +-
.../druid/segment/StringDimensionIndexer.java | 32 +
.../druid/segment/StringDimensionMergerV9.java | 10 +-
.../apache/druid/segment/UnnestCursorFactory.java | 79 +-
.../apache/druid/segment/V10RowCountInspector.java | 41 +-
.../druid/segment/V10TimeBoundaryInspector.java | 82 +
.../segment/column/CapabilitiesBasedFormat.java | 11 +
.../druid/segment/column/ConstantColumns.java | 110 +
.../segment/column/ConstantNumericColumn.java | 151 +
.../StringDictionaryEncodedColumnFormat.java | 150 +
.../druid/segment/data/CompressionStrategy.java | 55 +-
.../druid/segment/data/ConstantColumnarInts.java | 70 +
.../druid/segment/data/ConstantUtf8Indexed.java | 96 +
.../file/PartialSegmentDownloadListener.java | 62 +
.../segment/file/PartialSegmentFileMapperV10.java | 860 +-
.../druid/segment/file/SegmentFileBuilder.java | 20 +-
.../druid/segment/file/SegmentFileBuilderV10.java | 193 +-
.../segment/file/SegmentFileContainerMetadata.java | 58 +-
.../druid/segment/file/SegmentFileMetadata.java | 59 +
.../druid/segment/generator/DataGenerator.java | 26 +-
.../segment/generator/GeneratorBasicSchemas.java | 30 +
...AwareIncrementalIndexColumnSelectorFactory.java | 112 +
.../segment/incremental/IncrementalIndex.java | 7 +-
.../incremental/IncrementalIndexAdapter.java | 22 +
.../incremental/IncrementalIndexCursorFactory.java | 138 +-
.../IncrementalIndexPhysicalSegmentInspector.java | 1 +
.../incremental/IncrementalIndexSchema.java | 46 +-
.../incremental/NoopRowIngestionMeters.java | 5 +-
.../segment/incremental/OnHeapClusterGroup.java | 368 +
.../incremental/OnHeapClusteredBaseTable.java | 491 +
.../incremental/OnheapIncrementalIndex.java | 82 +-
.../segment/index/IndexedUtf8ValueIndexes.java | 1 -
.../segment/join/HashJoinSegmentCursorFactory.java | 338 +-
.../loading/DirectoryBackedRangeReader.java | 54 +
.../loading/PartialClusterGroupLoadSpec.java | 77 +-
.../druid/segment/loading/PartialLoadSpec.java | 16 +
.../segment/loading/PartialProjectionLoadSpec.java | 42 +
.../loading/TombstoneSegmentizerFactory.java | 3 +-
.../segment/nested/NestedDataComplexTypeSerde.java | 2 +-
.../segment/projections/ClusterGroupQueryPlan.java | 159 +
.../ClusteredValueGroupsBaseTableSchema.java | 411 +
.../ClusteringColumnSelectorFactory.java | 689 +
.../projections/ClusteringDictionaries.java | 180 +
.../ClusteringVectorColumnSelectorFactory.java | 490 +
.../projections/MergingColumnSelectorFactory.java | 461 +
.../segment/projections/ProjectionSchema.java | 3 +-
.../druid/segment/projections/Projections.java | 479 +-
.../segment/projections/QueryableProjection.java | 11 +
.../projections/RollupTableProjectionSchema.java | 3 +-
.../segment/projections/TableClusterGroupSpec.java | 176 +
.../segment/projections/TableProjectionSchema.java | 3 +-
.../serde/DictionaryEncodedColumnPartSerde.java | 36 +-
.../druid/segment/transform/Transformer.java | 40 +-
.../transform/TransformingInputEntityReader.java | 27 +-
.../segment/vector/ConcatenatingVectorCursor.java | 166 +
.../org/apache/druid/timeline/CompactionState.java | 65 +-
.../org/apache/druid/timeline/DataSegment.java | 42 +-
.../partition/DimensionValueSetShardSpec.java | 164 +
.../apache/druid/timeline/partition/ShardSpec.java | 2 +
.../resources/loggingEmitterAllowedMetrics.json | 3 +-
.../apache/druid/collections/BlockingPoolTest.java | 146 +-
.../common/asyncresource/AsyncResourcesTest.java | 177 +
.../asyncresource/CollectAsyncResourceTest.java | 131 +
.../asyncresource/RecoverAsyncResourceTest.java | 184 +
.../asyncresource/SettableAsyncResourceTest.java | 276 +
.../asyncresource/TransformAsyncResourceTest.java | 156 +
.../druid/common/guava/CombiningSequenceTest.java | 45 +-
.../druid/data/input/ResourceInputSource.java | 9 +-
.../input/impl/CloudObjectInputSourceTest.java | 129 +-
...eredValueGroupsBaseTableProjectionSpecTest.java | 352 +
.../druid/data/input/impl/DimensionSchemaTest.java | 47 +
.../druid/data/input/impl/FileEntityTest.java | 125 +
.../data/input/impl/RetryingInputStreamTest.java | 50 +-
.../frame/field/DoubleArrayFieldReaderTest.java | 63 +-
.../druid/frame/field/DoubleFieldReaderTest.java | 124 +-
.../frame/field/FloatArrayFieldReaderTest.java | 62 +-
.../druid/frame/field/FloatFieldReaderTest.java | 124 +-
.../druid/frame/field/TransformUtilsTest.java | 50 +-
.../druid/guice/StartupInjectorBuilderTest.java | 28 +
.../granularity/UniformGranularityTest.java | 79 +-
.../java/util/common/CompressionUtilsTest.java | 41 +-
.../druid/java/util/common/FileUtilsTest.java | 55 +
.../common/MemoryBoundLinkedBlockingQueueTest.java | 98 +-
.../common/concurrent/ScheduledExecutorsTest.java | 92 +-
.../java/util/common/guava/ConcatSequenceTest.java | 24 +-
.../java/util/common/guava/MergeSequenceTest.java | 121 +-
.../java/util/common/lifecycle/LifecycleTest.java | 40 +-
.../common/parsers/FlatTextFormatParserTest.java | 114 +-
.../java/util/metrics/StubServiceEmitter.java | 6 +-
.../math/expr/VectorExprResultConsistencyTest.java | 37 +-
.../VectorExprResultConsistencyVectorApiTest.java | 33 +-
.../org/apache/druid/query/DataSourceTest.java | 54 +-
.../apache/druid/query/InlineDataSourceTest.java | 104 +-
.../org/apache/druid/query/QueryContextTest.java | 72 +
.../org/apache/druid/query/QueryContextsTest.java | 135 +-
.../apache/druid/query/TimewarpOperatorTest.java | 24 +-
.../query/aggregation/AggregationTestHelper.java | 2 +-
.../query/aggregation/AggregatorFactoryTest.java | 24 +-
.../ExpressionLambdaAggregationTest.java | 215 +
.../ExpressionLambdaAggregatorFactoryTest.java | 304 +
.../CardinalityVectorAggregatorTest.java | 16 +-
.../first/DoubleFirstVectorAggregatorTest.java | 34 +-
.../first/FloatFirstVectorAggregatorTest.java | 44 +-
.../first/LongFirstVectorAggregatorTest.java | 38 +-
.../last/DoubleLastVectorAggregatorTest.java | 34 +-
.../last/FloatLastVectorAggregatorTest.java | 38 +-
.../mean/DoubleMeanAggregationTest.java | 59 +-
.../simd/SimdAggregatorTestHelpers.java | 191 +
.../simd/SimdDoubleMeanVectorAggregatorTest.java | 136 +
.../simd/SimdMinMaxVectorAggregatorTest.java | 319 +
.../simd/SimdSumVectorAggregatorTest.java | 260 +
.../druid/query/cache/CacheKeyBuilderTest.java | 24 +-
.../query/extraction/FunctionalExtractionTest.java | 57 +-
.../druid/query/filter/LikeDimFilterTest.java | 131 +
...ctorValueMatcherColumnProcessorFactoryTest.java | 108 +-
.../query/groupby/GroupByQueryRunnerTest.java | 41 +-
.../druid/query/groupby/GroupByQueryTest.java | 42 +-
.../groupby/GroupByTimeseriesQueryRunnerTest.java | 18 +-
.../epinephelinae/SpillOutputStreamTest.java | 272 +
.../groupby/epinephelinae/SpillingGrouperTest.java | 60 +-
.../druid/query/metadata/SegmentAnalyzerTest.java | 77 +
.../metadata/metadata/ColumnAnalysisTest.java | 36 +-
.../search/SearchQueryRunnerWithCaseTest.java | 53 +-
.../query/spec/SpecificSegmentQueryRunnerTest.java | 99 +-
.../timeseries/TimeseriesQueryRunnerTest.java | 34 +-
.../topn/TopNMetricSpecOptimizationsTest.java | 24 +-
.../org/apache/druid/query/topn/TopNQueryTest.java | 169 +-
.../ClusteredSegmentTimeOrderedQueryTest.java | 557 +
.../druid/segment/ConcatenatingCursorTest.java | 487 +
.../apache/druid/segment/CursorBuildSpecTest.java | 50 +-
.../druid/segment/DeferredCursorFactory.java} | 52 +-
.../java/org/apache/druid/segment/IndexIOTest.java | 47 +-
.../apache/druid/segment/IndexMergerTestBase.java | 9 +-
.../druid/segment/IndexMergerV10ClusteredTest.java | 697 +
.../segment/IndexMergerV10MinMaxTimeTest.java | 64 +
.../segment/MergingClusterGroupCursorTest.java | 349 +
.../org/apache/druid/segment/MetadataTest.java | 25 +-
.../druid/segment/NestedDataColumnSchemaTest.java | 2 +-
...eIndexCursorFactoryClusteredProjectionTest.java | 227 +
...alQueryableIndexCursorFactoryClusteredTest.java | 466 +
.../PartialQueryableIndexCursorFactoryTest.java | 1149 +
...PartialQueryableIndexCursorFactoryTestBase.java | 126 +
.../segment/PartialQueryableIndexSegmentTest.java | 276 +
.../druid/segment/PartialQueryableIndexTest.java | 499 +-
.../segment/PhysicalSegmentInspectorTest.java | 63 +
.../QueryableIndexCursorFactoryClusteredTest.java | 1125 +
.../segment/QueryableIndexCursorFactoryTest.java | 138 +-
.../segment/SimpleQueryableIndexClusteredTest.java | 193 +
.../druid/segment/StringDimensionIndexerTest.java | 23 +
.../org/apache/druid/segment/TestSegmentUtils.java | 4 +-
.../druid/segment/UnnestCursorFactoryTest.java | 58 +-
.../segment/V10TimeBoundaryInspectorTest.java | 109 +
.../segment/column/ConstantNumericColumnTest.java | 74 +
.../StringDictionaryEncodedColumnFormatTest.java | 98 +
.../data/CompressedColumnarIntsSerializerTest.java | 136 +-
.../segment/data/ConstantUtf8IndexedTest.java | 73 +
.../data/NumericNullColumnSelectorTest.java | 32 +-
.../druid/segment/file/CountingRangeReader.java | 88 +
.../file/PartialSegmentFileMapperV10Test.java | 899 +-
.../segment/file/SegmentFileBuilderV10Test.java | 396 +-
.../file/SegmentFileContainerMetadataTest.java | 37 +-
.../file/SegmentFileMetadataColumnFilesTest.java | 307 +
.../druid/segment/filter/BaseFilterTest.java | 84 +-
.../segment/filter/ExtractionDimFilterTest.java | 56 +-
.../druid/segment/generator/SegmentGenerator.java | 163 +
.../IncrementalIndexClusteredProjectionTest.java | 211 +
...IncrementalIndexCursorFactoryClusteredTest.java | 521 +
.../incremental/OnHeapClusteredBaseTableTest.java | 610 +
.../join/HashJoinSegmentCursorFactoryTest.java | 75 +
.../segment/join/JoinConditionAnalysisTest.java | 160 +-
.../segment/join/lookup/LookupJoinableTest.java | 58 +-
.../table/BroadcastSegmentIndexedTableTest.java | 6 +-
.../loading/PartialClusterGroupLoadSpecTest.java | 217 +-
.../loading/PartialProjectionLoadSpecTest.java | 99 +
.../nested/ScalarDoubleColumnSupplierTest.java | 84 +-
.../nested/ScalarLongColumnSupplierTest.java | 84 +-
.../nested/ScalarStringColumnSupplierTest.java | 94 +-
.../projections/ClusterGroupSchemaTestHelpers.java | 187 +
.../ClusteredValueGroupsBaseTableSchemaTest.java | 445 +
.../ClusteringColumnSelectorFactoryTest.java | 560 +
.../ClusteringVectorColumnSelectorFactoryTest.java | 530 +
.../MergingColumnSelectorFactoryTest.java | 274 +
.../druid/segment/projections/NoRewriteFilter.java | 62 +
.../ProjectionsPlanClusterGroupQueryTest.java | 1225 +
.../druid/segment/projections/ProjectionsTest.java | 84 +
.../projections/TableClusterGroupSpecTest.java | 320 +
.../DictionaryEncodedColumnPartSerdeTest.java | 26 +
.../druid/segment/transform/TransformerTest.java | 91 +
.../vector/ConcatenatingVectorCursorTest.java | 550 +
...ryableIndexVectorColumnSelectorFactoryTest.java | 85 +-
.../ListFilteredVirtualColumnSelectorTest.java | 38 +-
.../apache/druid/timeline/CompactionStateTest.java | 143 +
.../org/apache/druid/timeline/DataSegmentTest.java | 186 +-
.../partition/DimensionValueSetShardSpecTest.java | 313 +
.../timeline/partition/NumberedShardSpecTest.java | 60 +-
.../resources/loggingEmitterAllowedMetrics.json | 1 +
quidem-ut/pom.xml | 2 +-
server/pom.xml | 6 +-
.../ClusteredValueGroupsBaseTableMetadata.java | 178 +
.../catalog/model/DatasourceBaseTableMetadata.java | 65 +
.../catalog/model/facade/DatasourceFacade.java | 80 +-
.../druid/catalog/model/table/DatasourceDefn.java | 47 +-
.../druid/catalog/model/table/TableBuilder.java | 6 +
.../druid/client/CachingClusteredClient.java | 18 +-
.../druid/client/DataSegmentAndLoadProfile.java | 1 +
.../apache/druid/client/DataSourcesSnapshot.java | 79 +
.../org/apache/druid/client/DirectDruidClient.java | 43 +-
.../druid/client/HttpServerInventoryView.java | 25 +-
.../druid/client/ImmutableDruidDataSource.java | 6 +
.../indexing/ClientCompactionRunnerInfo.java | 15 +-
.../client/indexing/ClientCompactionTaskQuery.java | 16 +
.../curator/discovery/CuratorServiceAnnouncer.java | 121 -
.../curator/discovery/CuratorServiceUtils.java | 47 -
.../druid/curator/discovery/DiscoveryModule.java | 443 +-
.../curator/discovery/ServerDiscoveryFactory.java | 91 -
.../curator/discovery/ServerDiscoverySelector.java | 146 -
.../druid/curator/discovery/ServiceAnnouncer.java | 52 -
.../org/apache/druid/guice/AnnouncerModule.java | 13 -
.../java/org/apache/druid/guice/DruidBinders.java | 6 -
.../druid/guice/LocalDataStorageDruidModule.java | 4 -
.../org/apache/druid/guice/StorageNodeModule.java | 36 +-
.../IndexerMetadataStorageCoordinator.java | 23 +-
.../overlord/supervisor/SupervisorSpec.java | 11 +
.../supervisor/SupervisorSpecUpdateAction.java} | 21 +-
.../autoscaler/SupervisorTaskAutoScaler.java | 24 +-
.../IndexerSQLMetadataStorageCoordinator.java | 29 +-
.../druid/metadata/SQLMetadataConnector.java | 79 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 69 +-
.../org/apache/druid/metadata/input/SqlEntity.java | 2 +-
.../cache/HeapMemoryDatasourceSegmentCache.java | 50 +
.../cache/HeapMemorySegmentMetadataCache.java | 84 +-
.../druid/rpc/indexing/NoopOverlordClient.java | 6 +
.../apache/druid/rpc/indexing/OverlordClient.java | 9 +
.../druid/rpc/indexing/OverlordClientImpl.java | 17 +
.../druid/segment/indexing/CombinedDataSchema.java | 32 +
.../apache/druid/segment/indexing/DataSchema.java | 288 +-
.../apache/druid/segment/loading/AcquireMode.java | 46 +
.../druid/segment/loading/LocalLoadSpec.java | 16 +
.../loading/PartialSegmentBundleCacheEntry.java | 662 +
... PartialSegmentBundleCacheEntryIdentifier.java} | 38 +-
.../loading/PartialSegmentCacheBootstrap.java | 352 +
.../loading/PartialSegmentMetadataCacheEntry.java | 1573 +
.../loading/PermitLimitedSegmentRangeReader.java | 86 +
.../druid/segment/loading/ResizableCacheEntry.java | 39 +
.../druid/segment/loading/SegmentCacheEntry.java | 100 +
.../loading/SegmentCacheEntryIdentifier.java | 29 +-
.../druid/segment/loading/SegmentCacheManager.java | 74 +-
.../druid/segment/loading/SegmentLoaderConfig.java | 143 +-
.../segment/loading/SegmentLocalCacheManager.java | 1346 +-
.../segment/loading/StorageLoadingThreadPool.java | 232 +
.../druid/segment/loading/StorageLocation.java | 174 +
.../segment/loading/StorageLocationStats.java | 14 +
.../apache/druid/segment/loading/StorageStats.java | 64 -
.../segment/loading/VirtualPlaceholderSegment.java | 15 +-
.../loading/VirtualStorageLocationStats.java | 40 +
.../druid/segment/loading/external/CachedFile.java | 87 +
.../loading/external/DownloadableCacheEntry.java | 314 +
.../StorageLocationVirtualStorageManager.java | 282 +
.../external/StringCacheEntryIdentifier.java} | 20 +-
.../loading/external/VirtualStorageManager.java | 97 +
.../metadata/AbstractSegmentMetadataCache.java | 50 +-
.../org/apache/druid/segment/metadata/Metric.java | 1 +
.../apache/druid/segment/realtime/ChatHandler.java | 2 +-
.../segment/realtime/ChatHandlerProvider.java | 64 +-
.../apache/druid/segment/realtime/FireHydrant.java | 4 +-
.../ServiceAnnouncingChatHandlerProvider.java | 132 -
.../appenderator/BaseAppenderatorDriver.java | 15 +-
.../realtime/appenderator/BatchAppenderator.java | 11 +-
.../appenderator/SegmentsAndCommitMetadata.java | 28 +
.../appenderator/SinkQuerySegmentWalker.java | 81 +-
.../realtime/appenderator/StreamAppenderator.java | 60 +-
.../appenderator/StreamAppenderatorDriver.java | 12 +-
.../apache/druid/segment/realtime/sink/Sink.java | 1 +
.../java/org/apache/druid/server/DruidNode.java | 7 +-
.../apache/druid/server/QueryLaningStrategy.java | 4 +-
.../org/apache/druid/server/QueryScheduler.java | 10 +-
.../org/apache/druid/server/SegmentManager.java | 83 +-
.../org/apache/druid/server/ServerManager.java | 11 +-
.../druid/server/compaction/CompactionStatus.java | 58 +-
.../compaction/ReindexingDataSchemaRule.java | 22 +-
.../coordination/SegmentCacheBootstrapper.java | 8 +-
.../coordination/SegmentChangeRequestLoad.java | 30 +-
.../coordination/SegmentLoadDropHandler.java | 10 +-
.../CatalogDataSourceCompactionConfig.java | 9 +
.../coordinator/CoordinatorDynamicConfig.java | 45 +
.../coordinator/DataSourceCompactionConfig.java | 28 +-
.../druid/server/coordinator/DruidCluster.java | 2 +-
.../druid/server/coordinator/DruidCoordinator.java | 62 +-
.../InlineSchemaDataSourceCompactionConfig.java | 28 +-
.../coordinator/balancer/CostBalancerStrategy.java | 20 +-
.../DiskNormalizedCostBalancerStrategy.java | 127 +-
.../DiskNormalizedCostBalancerStrategyConfig.java | 32 +-
.../DiskNormalizedCostBalancerStrategyFactory.java | 2 +-
.../server/coordinator/duty/CompactSegments.java | 4 +
.../duty/MarkEternityTombstonesAsUnused.java | 94 +-
.../duty/MarkOvershadowedSegmentsAsUnused.java | 32 +-
.../duty/PrepareBalancerAndLoadQueues.java | 28 +-
.../druid/server/coordinator/duty/RunRules.java | 1 +
.../coordinator/loading/PartialLoadProfile.java | 43 +-
.../server/coordinator/loading/SegmentHolder.java | 13 +-
.../coordinator/loading/SegmentLoadingConfig.java | 20 +-
.../coordinator/loading/SegmentReplicaCount.java | 10 +
.../loading/SegmentReplicationStatus.java | 89 +-
.../coordinator/loading/SegmentStatsSnapshot.java | 78 +
.../loading/StrategicSegmentAssigner.java | 24 +-
.../rules/ClusterGroupPartialLoadMatcher.java | 35 +-
.../coordinator/rules/PartialLoadMatcher.java | 14 +
.../WildcardClusterGroupPartialLoadMatcher.java | 19 +-
.../druid/server/coordinator/stats/Dimension.java | 1 +
.../initialization/AuthorizerMapperModule.java | 26 +-
.../druid/server/initialization/ServerConfig.java | 12 +
.../jetty/CliIndexerServerModule.java | 8 +-
.../server/initialization/jetty/JettyBindings.java | 41 +-
.../jetty/PathExcludingQoSFilter.java | 82 +
.../druid/server/metrics/StorageMonitor.java | 76 +-
.../scheduling/ManualQueryLaningStrategy.java | 2 +-
.../scheduling/WeightedQueryLaningStrategy.java | 393 +
.../apache/druid/server/security/AuthConfig.java | 29 +-
.../druid/server/security/AuthorizationUtils.java | 79 +-
.../druid/server/security/AuthorizerMapper.java | 22 +-
.../ClusteredValueGroupsBaseTableMetadataTest.java | 341 +
.../catalog/model/table/DatasourceTableTest.java | 143 +
.../druid/client/CachingClusteredClientTest.java | 83 +-
.../druid/client/DataSourcesSnapshotTest.java | 125 +
.../client/DirectDruidClientAbortHttpTest.java | 184 +
.../druid/client/DruidServerPartialLoadTest.java | 9 +-
.../org/apache/druid/client/TestHttpClient.java | 15 +-
.../druid/client/cache/CaffeineCacheTest.java | 25 +-
.../indexing/ClientCompactionRunnerInfoTest.java | 104 +
.../discovery/LatchableServiceAnnouncer.java | 64 -
.../discovery/ServerDiscoverySelectorTest.java | 237 -
.../curator/discovery/ServiceAnnouncerTest.java | 105 -
.../apache/druid/guice/StorageNodeModuleTest.java | 22 +
.../IndexerSQLMetadataStorageCoordinatorTest.java | 213 +-
.../druid/metadata/SQLMetadataConnectorTest.java | 24 +-
.../metadata/SqlSegmentsMetadataQueryTest.java | 28 +-
.../cache/HeapMemorySegmentMetadataCacheTest.java | 30 +
.../apache/druid/query/EmittingQueryMetrics.java | 134 +
.../timeseries/EmittingTimeseriesQueryMetrics.java | 79 +
.../org/apache/druid/rpc/MockServiceClient.java | 3 +-
.../druid/segment/indexing/DataSchemaTest.java | 299 +-
.../segment/indexing/TestModifiedDataSchema.java | 2 +
.../segment/loading/NoopSegmentCacheManager.java | 22 +-
...tialSegmentBundleCacheEntryIdentifierTest.java} | 47 +-
.../PartialSegmentBundleCacheEntryTest.java | 951 +
.../loading/PartialSegmentCacheBootstrapTest.java | 568 +
.../PartialSegmentMetadataCacheEntryTest.java | 689 +
.../PermitLimitedSegmentRangeReaderTest.java | 88 +
.../segment/loading/SegmentLoaderConfigTest.java | 76 +-
.../SegmentLocalCacheManagerConcurrencyTest.java | 14 +-
...SegmentLocalCacheManagerPartialAcquireTest.java | 939 +
.../SegmentLocalCacheManagerPartialDropTest.java | 317 +
...egmentLocalCacheManagerPartialRuleLoadTest.java | 819 +
.../loading/SegmentLocalCacheManagerTest.java | 71 +-
.../loading/StorageLoadingThreadPoolTest.java | 147 +
.../druid/segment/loading/StorageLocationTest.java | 265 +
.../external/DownloadableCacheEntryTest.java | 225 +
.../StorageLocationVirtualStorageManagerTest.java | 1037 +
.../CoordinatorSegmentMetadataCacheTest.java | 125 +-
.../segment/metadata/IndexingStateCacheTest.java | 29 +-
.../metadata/SqlIndexingStateStorageTest.java | 126 +-
.../segment/realtime/ChatHandlerProviderTest.java | 64 +
.../ServiceAnnouncingChatHandlerProviderTest.java | 140 -
.../appenderator/BatchAppenderatorTest.java | 68 +
.../appenderator/BatchAppenderatorTester.java | 64 +-
.../appenderator/SegmentPublisherHelperTest.java | 19 +
.../appenderator/StreamAppenderatorDriverTest.java | 42 +
.../appenderator/StreamAppenderatorTest.java | 145 +-
.../appenderator/StreamAppenderatorTester.java | 11 +-
.../druid/segment/realtime/sink/SinkTest.java | 89 +
.../apache/druid/server/QuerySchedulerTest.java | 100 +
.../apache/druid/server/SegmentManagerTest.java | 6 +-
.../compaction/CompactionSlotManagerTest.java | 1 +
.../server/compaction/CompactionStatusTest.java | 228 +-
.../ComposingReindexingRuleProviderTest.java | 1 +
.../InlineReindexingRuleProviderTest.java | 1 +
.../compaction/NewestSegmentFirstPolicyTest.java | 414 +-
.../compaction/ReindexingDataSchemaRuleTest.java | 82 +
.../coordination/LoadableDataSegmentTest.java | 42 +-
.../SegmentCacheBootstrapperCacheTest.java | 3 +
.../coordination/SegmentChangeRequestLoadTest.java | 41 +-
.../coordination/SegmentLoadDropHandlerTest.java | 13 +-
...egmentManagerBroadcastJoinIndexedTableTest.java | 2 +
.../SegmentManagerThreadSafetyTest.java | 8 +-
.../server/coordination/ServerManagerTest.java | 27 +-
.../server/coordinator/DruidCoordinatorTest.java | 23 -
...InlineSchemaDataSourceCompactionConfigTest.java | 32 +
.../DiskNormalizedCostBalancerStrategyTest.java | 210 +-
.../coordinator/duty/CompactSegmentsTest.java | 129 +-
.../duty/RunRulesPartialLoadPlacementTest.java | 285 +
.../loading/PartialLoadProfileTest.java | 20 +-
.../loading/SegmentReplicationStatusTest.java | 187 +
.../StrategicSegmentAssignerPartialTest.java | 15 +-
.../server/coordinator/rules/LoadRuleTest.java | 42 +
...WildcardClusterGroupPartialLoadMatcherTest.java | 166 +-
.../simulate/CoordinatorSimulationBuilder.java | 3 -
.../simulate/HistoricalTierAliasTest.java | 138 +
.../simulate/TestSegmentLoadingHttpClient.java | 8 +-
.../server/http/CoordinatorDynamicConfigTest.java | 46 +-
.../druid/server/http/DataSegmentPlusTest.java | 43 +-
.../druid/server/http/DataSourcesResourceTest.java | 10 +-
.../druid/server/http/IntervalsResourceTest.java | 8 +-
.../http/security/ResourceFilterTestHelper.java | 3 +-
.../initialization/AuthorizerMapperModuleTest.java | 52 +-
.../server/initialization/JettyCertRenewTest.java | 9 +-
.../jetty/PathExcludingQoSFilterTest.java | 154 +
.../druid/server/metrics/LatchableEmitter.java | 60 +-
.../WeightedQueryLaningStrategyTest.java | 487 +
.../druid/server/security/AuthConfigTest.java | 14 +
.../server/security/AuthorizationUtilsTest.java | 211 +
.../druid/test/utils/TestSegmentCacheManager.java | 11 +-
.../druid/test/utils/TestSegmentManager.java | 3 +-
services/pom.xml | 2 +-
.../main/java/org/apache/druid/cli/CliBroker.java | 2 +-
.../java/org/apache/druid/cli/CliCoordinator.java | 20 +
.../main/java/org/apache/druid/cli/CliIndexer.java | 5 +-
.../org/apache/druid/cli/CliMiddleManager.java | 28 +-
.../java/org/apache/druid/cli/CliOverlord.java | 41 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 21 +-
.../main/java/org/apache/druid/cli/CliRouter.java | 3 -
.../java/org/apache/druid/cli/ServerRunnable.java | 28 +-
.../druid/server/AsyncQueryForwardingServlet.java | 103 +-
.../org/apache/druid/cli/CliCoordinatorTest.java | 121 +
.../java/org/apache/druid/cli/CliOverlordTest.java | 23 +-
.../java/org/apache/druid/cli/CliPeonTest.java | 2 +-
.../cli/DiscoverySideEffectsProviderTest.java | 6 +-
.../server/AsyncQueryForwardingServletTest.java | 57 +-
.../testing/embedded/EmbeddedClusterApis.java | 10 +
sql/pom.xml | 2 +-
.../java/org/apache/druid/sql/DirectStatement.java | 11 +-
.../org/apache/druid/sql/PreparedStatement.java | 16 +-
.../org/apache/druid/sql/SqlStatementFactory.java | 15 +-
.../druid/sql/avatica/DruidAvaticaJsonHandler.java | 6 +
.../sql/avatica/DruidAvaticaProtobufHandler.java | 72 +-
.../apache/druid/sql/avatica/DruidConnection.java | 6 +-
.../sql/avatica/DruidJdbcPreparedStatement.java | 5 +-
.../druid/sql/avatica/DruidJdbcStatement.java | 11 +-
.../org/apache/druid/sql/avatica/DruidMeta.java | 25 +-
.../sql/calcite/planner/DruidSqlValidator.java | 13 +-
.../sql/calcite/schema/MetadataSegmentView.java | 22 +-
.../druid/sql/calcite/schema/SystemSchema.java | 34 +-
.../sql/calcite/schema/SystemSchemaFilters.java | 184 +
.../schema/SystemServerPropertiesTable.java | 61 +-
.../org/apache/druid/sql/SqlStatementTest.java | 12 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 89 +
.../sql/avatica/DruidAvaticaJsonHandlerTest.java | 10 +-
.../avatica/DruidAvaticaProtobufHandlerTest.java | 18 +-
.../druid/sql/avatica/DruidStatementTest.java | 34 +-
.../calcite/CalciteCatalogIngestionDmlTest.java | 187 +-
...lVectorizedExpressionResultConsistencyTest.java | 4 +-
.../calcite/schema/SystemSchemaFiltersTest.java | 274 +
.../druid/sql/calcite/schema/SystemSchemaTest.java | 145 +-
.../sql/calcite/util/QueryFrameworkUtils.java | 6 +-
.../druid/sql/calcite/util/SqlTestFramework.java | 3 +-
web-console/package-lock.json | 4 +-
web-console/package.json | 2 +-
web-console/pom.xml | 2 +-
.../fancy-numeric-input/fancy-numeric-input.tsx | 10 +-
.../__snapshots__/header-bar.spec.tsx.snap | 5 +
.../src/components/header-bar/header-bar.tsx | 12 +-
.../__snapshots__/about-dialog.spec.tsx.snap | 1 +
.../src/dialogs/about-dialog/about-dialog.tsx | 7 +-
.../query-context-completions.ts | 12 +-
web-console/src/dialogs/index.ts | 2 +
.../supervisor-reset-to-latest-dialog.tsx | 84 +
.../supervisor-to-sql-dialog.scss | 44 +
.../supervisor-to-sql-dialog.spec.tsx | 109 +
.../supervisor-to-sql-dialog.tsx | 312 +
.../compaction-status/compaction-status.ts | 2 +-
.../supervisor-status/supervisor-status.ts | 12 +
.../src/helpers/supervisor-conversion.spec.ts | 369 +
web-console/src/helpers/supervisor-conversion.ts | 106 +
.../src/utils/query-manager/query-manager.spec.ts | 370 +
.../src/utils/query-manager/query-manager.ts | 22 +-
.../home-view/services-card/services-card.tsx | 26 +-
.../src/views/load-data-view/load-data-view.tsx | 1 +
.../src/views/services-view/services-view.tsx | 2 +-
.../schema-step/schema-step.tsx | 1 +
.../__snapshots__/supervisors-view.spec.tsx.snap | 58 +-
.../views/supervisors-view/supervisors-view.tsx | 129 +-
.../views/workbench-view/run-panel/run-panel.tsx | 1 +
.../src/views/workbench-view/workbench-view.tsx | 38 +-
web-console/unified-console.html | 2 +-
web-console/webpack.config.mjs | 13 +-
website/.spelling | 11 +-
website/docusaurus.config.js | 11 +-
website/package-lock.json | 50387 +++++++------------
website/package.json | 26 +-
1307 files changed, 104307 insertions(+), 49944 deletions(-)
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/DoubleMeanVectorAggregatorBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/query/SqlClusteredSegmentsBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/server/coordinator/ComputePlacementCostBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/server/coordinator/MarkOvershadowedSegmentsAsUnusedBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/sql/calcite/schema/SysSegmentsTableBenchmark.java
delete mode 100644 dev/intellij-sdk-config.jpg
create mode 100644 dev/intellij-sdk-config.png
create mode 100644 docs/development/extensions-contrib/openlineage-emitter.md
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/consul/ConsulClusterResourceTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/deltalake/DeltaLakeInputSourceIngestionTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/EmbeddedMSQParquetIngestionTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/S3ExternQueryTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/query/ClusteredSegmentProjectionQueryTest.java
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/query/PartialProjectionLoadRuleQueryTest.java
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/.part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/.part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/_delta_log/.00000000000000000000.json.crc
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/_delta_log/00000000000000000000.json
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet
create mode 100644
embedded-tests/src/test/resources/delta/large-row-group-table/part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/LargeRowGroupDeltaTable.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/.part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/.part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/_delta_log/.00000000000000000000.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/_delta_log/00000000000000000000.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/large-row-group-table/part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet
copy extensions-contrib/{consul-extensions => openlineage-emitter}/pom.xml
(73%)
create mode 100644
extensions-contrib/openlineage-emitter/src/main/java/org/apache/druid/extensions/openlineage/OpenLineageRequestLogger.java
rename
services/src/main/java/org/apache/druid/cli/convert/ChatHandlerConverter.java
=>
extensions-contrib/openlineage-emitter/src/main/java/org/apache/druid/extensions/openlineage/OpenLineageRequestLoggerModule.java
(57%)
create mode 100644
extensions-contrib/openlineage-emitter/src/main/java/org/apache/druid/extensions/openlineage/OpenLineageRequestLoggerProvider.java
create mode 100644
extensions-contrib/openlineage-emitter/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-contrib/openlineage-emitter/src/main/resources/openlineage-schema/DruidQueryContextRunFacet.json
create mode 100644
extensions-contrib/openlineage-emitter/src/main/resources/openlineage-schema/DruidQueryStatisticsRunFacet.json
create mode 100644
extensions-contrib/openlineage-emitter/src/test/java/org/apache/druid/extensions/openlineage/OpenLineageRequestLoggerTest.java
copy
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaIOConfigBuilder.java
=>
extensions-contrib/rabbit-stream-indexing-service/src/main/java/org/apache/druid/indexing/rabbitstream/supervisor/RabbitStreamIOConfigBuilder.java
(52%)
create mode 100644
extensions-core/datasketches/src/test/java/org/apache/druid/query/aggregation/datasketches/hll/HllSketchHolderTest.java
rename extensions-core/kafka-indexing-service/src/{test =>
main}/java/org/apache/druid/indexing/kafka/supervisor/KafkaIOConfigBuilder.java
(68%)
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/simulate/EmbeddedDimensionValueSetShardSpecTest.java
create mode 100644
extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/supervisor/KinesisIOConfigBuilder.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/AutoscalableThreadPoolExecutor.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunner.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerConfig.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerDelegate.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerFactory.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/execution/KubernetesTaskRunnerPodTemplateResource.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/AutoscalableThreadPoolExecutorTest.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerConfigTest.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerFactoryTest.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/MultipleKubernetesTaskRunnerTest.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/execution/KubernetesTaskRunnerPodTemplateResourceTest.java
create mode 100644
extensions-core/s3-extensions/src/main/java/org/apache/druid/storage/s3/S3SegmentRangeReader.java
create mode 100644
extensions-core/s3-extensions/src/test/java/org/apache/druid/storage/s3/S3LoadSpecTest.java
create mode 100644
extensions-core/s3-extensions/src/test/java/org/apache/druid/storage/s3/S3SegmentRangeReaderTest.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/SegmentUpgradeMetrics.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunner.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerFactory.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/ZkWorker.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/config/RemoteTaskRunnerConfig.java
copy
server/src/main/java/org/apache/druid/segment/realtime/NoopChatHandlerProvider.java
=>
indexing-service/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorSpecUpdateResult.java
(53%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/DimensionValueSetCollector.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/DimensionValueSetPartitionsSpec.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/StreamingPartitionsSpec.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/StreamingShardSpecCollector.java
rename indexing-service/src/{test =>
main}/java/org/apache/druid/indexing/seekablestream/supervisor/SupervisorIOConfigBuilder.java
(53%)
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerCuratorCoordinator.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/worker/WorkerTaskMonitor.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/server/initialization/IndexerZkConfig.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/SegmentCacheManagerFactoryTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/actions/SegmentTransactionalReplaceActionTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/OverlordBlinkLeadershipTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerFactoryTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerRunPendingTasksConcurrencyTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/RemoteTaskRunnerTestUtils.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/TestRemoteTaskRunnerConfig.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/ZkWorkerTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/config/RemoteTaskRunnerConfigTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/worker/WorkerTaskMonitorTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/server/initialization/IndexerZkConfigTest.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartTableInputSpecSlicerProvider.java
copy
server/src/main/java/org/apache/druid/segment/realtime/NoopChatHandlerProvider.java
=>
multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartSegmentsInputSliceReaderProvider.java
(51%)
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerSegmentsInputSliceReaderProvider.java
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerTableInputSpecSlicerProvider.java
copy
server/src/main/java/org/apache/druid/indexing/overlord/supervisor/autoscaler/SupervisorTaskAutoScaler.java
=>
multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSliceReaderProvider.java
(58%)
copy
server/src/main/java/org/apache/druid/server/coordinator/stats/Dimension.java
=>
multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecSlicerProvider.java
(55%)
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/input/LoadableSegmentUtils.java
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/dart/worker/DartWorkerContextSegmentLoadAheadTest.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/AsyncResource.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/AsyncResources.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/CollectAsyncResource.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/RecoverAsyncResource.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/SettableAsyncResource.java
create mode 100644
processing/src/main/java/org/apache/druid/common/asyncresource/TransformAsyncResource.java
copy
server/src/main/java/org/apache/druid/server/initialization/CuratorDiscoveryConfig.java
=> processing/src/main/java/org/apache/druid/data/input/InputFilePointer.java
(58%)
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/AdaptedBaseTableProjectionSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/BaseTableProjectionSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/ClusteredValueGroupsBaseTableProjectionSpec.java
rename
server/src/main/java/org/apache/druid/guice/annotations/DirectExecutorAnnouncer.java
=>
processing/src/main/java/org/apache/druid/guice/annotations/EphemeralStorageLoading.java
(88%)
create mode 100644
processing/src/main/java/org/apache/druid/indexer/granularity/SegmentGranularitySpec.java
copy
server/src/main/java/org/apache/druid/server/initialization/CuratorDiscoveryConfig.java
=> processing/src/main/java/org/apache/druid/io/FilePopulator.java (64%)
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleAbsProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleDoubleAddProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleDoubleDivProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleDoubleMulProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleDoubleProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleDoubleSubProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLongAddProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLongDivProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLongMulProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLongProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLongSubProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleNegProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleSqrtProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleUnaryProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongAbsProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongDoubleAddProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongDoubleDivProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongDoubleMulProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongDoubleProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongDoubleSubProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongLongAddProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongLongMulProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongLongProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongLongSubProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongNegProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleSqrtProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleUnaryProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongUnaryProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdProcessors.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdSupportedBinaryOp.java
copy server/src/main/java/org/apache/druid/segment/realtime/ChatHandler.java
=>
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdSupportedUnaryOp.java
(55%)
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/NullAwareVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdDoubleMaxVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdDoubleMeanVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdDoubleMinVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdDoubleSumVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdFloatMaxVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdFloatMinVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdFloatSumVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdLongMaxVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdLongMinVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/aggregation/simd/SimdLongSumVectorAggregator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/SpillOutputStream.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ConcatenatingCursor.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/EmptyCursorHolder.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/MergingClusterGroupCursor.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/PartialBundleAcquirer.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/PartialQueryableIndexCursorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/PartialQueryableIndexSegment.java
copy
processing/src/main/java/org/apache/druid/segment/{PhysicalSegmentInspector.java
=> PhysicalSegmentColumnInspector.java} (78%)
copy
server/src/main/java/org/apache/druid/server/coordinator/balancer/DiskNormalizedCostBalancerStrategyFactory.java
=>
processing/src/main/java/org/apache/druid/segment/ResidentCursorFactory.java
(51%)
copy
server/src/main/java/org/apache/druid/server/initialization/CuratorDiscoveryConfig.java
=> processing/src/main/java/org/apache/druid/segment/RowCountInspector.java
(72%)
copy
server/src/main/java/org/apache/druid/server/coordinator/stats/Dimension.java
=> processing/src/main/java/org/apache/druid/segment/V10RowCountInspector.java
(53%)
create mode 100644
processing/src/main/java/org/apache/druid/segment/V10TimeBoundaryInspector.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/column/ConstantColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/column/ConstantNumericColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/column/StringDictionaryEncodedColumnFormat.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/data/ConstantColumnarInts.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/data/ConstantUtf8Indexed.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/file/PartialSegmentDownloadListener.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/incremental/ClusteringAwareIncrementalIndexColumnSelectorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/incremental/OnHeapClusterGroup.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/incremental/OnHeapClusteredBaseTable.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/loading/DirectoryBackedRangeReader.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/ClusterGroupQueryPlan.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/ClusteredValueGroupsBaseTableSchema.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/ClusteringColumnSelectorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/ClusteringDictionaries.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/ClusteringVectorColumnSelectorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/MergingColumnSelectorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/projections/TableClusterGroupSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/vector/ConcatenatingVectorCursor.java
create mode 100644
processing/src/main/java/org/apache/druid/timeline/partition/DimensionValueSetShardSpec.java
create mode 100644
processing/src/test/java/org/apache/druid/common/asyncresource/AsyncResourcesTest.java
create mode 100644
processing/src/test/java/org/apache/druid/common/asyncresource/CollectAsyncResourceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/common/asyncresource/RecoverAsyncResourceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/common/asyncresource/SettableAsyncResourceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/common/asyncresource/TransformAsyncResourceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/ClusteredValueGroupsBaseTableProjectionSpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/FileEntityTest.java
rename
server/src/main/java/org/apache/druid/segment/realtime/NoopChatHandlerProvider.java
=>
processing/src/test/java/org/apache/druid/math/expr/VectorExprResultConsistencyVectorApiTest.java
(58%)
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/ExpressionLambdaAggregationTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/simd/SimdAggregatorTestHelpers.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/simd/SimdDoubleMeanVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/simd/SimdMinMaxVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/simd/SimdSumVectorAggregatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/SpillOutputStreamTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/ClusteredSegmentTimeOrderedQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/ConcatenatingCursorTest.java
copy
processing/src/{main/java/org/apache/druid/segment/RestrictedCursorFactory.java
=> test/java/org/apache/druid/segment/DeferredCursorFactory.java} (50%)
create mode 100644
processing/src/test/java/org/apache/druid/segment/IndexMergerV10ClusteredTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/MergingClusterGroupCursorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PartialQueryableIndexCursorFactoryClusteredProjectionTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PartialQueryableIndexCursorFactoryClusteredTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PartialQueryableIndexCursorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PartialQueryableIndexCursorFactoryTestBase.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PartialQueryableIndexSegmentTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/PhysicalSegmentInspectorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/QueryableIndexCursorFactoryClusteredTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/SimpleQueryableIndexClusteredTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/V10TimeBoundaryInspectorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/ConstantNumericColumnTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/StringDictionaryEncodedColumnFormatTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/data/ConstantUtf8IndexedTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/file/CountingRangeReader.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/file/SegmentFileMetadataColumnFilesTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/incremental/IncrementalIndexClusteredProjectionTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/incremental/IncrementalIndexCursorFactoryClusteredTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/incremental/OnHeapClusteredBaseTableTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/ClusterGroupSchemaTestHelpers.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/ClusteredValueGroupsBaseTableSchemaTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/ClusteringColumnSelectorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/ClusteringVectorColumnSelectorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/MergingColumnSelectorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/NoRewriteFilter.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/ProjectionsPlanClusterGroupQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/TableClusterGroupSpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/vector/ConcatenatingVectorCursorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/timeline/partition/DimensionValueSetShardSpecTest.java
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/ClusteredValueGroupsBaseTableMetadata.java
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/DatasourceBaseTableMetadata.java
delete mode 100644
server/src/main/java/org/apache/druid/curator/discovery/CuratorServiceAnnouncer.java
delete mode 100644
server/src/main/java/org/apache/druid/curator/discovery/CuratorServiceUtils.java
delete mode 100644
server/src/main/java/org/apache/druid/curator/discovery/ServerDiscoveryFactory.java
delete mode 100644
server/src/main/java/org/apache/druid/curator/discovery/ServerDiscoverySelector.java
delete mode 100644
server/src/main/java/org/apache/druid/curator/discovery/ServiceAnnouncer.java
copy
server/src/main/java/org/apache/druid/{server/initialization/CuratorDiscoveryConfig.java
=> indexing/overlord/supervisor/SupervisorSpecUpdateAction.java} (72%)
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/AcquireMode.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/PartialSegmentBundleCacheEntry.java
copy
server/src/main/java/org/apache/druid/segment/loading/{SegmentCacheEntryIdentifier.java
=> PartialSegmentBundleCacheEntryIdentifier.java} (58%)
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/PartialSegmentCacheBootstrap.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/PartialSegmentMetadataCacheEntry.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/PermitLimitedSegmentRangeReader.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/ResizableCacheEntry.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/SegmentCacheEntry.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/StorageLoadingThreadPool.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/loading/StorageStats.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/external/CachedFile.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/external/DownloadableCacheEntry.java
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/external/StorageLocationVirtualStorageManager.java
rename
server/src/main/java/org/apache/druid/{server/initialization/CuratorDiscoveryConfig.java
=> segment/loading/external/StringCacheEntryIdentifier.java} (71%)
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/external/VirtualStorageManager.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/ServiceAnnouncingChatHandlerProvider.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/loading/SegmentStatsSnapshot.java
create mode 100644
server/src/main/java/org/apache/druid/server/initialization/jetty/PathExcludingQoSFilter.java
create mode 100644
server/src/main/java/org/apache/druid/server/scheduling/WeightedQueryLaningStrategy.java
create mode 100644
server/src/test/java/org/apache/druid/catalog/model/ClusteredValueGroupsBaseTableMetadataTest.java
create mode 100644
server/src/test/java/org/apache/druid/client/DataSourcesSnapshotTest.java
create mode 100644
server/src/test/java/org/apache/druid/client/DirectDruidClientAbortHttpTest.java
delete mode 100644
server/src/test/java/org/apache/druid/curator/discovery/LatchableServiceAnnouncer.java
delete mode 100644
server/src/test/java/org/apache/druid/curator/discovery/ServerDiscoverySelectorTest.java
delete mode 100644
server/src/test/java/org/apache/druid/curator/discovery/ServiceAnnouncerTest.java
create mode 100644
server/src/test/java/org/apache/druid/query/EmittingQueryMetrics.java
create mode 100644
server/src/test/java/org/apache/druid/query/timeseries/EmittingTimeseriesQueryMetrics.java
copy
server/src/{main/java/org/apache/druid/segment/loading/SegmentCacheEntryIdentifier.java
=>
test/java/org/apache/druid/segment/loading/PartialSegmentBundleCacheEntryIdentifierTest.java}
(51%)
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/PartialSegmentBundleCacheEntryTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/PartialSegmentCacheBootstrapTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/PartialSegmentMetadataCacheEntryTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/PermitLimitedSegmentRangeReaderTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/SegmentLocalCacheManagerPartialAcquireTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/SegmentLocalCacheManagerPartialDropTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/SegmentLocalCacheManagerPartialRuleLoadTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/StorageLoadingThreadPoolTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/external/DownloadableCacheEntryTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/external/StorageLocationVirtualStorageManagerTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/realtime/ChatHandlerProviderTest.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/ServiceAnnouncingChatHandlerProviderTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/duty/RunRulesPartialLoadPlacementTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/loading/SegmentReplicationStatusTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/simulate/HistoricalTierAliasTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/initialization/jetty/PathExcludingQoSFilterTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/scheduling/WeightedQueryLaningStrategyTest.java
create mode 100644
services/src/test/java/org/apache/druid/cli/CliCoordinatorTest.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchemaFilters.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaFiltersTest.java
create mode 100644
web-console/src/dialogs/supervisor-reset-to-latest-dialog/supervisor-reset-to-latest-dialog.tsx
create mode 100644
web-console/src/dialogs/supervisor-to-sql-dialog/supervisor-to-sql-dialog.scss
create mode 100644
web-console/src/dialogs/supervisor-to-sql-dialog/supervisor-to-sql-dialog.spec.tsx
create mode 100644
web-console/src/dialogs/supervisor-to-sql-dialog/supervisor-to-sql-dialog.tsx
create mode 100644 web-console/src/helpers/supervisor-conversion.spec.ts
create mode 100644 web-console/src/helpers/supervisor-conversion.ts
create mode 100644 web-console/src/utils/query-manager/query-manager.spec.ts
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
