This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/web-console/webpack-dev-server-5.2.5
in repository https://gitbox.apache.org/repos/asf/druid.git
discard 5f3b1972121 build(deps-dev): bump webpack-dev-server in /web-console
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 0ea17adccd4 fix: isMounted() should never be blocked by a lock (#19746)
add 80667e8b37b Bump org.assertj:assertj-core from 3.24.2 to 3.27.7
(#18956)
add d1c3399e40c build(deps): bump org.asynchttpclient:async-http-client
from 3.0.2 to 3.0.10 (#19476)
add a4ac032b714 build(deps): bump
org.apache.commons:commons-configuration2 from 2.10.1 to 2.15.0 (#19490)
add bac0310989a build(deps): bump io.vertx:vertx-core from 4.5.24 to
4.5.27 in /extensions-core/kubernetes-overlord-extensions (#19546)
add b9e5016941f build(deps): bump org.postgresql:postgresql from 42.7.11
to 42.7.12 (#19760)
add 134d4c81866 build(deps): bump org.apache.thrift:libthrift from 0.13.0
to 0.23.0 in /extensions-contrib/thrift-extensions (#19764)
add 5b4e3f955f4 build(deps-dev): bump org.apache.thrift:libthrift from
0.13.0 to 0.23.0 in /embedded-tests (#19763)
add 27652077034 build(deps): bump Jetty from 12.1.8 to 12.1.11 (#19757)
add 0841ec68bea build(deps): bump at.yawk.lz4:lz4-java from 1.10.2 to
1.11.1 (#19756)
add c49ac0ac375 Bump org.apache.maven:maven-artifact from 3.6.0 to 3.9.11
(#18271)
add db7347cecb0 build(deps-dev): bump
io.github.ascopes:protobuf-maven-plugin (#18714)
add 5604d22139e build(deps): upgrade Protobuf from 3.25.8 to 4.33.0 with
gencode compatibility (#18650)
add cbe902f6b62 build(deps): bump io.grpc:grpc-netty-shaded from 1.65.1 to
1.75.0 in /extensions-contrib/opentelemetry-emitter (#18588)
add 36a7d964391 minor: empty cursor holder time ordering (#19773)
add 4bb735c1d75 fix: return actionable errors for invalid native queries
(#19775)
add 6c3e0a98e7a fix: Improve reserved keyword SQL parse errors (#19719)
add ea690003d09 feat: add support for specifying DimensionSchema to
catalog clustered segment spec (#19770)
add f0cbad8f0f0 feat: support partial loads for tasks (#19739)
add 0ed37086bc5 build(deps-dev): bump http-proxy-middleware in
/web-console (#19762)
add ef54970e5b3 build(deps): bump ws in /web-console (#19761)
add c799396edab build(deps): bump immutable from 4.3.0 to 4.3.9 in
/web-console (#19733)
add d19c5343322 build(deps-dev): bump shell-quote from 1.8.1 to 1.10.0 in
/web-console (#19710)
add 2cb507ea663 build(deps-dev): bump websocket-driver in /web-console
(#19694)
add 8211c1efe59 build(deps): bump protobuf.version from 4.33.0 to 4.35.1
(#19786)
add 67c055eadb2 build(deps): bump
org.apache.maven.plugins:maven-assembly-plugin (#19785)
add 326e5b22f94 build(deps): bump form-data from 4.0.5 to 4.0.6 in
/web-console (#19621)
add 596e1bc13fa build(deps): bump org.asynchttpclient:async-http-client
from 3.0.10 to 3.0.11 (#19784)
add 05e51802064 build(deps-dev): bump lodash from 4.17.21 to 4.18.1 in
/web-console (#19256)
add b4893b0dbb1 build(deps): bump avatica.version from 1.27.0 to 1.28.0
(#19783)
add c6e9389b1cf build(deps): bump net.hydromatic:quidem from 0.11 to 0.12
(#19781)
add 46913e2b386 build(deps): bump apache.curator.version from 5.8.0 to
5.9.0 (#19780)
add 14a9df2e84b build(deps-dev): bump
org.codehaus.mojo:animal-sniffer-maven-plugin (#19777)
add fc8e63cd889 build(deps-dev): bump webpack-dev-server in /web-console
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 (5f3b1972121)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/web-console/webpack-dev-server-5.2.5
(fc8e63cd889)
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 | 2 +-
.github/workflows/static-checks.yml | 2 +-
README.md | 4 +-
README.template | 2 +-
benchmarks/pom.xml | 9 +-
.../DoubleMeanVectorAggregatorBenchmark.java | 179 +
.../druid/benchmark/query/SqlBaseBenchmark.java | 40 +-
.../benchmark/query/SqlBenchmarkDatasets.java | 166 +-
.../query/SqlClusteredSegmentsBenchmark.java | 127 +
.../benchmark/query/SqlExpressionBenchmark.java | 112 +-
.../coordinator/ComputePlacementCostBenchmark.java | 141 +
.../MarkOvershadowedSegmentsAsUnusedBenchmark.java | 142 +
.../calcite/schema/SysSegmentsTableBenchmark.java | 286 +
cloud/aws-common/pom.xml | 2 +-
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 | 2 +-
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 | 2 +-
docs/api-reference/sql-api.md | 2 +-
docs/api-reference/sql-jdbc.md | 2 +-
docs/api-reference/supervisor-api.md | 4 +-
docs/api-reference/tasks-api.md | 2 +-
docs/configuration/extensions.md | 10 +-
docs/configuration/index.md | 59 +-
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 | 2 +-
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 +-
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 | 73 +-
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 | 10 +-
docs/ingestion/kinesis-ingestion.md | 2 +-
docs/ingestion/native-batch.md | 4 +-
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 | 4 +-
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 | 16 +-
docs/operations/kubernetes.md | 4 +-
docs/operations/metrics.md | 39 +-
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/querying/aggregations.md | 4 +-
docs/querying/arrays.md | 4 +-
docs/querying/caching.md | 4 +-
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 | 2 +-
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 | 2 +-
docs/tutorials/index.md | 4 +-
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 | 2 +-
docs/tutorials/tutorial-ingestion-spec.md | 12 +-
docs/tutorials/tutorial-kafka.md | 6 +-
docs/tutorials/tutorial-latest-by.md | 2 +-
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 | 17 +-
.../testing/embedded/auth/BasicAuthMSQTest.java | 122 +-
.../catalog/CatalogIngestAndQueryTest.java | 137 +-
.../testing/embedded/catalog/CatalogTestBase.java | 5 +-
.../DeltaLakeInputSourceIngestionTest.java | 132 +
.../IngestionBackwardCompatibilityDockerTest.java | 8 +
.../embedded/indexing/IngestionSmokeTest.java | 45 +-
.../indexing/StreamIndexFaultToleranceTest.java | 13 +-
.../embedded/indexing/StreamIndexTestBase.java | 43 +
.../CostBasedAutoScalerIntegrationTest.java | 70 +-
.../msq/EmbeddedMSQParquetIngestionTest.java | 162 +
.../msq/EmbeddedMSQPartialDownloadsTest.java | 204 +
.../query/ClusteredSegmentProjectionQueryTest.java | 294 +
.../query/PartialProjectionLoadRuleQueryTest.java | 425 +
.../embedded/query/QueryVirtualStorageTest.java | 25 +-
.../embedded/tools/ThriftEventSerializer.java | 13 +-
...-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc | Bin
...-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc | Bin
.../_delta_log/.00000000000000000000.json.crc | Bin
.../_delta_log/00000000000000000000.json | 0
...104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet | Bin
...2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet | Bin
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 +-
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-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 | 4 +-
.../apache/druid/grpc/server/ProtobufWriter.java | 8 +-
.../org/apache/druid/grpc/server/QueryDriver.java | 6 +-
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 +-
extensions-contrib/openlineage-emitter/pom.xml | 2 +-
extensions-contrib/opentelemetry-emitter/pom.xml | 6 +-
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/RabbitStreamSupervisorIOConfig.java | 28 +
.../supervisor/RabbitStreamSupervisorSpec.java | 38 +
.../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 | 4 +-
.../data/input/thrift/ThriftDeserialization.java | 29 +-
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 +-
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 +-
.../kafka/supervisor/KafkaIOConfigBuilder.java | 45 +-
.../kafka/supervisor/KafkaSupervisorIOConfig.java | 39 +
.../kafka/supervisor/KafkaSupervisorSpec.java | 38 +
.../supervisor/KafkaSupervisorTuningConfig.java | 24 +
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 2 +-
.../kafka/KafkaIndexTaskTuningConfigTest.java | 64 +-
.../EmbeddedDimensionValueSetShardSpecTest.java | 14 +-
.../indexing/kafka/simulate/KafkaResource.java | 2 +-
.../supervisor/KafkaSupervisorIOConfigTest.java | 83 +
.../kafka/supervisor/KafkaSupervisorTest.java | 240 +-
.../indexing/kafka/test/EmbeddedKafkaBroker.java | 2 +-
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../kinesis/supervisor/KinesisIOConfigBuilder.java | 125 +
.../supervisor/KinesisSupervisorIOConfig.java | 39 +
.../kinesis/supervisor/KinesisSupervisorSpec.java | 47 +
.../supervisor/KinesisSupervisorTuningConfig.java | 35 +
.../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 | 4 +-
.../k8s/overlord/KubernetesOverlordModule.java | 2 +
.../KubernetesTaskRunnerPodTemplateResource.java | 77 +
.../DynamicConfigPodTemplateSelector.java | 11 +
.../overlord/taskadapter/PodTemplateSelector.java | 8 +
.../taskadapter/PodTemplateTaskAdapter.java | 5 +
.../MultipleKubernetesTaskRunnerFactoryTest.java | 2 +-
...ubernetesTaskRunnerPodTemplateResourceTest.java | 62 +
.../DynamicConfigPodTemplateSelectorTest.java | 21 +
.../taskadapter/TestPodTemplateSelector.java | 9 +
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 +-
extensions-core/parquet-extensions/pom.xml | 2 +-
.../postgresql-metadata-storage/pom.xml | 2 +-
extensions-core/protobuf-extensions/pom.xml | 4 +-
extensions-core/s3-extensions/pom.xml | 2 +-
.../java/org/apache/druid/storage/s3/S3Utils.java | 5 +
.../org/apache/druid/storage/s3/S3UtilsTest.java | 20 +
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 | 2 +-
.../common/SegmentCacheManagerFactory.java | 86 +-
.../indexing/common/SegmentUpgradeMetrics.java | 64 +
.../druid/indexing/common/TaskToolboxFactory.java | 12 +-
.../common/actions/SegmentAllocateAction.java | 5 +-
.../common/actions/SegmentAllocationQueue.java | 1 +
.../actions/SegmentTransactionalReplaceAction.java | 90 +-
.../druid/indexing/common/config/TaskConfig.java | 27 +-
.../druid/indexing/common/task/IndexTaskUtils.java | 37 +
.../common/task/KillUnusedSegmentsTask.java | 162 +-
.../apache/druid/indexing/common/task/Tasks.java | 1 +
.../parallel/ParallelIndexSupervisorTask.java | 3 +-
.../druid/indexing/input/DruidInputSource.java | 2 +-
.../druid/indexing/overlord/ForkingTaskRunner.java | 30 +-
.../overlord/config/ForkingTaskRunnerConfig.java | 17 +-
.../overlord/duty/UnusedSegmentsKiller.java | 27 +-
.../supervisor/CompactionSupervisorManager.java | 5 +-
.../overlord/supervisor/SupervisorManager.java | 160 +-
.../overlord/supervisor/SupervisorResource.java | 45 +-
.../supervisor/SupervisorSpecUpdateResult.java | 33 +-
.../scheduledbatch/ScheduledBatchTaskManager.java | 8 +
.../seekablestream/DimensionValueSetCollector.java | 191 +
...c.java => DimensionValueSetPartitionsSpec.java} | 51 +-
.../SeekableStreamIndexTaskRunner.java | 221 +-
.../seekablestream/StreamingPartitionsSpec.java | 119 +-
.../StreamingShardSpecCollector.java | 75 +
.../seekablestream/supervisor/IdleConfig.java | 20 +
.../seekablestream/supervisor/LagAggregator.java | 23 +
.../supervisor/SeekableStreamSupervisor.java | 87 +-
.../SeekableStreamSupervisorIOConfig.java | 59 +
.../SeekableStreamSupervisorIngestionSpec.java | 23 +
.../supervisor/SeekableStreamSupervisorSpec.java | 133 +
.../supervisor/SupervisorIOConfigBuilder.java | 99 +-
.../supervisor/autoscaler/CostBasedAutoScaler.java | 107 +-
.../autoscaler/CostBasedAutoScalerConfig.java | 164 +-
.../supervisor/autoscaler/CostMetrics.java | 35 +-
.../autoscaler/WeightedCostFunction.java | 60 +-
.../common/SegmentCacheManagerFactoryTest.java | 209 +
.../druid/indexing/common/TaskToolboxTest.java | 4 +
.../SegmentTransactionalInsertActionTest.java | 2 +-
.../SegmentTransactionalReplaceActionTest.java | 180 +
.../indexing/common/actions/TaskActionTestKit.java | 36 +
.../indexing/common/config/TaskConfigBuilder.java | 10 +-
.../indexing/common/config/TaskConfigTest.java | 45 +
.../task/ClientCompactionTaskQuerySerdeTest.java | 4 +-
.../common/task/CompactionTaskParallelRunTest.java | 446 +-
.../common/task/CompactionTaskRunBase.java | 125 +-
.../indexing/common/task/CompactionTaskTest.java | 8 +-
.../druid/indexing/common/task/IndexTaskTest.java | 13 +-
.../indexing/common/task/IngestionTestBase.java | 6 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 150 +-
.../druid/indexing/common/task/TaskBuilder.java | 2 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 4 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 2 +-
.../concurrent/ConcurrentReplaceAndAppendTest.java | 61 +-
.../ConcurrentReplaceAndStreamingAppendTest.java | 8 +-
.../compact/OverlordCompactionSchedulerTest.java | 4 +-
.../ReindexingDeletionRuleOptimizerTest.java | 44 +-
.../indexing/input/DruidSegmentReaderTest.java | 4 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 47 +
.../overlord/SingleTaskBackgroundRunnerTest.java | 2 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 4 +-
.../indexing/overlord/TestTaskToolboxFactory.java | 2 +-
.../duty/KillUnreferencedIndexingStateTest.java | 15 +-
.../overlord/duty/UnusedSegmentsKillerTest.java | 32 +-
.../http/OverlordCompactionResourceTest.java | 10 +-
.../overlord/http/OverlordResourceTest.java | 2 +-
.../security/SupervisorResourceFilterTest.java | 9 +-
.../sampler/InputSourceSamplerDiscoveryTest.java | 2 +-
.../overlord/sampler/SamplerResourceTest.java | 2 +-
.../overlord/supervisor/SupervisorManagerTest.java | 300 +-
.../supervisor/SupervisorResourceTest.java | 69 +-
.../SeekableStreamIndexTaskRunnerAuthTest.java | 1 +
.../SeekableStreamIndexTaskRunnerTest.java | 119 +-
.../SeekableStreamIndexTaskTestBase.java | 2 +-
.../SeekableStreamSamplerSpecTest.java | 7 +
.../SeekableStreamSupervisorIOConfigTest.java | 147 +-
.../SeekableStreamSupervisorSpecTest.java | 354 +-
.../SeekableStreamSupervisorStateTest.java | 360 +-
.../SeekableStreamSupervisorTestBase.java | 84 +-
.../autoscaler/CostBasedAutoScalerConfigTest.java | 120 +-
.../autoscaler/CostBasedAutoScalerMockTest.java | 3 +-
.../autoscaler/CostBasedAutoScalerTest.java | 254 +-
.../autoscaler/WeightedCostFunctionTest.java | 215 +-
.../TestIndexerMetadataStorageCoordinator.java | 4 +-
.../indexing/worker/WorkerTaskManagerTest.java | 2 +-
licenses.yaml | 128 +-
multi-stage-query/pom.xml | 2 +-
.../druid/msq/indexing/IndexerWorkerContext.java | 8 +-
.../input/external/ExternalInputSliceReader.java | 11 +
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 42 +-
.../druid/msq/util/MultiStageQueryContext.java | 15 +
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 34 +-
.../org/apache/druid/msq/exec/MSQInsertTest.java | 170 +
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 19 +-
.../msq/indexing/MSQCompactionRunnerTest.java | 7 +-
.../msq/input/RegularLoadableSegmentTest.java | 17 +-
.../input/table/DataSegmentWithLocationTest.java | 44 +-
.../druid/msq/test/CalciteMSQTestsHelper.java | 4 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 24 +-
.../druid/msq/test/MSQTestWorkerContext.java | 7 +-
.../druid/msq/util/MultiStageQueryContextTest.java | 24 +
pom.xml | 66 +-
processing/pom.xml | 7 +-
.../druid/common/asyncresource/AsyncResource.java | 4 +
...lusteredValueGroupsBaseTableProjectionSpec.java | 102 +-
.../druid/data/input/impl/DimensionSchema.java | 7 +-
.../columnar/ColumnarFrameCursorFactory.java | 3 +-
.../frame/segment/row/RowFrameCursorFactory.java | 3 +-
.../guice/annotations/EphemeralStorageLoading.java | 35 +-
.../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 +
.../java/org/apache/druid/math/expr/Function.java | 1 -
.../SimpleVectorMathBivariateProcessorFactory.java | 2 +-
...VectorMathUnivariateDoubleProcessorFactory.java | 29 +-
...SimpleVectorMathUnivariateProcessorFactory.java | 29 +-
.../math/expr/vector/VectorMathProcessors.java | 11 +-
.../expr/vector/simd/SimdDoubleAbsProcessor.java | 57 +
.../vector/simd/SimdDoubleDoubleDivProcessor.java | 95 +
.../vector/simd/SimdDoubleLongDivProcessor.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/SimdLongDoubleDivProcessor.java | 96 +
.../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 | 50 +-
.../expr/vector/simd/SimdSupportedBinaryOp.java | 28 +-
...rtedBinaryOp.java => SimdSupportedUnaryOp.java} | 12 +-
.../apache/druid/query/BadJsonQueryException.java | 24 +
.../apache/druid/query/DefaultQueryMetrics.java | 1 +
.../java/org/apache/druid/query/DruidMetrics.java | 1 +
.../java/org/apache/druid/query/QueryMetrics.java | 11 +-
.../aggregation/DoubleMaxAggregatorFactory.java | 5 +
.../aggregation/DoubleMinAggregatorFactory.java | 5 +
.../aggregation/DoubleSumAggregatorFactory.java | 5 +
.../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 +
.../apache/druid/segment/ConcatenatingCursor.java | 10 +-
.../org/apache/druid/segment/CursorFactory.java | 17 +-
.../druid/segment/DefaultColumnFormatConfig.java | 2 +-
.../segment/DictionaryEncodedColumnMerger.java | 11 +-
.../apache/druid/segment/EmptyCursorHolder.java | 32 +-
.../org/apache/druid/segment/IndexMergerV10.java | 52 +-
.../druid/segment/MergingClusterGroupCursor.java | 294 +
.../druid/segment/NestedDataColumnSchema.java | 11 +-
.../druid/segment/PartialQueryableIndex.java | 670 +-
.../PartialQueryableIndexCursorFactory.java | 308 +-
.../org/apache/druid/segment/QueryableIndex.java | 9 +-
.../druid/segment/QueryableIndexCursorFactory.java | 340 +-
.../druid/segment/QueryableIndexCursorHolder.java | 30 +-
.../segment/QueryableIndexIndexableAdapter.java | 3 +-
.../druid/segment/ResidentCursorFactory.java | 39 +-
.../druid/segment/RowBasedCursorFactory.java | 2 +-
.../apache/druid/segment/SimpleQueryableIndex.java | 21 +-
.../apache/druid/segment/UnnestCursorFactory.java | 79 +-
.../druid/segment/column/ConstantColumns.java | 110 +
.../segment/column/ConstantNumericColumn.java | 151 +
.../druid/segment/data/ConstantColumnarInts.java | 70 +
.../druid/segment/data/ConstantUtf8Indexed.java | 96 +
.../file/PartialSegmentDownloadListener.java | 62 +
.../segment/file/PartialSegmentFileMapperV10.java | 580 +-
.../druid/segment/file/SegmentFileBuilderV10.java | 58 +-
.../druid/segment/file/SegmentFileMetadata.java | 59 +
.../druid/segment/generator/DataGenerator.java | 26 +-
.../segment/generator/GeneratorBasicSchemas.java | 30 +
...AwareIncrementalIndexColumnSelectorFactory.java | 112 +
.../incremental/IncrementalIndexCursorFactory.java | 73 +-
.../incremental/OnheapIncrementalIndex.java | 6 -
.../segment/index/IndexedUtf8ValueIndexes.java | 1 -
.../segment/join/HashJoinSegmentCursorFactory.java | 338 +-
.../loading/PartialClusterGroupLoadSpec.java | 67 +
.../druid/segment/loading/PartialLoadSpec.java | 16 +
.../segment/loading/PartialProjectionLoadSpec.java | 42 +
.../loading/TombstoneSegmentizerFactory.java | 3 +-
.../segment/nested/NestedDataComplexTypeSerde.java | 2 +-
.../segment/projections/ClusterGroupQueryPlan.java | 101 +-
.../ClusteringColumnSelectorFactory.java | 125 +-
.../ClusteringVectorColumnSelectorFactory.java | 315 +-
.../projections/MergingColumnSelectorFactory.java | 461 +
.../druid/segment/projections/Projections.java | 238 +-
.../segment/vector/ConcatenatingVectorCursor.java | 10 +-
.../org/apache/druid/timeline/DataSegment.java | 40 -
.../resources/loggingEmitterAllowedMetrics.json | 3 +-
.../apache/druid/collections/BlockingPoolTest.java | 146 +-
.../druid/common/guava/CombiningSequenceTest.java | 45 +-
...eredValueGroupsBaseTableProjectionSpecTest.java | 217 +
.../druid/data/input/impl/DimensionSchemaTest.java | 47 +
.../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 +-
.../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 +-
.../druid/query/BadJsonQueryExceptionTest.java | 73 +
.../org/apache/druid/query/DataSourceTest.java | 54 +-
.../apache/druid/query/InlineDataSourceTest.java | 104 +-
.../org/apache/druid/query/QueryContextsTest.java | 135 +-
.../apache/druid/query/TimewarpOperatorTest.java | 24 +-
.../query/aggregation/AggregatorFactoryTest.java | 24 +-
.../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 +-
...ctorValueMatcherColumnProcessorFactoryTest.java | 108 +-
.../query/groupby/GroupByQueryRunnerTest.java | 41 +-
.../druid/query/groupby/GroupByQueryTest.java | 42 +-
.../groupby/GroupByTimeseriesQueryRunnerTest.java | 18 +-
.../epinephelinae/SpillOutputStreamTest.java | 115 +-
.../metadata/metadata/ColumnAnalysisTest.java | 36 +-
.../search/SearchQueryRunnerWithCaseTest.java | 53 +-
.../timeseries/TimeseriesQueryRunnerTest.java | 34 +-
.../topn/TopNMetricSpecOptimizationsTest.java | 24 +-
.../org/apache/druid/query/topn/TopNQueryTest.java | 169 +-
.../ClusteredSegmentTimeOrderedQueryTest.java | 583 +
.../druid/segment/ConcatenatingCursorTest.java | 25 +-
.../apache/druid/segment/CursorBuildSpecTest.java | 50 +-
.../druid/segment/DeferredCursorFactory.java | 80 +
.../druid/segment/EmptyCursorHolderTest.java | 91 +
.../java/org/apache/druid/segment/IndexIOTest.java | 47 +-
.../druid/segment/IndexMergerV10ClusteredTest.java | 396 +-
.../segment/IndexMergerV10MinMaxTimeTest.java | 64 +
.../segment/MergingClusterGroupCursorTest.java | 349 +
.../druid/segment/NestedDataColumnSchemaTest.java | 2 +-
...eIndexCursorFactoryClusteredProjectionTest.java | 227 +
...alQueryableIndexCursorFactoryClusteredTest.java | 466 +
.../PartialQueryableIndexCursorFactoryTest.java | 510 +-
...PartialQueryableIndexCursorFactoryTestBase.java | 126 +
.../segment/PartialQueryableIndexSegmentTest.java | 6 +-
.../druid/segment/PartialQueryableIndexTest.java | 463 +-
.../QueryableIndexCursorFactoryClusteredTest.java | 639 +-
.../segment/QueryableIndexCursorFactoryTest.java | 138 +-
.../druid/segment/UnnestCursorFactoryTest.java | 58 +-
.../segment/column/ConstantNumericColumnTest.java | 74 +
.../data/CompressedColumnarIntsSerializerTest.java | 136 +-
.../segment/data/ConstantUtf8IndexedTest.java | 73 +
.../data/NumericNullColumnSelectorTest.java | 32 +-
.../druid/segment/file/CountingRangeReader.java | 9 +
.../file/PartialSegmentFileMapperV10Test.java | 752 +-
.../segment/file/SegmentFileBuilderV10Test.java | 208 +
.../file/SegmentFileMetadataColumnFilesTest.java | 307 +
.../segment/filter/ExtractionDimFilterTest.java | 56 +-
.../druid/segment/generator/SegmentGenerator.java | 163 +
.../IncrementalIndexClusteredProjectionTest.java | 211 +
...IncrementalIndexCursorFactoryClusteredTest.java | 228 +
.../join/HashJoinSegmentCursorFactoryTest.java | 75 +
.../segment/join/JoinConditionAnalysisTest.java | 160 +-
.../segment/join/lookup/LookupJoinableTest.java | 58 +-
.../loading/PartialClusterGroupLoadSpecTest.java | 209 +
.../loading/PartialProjectionLoadSpecTest.java | 99 +
.../nested/ScalarDoubleColumnSupplierTest.java | 84 +-
.../nested/ScalarLongColumnSupplierTest.java | 84 +-
.../nested/ScalarStringColumnSupplierTest.java | 94 +-
.../ClusteringColumnSelectorFactoryTest.java | 177 +-
.../ClusteringVectorColumnSelectorFactoryTest.java | 285 +-
.../MergingColumnSelectorFactoryTest.java | 274 +
.../druid/segment/projections/NoRewriteFilter.java | 62 +
.../ProjectionsPlanClusterGroupQueryTest.java | 324 +-
.../druid/segment/projections/ProjectionsTest.java | 46 +
.../vector/ConcatenatingVectorCursorTest.java | 28 +-
...ryableIndexVectorColumnSelectorFactoryTest.java | 85 +-
.../ListFilteredVirtualColumnSelectorTest.java | 38 +-
.../org/apache/druid/timeline/DataSegmentTest.java | 194 +-
.../timeline/partition/NumberedShardSpecTest.java | 60 +-
.../resources/loggingEmitterAllowedMetrics.json | 1 +
quidem-ut/pom.xml | 2 +-
server/pom.xml | 2 +-
.../ClusteredValueGroupsBaseTableMetadata.java | 304 +
.../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/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 +
.../org/apache/druid/guice/StorageNodeModule.java | 15 +
.../IndexerMetadataStorageCoordinator.java | 23 +-
.../overlord/supervisor/SupervisorSpec.java | 11 +
.../supervisor/SupervisorSpecUpdateAction.java} | 29 +-
.../IndexerSQLMetadataStorageCoordinator.java | 29 +-
.../druid/metadata/SQLMetadataConnector.java | 79 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 69 +-
.../cache/HeapMemoryDatasourceSegmentCache.java | 50 +
.../cache/HeapMemorySegmentMetadataCache.java | 84 +-
.../loading/PartialSegmentBundleCacheEntry.java | 19 +-
.../loading/PartialSegmentCacheBootstrap.java | 66 +-
.../loading/PartialSegmentMetadataCacheEntry.java | 701 +-
.../loading/PermitLimitedSegmentRangeReader.java | 86 +
.../druid/segment/loading/SegmentCacheManager.java | 10 +-
.../druid/segment/loading/SegmentLoaderConfig.java | 465 +-
.../segment/loading/SegmentLocalCacheManager.java | 629 +-
.../segment/loading/StorageLoadingThreadPool.java | 303 +-
.../druid/segment/loading/StorageLocation.java | 42 +-
.../loading/VirtualStorageLocationStats.java | 23 +-
.../StorageLocationVirtualStorageManager.java | 10 +-
.../metadata/AbstractSegmentMetadataCache.java | 50 +-
.../org/apache/druid/segment/metadata/Metric.java | 1 +
.../appenderator/SinkQuerySegmentWalker.java | 56 +-
.../realtime/appenderator/StreamAppenderator.java | 49 +-
.../apache/druid/server/QueryLaningStrategy.java | 4 +-
.../org/apache/druid/server/QueryResource.java | 4 +
.../org/apache/druid/server/QueryScheduler.java | 10 +-
.../org/apache/druid/server/SegmentManager.java | 24 +-
.../org/apache/druid/server/ServerManager.java | 1 +
.../coordination/SegmentCacheBootstrapper.java | 8 +-
.../coordination/SegmentChangeRequestLoad.java | 30 +-
.../coordination/SegmentLoadDropHandler.java | 10 +-
.../druid/server/coordinator/DruidCluster.java | 2 +-
.../druid/server/coordinator/DruidCoordinator.java | 51 +-
.../coordinator/balancer/CostBalancerStrategy.java | 20 +-
.../DiskNormalizedCostBalancerStrategy.java | 124 +-
.../DiskNormalizedCostBalancerStrategyConfig.java | 34 +-
.../DiskNormalizedCostBalancerStrategyFactory.java | 2 +-
.../duty/MarkEternityTombstonesAsUnused.java | 94 +-
.../duty/MarkOvershadowedSegmentsAsUnused.java | 32 +-
.../duty/PrepareBalancerAndLoadQueues.java | 14 +-
.../druid/server/coordinator/duty/RunRules.java | 109 +-
.../coordinator/loading/PartialLoadProfile.java | 43 +-
.../server/coordinator/loading/SegmentHolder.java | 13 +-
.../coordinator/loading/SegmentReplicaCount.java | 10 +
.../loading/SegmentReplicationStatus.java | 89 +-
.../coordinator/loading/SegmentStatsSnapshot.java | 78 +
.../loading/StrategicSegmentAssigner.java | 6 +-
.../rules/ClusterGroupPartialLoadMatcher.java | 31 +-
.../coordinator/rules/PartialLoadMatcher.java | 19 +-
.../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 | 42 +-
.../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 | 567 +
.../catalog/model/table/DatasourceTableTest.java | 144 +
.../druid/client/DataSourcesSnapshotTest.java | 125 +
.../client/DirectDruidClientAbortHttpTest.java | 184 +
.../apache/druid/client/DruidServerConfigTest.java | 13 +-
.../druid/client/DruidServerPartialLoadTest.java | 9 +-
.../org/apache/druid/client/TestHttpClient.java | 15 +-
.../apache/druid/guice/StorageNodeModuleTest.java | 22 +
.../IndexerSQLMetadataStorageCoordinatorTest.java | 218 +-
.../druid/metadata/SQLMetadataConnectorTest.java | 24 +-
.../metadata/SqlSegmentsMetadataQueryTest.java | 32 +-
.../cache/HeapMemorySegmentMetadataCacheTest.java | 30 +
.../apache/druid/query/EmittingQueryMetrics.java | 134 +
.../timeseries/EmittingTimeseriesQueryMetrics.java | 79 +
.../org/apache/druid/rpc/MockServiceClient.java | 3 +-
.../segment/loading/NoopSegmentCacheManager.java | 4 +-
.../PartialSegmentBundleCacheEntryTest.java | 22 +-
.../loading/PartialSegmentCacheBootstrapTest.java | 112 +-
.../PartialSegmentMetadataCacheEntryTest.java | 275 +-
.../PermitBoundedListeningExecutorServiceTest.java | 106 -
.../PermitLimitedSegmentRangeReaderTest.java | 81 +
.../segment/loading/SegmentLoaderConfigTest.java | 122 +-
.../SegmentLocalCacheManagerConcurrencyTest.java | 168 +-
...SegmentLocalCacheManagerPartialAcquireTest.java | 295 +-
.../SegmentLocalCacheManagerPartialDropTest.java | 6 +-
...egmentLocalCacheManagerPartialRuleLoadTest.java | 820 +
.../loading/SegmentLocalCacheManagerTest.java | 246 +-
.../loading/StorageLoadingThreadPoolTest.java | 127 +
.../CoordinatorSegmentMetadataCacheTest.java | 121 +
.../segment/metadata/IndexingStateCacheTest.java | 33 +-
.../metadata/SqlIndexingStateStorageTest.java | 142 +-
.../appenderator/StreamAppenderatorTest.java | 130 +-
.../appenderator/StreamAppenderatorTester.java | 22 +-
.../org/apache/druid/server/QueryResourceTest.java | 18 +
.../apache/druid/server/QuerySchedulerTest.java | 100 +
.../apache/druid/server/SegmentManagerTest.java | 48 +-
.../apache/druid/server/StatusResourceTest.java | 6 +-
.../server/compaction/CompactionStatusTest.java | 206 +-
.../compaction/NewestSegmentFirstPolicyTest.java | 454 +-
.../coordination/LoadableDataSegmentTest.java | 44 +-
.../SegmentCacheBootstrapperCacheTest.java | 23 +-
.../coordination/SegmentCacheBootstrapperTest.java | 35 +-
.../coordination/SegmentChangeRequestLoadTest.java | 41 +-
.../coordination/SegmentLoadDropHandlerTest.java | 96 +-
...egmentManagerBroadcastJoinIndexedTableTest.java | 20 +-
.../SegmentManagerThreadSafetyTest.java | 20 +-
.../server/coordination/ServerManagerTest.java | 27 +-
.../DiskNormalizedCostBalancerStrategyTest.java | 94 +-
.../coordinator/duty/CompactSegmentsTest.java | 97 +-
.../duty/RunRulesEmptyDeferringHandlerTest.java | 255 -
.../duty/RunRulesPartialLoadPlacementTest.java | 285 +
.../loading/PartialLoadProfileTest.java | 20 +-
.../loading/SegmentReplicationStatusTest.java | 187 +
.../StrategicSegmentAssignerPartialTest.java | 15 +-
...WildcardClusterGroupPartialLoadMatcherTest.java | 22 +-
.../simulate/TestSegmentLoadingHttpClient.java | 8 +-
.../druid/server/http/DataSegmentPlusTest.java | 45 +-
.../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 | 46 +
.../server/metrics/SegmentStatsMonitorTest.java | 2 +-
.../WeightedQueryLaningStrategyTest.java | 487 +
.../druid/server/security/AuthConfigTest.java | 14 +
.../server/security/AuthorizationUtilsTest.java | 211 +
.../druid/test/utils/TestSegmentCacheManager.java | 6 +-
services/pom.xml | 2 +-
.../java/org/apache/druid/cli/CliCoordinator.java | 20 +
.../java/org/apache/druid/cli/CliOverlord.java | 32 +-
.../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 +-
.../server/AsyncQueryForwardingServletTest.java | 57 +-
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 +-
.../druid/sql/calcite/parser/DruidSqlParser.java | 95 +-
.../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 | 194 +-
...lVectorizedExpressionResultConsistencyTest.java | 4 +-
.../sql/calcite/parser/DruidSqlParserTest.java | 50 +
.../calcite/schema/SystemSchemaFiltersTest.java | 274 +
.../druid/sql/calcite/schema/SystemSchemaTest.java | 147 +-
.../sql/calcite/util/QueryFrameworkUtils.java | 6 +-
web-console/package-lock.json | 205 +-
web-console/package.json | 4 +-
web-console/pom.xml | 2 +-
web-console/src/dialogs/index.ts | 1 +
.../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 +-
.../views/supervisors-view/supervisors-view.tsx | 19 +-
.../src/views/workbench-view/workbench-view.tsx | 37 +-
web-console/unified-console.html | 2 +-
web-console/webpack.config.mjs | 13 +-
website/.spelling | 4 +-
website/docusaurus.config.js | 11 +-
website/package-lock.json | 50387 +++++++------------
website/package.json | 26 +-
860 files changed, 59508 insertions(+), 40423 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
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/EmbeddedMSQPartialDownloadsTest.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
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/.part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet.crc
(100%)
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/.part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet.crc
(100%)
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/_delta_log/.00000000000000000000.json.crc
(100%)
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/_delta_log/00000000000000000000.json
(100%)
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/part-00000-42349806-104f-42a0-a6fe-5397f37d29d8-c000.snappy.parquet
(100%)
copy {extensions-contrib/druid-deltalake-extensions/src/test/resources =>
embedded-tests/src/test/resources/delta}/large-row-group-table/part-00001-42b5d278-2c32-4094-af60-5eaca2f7ba03-c000.snappy.parquet
(100%)
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%)
rename extensions-core/kafka-indexing-service/src/{test =>
main}/java/org/apache/druid/indexing/kafka/supervisor/KafkaIOConfigBuilder.java
(68%)
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/execution/KubernetesTaskRunnerPodTemplateResource.java
create mode 100644
extensions-core/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/execution/KubernetesTaskRunnerPodTemplateResourceTest.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/SegmentUpgradeMetrics.java
copy
server/src/main/java/org/apache/druid/server/security/AuthorizerMapper.java =>
indexing-service/src/main/java/org/apache/druid/indexing/overlord/supervisor/SupervisorSpecUpdateResult.java
(52%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/DimensionValueSetCollector.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/{StreamingPartitionsSpec.java
=> DimensionValueSetPartitionsSpec.java} (65%)
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%)
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
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/config/TaskConfigTest.java
copy
server/src/main/java/org/apache/druid/server/security/AuthorizerMapper.java =>
processing/src/main/java/org/apache/druid/guice/annotations/EphemeralStorageLoading.java
(60%)
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/SimdDoubleDoubleDivProcessor.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/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/SimdLongDoubleDivProcessor.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
copy
processing/src/main/java/org/apache/druid/math/expr/vector/simd/{SimdSupportedBinaryOp.java
=> SimdSupportedUnaryOp.java} (81%)
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/segment/MergingClusterGroupCursor.java
copy
server/src/main/java/org/apache/druid/server/coordinator/balancer/DiskNormalizedCostBalancerStrategyFactory.java
=>
processing/src/main/java/org/apache/druid/segment/ResidentCursorFactory.java
(51%)
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/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/projections/MergingColumnSelectorFactory.java
create mode 100644
processing/src/test/java/org/apache/druid/query/BadJsonQueryExceptionTest.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/segment/ClusteredSegmentTimeOrderedQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/DeferredCursorFactory.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/EmptyCursorHolderTest.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/PartialQueryableIndexCursorFactoryTestBase.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/data/ConstantUtf8IndexedTest.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/projections/MergingColumnSelectorFactoryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/projections/NoRewriteFilter.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
copy
server/src/main/java/org/apache/druid/{server/security/AuthorizerMapper.java =>
indexing/overlord/supervisor/SupervisorSpecUpdateAction.java} (64%)
create mode 100644
server/src/main/java/org/apache/druid/segment/loading/PermitLimitedSegmentRangeReader.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
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
delete mode 100644
server/src/test/java/org/apache/druid/segment/loading/PermitBoundedListeningExecutorServiceTest.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/SegmentLocalCacheManagerPartialRuleLoadTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/StorageLoadingThreadPoolTest.java
delete mode 100644
server/src/test/java/org/apache/druid/server/coordinator/duty/RunRulesEmptyDeferringHandlerTest.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/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-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]
