This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/com.nimbusds-oauth2-oidc-sdk-11.9.1
in repository https://gitbox.apache.org/repos/asf/druid.git
discard a3312af9254 Bump com.nimbusds:oauth2-oidc-sdk from 6.5 to 11.9.1
add 52313c51acb docs: Anchor link checker (#15624)
add 468b99e608c Enable query request queuing by default when total laning
is turned on. (#15440)
add 911941b4a63 fix issue with nested virtual column index supplier for
partial paths when processing from raw (#15643)
add cafc748f7ec skip expression virtual column indexes when mvd is used as
array (#15644)
add ea6ba40ce1e Add support for Azure Goverment storage (#15523)
add 747d9737528 Skip waiting for first lookup version to get initialized
(#15598)
add 85b8cf9f378 Web console: Fix concurrent tasks (#15649)
add 71f53072771 Eliminate Periodic Realtime Segment Metadata Queries: Task
Now Publish Schema for Seamless Coordinator Updates (#15475)
add 2938b8de53f fix issue with NestedPathArrayElement not correctly
handling negative index for Object[] like it has for List (#15650)
add 047c7340ab3 Adding retries to update the metadata store instead of
failure (#15141)
add 355c2f5da00 Add sql + ingestion compatibility for first/last on
numeric values (#15607)
add 4149f98934f Fixes a bug with long string pair serde where null and
empty strings are treated equivalently (#15525)
add 99d4b7dca71 Use to trigger search bar of official site (#15652)
add fefa7637220 Resultcache fetch should deserialize aggregates when they
are real results (#15654)
add d623756c668 Add cache for password hash in druid-basic-security
(#15648)
add 0b91cc4db20 Fix incorrect tests in Sting first/last serde's null
handling (#15657)
add ee77fa7fb3c Add tests for CASE decomposition. (#15639)
add f445ba4d6b8 Audit API DELETE datasource (markAllSegmentsAsUnused)
(#15653)
add 5b769a7d326 Update load query detail archive dialog for file input
support (#15632)
add 87fbe422187 "Partition boost" the group by queries in MSQ for better
splits (#15474)
add 2118258b547 tidy up group by engines after removal of v1 (#15665)
add 2231cb30a4d Faster k-way merging using tournament trees, 8-byte key
strides. (#15661)
add 6c18434028b CONCAT flattening, filter decomposition. (#15634)
add e597cc2949c Remove UnaryFunctionOperatorConversion and
RoundOperatorConversion (#15566)
add cccf13ea824 Reverse, pull up lookups in the SQL planner. (#15626)
add 0457c71d039 Fix k8sAndWorker mode in a zookeeper-less environment
(#15445)
add 866fe1cda60 Fix some naming related to AggregatePullUpLookupRule.
(#15677)
add 500681d0cb4 Add ImmutableLookupMap for static lookups. (#15675)
add f0c552b2f91 Fix basic auth integration test (#15679)
add e49a7bb3cd9 Add SpectatorHistogram extension (#15340)
add 08c01f1dae9 Handle and map errors in delete pending segments API
(#15673)
add 18d2a8957f6 Refactor: Cleanup test impls of ServiceEmitter (#15683)
add d359fb3d689 Cache value selectors in RowBasedColumnSelectorFactory.
(#15615)
add 072b16c6df4 Fix SQL Innterval.of() error message (#15454)
add 67720b60ae6 Skip compaction for intervals without data (#15676)
add 11dbfb6e3fd Better error message when partition space is exhausted
(#15685)
add 6b951b94c05 Add new context parameter for using concurrent locks
(#15684)
add 8ba06cf7230 account for null values in the stddev post aggregator
(#15660)
add 8a43db9395b Range support in window expressions (support them as
groups) (#15365)
add c27f5bf52f6 Report zero values instead of unknown for empty ingest
queries (#15674)
add fc06f2d075f Fix summary iterator in grouping engine(#15658)
add a26defd64bb Clean up stale entries from upgradeSegments table (#15637)
add a3b32fbd26a Fix comparator and remove deprecated methods from
spectatorHistogram extension (#15698)
add 55acf2e2ff4 Fix incorrect scale when reading decimal from parquet
(#15715)
add d3d0c1c91ec Faster parsing: reduce String usage, list-based input
rows. (#15681)
add 764f41d9593 Clear "lineSplittable" for JSON when using
KafkaInputFormat. (#15692)
add 792e5c58e4e IncrementalIndex#add is no longer thread-safe. (#15697)
add dd03f7061a7 Implement task payload management with azure storage
(#15695)
add c8c04f1032d fix worker disable rendering (#15712)
add 18d42cae3ff Kafka emitter wasn't given the correct number of threads.
It should be 1 thread per scheduled task. (#15719)
add f51f0e07e2d Remove documentation for unused segments retrieval API
(#15721)
add 96b4abc8e9f Add @VisibleForTesting annotation for the backingArray()
method (#15690)
add 38c1def95a0 Kill tasks honor the buffer period of unused segments
(#15710)
add 9d4e8053a4a Kinesis adaptive memory management (#15360)
add 45b30dc07d6 Revert "Change default inSubQueryThreshold (#15336)"
(#15722)
add d6a12c4389b Add ability to enable ResultCache in tests (#15465)
add c4990f56d6c Prepare main branch for next 30.0.0 release. (#15707)
add bf7d8680b33 Update notice file. (#15702)
add 3fe3a653443 New: Add DDSketch in extensions-contrib (#15049)
add 2eba20d7248 Fix minor build issues and stabilize intellij-inspections
runs (#15747)
add ef0232290cf Fix AzureStorage.batchDeleteFiles (#15730)
add 55ed69f8300 update mocks (#15745)
add 06b228ff7cb Return a 503 status code instead of 400 during transient
errors (#15756)
add 0ab2781a7f2 Disable eager initialization for non-query connection
requests (#15751)
add 01e9d963bd8 Merge hydrant runners flatly for realtime queries. (#15757)
add ed6df26a91a update salt size (#15758)
add 867c636629c Document pivot and unpivot operators (#15669)
add 3e512249e37 Azure multi read options (#15630)
add 4e50a14d509 fix router page value inconsistent issue (#15742)
add 45ad47cc666 allow segment table to sort on start and end when grouped
(#15720)
add 00cb0a2900a Fix extractionFns on number-wrapping dimension selectors.
(#15761)
add a7918be268a Temporarily bump up the delay in auth IT from 5s to 10s.
(#15765)
add ae6afc0751b Extend unused segment metadata api response to include
created date and last used updated time (#15738)
add ba07965580d docs: clean up some rolling updates stuff (#15762)
add f58fd5b75f0 Remove TestObjectMapper in favor of DefaultObjectMapper.
(#15769)
add 989a8f78744 Better error message for date_trunc operators (#15759)
add 01fa5c7ea61 add null value index wiring for nested column to speed up
is null/is not null (#15687)
add 54d0e482dc5 Consolidate RetrieveSegmentsToReplaceAction into
RetrieveUsedSegmentsAction (#15699)
add 38a1e827ab0 Fix up value types when creating range filters. (#15778)
add 497e2123f04 Web console: Make table driven query modification actions
work with slices. (#15779)
add ef46d882007 Release unneeded append locks after acquiring a new
superseding append lock (#15682)
add 62886e23acd docs: add mermaid diagram support (#15771)
add dbdfae3011f Fix up typo </br /> -> <br /> and adjust interpolated
exception msg in InvalidNullByteFault. (#15804)
add dbcfb2bb8b2 Allow null values for account when injecting (#15777)
add d9e8448c502 Close open segments when a newer segment with higher
version is allocated (#15727)
add 6177f6efd73 Fixing formatting of Iceberg Catalog Object (#15748)
add 9f95a691f78 Extension to read and ingest Delta Lake tables (#15755)
add f701197224b Enable ArrayListRowsAndColumns to StorageAdapter
conversion (#15735)
add 2a250a4e6e9 Fix GHA logs dir and make tar and upload conditional on
web console test failures (#15810)
add 37d1650ccfd Benchmark for query planning time for IN queries (#15688)
add 0089f6b905f Web console: Don't force waitUntilSegmentLoad to true
(#15781)
add 5edfa9429f4 Batch kill in azure (#15770)
add fcd65c98010 Web console: use arrayIngestMode: array (#15588)
add 7d65caf0c5f Update the docs for EARLIEST_BY/LATEST_BY aggregators with
the newly added numeric capabilities (#15670)
add 5de39c62519 Resolve CVE issues (#15814)
add 50bae96e8b4 Add azure integrationt ests (#15799)
add 65857dc0e79 pac4j: fix incompatible dependencies + authorization
regression (#15753)
add 9afcfa79893 Bump com.nimbusds:oauth2-oidc-sdk from 6.5 to 11.9.1
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 (a3312af9254)
\
N -- N -- N
refs/heads/dependabot/maven/com.nimbusds-oauth2-oidc-sdk-11.9.1 (9afcfa79893)
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/static-checks.yml | 12 +-
NOTICE | 2 +-
benchmarks/pom.xml | 7 +-
.../benchmark/DelimitedInputFormatBenchmark.java | 167 ++
.../frame/FrameChannelMergerBenchmark.java | 353 +++
.../indexing/OnheapIncrementalIndexBenchmark.java | 335 +++
.../benchmark/lookup/LookupBenchmarkUtil.java | 122 +
.../benchmark/lookup/LookupExtractorBenchmark.java | 133 +
.../lookup/SqlReverseLookupBenchmark.java | 156 ++
.../druid/benchmark/query/InPlanningBenchmark.java | 293 +++
.../apache/druid/benchmark/query/SqlBenchmark.java | 138 +-
.../benchmark/query/SqlExpressionBenchmark.java | 2 +-
.../benchmark/query/SqlNestedDataBenchmark.java | 4 +-
.../benchmark/query/SqlVsNativeBenchmark.java | 2 +-
cloud/aws-common/pom.xml | 2 +-
cloud/gcp-common/pom.xml | 2 +-
distribution/docker/docker-compose.yml | 10 +-
distribution/pom.xml | 10 +-
docs/_bin/broken-link-check.py | 101 -
docs/api-reference/legacy-metadata-api.md | 10 -
.../assets/spectator-histogram-size-comparison.png | Bin 0 -> 45331 bytes
docs/configuration/extensions.md | 2 +
docs/configuration/index.md | 4 +-
docs/data-management/delete.md | 14 +-
docs/data-management/index.md | 2 +-
docs/data-management/schema-changes.md | 2 +-
docs/data-management/update.md | 2 +-
docs/development/docs-contribute.md | 10 +-
docs/development/experimental-features.md | 2 +-
.../extensions-contrib/ddsketch-quantiles.md | 139 ++
docs/development/extensions-contrib/delta-lake.md | 44 +
.../extensions-contrib/spectator-histogram.md | 457 ++++
docs/development/extensions-core/azure.md | 1 +
.../extensions-core/kinesis-ingestion.md | 27 +-
.../extensions-core/lookups-cached-global.md | 2 +-
docs/ingestion/index.md | 2 +-
docs/ingestion/ingestion-spec.md | 8 +-
docs/ingestion/input-sources.md | 151 +-
docs/multi-stage-query/concepts.md | 6 +-
docs/multi-stage-query/known-issues.md | 5 -
docs/multi-stage-query/reference.md | 2 +-
docs/operations/basic-cluster-tuning.md | 2 +-
docs/operations/clean-metadata-store.md | 11 +-
docs/operations/mixed-workloads.md | 5 +-
docs/operations/rolling-updates.md | 12 +-
docs/operations/web-console.md | 2 +-
docs/querying/aggregations.md | 7 +-
docs/querying/dimensionspecs.md | 2 +-
docs/querying/lookups.md | 169 +-
docs/querying/query-context.md | 10 +-
docs/querying/sql-aggregations.md | 4 +-
docs/querying/sql-data-types.md | 2 +-
docs/querying/sql-metadata-tables.md | 6 +-
docs/querying/sql-operators.md | 7 +
docs/querying/sql-query-context.md | 5 +
docs/querying/sql.md | 125 +-
docs/release-info/upgrade-notes.md | 2 +-
.../druid/auto/_common/common.runtime.properties | 5 -
.../cluster/_common/common.runtime.properties | 5 -
.../large/_common/common.runtime.properties | 4 -
.../medium/_common/common.runtime.properties | 4 -
.../_common/common.runtime.properties | 4 -
.../_common/common.runtime.properties | 4 -
.../small/_common/common.runtime.properties | 4 -
.../xlarge/_common/common.runtime.properties | 4 -
extensions-contrib/aliyun-oss-extensions/pom.xml | 2 +-
extensions-contrib/ambari-metrics-emitter/pom.xml | 2 +-
extensions-contrib/cassandra-storage/pom.xml | 2 +-
extensions-contrib/cloudfiles-extensions/pom.xml | 2 +-
extensions-contrib/compressed-bigdecimal/pom.xml | 2 +-
.../CompressedBigDecimalSqlAggregatorTestBase.java | 2 +-
.../{tdigestsketch => ddsketch}/pom.xml | 51 +-
.../aggregation/ddsketch/DDSketchAggregator.java | 101 +
.../ddsketch/DDSketchAggregatorFactory.java | 336 +++
.../ddsketch/DDSketchBufferAggregator.java | 135 +
.../ddsketch/DDSketchComplexMetricSerde.java | 114 +
.../ddsketch/DDSketchJsonSerializer.java | 28 +-
.../query/aggregation/ddsketch/DDSketchModule.java | 74 +
.../ddsketch/DDSketchObjectStrategy.java | 73 +
.../ddsketch/DDSketchToQuantilePostAggregator.java | 159 ++
.../DDSketchToQuantilesPostAggregator.java | 172 ++
.../query/aggregation/ddsketch/DDSketchUtils.java | 97 +
.../org.apache.druid.initialization.DruidModule | 16 +
.../ddsketch/DDSketchAggregatorFactoryTest.java | 73 +
.../ddsketch/DDSketchAggregatorTest.java | 203 ++
.../DDSketchToQuantilePostAggregatorTest.java | 68 +
.../DDSketchToQuantilesPostAggregatorTest.java | 86 +
.../src/test/resources/doubles_build_data.tsv | 0
extensions-contrib/distinctcount/pom.xml | 2 +-
extensions-contrib/dropwizard-emitter/pom.xml | 2 +-
.../pom.xml | 98 +-
.../druid/delta/common/DeltaLakeDruidModule.java | 70 +
.../apache/druid/delta/input/DeltaInputRow.java | 208 ++
.../apache/druid/delta/input/DeltaInputSource.java | 261 ++
.../druid/delta/input/DeltaInputSourceReader.java | 138 +
.../org/apache/druid/delta/input/DeltaSplit.java | 71 +
.../apache/druid/delta/input/DeltaTimeUtils.java | 59 +
.../org/apache/druid/delta/input/RowSerde.java | 158 ++
.../org.apache.druid.initialization.DruidModule | 16 +
.../druid/delta/input/DeltaInputRowTest.java | 80 +
.../druid/delta/input/DeltaInputSourceTest.java | 256 ++
.../apache/druid/delta/input/DeltaTestUtils.java | 322 +++
.../druid/delta/input/DeltaTimeUtilsTest.java | 80 +
.../org/apache/druid/delta/input/RowSerdeTest.java | 43 +-
.../src/test/resources/README.md | 68 +
.../src/test/resources/create_delta_table.py | 122 +
...-4e49-b8e7-46132a57d039-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4dbc-90e5-de1d6a5b5ac6-c000.snappy.parquet.crc | Bin 0 -> 16 bytes
...-40f2-9185-45237f51b9bf-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4189-8927-97fe1720df8d-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4a5c-b504-62c7c27702c1-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-475a-afbb-44ae0b9cba30-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4145-ac40-6ccbc04acc79-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-43b7-87db-448c67a315df-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-444c-8984-6baecf6987ee-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-415f-b28a-a85d960ccb04-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-477d-b5fd-d00a857f7e54-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4092-8ea2-0ee576ca7327-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-45ab-92d4-24d725cc07e1-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4f1c-8c07-3dac19b12e91-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4c02-b256-bc890fadce7e-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
...-4f80-bd63-e369c6335699-c000.snappy.parquet.crc | Bin 0 -> 28 bytes
.../_delta_log/.00000000000000000000.json.crc | Bin 0 -> 72 bytes
.../_delta_log/.00000000000000000001.json.crc | Bin 0 -> 36 bytes
.../_delta_log/00000000000000000000.json | 13 +
.../_delta_log/00000000000000000001.json | 6 +
...0c50-4e49-b8e7-46132a57d039-c000.snappy.parquet | Bin 0 -> 2316 bytes
...c0df-4dbc-90e5-de1d6a5b5ac6-c000.snappy.parquet | Bin 0 -> 979 bytes
...db98-40f2-9185-45237f51b9bf-c000.snappy.parquet | Bin 0 -> 2316 bytes
...a2b2-4189-8927-97fe1720df8d-c000.snappy.parquet | Bin 0 -> 2301 bytes
...0232-4a5c-b504-62c7c27702c1-c000.snappy.parquet | Bin 0 -> 2455 bytes
...8ebd-475a-afbb-44ae0b9cba30-c000.snappy.parquet | Bin 0 -> 2317 bytes
...bb75-4145-ac40-6ccbc04acc79-c000.snappy.parquet | Bin 0 -> 2454 bytes
...54cb-43b7-87db-448c67a315df-c000.snappy.parquet | Bin 0 -> 2302 bytes
...c414-444c-8984-6baecf6987ee-c000.snappy.parquet | Bin 0 -> 2316 bytes
...5a9e-415f-b28a-a85d960ccb04-c000.snappy.parquet | Bin 0 -> 2302 bytes
...faaa-477d-b5fd-d00a857f7e54-c000.snappy.parquet | Bin 0 -> 2317 bytes
...e71e-4092-8ea2-0ee576ca7327-c000.snappy.parquet | Bin 0 -> 2455 bytes
...b81a-45ab-92d4-24d725cc07e1-c000.snappy.parquet | Bin 0 -> 2302 bytes
...2392-4f1c-8c07-3dac19b12e91-c000.snappy.parquet | Bin 0 -> 2455 bytes
...e177-4c02-b256-bc890fadce7e-c000.snappy.parquet | Bin 0 -> 2454 bytes
...aaec-4f80-bd63-e369c6335699-c000.snappy.parquet | Bin 0 -> 2324 bytes
.../src/test/resources/requirements.txt | 2 +
.../druid-iceberg-extensions/pom.xml | 2 +-
extensions-contrib/gce-extensions/pom.xml | 2 +-
extensions-contrib/graphite-emitter/pom.xml | 2 +-
extensions-contrib/influx-extensions/pom.xml | 2 +-
extensions-contrib/influxdb-emitter/pom.xml | 2 +-
extensions-contrib/kafka-emitter/pom.xml | 2 +-
.../apache/druid/emitter/kafka/KafkaEmitter.java | 10 +-
.../druid/emitter/kafka/KafkaEmitterConfig.java | 2 +
.../kafka/MemoryBoundLinkedBlockingQueue.java | 85 -
.../kubernetes-overlord-extensions/pom.xml | 2 +-
.../KubernetesAndWorkerTaskRunnerFactory.java | 24 +-
.../k8s/overlord/KubernetesOverlordModule.java | 25 +
.../KubernetesAndWorkerTaskRunnerFactoryTest.java | 55 +-
.../k8s/overlord/KubernetesOverlordModuleTest.java | 130 +
.../materialized-view-maintenance/pom.xml | 2 +-
.../materialized-view-selection/pom.xml | 2 +-
.../materializedview/DatasourceOptimizerTest.java | 7 +
extensions-contrib/momentsketch/pom.xml | 2 +-
extensions-contrib/moving-average-query/pom.xml | 2 +-
extensions-contrib/opentelemetry-emitter/pom.xml | 2 +-
extensions-contrib/opentsdb-emitter/pom.xml | 2 +-
extensions-contrib/prometheus-emitter/pom.xml | 2 +-
extensions-contrib/redis-cache/pom.xml | 2 +-
.../spectator-histogram}/pom.xml | 106 +-
.../spectator/histogram/NullableOffsetsHeader.java | 387 +++
.../spectator/histogram/SpectatorHistogram.java | 423 ++++
.../histogram/SpectatorHistogramAggregator.java | 103 +
.../SpectatorHistogramAggregatorFactory.java | 348 +++
.../SpectatorHistogramBufferAggregator.java | 131 +
.../SpectatorHistogramColumnPartSupplier.java | 35 +-
.../SpectatorHistogramComplexMetricSerde.java | 109 +
.../SpectatorHistogramIndexBasedComplexColumn.java | 130 +
.../histogram/SpectatorHistogramIndexed.java | 185 ++
.../SpectatorHistogramJsonSerializer.java | 41 +-
.../histogram/SpectatorHistogramModule.java | 91 +
.../SpectatorHistogramObjectStrategy.java | 38 +-
...SpectatorHistogramPercentilePostAggregator.java | 153 ++
...pectatorHistogramPercentilesPostAggregator.java | 155 ++
.../histogram/SpectatorHistogramSerializer.java | 112 +
.../org.apache.druid.initialization.DruidModule | 16 +
.../histogram/NullableOffsetsHeaderTest.java | 441 ++++
.../SpectatorHistogramAggregatorTest.java | 733 ++++++
.../histogram/SpectatorHistogramTest.java | 451 ++++
.../src/test/resources/input_data.tsv | 12 +
.../src/test/resources/pre_agg_data.tsv | 6 +
.../sqlserver-metadata-storage/pom.xml | 2 +-
extensions-contrib/statsd-emitter/pom.xml | 2 +-
extensions-contrib/tdigestsketch/pom.xml | 2 +-
.../sql/TDigestSketchSqlAggregatorTest.java | 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 +-
.../apache/druid/data/input/azure/AzureEntity.java | 17 +-
.../druid/data/input/azure/AzureEntityFactory.java | 7 +-
.../druid/data/input/azure/AzureInputSource.java | 7 +-
...ce.java => AzureStorageAccountInputSource.java} | 101 +-
.../AzureStorageAccountInputSourceConfig.java | 138 +
.../druid/storage/azure/AzureAccountConfig.java | 21 +-
.../druid/storage/azure/AzureByteSource.java | 2 +-
.../storage/azure/AzureByteSourceFactory.java | 6 +-
.../druid/storage/azure/AzureClientFactory.java | 47 +-
.../storage/azure/AzureCloudBlobIterable.java | 7 +-
.../azure/AzureCloudBlobIterableFactory.java | 2 +-
.../storage/azure/AzureCloudBlobIterator.java | 28 +-
.../azure/AzureCloudBlobIteratorFactory.java | 2 +-
.../storage/azure/AzureDataSegmentKiller.java | 52 +-
.../storage/azure/AzureDataSegmentPuller.java | 15 +-
.../storage/azure/AzureDataSegmentPusher.java | 5 +-
.../storage/azure/AzureIngestClientFactory.java | 78 +
.../apache/druid/storage/azure/AzureStorage.java | 86 +-
.../storage/azure/AzureStorageDruidModule.java | 20 +-
.../apache/druid/storage/azure/AzureTaskLogs.java | 30 +-
.../org/apache/druid/storage/azure/AzureUtils.java | 11 +-
.../druid/storage/azure/blob/CloudBlobHolder.java | 9 +-
.../azure/output/AzureStorageConnector.java | 5 +-
.../output/AzureStorageConnectorProvider.java | 2 +
.../druid/data/input/azure/AzureEntityTest.java | 70 +-
.../input/azure/AzureInputSourceSerdeTest.java | 6 +-
.../data/input/azure/AzureInputSourceTest.java | 15 +-
...ava => AzureStorageAccountInputSourceTest.java} | 164 +-
.../storage/azure/AzureClientFactoryTest.java | 26 +-
.../storage/azure/AzureCloudBlobIteratorTest.java | 142 +-
.../storage/azure/AzureDataSegmentKillerTest.java | 109 +-
.../storage/azure/AzureDataSegmentPullerTest.java | 20 +-
.../azure/AzureIngestClientFactoryTest.java | 190 ++
.../storage/azure/AzureStorageDruidModuleTest.java | 61 +-
.../druid/storage/azure/AzureStorageTest.java | 120 +-
.../druid/storage/azure/AzureTaskLogsTest.java | 111 +-
.../apache/druid/storage/azure/AzureTestUtils.java | 6 +-
.../apache/druid/storage/azure/AzureUtilsTest.java | 18 +-
.../azure/output/AzureStorageConnectorTest.java | 37 +-
extensions-core/datasketches/pom.xml | 2 +-
.../hll/sql/HllSketchSqlAggregatorTest.java | 62 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 2 +-
.../theta/sql/ThetaSketchSqlAggregatorTest.java | 2 +-
.../sql/ArrayOfDoublesSketchSqlAggregatorTest.java | 2 +-
extensions-core/druid-aws-rds-extensions/pom.xml | 2 +-
extensions-core/druid-basic-security/pom.xml | 2 +-
.../druid/security/basic/BasicAuthUtils.java | 34 -
.../basic/authentication/LdapUserPrincipal.java | 7 +-
.../entity/BasicAuthenticatorCredentials.java | 3 +-
.../validator/LDAPCredentialsValidator.java | 4 +-
.../MetadataStoreCredentialsValidator.java | 4 +-
.../validator/PasswordHashGenerator.java | 163 ++
.../apache/druid/security/BasicAuthUtilsTest.java | 12 -
...sicAuthenticatorMetadataStorageUpdaterTest.java | 3 +-
.../CoordinatorBasicAuthenticatorResourceTest.java | 9 +-
.../validator/PasswordHashGeneratorTest.java | 70 +
extensions-core/druid-bloom-filter/pom.xml | 2 +-
.../bloom/sql/BloomFilterSqlAggregatorTest.java | 2 +-
extensions-core/druid-catalog/pom.xml | 2 +-
extensions-core/druid-kerberos/pom.xml | 2 +-
extensions-core/druid-pac4j/pom.xml | 11 +-
.../apache/druid/security/pac4j/Pac4jFilter.java | 23 +-
.../druid/security/pac4j/Pac4jSessionStore.java | 2 +-
.../druid/security/pac4j/Pac4jFilterTest.java | 77 +
extensions-core/druid-ranger-security/pom.xml | 2 +-
extensions-core/ec2-extensions/pom.xml | 2 +-
extensions-core/google-extensions/pom.xml | 2 +-
extensions-core/hdfs-storage/pom.xml | 2 +-
extensions-core/histogram/pom.xml | 2 +-
...dBucketsHistogramQuantileSqlAggregatorTest.java | 2 +-
.../histogram/sql/QuantileSqlAggregatorTest.java | 2 +-
extensions-core/kafka-extraction-namespace/pom.xml | 2 +-
extensions-core/kafka-indexing-service/pom.xml | 2 +-
.../data/input/kafkainput/KafkaInputFormat.java | 5 +-
.../indexing/kafka/KafkaDataSourceMetadata.java | 20 +-
.../input/kafkainput/KafkaInputFormatTest.java | 10 +-
.../kafka/supervisor/KafkaSupervisorTest.java | 24 +-
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../druid/indexing/kinesis/KinesisIndexTask.java | 69 +-
.../indexing/kinesis/KinesisIndexTaskIOConfig.java | 56 +-
.../kinesis/KinesisIndexTaskTuningConfig.java | 63 +-
.../indexing/kinesis/KinesisRecordSupplier.java | 168 +-
.../druid/indexing/kinesis/KinesisSamplerSpec.java | 6 +-
.../kinesis/supervisor/KinesisSupervisor.java | 10 +-
.../supervisor/KinesisSupervisorIOConfig.java | 4 +-
.../supervisor/KinesisSupervisorTuningConfig.java | 15 +-
.../indexing/kinesis/KinesisIOConfigTest.java | 42 +-
.../kinesis/KinesisIndexTaskSerdeTest.java | 6 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 33 +-
.../kinesis/KinesisIndexTaskTuningConfigTest.java | 24 +-
.../kinesis/KinesisRecordSupplierTest.java | 212 +-
.../supervisor/KinesisSupervisorIOConfigTest.java | 8 +-
.../kinesis/supervisor/KinesisSupervisorTest.java | 135 +-
.../TestModifiedKinesisIndexTaskTuningConfig.java | 6 +
extensions-core/kubernetes-extensions/pom.xml | 2 +-
extensions-core/lookups-cached-global/pom.xml | 7 +-
.../lookup/NamespaceLookupExtractorFactory.java | 18 +-
.../lookup/NamespaceLookupIntrospectHandler.java | 3 +-
.../lookup/namespace/cache/CacheHandler.java | 10 +
.../lookup/namespace/cache/CacheScheduler.java | 10 +
.../cache/NamespaceExtractionCacheManager.java | 12 +
.../OffHeapNamespaceExtractionCacheManager.java | 23 +-
.../OnHeapNamespaceExtractionCacheManager.java | 37 +-
.../NamespaceLookupExtractorFactoryTest.java | 17 +-
extensions-core/lookups-cached-single/pom.xml | 2 +-
.../apache/druid/server/lookup/LoadingLookup.java | 19 +-
.../apache/druid/server/lookup/PollingLookup.java | 19 +-
.../lookup/cache/polling/OnHeapPollingCache.java | 8 +-
.../druid/server/lookup/LoadingLookupTest.java | 8 +-
.../druid/server/lookup/PollingLookupTest.java | 8 +-
extensions-core/multi-stage-query/pom.xml | 2 +-
.../org/apache/druid/msq/exec/ControllerImpl.java | 15 +-
.../msq/indexing/CountableInputSourceReader.java | 7 +
.../msq/indexing/error/InvalidNullByteFault.java | 2 +-
.../druid/msq/input/external/ExternalSegment.java | 3 +-
.../apache/druid/msq/querykit/QueryKitUtils.java | 5 +-
.../groupby/GroupByPostShuffleFrameProcessor.java | 31 +-
.../msq/querykit/groupby/GroupByQueryKit.java | 99 +-
.../druid/msq/util/MultiStageQueryContext.java | 7 +
.../msq/util/PassthroughAggregatorFactory.java | 7 -
.../druid/msq/util/SqlStatementResourceHelper.java | 20 +-
.../druid/msq/exec/MSQLoadedSegmentTests.java | 2 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 139 +-
.../resources/SqlMSQStatementResourcePostTest.java | 60 +-
.../druid/msq/test/CalciteArraysQueryMSQTest.java | 21 +-
.../druid/msq/test/CalciteMSQTestsHelper.java | 3 +
.../msq/test/CalciteSelectJoinQueryMSQTest.java | 21 +-
.../druid/msq/test/CalciteSelectQueryMSQTest.java | 18 +-
.../druid/msq/test/CalciteUnionQueryMSQTest.java | 20 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 4 +-
.../druid/msq/test/MSQTestTaskActionClient.java | 24 -
.../druid/msq/util/MultiStageQueryContextTest.java | 18 +
.../msq/util/SqlStatementResourceHelperTest.java | 193 +-
extensions-core/mysql-metadata-storage/pom.xml | 2 +-
extensions-core/orc-extensions/pom.xml | 2 +-
extensions-core/parquet-extensions/pom.xml | 2 +-
.../parquet/simple/ParquetGroupConverter.java | 8 +-
.../input/parquet/DecimalParquetInputTest.java | 95 +-
.../input/parquet/DecimalParquetReaderTest.java | 102 +-
.../postgresql-metadata-storage/pom.xml | 2 +-
extensions-core/protobuf-extensions/pom.xml | 2 +-
extensions-core/s3-extensions/pom.xml | 2 +-
extensions-core/simple-client-sslcontext/pom.xml | 2 +-
extensions-core/stats/pom.xml | 2 +-
.../variance/StandardDeviationPostAggregator.java | 6 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 2 +-
extensions-core/testing-tools/pom.xml | 2 +-
indexing-hadoop/pom.xml | 2 +-
.../org/apache/druid/indexer/InputRowSerde.java | 7 +-
indexing-service/pom.xml | 2 +-
.../ActionBasedUsedSegmentChecker.java | 3 +-
.../apache/druid/indexing/common/TaskToolbox.java | 22 +-
.../druid/indexing/common/TaskToolboxFactory.java | 7 +-
.../actions/RetrieveSegmentsToReplaceAction.java | 202 --
.../actions/RetrieveUnusedSegmentsAction.java | 18 +-
.../common/actions/RetrieveUsedSegmentsAction.java | 96 +-
.../druid/indexing/common/actions/TaskAction.java | 1 -
.../druid/indexing/common/actions/TaskLocks.java | 7 +
.../druid/indexing/common/config/TaskConfig.java | 27 +-
.../common/task/AbstractBatchIndexTask.java | 14 +-
.../task/AppenderatorDriverRealtimeIndexTask.java | 3 +-
.../druid/indexing/common/task/ArchiveTask.java | 2 +-
.../druid/indexing/common/task/CompactionTask.java | 7 +-
.../common/task/KillUnusedSegmentsTask.java | 39 +-
.../druid/indexing/common/task/MoveTask.java | 2 +-
.../indexing/common/task/RealtimeIndexTask.java | 11 +
.../druid/indexing/common/task/RestoreTask.java | 2 +-
.../apache/druid/indexing/common/task/Tasks.java | 2 +
.../task/batch/parallel/TombstoneHelper.java | 5 +-
.../druid/indexing/input/DruidInputSource.java | 9 +-
.../overlord/IndexerMetadataStorageAdapter.java | 39 +-
.../druid/indexing/overlord/TaskLockbox.java | 220 +-
.../apache/druid/indexing/overlord/TaskMaster.java | 2 +-
.../indexing/overlord/http/OverlordResource.java | 21 +-
.../seekablestream/RecordSupplierInputSource.java | 2 +-
.../SeekableStreamEndSequenceNumbers.java | 33 +
.../seekablestream/SeekableStreamIndexTask.java | 3 +-
.../SeekableStreamSequenceNumbers.java | 8 +
.../SeekableStreamStartSequenceNumbers.java | 33 +
.../seekablestream/SettableByteEntityReader.java | 2 +-
.../ActionBasedUsedSegmentCheckerTest.java | 7 +-
.../druid/indexing/common/TaskToolboxTest.java | 4 +-
.../actions/RetrieveSegmentsActionsTest.java | 23 +-
.../RetrieveUsedSegmentsActionSerdeTest.java | 4 +-
.../SegmentTransactionalInsertActionTest.java | 6 +-
.../indexing/common/actions/TaskLocksTest.java | 11 +
.../indexing/common/config/TaskConfigBuilder.java | 16 +-
.../AppenderatorDriverRealtimeIndexTaskTest.java | 4 +-
...ClientKillUnusedSegmentsTaskQuerySerdeTest.java | 37 +-
.../indexing/common/task/CompactionTaskTest.java | 20 +-
.../druid/indexing/common/task/IndexTaskTest.java | 36 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 495 +++-
.../common/task/RealtimeIndexTaskTest.java | 4 +-
.../common/task/TestAppenderatorsManager.java | 8 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 5 +-
.../concurrent/ConcurrentReplaceAndAppendTest.java | 41 +-
.../IndexerMetadataStorageAdapterTest.java | 75 +-
.../overlord/SingleTaskBackgroundRunnerTest.java | 4 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 25 +-
.../druid/indexing/overlord/TaskLockboxTest.java | 219 +-
.../indexing/overlord/TestTaskToolboxFactory.java | 10 +-
.../overlord/http/OverlordResourceTest.java | 138 +-
.../overlord/sampler/InputSourceSamplerTest.java | 4 +-
.../SeekableStreamEndSequenceNumbersTest.java | 37 +
.../SeekableStreamIndexTaskTestBase.java | 4 +-
.../SeekableStreamStartSequenceNumbersTest.java | 41 +
.../indexing/test/TestDataSegmentAnnouncer.java | 10 +
.../TestIndexerMetadataStorageCoordinator.java | 34 +-
.../indexing/worker/WorkerTaskManagerTest.java | 4 +-
.../indexing/worker/WorkerTaskMonitorTest.java | 4 +-
integration-tests-ex/cases/pom.xml | 2 +-
.../apache/druid/testsEx/config/Initializer.java | 4 +-
.../AbstractCloudInputSourceParallelIndexTest.java | 6 +
.../indexer/ITAzureV2ParallelIndexTest.java | 52 +
.../msq/ITAzureV2SQLBasedIngestionTest.java | 57 +
integration-tests-ex/image/pom.xml | 2 +-
integration-tests-ex/tools/pom.xml | 2 +-
...ocker-compose.centralized-datasource-schema.yml | 2 +
integration-tests/pom.xml | 2 +-
.../security/ITBasicAuthConfigurationTest.java | 15 +
licenses.yaml | 20 +-
owasp-dependency-check-suppressions.xml | 21 +
pom.xml | 15 +-
processing/pom.xml | 6 +-
.../apache/druid/common/config/NullHandling.java | 5 +-
.../org/apache/druid/data/input/InputFormat.java | 13 +
.../apache/druid/data/input/InputSourceReader.java | 10 +
.../data/input/IntermediateRowParsingReader.java | 30 +-
.../apache/druid/data/input/ListBasedInputRow.java | 208 ++
.../druid/data/input/ListBasedInputRowAdapter.java | 60 +
.../apache/druid/data/input/MapBasedInputRow.java | 2 +-
.../java/org/apache/druid/data/input/Rows.java | 89 +-
.../org/apache/druid/data/input/TextReader.java | 73 +-
.../druid/data/input/impl/CsvInputFormat.java | 4 +-
.../druid/data/input/impl/DelimitedBytes.java | 67 +
.../data/input/impl/DelimitedInputFormat.java | 26 +-
.../data/input/impl/DelimitedValueReader.java | 96 +-
.../druid/data/input/impl/FastLineIterator.java | 231 +-
.../druid/data/input/impl/FlatTextInputFormat.java | 63 +-
.../input/impl/InputEntityIteratingReader.java | 7 +
.../druid/data/input/impl/JsonInputFormat.java | 21 +
.../druid/data/input/impl/JsonLineReader.java | 8 +-
.../druid/data/input/impl/MapInputRowParser.java | 54 +-
.../apache/druid/data/input/impl/RegexReader.java | 2 +-
.../input/impl/TimedShutoffInputSourceReader.java | 7 +
.../org/apache/druid/error/InvalidSqlInput.java | 6 +
.../druid/frame/key/FrameComparisonWidgetImpl.java | 18 +-
.../druid/frame/processor/FrameChannelMerger.java | 70 +-
.../druid/frame/processor/TournamentTree.java | 213 ++
.../apache/druid/frame/read/FrameReaderUtils.java | 43 +-
.../apache/druid/jackson/DefaultObjectMapper.java | 4 +-
.../apache/druid/java/util/common/Intervals.java | 8 +-
.../common/MemoryBoundLinkedBlockingQueue.java | 211 ++
.../apache/druid/java/util/common/StringUtils.java | 6 -
.../parsers/AbstractFlatTextFormatParser.java | 2 +-
.../main/java/org/apache/druid/math/expr/Expr.java | 10 +-
.../java/org/apache/druid/query/CacheStrategy.java | 13 +-
.../java/org/apache/druid/query/QueryContexts.java | 2 +-
.../druid/query/aggregation/AggregatorUtil.java | 8 +
...zablePairLongStringDeltaEncodedStagedSerde.java | 18 +-
...erializablePairLongStringSimpleStagedSerde.java | 18 +-
.../cardinality/CardinalityAggregator.java | 8 +-
.../hyperloglog/HyperUniquesAggregator.java | 8 +-
.../query/aggregation/post/PostAggregatorIds.java | 4 +
.../druid/query/extraction/MapLookupExtractor.java | 54 +-
.../org/apache/druid/query/filter/InDimFilter.java | 25 +-
.../apache/druid/query/groupby/GroupingEngine.java | 191 +-
.../groupby/epinephelinae/BufferArrayGrouper.java | 2 +-
...unnerV2.java => GroupByMergingQueryRunner.java} | 8 +-
...yQueryEngineV2.java => GroupByQueryEngine.java} | 269 +-
...ByBinaryFnV2.java => GroupByResultMergeFn.java} | 4 +-
.../groupby/epinephelinae/GroupByRowProcessor.java | 2 +-
.../epinephelinae/RowBasedGrouperHelper.java | 2 +-
.../epinephelinae/vector/VectorGroupByEngine.java | 119 +-
.../druid/query/lookup/ImmutableLookupMap.java | 261 ++
.../apache/druid/query/lookup/LookupExtractor.java | 32 +-
.../apache/druid/query/lookup/LookupSegment.java | 8 +-
.../druid/query/operator/window/WindowFrame.java | 59 +-
.../window/WindowFramedAggregateProcessor.java | 30 +-
.../query/rowsandcols/ArrayListRowsAndColumns.java | 70 +-
.../rowsandcols/LazilyDecoratedRowsAndColumns.java | 4 +-
.../rowsandcols/MapOfColumnsRowsAndColumns.java | 13 -
.../concrete/QueryableIndexRowsAndColumns.java | 22 +-
.../semantic/DefaultFramedOnHeapAggregatable.java | 310 ++-
.../segment/DoubleWrappingDimensionSelector.java | 8 +-
.../segment/FloatWrappingDimensionSelector.java | 8 +-
.../segment/LongWrappingDimensionSelector.java | 8 +-
.../segment/RowBasedColumnSelectorFactory.java | 83 +-
.../druid/segment/RowBasedStorageAdapter.java | 5 +-
.../segment/generator/GeneratorBasicSchemas.java | 21 +
.../segment/generator/GeneratorSchemaInfo.java | 13 +
.../segment/incremental/IncrementalIndex.java | 116 +-
.../incremental/OnheapIncrementalIndex.java | 133 +-
.../segment/join/lookup/LookupJoinMatcher.java | 10 +-
.../druid/segment/join/lookup/LookupJoinable.java | 4 +-
.../segment/nested/NestedDataColumnSupplier.java | 15 +-
.../segment/nested/NestedPathArrayElement.java | 12 +-
.../serde/NestedCommonFormatColumnPartSerde.java | 9 +
.../segment/virtual/NestedFieldVirtualColumn.java | 7 +-
.../timeline/partition/OvershadowableManager.java | 13 +-
.../java/org/apache/druid/TestObjectMapper.java | 70 -
.../druid/data/input/impl/CsvReaderTest.java | 52 +-
.../druid/data/input/impl/DelimitedBytesTest.java | 88 +
.../data/input/impl/DelimitedParseSpecTest.java | 4 +-
.../data/input/impl/FastLineIteratorTest.java | 70 +-
.../data/input/impl/InputRowParserSerdeTest.java | 4 +-
.../druid/data/input/impl/JSONParseSpecTest.java | 4 +-
.../druid/data/input/impl/JSONPathSpecTest.java | 4 +-
.../data/input/impl/JavaScriptParseSpecTest.java | 4 +-
.../druid/data/input/impl/JsonInputFormatTest.java | 60 +
.../druid/data/input/impl/RegexParseSpecTest.java | 4 +-
.../druid/frame/processor/TournamentTreeTest.java | 196 ++
.../apache/druid/guice/JsonConfiguratorTest.java | 24 +-
.../apache/druid/indexer/TaskStatusPlusTest.java | 57 +-
.../druid/java/util/common/IntervalsTest.java | 8 +
.../common/MemoryBoundLinkedBlockingQueueTest.java | 319 +++
.../emitter/core/HttpPostEmitterStressTest.java | 4 +-
.../java/util/metrics/StubServiceEmitter.java | 5 +
.../druid/query/DefaultQueryMetricsTest.java | 69 +-
.../query/aggregation/AggregationTestHelper.java | 4 +-
...ePairLongStringDeltaEncodedStagedSerdeTest.java | 270 ++
...lizablePairLongStringSimpleStagedSerdeTest.java | 195 ++
...ePairLongStringDeltaEncodedStagedSerdeTest.java | 13 +
...lizablePairLongStringSimpleStagedSerdeTest.java | 6 +
.../extraction/MapBasedLookupExtractorTest.java | 234 ++
.../query/extraction/MapLookupExtractorTest.java | 124 +-
.../apache/druid/query/filter/InDimFilterTest.java | 21 +-
.../groupby/DefaultGroupByQueryMetricsTest.java | 15 +-
.../query/groupby/NestedGroupByArrayQueryTest.java | 3 +-
...gineV2Test.java => GroupByQueryEngineTest.java} | 18 +-
.../LimitedBufferHashGrouperTest.java | 2 +-
.../ImmutableLookupMapTest.java} | 40 +-
.../window/WindowFramedAggregateProcessorTest.java | 13 +-
.../DefaultFramedOnHeapAggregatableTest.java | 52 +
.../semantic/FramedOnHeapAggregatableTest.java | 166 +-
.../semantic/SemanticCreatorUsageTest.java | 110 +
.../druid/query/scan/NestedDataScanQueryTest.java | 186 ++
.../search/DefaultSearchQueryMetricsTest.java | 15 +-
.../DefaultTimeseriesQueryMetricsTest.java | 15 +-
.../query/topn/DefaultTopNQueryMetricsTest.java | 15 +-
.../druid/segment/RowBasedStorageAdapterTest.java | 14 +-
.../segment/WrappingDimensionSelectorTest.java | 139 ++
.../druid/segment/data/IncrementalIndexTest.java | 71 +-
.../druid/segment/filter/BaseFilterTest.java | 1 +
.../druid/segment/filter/EqualityFilterTests.java | 10 +
.../druid/segment/generator/DataGeneratorTest.java | 1 -
.../segment/generator/GeneratorSchemaInfoTest.java | 39 +-
.../incremental/IncrementalIndexIngestionTest.java | 152 --
.../IncrementalIndexStorageAdapterTest.java | 123 +-
.../OnheapIncrementalIndexBenchmark.java | 428 ----
.../segment/join/lookup/LookupJoinableTest.java | 42 +-
.../segment/join/table/LookupJoinMatcherTest.java | 6 +-
.../druid/segment/nested/NestedPathFinderTest.java | 16 +-
.../org/apache/druid/timeline/DataSegmentTest.java | 4 +-
.../druid/timeline/SegmentStatusInClusterTest.java | 4 +-
.../timeline/partition/NoneShardSpecTest.java | 12 +-
server/pom.xml | 2 +-
.../org/apache/druid/client/BrokerServerView.java | 7 +
.../druid/client/CachingClusteredClient.java | 6 +-
.../apache/druid/client/CoordinatorServerView.java | 8 +
.../FilteredServerInventoryViewProvider.java | 7 +-
.../druid/client/FilteringSegmentCallback.java | 7 +
.../druid/client/HttpServerInventoryView.java | 5 +
.../druid/client/ServerInventoryViewProvider.java | 7 +-
.../java/org/apache/druid/client/ServerView.java | 15 +
.../apache/druid/client/TimelineServerView.java | 11 +
.../ClientKillUnusedSegmentsTaskQuery.java | 35 +-
.../apache/druid/guice/DruidInjectorBuilder.java | 4 +-
.../org/apache/druid/guice/ServerViewModule.java | 21 +-
.../druid/guice/http/DruidHttpClientConfig.java | 7 +-
.../apache/druid/guice/http/HttpClientModule.java | 16 +-
.../IndexerMetadataStorageCoordinator.java | 23 +-
.../druid/initialization/CoreInjectorBuilder.java | 4 +-
.../initialization/ServerInjectorBuilder.java | 2 +-
.../initialization/ServiceInjectorBuilder.java | 7 -
.../IndexerSQLMetadataStorageCoordinator.java | 57 +-
.../druid/metadata/SegmentsMetadataManager.java | 31 +-
.../druid/metadata/SqlSegmentsMetadataManager.java | 19 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 267 +-
.../query/lookup/LookupReferencesManager.java | 6 +-
.../apache/druid/rpc/indexing/OverlordClient.java | 34 +-
.../metadata/AbstractSegmentMetadataCache.java | 59 +-
.../CentralizedDatasourceSchemaConfig.java | 64 +
.../metadata/CoordinatorSegmentMetadataCache.java | 196 +-
.../realtime/appenderator/Appenderators.java | 11 +-
.../appenderator/AppenderatorsManager.java | 4 +-
.../appenderator/BaseAppenderatorDriver.java | 218 +-
.../DefaultRealtimeAppenderatorFactory.java | 4 +-
.../DummyForInjectionAppenderatorsManager.java | 4 +-
.../appenderator/PeonAppenderatorsManager.java | 8 +-
.../realtime/appenderator/SegmentSchemas.java | 186 ++
.../appenderator/SinkQuerySegmentWalker.java | 303 +--
.../realtime/appenderator/SinkSchemaUtil.java | 165 ++
.../realtime/appenderator/StreamAppenderator.java | 94 +-
.../appenderator/StreamAppenderatorDriver.java | 8 +-
.../UnifiedIndexerAppenderatorsManager.java | 8 +-
.../segment/realtime/plumber/FlushingPlumber.java | 1 -
.../segment/realtime/plumber/RealtimePlumber.java | 4 -
.../realtime/plumber/RealtimePlumberSchool.java | 1 -
.../druid/segment/realtime/plumber/Sink.java | 96 +-
.../server/AsyncManagementForwardingServlet.java | 18 +-
.../coordination/BatchDataSegmentAnnouncer.java | 43 +-
.../server/coordination/DataSegmentAnnouncer.java | 21 +
.../coordination/DataSegmentChangeRequest.java | 3 +-
.../coordination/NoopDataSegmentAnnouncer.java | 11 +
...uncer.java => SegmentSchemasChangeRequest.java} | 30 +-
.../CachingCostBalancerStrategyFactory.java | 7 +
.../compact/NewestSegmentFirstIterator.java | 6 +
.../coordinator/duty/KillUnusedSegments.java | 117 +-
.../apache/druid/server/http/DataSegmentPlus.java | 113 +
.../druid/server/http/DataSourcesResource.java | 59 +-
.../apache/druid/server/http/MetadataResource.java | 10 +-
.../druid/server/initialization/ServerConfig.java | 6 +-
.../apache/druid/client/BrokerServerViewTest.java | 7 +
.../druid/client/CoordinatorServerViewTest.java | 13 +
.../druid/client/HttpServerInventoryViewTest.java | 7 +
.../ClientKillUnusedSegmentsTaskQueryTest.java | 3 +-
.../IndexerSQLMetadataStorageCoordinatorTest.java | 485 +++-
.../metadata/SqlSegmentsMetadataManagerTest.java | 38 -
.../LookupEnabledTestExprMacroTable.java | 118 +-
.../query/lookup/LookupReferencesManagerTest.java | 30 +
.../druid/rpc/indexing/OverlordClientImplTest.java | 1 +
...CoordinatorSegmentDataCacheConcurrencyTest.java | 25 +-
.../CoordinatorSegmentMetadataCacheTest.java | 331 ++-
.../metadata/TestCoordinatorServerView.java | 8 +
.../realtime/appenderator/SinkSchemaUtilTest.java | 285 +++
.../appenderator/StreamAppenderatorTest.java | 235 ++
.../appenderator/StreamAppenderatorTester.java | 40 +-
.../druid/segment/realtime/plumber/SinkTest.java | 130 +
.../AsyncManagementForwardingServletTest.java | 54 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 8 +-
.../java/org/apache/druid/server/EtagProvider.java | 68 +
.../org/apache/druid/server/QueryResourceTest.java | 3 +-
.../apache/druid/server/QuerySchedulerTest.java | 19 +-
.../org/apache/druid/server/QueryStackTests.java | 76 +-
.../server/SpecificSegmentsQuerySegmentWalker.java | 62 +-
.../server/TestClusterQuerySegmentWalker.java | 12 +-
.../coordination/SegmentLoadDropHandlerTest.java | 12 +-
.../BatchDataSegmentAnnouncerTest.java | 95 +
.../coordinator/CuratorDruidCoordinatorTest.java | 7 +
.../compact/NewestSegmentFirstPolicyTest.java | 113 +
.../coordinator/duty/KillUnusedSegmentsTest.java | 56 +-
.../simulate/TestSegmentsMetadataManager.java | 5 +-
.../druid/server/http/DataSegmentPlusTest.java | 149 ++
.../druid/server/http/DataSourcesResourceTest.java | 35 +-
.../druid/server/http/MetadataResourceTest.java | 37 +-
.../metrics/ExceptionCapturingServiceEmitter.java | 72 -
.../sql/calcite/util/CacheTestHelperModule.java | 121 +
services/pom.xml | 2 +-
.../java/org/apache/druid/cli/CliCoordinator.java | 27 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 27 +
.../druid/server/router/QueryHostFinder.java | 12 +-
sql/pom.xml | 2 +-
.../sql/type/CastedLiteralOperandTypeCheckers.java | 24 -
.../builtin/EarliestLatestAnySqlAggregator.java | 30 +-
.../builtin/EarliestLatestBySqlAggregator.java | 3 -
.../expression/AliasedOperatorConversion.java | 2 -
.../druid/sql/calcite/expression/Expressions.java | 12 +-
.../UnaryFunctionOperatorConversion.java | 64 -
.../builtin/ConcatOperatorConversion.java | 2 +-
.../builtin/DateTruncOperatorConversion.java | 13 +-
.../MultiValueStringOperatorConversions.java | 13 +-
.../builtin/QueryLookupOperatorConversion.java | 19 +-
.../builtin/TextcatOperatorConversion.java | 2 +-
.../druid/sql/calcite/filtration/RangeValue.java | 5 -
.../druid/sql/calcite/filtration/Ranges.java | 41 +-
.../sql/calcite/planner/CalciteRulesManager.java | 155 +-
.../sql/calcite/planner/DruidOperatorTable.java | 15 +-
.../druid/sql/calcite/planner/DruidTypeSystem.java | 2 -
.../druid/sql/calcite/planner/PlannerContext.java | 85 +-
.../sql/calcite/planner/PlannerLookupCache.java | 62 +
.../druid/sql/calcite/planner/QueryHandler.java | 14 +-
.../planner/UnsupportedSQLQueryException.java | 38 -
.../apache/druid/sql/calcite/rel/DruidQuery.java | 24 +-
.../apache/druid/sql/calcite/rel/Windowing.java | 8 +-
.../calcite/rule/AggregatePullUpLookupRule.java | 125 +
.../calcite/rule/FilterDecomposeConcatRule.java | 305 +++
.../druid/sql/calcite/rule/FlattenConcatRule.java | 133 +
.../druid/sql/calcite/rule/ReverseLookupRule.java | 678 +++++
.../calcite/schema/BrokerSegmentMetadataCache.java | 7 +
.../druid/query/OperatorFactoryBuilders.java | 8 +
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 16 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 21 +-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 3 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 12 +-
.../calcite/CalciteLookupFunctionQueryTest.java | 2083 +++++++++++++++
.../calcite/CalciteMultiValueStringQueryTest.java | 25 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 2 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 1082 +++++---
.../druid/sql/calcite/CalciteSelectQueryTest.java | 6 +-
.../druid/sql/calcite/CalciteSimpleQueryTest.java | 2 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 50 -
.../apache/druid/sql/calcite/NotYetSupported.java | 9 +-
.../druid/sql/calcite/SqlTestFrameworkConfig.java | 51 +-
.../calcite/SqlVectorizedExpressionSanityTest.java | 2 +-
.../sql/calcite/expression/ExpressionsTest.java | 21 +-
.../rule/FilterDecomposeConcatRuleTest.java | 388 +++
.../schema/BrokerSegmentMetadataCacheCommon.java | 2 +-
.../BrokerSegmentMetadataCacheConcurrencyTest.java | 15 +-
.../schema/BrokerSegmentMetadataCacheTest.java | 8 +
.../calcite/schema/DruidSchemaNoDataInitTest.java | 2 +-
.../druid/sql/calcite/schema/SystemSchemaTest.java | 2 +-
.../calcite/util/CalciteTestInjectorBuilder.java | 63 -
.../druid/sql/calcite/util/CalciteTests.java | 11 +-
.../druid/sql/calcite/util/LookylooModule.java | 60 +-
.../druid/sql/calcite/util/SqlTestFramework.java | 20 +-
.../druid/sql/calcite/util/TestDataBuilder.java | 70 +-
.../druid/sql/calcite/util/TestLookupProvider.java | 58 +
.../sql/calcite/util/TestTimelineServerView.java | 7 +
.../org/apache/druid/sql/http/SqlResourceTest.java | 10 +-
.../calcite/tests/window/range_handling.sqlTest | 24 +
.../calcite/tests/window/simpleSum.sqlTest | 8 +-
.../wikipediaAggregationsMultipleOrdering.sqlTest | 10 +-
.../window/wikipediaCumulativeOrdered.sqlTest | 50 +-
.../window/wikipediaFramedAggregations.sqlTest | 8 +-
.../tests/window/windowed_long_null.sqlTest | 2 +-
web-console/assets/delta.png | Bin 0 -> 26090 bytes
web-console/package-lock.json | 18 +-
web-console/package.json | 4 +-
web-console/pom.xml | 2 +-
web-console/script/create-sql-docs.js | 12 +-
web-console/src/blueprint-overrides/_index.scss | 1 +
.../_special-switch-modes.scss} | 24 +-
.../__snapshots__/array-mode-swtich.spec.tsx.snap | 47 +
.../array-mode-switch/array-mode-switch.tsx | 62 +
.../array-mode-switch/array-mode-swtich.spec.tsx} | 8 +-
web-console/src/components/auto-form/auto-form.tsx | 11 +-
web-console/src/components/index.ts | 1 +
.../__snapshots__/warning-checklist.spec.tsx.snap | 6 +-
.../warning-checklist/warning-checklist.tsx | 2 +-
.../compaction-config-dialog.spec.tsx.snap | 2640 ++++++++++----------
.../compaction-config-dialog.tsx | 27 +-
.../compaction-config/compaction-config.tsx | 9 -
.../druid-models/dimension-spec/dimension-spec.ts | 128 +-
.../execution/execution-ingest-complete.mock.ts | 72 +-
.../execution/execution-ingest-error.mock.ts | 61 +-
.../src/druid-models/execution/execution.spec.ts | 66 +-
.../src/druid-models/execution/execution.ts | 59 +-
.../external-config/external-config.ts | 10 +-
.../ingest-query-pattern.spec.ts | 139 +-
.../ingest-query-pattern/ingest-query-pattern.ts | 23 +-
.../ingestion-spec/ingestion-spec.spec.ts | 311 ++-
.../druid-models/ingestion-spec/ingestion-spec.tsx | 226 +-
.../src/druid-models/input-source/input-source.tsx | 36 +-
.../src/druid-models/metric-spec/metric-spec.tsx | 30 +-
.../druid-models/query-context/query-context.tsx | 1 +
web-console/src/druid-models/stages/stages.mock.ts | 1000 +++++---
web-console/src/druid-models/stages/stages.spec.ts | 474 ++--
web-console/src/druid-models/stages/stages.ts | 5 +-
web-console/src/druid-models/task/task.ts | 20 +
.../druid-models/timestamp-spec/timestamp-spec.tsx | 2 +-
.../workbench-query/workbench-query.spec.ts | 5 +
.../workbench-query/workbench-query.ts | 22 +-
.../__snapshots__/spec-conversion.spec.ts.snap | 23 +
web-console/src/helpers/execution/general.ts | 8 +-
.../src/helpers/execution/sql-task-execution.ts | 81 +-
web-console/src/helpers/spec-conversion.spec.ts | 79 +
web-console/src/helpers/spec-conversion.ts | 148 +-
web-console/src/react-table/react-table-extra.scss | 4 +
web-console/src/utils/index.tsx | 1 +
web-console/src/utils/null-mode-detection.ts | 154 ++
web-console/src/utils/object-change.ts | 8 +-
web-console/src/utils/sample-query.tsx | 30 +-
web-console/src/utils/sql.spec.ts | 70 +-
web-console/src/utils/sql.ts | 17 +-
.../__snapshots__/home-view.spec.tsx.snap | 36 +-
web-console/src/views/home-view/home-view.tsx | 2 +-
.../home-view/status-card/status-card.spec.tsx | 4 +-
.../views/home-view/status-card/status-card.tsx | 48 +-
.../__snapshots__/load-data-view.spec.tsx.snap | 14 +
.../src/views/load-data-view/load-data-view.tsx | 173 +-
.../load-data-view/schema-table/schema-table.scss | 28 +-
.../load-data-view/schema-table/schema-table.tsx | 14 +-
.../__snapshots__/segments-view.spec.tsx.snap | 1 +
.../src/views/segments-view/segments-view.tsx | 84 +-
.../src/views/services-view/services-view.tsx | 3 +-
.../column-editor/column-editor.tsx | 270 +-
.../schema-step/preview-table/preview-table.scss | 16 +
.../schema-step/preview-table/preview-table.tsx | 19 +-
.../schema-step/schema-step.tsx | 26 +-
.../sql-data-loader-view/sql-data-loader-view.tsx | 19 +-
.../connect-external-data-dialog.tsx | 8 +-
.../execution-details-pane.spec.tsx.snap | 440 ++--
.../execution-error-pane.spec.tsx.snap | 2 +-
.../execution-progress-bar-pane.spec.tsx.snap | 2 +-
.../execution-stages-pane.spec.tsx.snap | 18 +-
.../execution-stages-pane.tsx | 14 +-
.../execution-submit-dialog.spec.tsx.snap | 70 +
.../execution-submit-dialog.scss | 18 +-
.../execution-submit-dialog.spec.tsx} | 12 +-
.../execution-submit-dialog.tsx | 115 +-
.../ingest-success-pane.spec.tsx.snap | 4 +-
.../input-format-step/input-format-step.tsx | 15 +-
.../input-source-step/input-source-info.tsx | 3 +
.../views/workbench-view/query-tab/query-tab.tsx | 97 +-
.../result-table-pane/result-table-pane.tsx | 41 +-
.../views/workbench-view/run-panel/run-panel.tsx | 2 +-
.../src/views/workbench-view/workbench-view.tsx | 9 +-
web-console/unified-console.html | 2 +-
website/.spelling | 40 +-
website/docusaurus.config.js | 7 +-
website/package.json | 4 +-
website/script/link-lint.js | 97 +
800 files changed, 35784 insertions(+), 9299 deletions(-)
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/DelimitedInputFormatBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/frame/FrameChannelMergerBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/indexing/OnheapIncrementalIndexBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/lookup/LookupBenchmarkUtil.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/lookup/LookupExtractorBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/lookup/SqlReverseLookupBenchmark.java
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/query/InPlanningBenchmark.java
delete mode 100755 docs/_bin/broken-link-check.py
create mode 100644 docs/assets/spectator-histogram-size-comparison.png
create mode 100644 docs/development/extensions-contrib/ddsketch-quantiles.md
create mode 100644 docs/development/extensions-contrib/delta-lake.md
create mode 100644 docs/development/extensions-contrib/spectator-histogram.md
copy extensions-contrib/{tdigestsketch => ddsketch}/pom.xml (89%)
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchAggregator.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchAggregatorFactory.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchBufferAggregator.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchComplexMetricSerde.java
rename
sql/src/main/java/org/apache/druid/sql/calcite/expression/builtin/RoundOperatorConversion.java
=>
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchJsonSerializer.java
(59%)
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchModule.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchObjectStrategy.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchToQuantilePostAggregator.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchToQuantilesPostAggregator.java
create mode 100644
extensions-contrib/ddsketch/src/main/java/org/apache/druid/query/aggregation/ddsketch/DDSketchUtils.java
create mode 100644
extensions-contrib/ddsketch/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-contrib/ddsketch/src/test/java/org/apache/druid/query/aggregation/ddsketch/DDSketchAggregatorFactoryTest.java
create mode 100644
extensions-contrib/ddsketch/src/test/java/org/apache/druid/query/aggregation/ddsketch/DDSketchAggregatorTest.java
create mode 100644
extensions-contrib/ddsketch/src/test/java/org/apache/druid/query/aggregation/ddsketch/DDSketchToQuantilePostAggregatorTest.java
create mode 100644
extensions-contrib/ddsketch/src/test/java/org/apache/druid/query/aggregation/ddsketch/DDSketchToQuantilesPostAggregatorTest.java
copy extensions-contrib/{tdigestsketch =>
ddsketch}/src/test/resources/doubles_build_data.tsv (100%)
copy extensions-contrib/{prometheus-emitter =>
druid-deltalake-extensions}/pom.xml (69%)
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/common/DeltaLakeDruidModule.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/DeltaInputRow.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/DeltaInputSource.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/DeltaInputSourceReader.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/DeltaSplit.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/DeltaTimeUtils.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/java/org/apache/druid/delta/input/RowSerde.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/DeltaInputRowTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/DeltaInputSourceTest.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/DeltaTestUtils.java
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/DeltaTimeUtilsTest.java
copy processing/src/test/java/org/apache/druid/query/CachingEmitter.java =>
extensions-contrib/druid-deltalake-extensions/src/test/java/org/apache/druid/delta/input/RowSerdeTest.java
(50%)
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/README.md
create mode 100755
extensions-contrib/druid-deltalake-extensions/src/test/resources/create_delta_table.py
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00000-b17c520a-0c50-4e49-b8e7-46132a57d039-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00000-f0224389-c0df-4dbc-90e5-de1d6a5b5ac6-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00001-e18dc7d0-db98-40f2-9185-45237f51b9bf-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00001-f5c4b19d-a2b2-4189-8927-97fe1720df8d-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00002-b2249397-0232-4a5c-b504-62c7c27702c1-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00003-648766cd-8ebd-475a-afbb-44ae0b9cba30-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00003-fa1d35b8-bb75-4145-ac40-6ccbc04acc79-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00004-d580234a-54cb-43b7-87db-448c67a315df-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00005-963e7ff5-c414-444c-8984-6baecf6987ee-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00005-9ff9b585-5a9e-415f-b28a-a85d960ccb04-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00006-78cd057e-faaa-477d-b5fd-d00a857f7e54-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00007-00eb0d30-e71e-4092-8ea2-0ee576ca7327-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00007-15147217-b81a-45ab-92d4-24d725cc07e1-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00008-9f526a56-2392-4f1c-8c07-3dac19b12e91-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00009-e21486a5-e177-4c02-b256-bc890fadce7e-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/.part-00009-ee9dd918-aaec-4f80-bd63-e369c6335699-c000.snappy.parquet.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/_delta_log/.00000000000000000000.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/_delta_log/.00000000000000000001.json.crc
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/_delta_log/00000000000000000000.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/_delta_log/00000000000000000001.json
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00000-b17c520a-0c50-4e49-b8e7-46132a57d039-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00000-f0224389-c0df-4dbc-90e5-de1d6a5b5ac6-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00001-e18dc7d0-db98-40f2-9185-45237f51b9bf-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00001-f5c4b19d-a2b2-4189-8927-97fe1720df8d-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00002-b2249397-0232-4a5c-b504-62c7c27702c1-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00003-648766cd-8ebd-475a-afbb-44ae0b9cba30-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00003-fa1d35b8-bb75-4145-ac40-6ccbc04acc79-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00004-d580234a-54cb-43b7-87db-448c67a315df-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00005-963e7ff5-c414-444c-8984-6baecf6987ee-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00005-9ff9b585-5a9e-415f-b28a-a85d960ccb04-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00006-78cd057e-faaa-477d-b5fd-d00a857f7e54-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00007-00eb0d30-e71e-4092-8ea2-0ee576ca7327-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00007-15147217-b81a-45ab-92d4-24d725cc07e1-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00008-9f526a56-2392-4f1c-8c07-3dac19b12e91-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00009-e21486a5-e177-4c02-b256-bc890fadce7e-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/employee-delta-table/part-00009-ee9dd918-aaec-4f80-bd63-e369c6335699-c000.snappy.parquet
create mode 100644
extensions-contrib/druid-deltalake-extensions/src/test/resources/requirements.txt
delete mode 100644
extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/MemoryBoundLinkedBlockingQueue.java
create mode 100644
extensions-contrib/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/KubernetesOverlordModuleTest.java
copy {extensions-core/druid-bloom-filter =>
extensions-contrib/spectator-histogram}/pom.xml (79%)
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/NullableOffsetsHeader.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogram.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramAggregator.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramAggregatorFactory.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramBufferAggregator.java
copy processing/src/test/java/org/apache/druid/query/CachingEmitter.java =>
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramColumnPartSupplier.java
(58%)
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramComplexMetricSerde.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramIndexBasedComplexColumn.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramIndexed.java
copy processing/src/test/java/org/apache/druid/query/CachingEmitter.java =>
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramJsonSerializer.java
(59%)
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramModule.java
copy
indexing-service/src/test/java/org/apache/druid/indexing/test/TestDataSegmentAnnouncer.java
=>
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramObjectStrategy.java
(51%)
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramPercentilePostAggregator.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramPercentilesPostAggregator.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/java/org/apache/druid/spectator/histogram/SpectatorHistogramSerializer.java
create mode 100644
extensions-contrib/spectator-histogram/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-contrib/spectator-histogram/src/test/java/org/apache/druid/spectator/histogram/NullableOffsetsHeaderTest.java
create mode 100644
extensions-contrib/spectator-histogram/src/test/java/org/apache/druid/spectator/histogram/SpectatorHistogramAggregatorTest.java
create mode 100644
extensions-contrib/spectator-histogram/src/test/java/org/apache/druid/spectator/histogram/SpectatorHistogramTest.java
create mode 100644
extensions-contrib/spectator-histogram/src/test/resources/input_data.tsv
create mode 100644
extensions-contrib/spectator-histogram/src/test/resources/pre_agg_data.tsv
copy
extensions-core/azure-extensions/src/main/java/org/apache/druid/data/input/azure/{AzureInputSource.java
=> AzureStorageAccountInputSource.java} (59%)
create mode 100644
extensions-core/azure-extensions/src/main/java/org/apache/druid/data/input/azure/AzureStorageAccountInputSourceConfig.java
create mode 100644
extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureIngestClientFactory.java
copy
extensions-core/azure-extensions/src/test/java/org/apache/druid/data/input/azure/{AzureInputSourceTest.java
=> AzureStorageAccountInputSourceTest.java} (63%)
create mode 100644
extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureIngestClientFactoryTest.java
create mode 100644
extensions-core/druid-basic-security/src/main/java/org/apache/druid/security/basic/authentication/validator/PasswordHashGenerator.java
create mode 100644
extensions-core/druid-basic-security/src/test/java/org/apache/druid/security/basic/authentication/validator/PasswordHashGeneratorTest.java
create mode 100644
extensions-core/druid-pac4j/src/test/java/org/apache/druid/security/pac4j/Pac4jFilterTest.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/RetrieveSegmentsToReplaceAction.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITAzureV2ParallelIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/msq/ITAzureV2SQLBasedIngestionTest.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/ListBasedInputRow.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/ListBasedInputRowAdapter.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/DelimitedBytes.java
create mode 100644
processing/src/main/java/org/apache/druid/frame/processor/TournamentTree.java
create mode 100644
processing/src/main/java/org/apache/druid/java/util/common/MemoryBoundLinkedBlockingQueue.java
rename
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/{GroupByMergingQueryRunnerV2.java
=> GroupByMergingQueryRunner.java} (98%)
rename
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/{GroupByQueryEngineV2.java
=> GroupByQueryEngine.java} (79%)
rename
processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/{GroupByBinaryFnV2.java
=> GroupByResultMergeFn.java} (96%)
create mode 100644
processing/src/main/java/org/apache/druid/query/lookup/ImmutableLookupMap.java
delete mode 100644
processing/src/test/java/org/apache/druid/TestObjectMapper.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/DelimitedBytesTest.java
create mode 100644
processing/src/test/java/org/apache/druid/frame/processor/TournamentTreeTest.java
create mode 100644
processing/src/test/java/org/apache/druid/java/util/common/MemoryBoundLinkedBlockingQueueTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/BackwardCompatibleSerializablePairLongStringDeltaEncodedStagedSerdeTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/aggregation/BackwardCompatibleSerializablePairLongStringSimpleStagedSerdeTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/extraction/MapBasedLookupExtractorTest.java
rename
processing/src/test/java/org/apache/druid/query/groupby/epinephelinae/{GroupByQueryEngineV2Test.java
=> GroupByQueryEngineTest.java} (90%)
rename processing/src/test/java/org/apache/druid/query/{CachingEmitter.java =>
lookup/ImmutableLookupMapTest.java} (55%)
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/DefaultFramedOnHeapAggregatableTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/SemanticCreatorUsageTest.java
copy
server/src/main/java/org/apache/druid/server/coordination/NoopDataSegmentAnnouncer.java
=>
processing/src/test/java/org/apache/druid/segment/generator/GeneratorSchemaInfoTest.java
(57%)
delete mode 100644
processing/src/test/java/org/apache/druid/segment/incremental/OnheapIncrementalIndexBenchmark.java
create mode 100644
server/src/main/java/org/apache/druid/segment/metadata/CentralizedDatasourceSchemaConfig.java
create mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/SegmentSchemas.java
create mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/SinkSchemaUtil.java
copy
server/src/main/java/org/apache/druid/server/coordination/{NoopDataSegmentAnnouncer.java
=> SegmentSchemasChangeRequest.java} (51%)
create mode 100644
server/src/main/java/org/apache/druid/server/http/DataSegmentPlus.java
create mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/SinkSchemaUtilTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/EtagProvider.java
create mode 100644
server/src/test/java/org/apache/druid/server/http/DataSegmentPlusTest.java
delete mode 100644
server/src/test/java/org/apache/druid/server/metrics/ExceptionCapturingServiceEmitter.java
create mode 100644
server/src/test/java/org/apache/druid/sql/calcite/util/CacheTestHelperModule.java
delete mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/expression/UnaryFunctionOperatorConversion.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/PlannerLookupCache.java
delete mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/UnsupportedSQLQueryException.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rule/AggregatePullUpLookupRule.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rule/FilterDecomposeConcatRule.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rule/FlattenConcatRule.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rule/ReverseLookupRule.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteLookupFunctionQueryTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/rule/FilterDecomposeConcatRuleTest.java
delete mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/util/CalciteTestInjectorBuilder.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/util/TestLookupProvider.java
create mode 100644
sql/src/test/resources/calcite/tests/window/range_handling.sqlTest
create mode 100644 web-console/assets/delta.png
copy
web-console/src/{views/workbench-view/execution-submit-dialog/execution-submit-dialog.scss
=> blueprint-overrides/_special-switch-modes.scss} (67%)
create mode 100644
web-console/src/components/array-mode-switch/__snapshots__/array-mode-swtich.spec.tsx.snap
create mode 100644
web-console/src/components/array-mode-switch/array-mode-switch.tsx
copy web-console/src/{views/home-view/status-card/status-card.spec.tsx =>
components/array-mode-switch/array-mode-swtich.spec.tsx} (80%)
create mode 100644 web-console/src/utils/null-mode-detection.ts
create mode 100644
web-console/src/views/workbench-view/execution-submit-dialog/__snapshots__/execution-submit-dialog.spec.tsx.snap
copy web-console/src/views/{home-view/status-card/status-card.spec.tsx =>
workbench-view/execution-submit-dialog/execution-submit-dialog.spec.tsx} (74%)
create mode 100644 website/script/link-lint.js
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
