This is an automated email from the ASF dual-hosted git repository.
asdf2014 pushed a change to branch
dependabot/maven/io.grpc-grpc-netty-shaded-1.65.1
in repository https://gitbox.apache.org/repos/asf/druid.git
from a81663986c8 Bump io.grpc:grpc-netty-shaded from 1.57.2 to 1.65.1
add a618c5dd0de Refactor: Miscellaneous batch task cleanup (#16730)
add 656667ee897 Tests: Add utility class TuningConfigBuilder to make
IndexTask tests more readable and concise (#16732)
add d6c760f7ce7 Do not kill segments with referenced load specs from deep
storage (#16667)
add 209f8a95468 Deserialize complex dimensions in group by queries to
their respective types when reading from spilled files and cached results
(#16620)
add 64104533acf Enable querying entirely cold datasources (#16676)
add 78a4a09d018 Window Function offset correction for RAC (#16718)
add 6891866c434 Process retrieval of parent and child segment ids in
batches (#16734)
add 6cf6838eb97 kubernetes-overlord-extension: Fix tasks not being
shutdown (#16711)
add 01d67ae543b Allow CompactionSegmentIterator to have custom priority
(#16737)
add ebf216829dc #16717 defer provider instantiation in Kubernetes Module
(#16726)
add 9f6ce6ddc01 Remove task action audit logging and druid_taskLog
metadata table (#16309)
add 40ef9fc4ec9 Bug fix for array type selector causing array aggregation
over window frame fail (#16653)
add 89066b72cfe Fix bug in TaskStorageQueryAdapter (#16750)
add 44b3f8e5880 Web console: fix a few console bugs (#16735)
add b53c26f5c59 Fix issues with partitioning boundaries for MSQ window
functions (#16729)
add 0eaa810e89b Fix the maven warning during build (#16746)
add 721a65046f6 docs: add examples for SQL functions (#16745)
add 0a274d56a12 Web console: upgrade to Blueprint5 (#16756)
add 35b876436b8 remove native scan query legacy mode (#16659)
add b1edf4a5b40 Refactor: Clean up Overlord guice dependencies (#16752)
add e286be94278 Exposes hooks to customize the workbench-view (#16749)
add 18818807149 [Docs] Adds a migration guide SQL compatible null handling
(#16704)
add a34a06e1926 remove Firehose and FirehoseFactory (#16758)
add 72eeeec0244 fix NPE in number formatting (#16760)
add 7f7e6ca1e5c Fix excessive logging from druid-basic-security (#16767)
add c9aae9d8e68 Enable WINDOW_LEAF_OPERATOR for native engine to support
queries without group by (#16753)
add 149d7c5207a Throw exceptions in SqlValidator when DISTINCT used over
WINDOW (#16738)
add 6a2348b78b3 Preemptive restriction for queries with approximate count
distinct on complex columns of unsupported type (#16682)
add 02b8738c00c remove batchProcessingMode from task config, remove
AppenderatorImpl (#16765)
add 934c10b1cd3 docs: Adding admonition box to warn about MVD (#16712)
add b645d09c5dc move long and double nested field serialization to later
phase of serialization (#16769)
add 8b8ca0d7fce DimFilterUtils: Exit filterShards early when filter is
null. (#16774)
add c45d4fdbcad MSQ window functions: Minor cleanup for empty over clause
related flows + Exhaustive tests (#16754)
add 11bb40981e0 Deduce type from the aggregators when materializing
subquery results (#16703)
add a64e9a17462 Add annotation for pod template (#16772)
add 704962ec8e5 doc: minor fixes to migration guides (#16784)
add aeb2ee59a28 Added an option to hide the workbench-view toolbar (#16785)
add 3f4d66c3997 Check for Unsupported Aggregation with Distinct when
useApproxCountDistinct is enabled (#16770)
add 4f0b80bef5c Web console: change to use @fontsource/open-sans (#16786)
add 302739aa58c more aggressive cancellation of broker parallel merge,
more chill blocking queue timeouts, and query cancellation participation
(#16748)
add a0437b6c931 MSQ window functions: Fix partition boundary issues for
arrays (#16780)
add 6ff0cbfa545 Prune date-fns locales, bump sass TODO (#16792)
add ca787885c96 [docs] batch02 of updating functions (#16761)
add 7e3fab5bf96 Make WindowFrames more specific (#16741)
add 5da69a01cbc change arrayIngestMode default to array (#16789)
add c1875e7c1dc HashJoinEngine: Check for interruptions while walking left
cursor. (#16773)
add 14954c7eb97 serialize legacy as false for scan query for rolling
downgrade/upgrade (#16793)
add b5f117bca27 Check for tombstones in wrapping storage adapters (#16791)
add b2a88da200b Attempt to coerce COMPLEX to number in numeric
aggregators. (#16564)
add 71725b41b54 ignore dependencies for github stale action (#16797)
add 725d442355f Faster dimension deserialization on the brokers (#16740)
add 9b76d13ff8f Check for Aggregation inside a window clause when syntax
used as - WINDOW W AS DEF (#16801)
add 3c493dc3edd CircularList round-robin iterator for the
KillUnusedSegments duty (#16719)
add ed48cb82e99 [Docs} Remove avro_ocf support from Kafka & Kinesis
streaming sources (Revert changes from #11865) (#16807)
add 028ee23a1e9 [Docs] batch 03 - trig functions (#16795)
add c07aeedbec7 [docs] Updating Rollup tutorial (#16762)
add caedeb66cd7 Add API to update compaction engine (#16803)
add cbca0dc9695 Bump jclouds.version from 2.5.0 to 2.6.0 (#16796)
add 7f46eae2e17 Merge branch 'master' into
dependabot/maven/io.grpc-grpc-netty-shaded-1.65.1
No new revisions were added by this update.
Summary of changes:
.github/workflows/stale.yml | 2 +-
.../benchmark/GroupByDeserializationBenchmark.java | 193 +++
.../druid/benchmark/query/ScanBenchmark.java | 6 +-
.../NewestSegmentFirstPolicyBenchmark.java | 23 +-
docs/api-reference/sql-ingestion-api.md | 1 -
docs/api-reference/tasks-api.md | 17 +-
docs/configuration/extensions.md | 2 +-
docs/configuration/index.md | 6 +-
docs/development/extensions-contrib/cloudfiles.md | 56 -
docs/development/extensions-core/postgresql.md | 2 +-
docs/development/overview.md | 13 +-
docs/ingestion/kafka-ingestion.md | 1 -
docs/ingestion/kinesis-ingestion.md | 1 -
docs/ingestion/native-batch-firehose.md | 316 +---
docs/operations/clean-metadata-store.md | 14 +-
docs/operations/metrics.md | 9 -
docs/operations/migrate-from-firehose-ingestion.md | 4 +-
docs/operations/request-logging.md | 1 -
docs/operations/security-overview.md | 2 +-
docs/querying/arrays.md | 71 +-
docs/querying/lookups.md | 4 +
docs/querying/multi-value-dimensions.md | 4 +-
docs/querying/scan-query.md | 37 +-
docs/querying/sql-functions.md | 494 +++++-
docs/querying/sql-translation.md | 2 -
docs/querying/sql-window-functions.md | 3 -
docs/release-info/migr-ansi-sql-null.md | 386 +++++
docs/release-info/migration-guide.md | 12 +-
docs/tutorials/tutorial-rollup.md | 200 +--
docs/tutorials/tutorial-sql-null.md | 2 +-
docs/tutorials/tutorial-unnest-arrays.md | 5 -
extensions-contrib/cloudfiles-extensions/pom.xml | 2 +-
.../druid/k8s/overlord/KubernetesTaskRunner.java | 14 +-
.../k8s/overlord/common/DruidK8sConstants.java | 2 +
.../execution/PodTemplateSelectStrategy.java | 5 +-
.../SelectorBasedPodTemplateSelectStrategy.java | 11 +-
.../TaskTypePodTemplateSelectStrategy.java | 7 +-
.../taskadapter/PodTemplateTaskAdapter.java | 6 +-
.../PodTemplateWithName.java} | 52 +-
.../k8s/overlord/KubernetesTaskRunnerTest.java | 18 +
.../druid/k8s/overlord/common/K8sTestUtils.java | 1 -
.../overlord/common/PodTemplateWithNameTest.java | 60 +
...SelectorBasedPodTemplateSelectStrategyTest.java | 14 +-
.../DruidPeonClientIntegrationTest.java | 5 -
.../overlord/taskadapter/K8sTaskAdapterTest.java | 5 -
.../taskadapter/MultiContainerTaskAdapterTest.java | 5 -
.../taskadapter/PodTemplateTaskAdapterTest.java | 4 +-
.../SingleContainerTaskAdapterTest.java | 5 -
.../src/test/resources/expectedNoopJob.yaml | 3 +
...pectedNoopJob.yaml => expectedNoopJobBase.yaml} | 3 +
.../src/test/resources/expectedNoopJobLongIds.yaml | 2 +
.../test/resources/expectedNoopJobNoTaskJson.yaml | 2 +
.../test/resources/expectedNoopJobTlsEnabled.yaml | 2 +
...led.yaml => expectedNoopJobTlsEnabledBase.yaml} | 2 +
.../MaterializedViewSupervisorSpec.java | 2 +-
.../MaterializedViewSupervisorSpecTest.java | 4 +-
.../MaterializedViewSupervisorTest.java | 2 +-
.../src/main/resources/defaultMetrics.json | 3 -
extensions-contrib/spectator-histogram/pom.xml | 10 +
.../SpectatorHistogramIndexBasedComplexColumn.java | 69 +-
.../SpectatorHistogramAggregatorTest.java | 67 +
...ctatorHistogramIndexBasedComplexColumnTest.java | 23 +-
extensions-core/azure-extensions/pom.xml | 4 -
.../hll/HllSketchMergeAggregatorFactory.java | 36 +
.../HllSketchApproxCountDistinctSqlAggregator.java | 48 +-
.../hll/sql/HllSketchBaseSqlAggregator.java | 20 +-
.../theta/SketchAggregatorFactory.java | 50 +-
...hetaSketchApproxCountDistinctSqlAggregator.java | 36 +-
.../theta/sql/ThetaSketchBaseSqlAggregator.java | 18 +-
.../hll/HllSketchMergeAggregatorFactoryTest.java | 49 +
.../hll/sql/HllSketchSqlAggregatorTest.java | 43 +
.../theta/SketchAggregatorFactoryTest.java | 45 +
.../theta/sql/ThetaSketchSqlAggregatorTest.java | 39 +
...natorPollingBasicAuthenticatorCacheManager.java | 2 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 5 +-
.../kinesis/KinesisIndexTaskSerdeTest.java | 4 +-
extensions-core/kubernetes-extensions/pom.xml | 2 +
.../druid/k8s/discovery/K8sDiscoveryModule.java | 58 +-
.../discovery/K8sDruidLeaderSelectorProvider.java | 97 ++
.../msq/indexing/IndexerControllerContext.java | 2 +-
.../druid/msq/indexing/MSQCompactionRunner.java | 3 +-
.../msq/indexing/client/ControllerChatHandler.java | 2 +-
.../msq/indexing/client/WorkerChatHandler.java | 4 +-
.../SegmentGeneratorFrameProcessorFactory.java | 3 +-
.../WindowOperatorQueryFrameProcessor.java | 101 +-
.../WindowOperatorQueryFrameProcessorFactory.java | 36 +-
.../druid/msq/querykit/WindowOperatorQueryKit.java | 199 ++-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 6 -
.../org/apache/druid/msq/util/ArrayIngestMode.java | 5 -
.../druid/msq/util/DimensionSchemaUtils.java | 12 +-
.../druid/msq/util/MultiStageQueryContext.java | 2 +-
.../druid/msq/exec/DataServerQueryHandlerTest.java | 2 +-
.../org/apache/druid/msq/exec/MSQArraysTest.java | 79 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 4 -
.../org/apache/druid/msq/exec/MSQWindowTest.java | 84 +-
.../msq/indexing/MSQCompactionRunnerTest.java | 48 +-
.../druid/msq/indexing/MSQControllerTaskTest.java | 1 -
...ndowOperatorQueryFrameProcessorFactoryTest.java | 17 +-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 1 -
.../resources/SqlMSQStatementResourcePostTest.java | 11 +-
.../sql/resources/SqlStatementResourceTest.java | 1 -
.../druid/msq/test/CalciteMSQTestsHelper.java | 16 +
.../druid/msq/test/MSQTestWorkerContext.java | 2 +-
.../druid/msq/util/MultiStageQueryContextTest.java | 7 +-
.../input/MySQLInputSourceDatabaseConnector.java} | 10 +-
.../storage/mysql/MySQLMetadataStorageModule.java | 4 +-
.../MySQLInputSourceDatabaseConnectorTest.java} | 34 +-
.../PostgresqlInputSourceDatabaseConnector.java} | 12 +-
.../PostgreSQLMetadataStorageModule.java | 4 +-
...ostgresqlInputSourceDatabaseConnectorTest.java} | 26 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 27 +-
.../org/apache/druid/query/sql/SleepSqlTest.java | 1 -
.../indexer/hadoop/DatasourceRecordReader.java | 193 ++-
.../druid/indexer/BatchDeltaIngestionTest.java | 12 +-
.../DatasourceRecordReaderSegmentReaderTest.java | 19 +-
.../druid/guice/IndexingServiceFirehoseModule.java | 49 -
.../ActionBasedPublishedSegmentRetriever.java | 2 +-
.../apache/druid/indexing/common/TaskToolbox.java | 2 +-
.../druid/indexing/common/TaskToolboxFactory.java | 2 +-
.../CheckPointDataSourceMetadataAction.java | 6 -
.../common/actions/LocalTaskActionClient.java | 28 +-
.../actions/LocalTaskActionClientFactory.java | 9 +-
.../indexing/common/actions/LockListAction.java | 6 -
.../indexing/common/actions/LockReleaseAction.java | 6 -
.../common/actions/MarkSegmentsAsUnusedAction.java | 5 -
.../actions/ResetDataSourceMetadataAction.java | 6 -
.../common/actions/RetrieveSegmentsByIdAction.java | 6 -
.../actions/RetrieveUnusedSegmentsAction.java | 6 -
...a => RetrieveUpgradedFromSegmentIdsAction.java} | 46 +-
...ava => RetrieveUpgradedToSegmentIdsAction.java} | 51 +-
.../common/actions/RetrieveUsedSegmentsAction.java | 6 -
.../common/actions/SegmentAllocateAction.java | 6 -
.../common/actions/SegmentInsertAction.java | 101 --
.../common/actions/SegmentLockAcquireAction.java | 6 -
.../actions/SegmentLockTryAcquireAction.java | 6 -
.../actions/SegmentMetadataUpdateAction.java | 6 -
.../indexing/common/actions/SegmentNukeAction.java | 6 -
.../actions/SegmentTransactionalAppendAction.java | 7 -
.../actions/SegmentTransactionalInsertAction.java | 6 -
.../actions/SegmentTransactionalReplaceAction.java | 6 -
.../indexing/common/actions/SurrogateAction.java | 6 -
.../druid/indexing/common/actions/TaskAction.java | 5 +-
.../common/actions/TimeChunkLockAcquireAction.java | 6 -
.../actions/TimeChunkLockTryAcquireAction.java | 6 -
.../common/actions/UpdateLocationAction.java | 6 -
.../common/actions/UpdateStatusAction.java | 6 -
...nfig.java => UpgradedFromSegmentsResponse.java} | 24 +-
...Config.java => UpgradedToSegmentsResponse.java} | 26 +-
.../druid/indexing/common/config/TaskConfig.java | 62 -
.../indexing/common/task/BatchAppenderators.java | 64 +-
.../druid/indexing/common/task/CompactionTask.java | 70 +-
.../indexing/common/task/HadoopIndexTask.java | 4 +-
.../druid/indexing/common/task/IndexTask.java | 59 +-
.../common/task/KillUnusedSegmentsTask.java | 150 +-
.../common/task/NativeCompactionRunner.java | 17 +-
.../apache/druid/indexing/common/task/Task.java | 12 +-
.../apache/druid/indexing/common/task/Tasks.java | 38 +-
.../InputSourceSplitParallelIndexTaskRunner.java | 4 -
.../batch/parallel/LegacySinglePhaseSubTask.java | 3 -
.../task/batch/parallel/ParallelIndexIOConfig.java | 17 +-
.../parallel/ParallelIndexSupervisorTask.java | 9 +-
.../batch/parallel/ParallelIndexTuningConfig.java | 39 -
.../parallel/PartialDimensionCardinalityTask.java | 3 -
.../parallel/PartialDimensionDistributionTask.java | 3 -
.../parallel/PartialHashSegmentGenerateTask.java | 3 -
.../parallel/PartialRangeSegmentGenerateTask.java | 3 -
.../batch/parallel/PartialSegmentGenerateTask.java | 2 +-
.../SinglePhaseParallelIndexTaskRunner.java | 4 -
.../task/batch/parallel/SinglePhaseSubTask.java | 5 +-
.../iterator/IndexTaskInputRowIteratorBuilder.java | 2 -
.../druid/indexing/input/DruidInputSource.java | 5 +-
.../druid/indexing/input/DruidSegmentReader.java | 2 +-
.../{firehose => input}/WindowedSegmentId.java | 2 +-
.../{TaskMaster.java => DruidOverlord.java} | 235 +--
.../indexing/overlord/HeapMemoryTaskStorage.java | 18 -
.../overlord/IndexerMetadataStorageAdapter.java | 11 +-
.../indexing/overlord/MetadataTaskStorage.java | 26 -
.../apache/druid/indexing/overlord/TaskMaster.java | 239 +--
.../druid/indexing/overlord/TaskQueryTool.java | 384 +++++
.../druid/indexing/overlord/TaskStorage.java | 21 -
.../indexing/overlord/TaskStorageQueryAdapter.java | 152 --
.../overlord/http/OverlordRedirectInfo.java | 12 +-
.../indexing/overlord/http/OverlordResource.java | 385 +----
.../indexing/overlord/http/TaskStateLookup.java} | 28 +-
.../overlord/http/security/TaskResourceFilter.java | 10 +-
.../overlord/sampler/InputSourceSampler.java | 4 +-
.../seekablestream/SeekableStreamIndexTask.java | 2 +-
.../SeekableStreamIndexTaskRunner.java | 2 +-
.../druid/indexing/common/TaskToolboxTest.java | 3 +-
.../apache/druid/indexing/common/TestFirehose.java | 118 --
.../druid/indexing/common/TestIndexTask.java | 37 +-
.../apache/druid/indexing/common/TestUtils.java | 10 +-
.../common/actions/SegmentInsertActionTest.java | 154 --
.../indexing/common/config/TaskConfigBuilder.java | 16 -
.../common/task/BatchAppenderatorsTest.java | 604 --------
.../task/ClientCompactionTaskQuerySerdeTest.java | 64 +-
.../common/task/CompactionTaskParallelRunTest.java | 48 +-
.../common/task/CompactionTaskRunTest.java | 110 +-
.../indexing/common/task/CompactionTaskTest.java | 635 +++-----
.../common/task/CompactionTuningConfigTest.java | 152 +-
.../task/CountingLocalTaskActionClientForTest.java | 3 +-
.../druid/indexing/common/task/HadoopTaskTest.java | 1 -
.../common/task/IndexIngestionSpecTest.java | 2 -
.../indexing/common/task/IndexTaskSerdeTest.java | 188 +--
.../druid/indexing/common/task/IndexTaskTest.java | 156 +-
.../indexing/common/task/IngestionTestBase.java | 33 +-
.../common/task/KillUnusedSegmentsTaskTest.java | 227 ++-
.../druid/indexing/common/task/TaskSerdeTest.java | 98 +-
.../druid/indexing/common/task/TasksTest.java | 94 --
.../common/task/TestAppenderatorsManager.java | 68 +-
.../indexing/common/task/TuningConfigBuilder.java | 415 +++++
.../AbstractMultiPhaseParallelIndexingTest.java | 8 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 113 +-
.../batch/parallel/HashPartitionTaskKillTest.java | 2 -
...ltiPhaseParallelIndexingWithNullColumnTest.java | 4 -
.../ParallelIndexSupervisorTaskKillTest.java | 74 +-
.../ParallelIndexSupervisorTaskResourceTest.java | 58 +-
.../ParallelIndexSupervisorTaskSerdeTest.java | 61 +-
.../parallel/ParallelIndexSupervisorTaskTest.java | 198 +--
.../parallel/ParallelIndexTestingFactory.java | 149 +-
.../parallel/ParallelIndexTuningConfigTest.java | 351 +----
.../task/batch/parallel/PartialCompactionTest.java | 3 +-
.../PartialDimensionCardinalityTaskTest.java | 71 +-
.../PartialDimensionDistributionTaskTest.java | 92 +-
.../PartialGenericSegmentMergeTaskTest.java | 21 +-
.../PartialHashSegmentGenerateTaskTest.java | 11 +-
.../PartialRangeSegmentGenerateTaskTest.java | 32 +-
.../parallel/PartialSegmentMergeIOConfigTest.java | 9 -
.../PartialSegmentMergeIngestionSpecTest.java | 22 +-
.../batch/parallel/RangePartitionTaskKillTest.java | 1 -
.../parallel/SinglePhaseParallelIndexingTest.java | 129 +-
.../batch/parallel/SinglePhaseSubTaskSpecTest.java | 1 -
.../druid/indexing/input/DruidInputSourceTest.java | 1 -
.../{firehose => input}/WindowedSegmentIdTest.java | 2 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 5 +-
.../IndexerMetadataStorageAdapterTest.java | 21 +-
.../overlord/OverlordBlinkLeadershipTest.java | 2 +-
.../druid/indexing/overlord/RealtimeishTask.java | 43 +-
.../overlord/SingleTaskBackgroundRunnerTest.java | 3 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 223 +--
.../druid/indexing/overlord/TaskQueueTest.java | 1 -
.../indexing/overlord/TestTaskToolboxFactory.java | 2 +-
.../overlord/http/OverlordRedirectInfoTest.java | 38 +-
.../overlord/http/OverlordResourceTest.java | 707 +++------
.../druid/indexing/overlord/http/OverlordTest.java | 33 +-
.../OverlordSecurityResourceFilterTest.java | 8 +-
.../http/security/TaskResourceFilterTest.java | 14 +-
.../overlord/sampler/IndexTaskSamplerSpecTest.java | 5 +-
.../SeekableStreamIndexTaskTestBase.java | 8 +-
.../druid/indexing/test/TestDataSegmentKiller.java | 13 +-
.../TestIndexerMetadataStorageCoordinator.java | 18 +
.../indexing/worker/TaskAnnouncementTest.java | 2 +-
.../indexing/worker/WorkerTaskManagerTest.java | 3 +-
.../indexing/worker/WorkerTaskMonitorTest.java | 3 +-
...ocalIntermediaryDataManagerAutoCleanupTest.java | 1 -
...ermediaryDataManagerManualAddAndDeleteTest.java | 1 -
.../shuffle/ShuffleDataSegmentPusherTest.java | 1 -
.../worker/shuffle/ShuffleResourceTest.java | 1 -
.../ITBestEffortRollupParallelIndexTest.java | 2 +-
.../src/test/resources/indexer/export_task.json | 1 -
.../clients/EventReceiverFirehoseTestClient.java | 181 ---
.../testing/guice/DruidTestModuleFactory.java | 2 -
.../ITBestEffortRollupParallelIndexTest.java | 2 +-
.../indexer/ITPerfectRollupParallelIndexTest.java | 2 +-
licenses.yaml | 265 +---
licenses/bin/@fontsource-open-sans.OFL | 93 ++
licenses/bin/react-innertext.MIT | 21 +
licenses/bin/react-uid.MIT | 21 +
pom.xml | 2 +-
processing/pom.xml | 2 +-
.../org/apache/druid/collections/CircularList.java | 89 ++
.../java/org/apache/druid/data/input/Firehose.java | 97 --
.../apache/druid/data/input/FirehoseFactory.java | 82 -
.../druid/data/input/SegmentsSplitHintSpec.java | 5 +-
.../apache/druid/jackson/AggregatorsModule.java | 15 +-
.../guava/ParallelMergeCombiningSequence.java | 290 ++--
.../java/util/common/jackson/JacksonUtils.java | 37 +
.../metadata/MetadataStorageActionHandler.java | 36 +-
.../MetadataStorageActionHandlerTypes.java | 1 -
.../java/org/apache/druid/metadata/TaskLookup.java | 5 +
.../main/java/org/apache/druid/query/Druids.java | 9 -
.../java/org/apache/druid/query/QueryContext.java | 8 -
.../java/org/apache/druid/query/QueryContexts.java | 2 -
.../org/apache/druid/query/QueryToolChest.java | 26 +-
.../druid/query/aggregation/AggregatorUtil.java | 26 +
.../query/aggregation/DelegatingAggregator.java | 2 +-
.../aggregation/DelegatingBufferAggregator.java | 2 +-
.../NullableNumericAggregatorFactory.java | 46 +-
...va => ObjectColumnDoubleAggregatorWrapper.java} | 6 +-
...ObjectColumnDoubleBufferAggregatorWrapper.java} | 6 +-
...ava => ObjectColumnFloatAggregatorWrapper.java} | 6 +-
... ObjectColumnFloatBufferAggregatorWrapper.java} | 6 +-
...java => ObjectColumnLongAggregatorWrapper.java} | 6 +-
...> ObjectColumnLongBufferAggregatorWrapper.java} | 6 +-
.../aggregation/SimpleDoubleAggregatorFactory.java | 20 +-
.../aggregation/SimpleFloatAggregatorFactory.java | 26 +-
.../aggregation/SimpleLongAggregatorFactory.java | 26 +-
.../hyperloglog/HyperUniquesAggregatorFactory.java | 44 +-
.../DataSourceQueryQueryToolChest.java | 8 +
.../apache/druid/query/filter/DimFilterUtils.java | 9 +-
.../druid/query/groupby/GroupByQueryConfig.java | 1 -
.../query/groupby/GroupByQueryQueryToolChest.java | 218 +--
.../ResultRowObjectMapperDecoratorUtil.java | 267 ++++
.../druid/query/groupby/epinephelinae/Grouper.java | 11 +
.../epinephelinae/RowBasedGrouperHelper.java | 138 +-
.../epinephelinae/RowBasedKeySerdeHelper.java | 5 +
.../groupby/epinephelinae/SpillingGrouper.java | 2 +-
.../SegmentMetadataQueryQueryToolChest.java | 11 +
.../org/apache/druid/query/operator/Operator.java | 2 +-
.../query/operator/window/ComposingProcessor.java | 12 +
.../druid/query/operator/window/Processor.java | 7 +
.../druid/query/operator/window/WindowFrame.java | 259 ++--
.../window/WindowFramedAggregateProcessor.java | 12 +
.../window/ranking/WindowPercentileProcessor.java | 8 +
.../window/ranking/WindowRankingProcessorBase.java | 6 +
.../window/ranking/WindowRowNumberProcessor.java | 9 +
.../window/value/WindowValueProcessorBase.java | 8 +
.../query/rowsandcols/ArrayListRowsAndColumns.java | 9 +-
.../DefaultColumnSelectorFactoryMaker.java | 4 +-
.../semantic/DefaultFramedOnHeapAggregatable.java | 46 +-
.../org/apache/druid/query/scan/ScanQuery.java | 42 +-
.../apache/druid/query/scan/ScanQueryConfig.java | 31 +-
.../apache/druid/query/scan/ScanQueryEngine.java | 53 +-
.../druid/query/scan/ScanQueryQueryToolChest.java | 11 +-
.../query/search/SearchQueryQueryToolChest.java | 10 +
.../TimeBoundaryQueryQueryToolChest.java | 12 +
.../druid/query/timeseries/TimeseriesQuery.java | 16 +
.../timeseries/TimeseriesQueryQueryToolChest.java | 27 +-
.../org/apache/druid/query/topn/TopNQuery.java | 11 +
.../druid/query/topn/TopNQueryQueryToolChest.java | 26 +-
.../druid/segment/FilteredStorageAdapter.java | 6 +
.../java/org/apache/druid/segment/Metadata.java | 2 +-
.../apache/druid/segment/UnnestStorageAdapter.java | 6 +
.../column/ObjectStrategyComplexTypeStrategy.java | 6 +-
.../druid/segment/column/TypeStrategies.java | 30 +
.../apache/druid/segment/column/TypeStrategy.java | 2 +-
.../apache/druid/segment/join/HashJoinEngine.java | 13 +-
.../join/HashJoinSegmentStorageAdapter.java | 6 +
.../druid/segment/nested/DictionaryIdLookup.java | 158 +-
.../GlobalDictionaryEncodedFieldColumnWriter.java | 10 +-
.../nested/ScalarDoubleFieldColumnWriter.java | 26 +-
.../nested/ScalarLongFieldColumnWriter.java | 26 +-
.../druid/segment/virtual/ExpressionSelectors.java | 8 +-
.../BuildingHashBasedNumberedShardSpec.java | 4 +-
.../partition/BuildingNumberedShardSpec.java | 4 +-
.../apache/druid/collections/CircularListTest.java | 135 ++
.../input/impl/InputEntityIteratingReaderTest.java | 4 +-
.../guava/ParallelMergeCombiningSequenceTest.java | 156 +-
.../metadata/MetadataStorageActionHandlerTest.java | 178 +++
.../org/apache/druid/metadata/TaskLookupTest.java | 2 +-
.../org/apache/druid/query/DoubleStorageTest.java | 4 +-
.../org/apache/druid/query/QueryContextsTest.java | 9 -
.../query/aggregation/AggregationTestHelper.java | 9 +-
.../aggregation/DoubleMaxAggregationTest.java | 2 +-
.../aggregation/DoubleMinAggregationTest.java | 2 +-
.../query/aggregation/LongMaxAggregationTest.java | 2 +-
.../query/aggregation/LongMinAggregationTest.java | 2 +-
.../HyperUniquesAggregatorFactoryTest.java | 67 +
.../groupby/ComplexDimensionGroupByQueryTest.java | 164 ++
.../groupby/GroupByQueryQueryToolChestTest.java | 108 +-
.../query/groupby/GroupByQueryRunnerTest.java | 6 +-
.../operator/WindowProcessorOperatorTest.java | 9 +
.../operator/window/ComposingProcessorTest.java | 10 +
.../query/operator/window/WindowFrameTest.java | 70 +
.../window/WindowFramedAggregateProcessorTest.java | 6 +-
.../ranking/WindowCumeDistProcessorTest.java | 2 +
.../ranking/WindowDenseRankProcessorTest.java | 2 +
.../ranking/WindowPercentileProcessorTest.java | 7 +
.../window/ranking/WindowRankProcessorTest.java | 4 +
.../ranking/WindowRowNumberProcessorTest.java | 3 +
.../window/value/WindowFirstProcessorTest.java | 7 +
.../window/value/WindowLastProcessorTest.java | 6 +
.../rowsandcols/ArrayListRowsAndColumnsTest.java | 39 +-
.../semantic/FramedOnHeapAggregatableTest.java | 77 +-
.../query/scan/MultiSegmentScanQueryTest.java | 2 -
.../druid/query/scan/ScanQueryConfigTest.java | 5 -
.../query/scan/ScanQueryQueryToolChestTest.java | 21 +-
.../query/scan/ScanQueryResultOrderingTest.java | 5 +-
.../query/scan/ScanQueryRunnerFactoryTest.java | 5 +-
.../druid/query/scan/ScanQueryRunnerTest.java | 185 +--
.../apache/druid/query/scan/ScanQuerySpecTest.java | 27 +-
.../org/apache/druid/query/scan/ScanQueryTest.java | 19 +
.../query/scan/UnnestScanQueryRunnerTest.java | 288 +---
.../apache/druid/segment/join/JoinTestHelper.java | 9 +-
.../segment/virtual/ExpressionSelectorsTest.java | 15 +
.../druid/client/CachingClusteredClient.java | 6 +-
.../apache/druid/client/CachingQueryRunner.java | 2 +-
.../client/coordinator/CoordinatorClient.java | 5 +
.../client/coordinator/CoordinatorClientImpl.java | 13 +
.../indexing/ClientCompactionRunnerInfo.java | 42 +-
.../ClientCompactionTaskQueryTuningConfig.java | 12 +
.../org/apache/druid/guice/FirehoseModule.java | 55 -
.../IndexerMetadataStorageCoordinator.java | 17 +
.../druid/initialization/CoreInjectorBuilder.java | 2 -
.../apache/druid/metadata/BasicDataSourceExt.java | 2 +-
.../DerbyMetadataStorageActionHandler.java | 9 -
.../IndexerSQLMetadataStorageCoordinator.java | 121 +-
.../druid/metadata/PendingSegmentRecord.java | 5 +-
.../PostgreSQLMetadataStorageActionHandler.java | 10 -
...r.java => SQLInputSourceDatabaseConnector.java} | 2 +-
.../druid/metadata/SQLMetadataConnector.java | 30 +-
.../metadata/SQLMetadataStorageActionHandler.java | 111 +-
.../druid/metadata/SegmentsMetadataManager.java | 2 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 13 +-
.../org/apache/druid/metadata/input/SqlEntity.java | 20 +-
.../druid/metadata/input/SqlInputSource.java | 23 +-
.../druid/query/ResultLevelCachingQueryRunner.java | 2 +-
.../rpc/indexing/SpecificTaskRetryPolicy.java | 2 +-
.../metadata/AbstractSegmentMetadataCache.java | 16 +-
.../metadata/CoordinatorSegmentMetadataCache.java | 220 ++-
.../realtime/{firehose => }/ChatHandler.java | 2 +-
.../{firehose => }/ChatHandlerProvider.java | 2 +-
.../{firehose => }/ChatHandlerResource.java | 2 +-
.../realtime/{firehose => }/ChatHandlers.java | 2 +-
.../apache/druid/segment/realtime/FireHydrant.java | 2 +
.../{firehose => }/NoopChatHandlerProvider.java | 2 +-
.../ServiceAnnouncingChatHandlerProvider.java | 2 +-
.../{firehose => }/WindowedStorageAdapter.java | 2 +-
.../realtime/appenderator/AppenderatorImpl.java | 1638 --------------------
.../realtime/appenderator/Appenderators.java | 76 +-
.../appenderator/AppenderatorsManager.java | 41 +-
.../realtime/appenderator/BatchAppenderator.java | 2 +-
.../DummyForInjectionAppenderatorsManager.java | 40 +-
.../appenderator/PeonAppenderatorsManager.java | 79 +-
.../realtime/appenderator/StreamAppenderator.java | 2 +-
.../UnifiedIndexerAppenderatorsManager.java | 88 +-
.../realtime/firehose/ClippedFirehoseFactory.java | 81 -
.../firehose/EventReceiverFirehoseFactory.java | 659 --------
.../firehose/FixedCountFirehoseFactory.java | 93 --
.../realtime/firehose/IngestSegmentFirehose.java | 210 ---
.../realtime/firehose/PredicateFirehose.java | 89 --
.../firehose/TimedShutoffFirehoseFactory.java | 139 --
.../realtime/{firehose => }/package-info.java | 2 +-
.../server/coordinator/AutoCompactionSnapshot.java | 91 +-
.../CompactionConfigValidationResult.java | 15 +-
.../coordinator/CoordinatorCompactionConfig.java | 17 +-
.../coordinator/DataSourceCompactionConfig.java | 7 +
.../druid/server/coordinator/DruidCoordinator.java | 3 +
.../compact/CompactionSegmentSearchPolicy.java | 4 +-
.../coordinator/compact/CompactionStatistics.java | 16 +-
.../coordinator/compact/CompactionStatus.java | 7 +-
...a => DataSourceCompactibleSegmentIterator.java} | 137 +-
.../compact/NewestSegmentFirstPolicy.java | 15 +-
.../PriorityBasedCompactionSegmentIterator.java | 135 ++
.../coordinator/compact/SegmentsToCompact.java | 4 +-
.../config/DataSourceCompactionConfigBuilder.java | 155 ++
.../server/coordinator/duty/CompactSegments.java | 108 +-
.../coordinator/duty/KillUnusedSegments.java | 91 +-
.../server/http/CompactionConfigUpdateRequest.java | 82 +
.../http/CoordinatorCompactionConfigsResource.java | 59 +-
.../apache/druid/server/http/DataSegmentPlus.java | 23 +-
.../jetty/ChatHandlerServerModule.java | 2 +-
.../jetty/CliIndexerServerModule.java | 2 +-
.../jetty/TaskIdResponseHeaderFilterHolder.java | 2 +-
.../metrics/EventReceiverFirehoseMetric.java | 48 -
.../metrics/EventReceiverFirehoseMonitor.java | 90 --
.../metrics/EventReceiverFirehoseRegister.java | 56 -
.../apache/druid/server/metrics/MetricsModule.java | 1 -
.../druid/client/CachingQueryRunnerTest.java | 15 +-
.../client/coordinator/NoopCoordinatorClient.java | 6 +
.../indexing/ClientCompactionRunnerInfoTest.java | 9 +-
.../curator/discovery/ServiceAnnouncerTest.java | 27 +-
.../org/apache/druid/guice/FirehoseModuleTest.java | 93 --
.../IndexerSQLMetadataStorageCoordinatorTest.java | 290 +++-
...dexerSqlMetadataStorageCoordinatorTestBase.java | 49 +
.../SQLMetadataConnectorSchemaPersistenceTest.java | 2 -
.../druid/metadata/SQLMetadataConnectorTest.java | 1 -
.../SQLMetadataStorageActionHandlerTest.java | 56 +-
.../apache/druid/metadata/input/SqlEntityTest.java | 4 +-
.../druid/metadata/input/SqlInputSourceTest.java | 111 +-
.../apache/druid/metadata/input/SqlTestUtils.java | 55 +-
...CoordinatorSegmentDataCacheConcurrencyTest.java | 23 +-
.../CoordinatorSegmentMetadataCacheTest.java | 479 +++++-
.../{firehose => }/ChatHandlerResourceTest.java | 2 +-
.../ServiceAnnouncingChatHandlerProviderTest.java | 2 +-
.../realtime/appenderator/AppenderatorsTest.java | 245 ---
...rTest.java => BatchAppenderatorDriverTest.java} | 6 +-
...deratorTest.java => BatchAppenderatorTest.java} | 78 +-
...torTester.java => BatchAppenderatorTester.java} | 16 +-
.../OpenAndClosedSegmentsAppenderatorTester.java | 289 ----
...dClosedSegmentsBatchAppenderatorDriverTest.java | 205 ---
...OpenAndClosedSegmentsBatchAppenderatorTest.java | 228 ---
.../appenderator/StreamAppenderatorTester.java | 10 +-
.../UnifiedIndexerAppenderatorsManagerTest.java | 2 +-
.../firehose/EventReceiverFirehoseIdleTest.java | 136 --
.../firehose/EventReceiverFirehoseTest.java | 442 ------
.../druid/server/ClientQuerySegmentWalkerTest.java | 4 -
.../org/apache/druid/server/QueryStackTests.java | 5 +-
.../coordinator/AutoCompactionSnapshotTest.java | 15 +-
.../CoordinatorCompactionConfigTest.java} | 28 +-
.../DataSourceCompactionConfigTest.java | 372 ++---
.../coordinator/compact/CompactionStatusTest.java | 178 +++
.../DataSourceCompactibleSegmentIteratorTest.java | 77 +
.../compact/NewestSegmentFirstIteratorTest.java | 477 ------
.../compact/NewestSegmentFirstPolicyTest.java | 112 +-
.../coordinator/duty/KillUnusedSegmentsTest.java | 193 ++-
.../CoordinatorCompactionConfigsResourceTest.java | 849 +++++-----
.../druid/server/http/DataSegmentPlusTest.java | 3 +-
.../druid/server/http/MetadataResourceTest.java | 2 +-
.../main/java/org/apache/druid/cli/CliIndexer.java | 2 -
.../org/apache/druid/cli/CliMiddleManager.java | 6 +-
.../java/org/apache/druid/cli/CliOverlord.java | 18 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 10 +-
.../druid/cli/CoordinatorOverlordRedirectInfo.java | 6 +-
.../druid/cli/validate/DruidJsonValidator.java | 4 -
.../cli/CoordinatorOverlordRedirectInfoTest.java | 53 +
.../druid/cli/validate/DruidJsonValidatorTest.java | 1 -
.../ApproxCountDistinctSqlAggregator.java | 18 +-
.../aggregation/NativelySupportsDistinct.java | 17 +-
.../builtin/ArrayConcatSqlAggregator.java | 2 +
.../aggregation/builtin/ArraySqlAggregator.java | 2 +
.../BuiltinApproxCountDistinctSqlAggregator.java | 26 +-
.../aggregation/builtin/StringSqlAggregator.java | 2 +
.../sql/calcite/planner/DruidSqlValidator.java | 81 +-
.../apache/druid/sql/calcite/rel/DruidQuery.java | 1 -
.../apache/druid/sql/calcite/rel/Windowing.java | 29 +-
.../druid/sql/calcite/rule/GroupByRules.java | 12 +
.../druid/sql/calcite/run/NativeSqlEngine.java | 2 +-
.../calcite/schema/BrokerSegmentMetadataCache.java | 41 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 8 +-
.../druid/sql/calcite/CalciteArraysQueryTest.java | 74 +-
.../druid/sql/calcite/CalciteExplainQueryTest.java | 188 +--
.../druid/sql/calcite/CalciteExportTest.java | 5 -
.../druid/sql/calcite/CalciteInsertDmlTest.java | 224 +--
.../druid/sql/calcite/CalciteJoinQueryTest.java | 10 -
.../calcite/CalciteLookupFunctionQueryTest.java | 3 -
.../calcite/CalciteMultiValueStringQueryTest.java | 4 -
.../sql/calcite/CalciteNestedDataQueryTest.java | 52 +-
.../sql/calcite/CalciteParameterQueryTest.java | 2 -
.../apache/druid/sql/calcite/CalciteQueryTest.java | 75 +-
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 36 +-
.../druid/sql/calcite/CalciteSelectQueryTest.java | 67 +-
.../druid/sql/calcite/CalciteSubqueryTest.java | 219 ++-
.../druid/sql/calcite/CalciteTableAppendTest.java | 6 -
.../druid/sql/calcite/CalciteWindowQueryTest.java | 151 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 242 ++-
.../druid/sql/calcite/IngestTableFunctionTest.java | 14 +-
.../apache/druid/sql/calcite/NotYetSupported.java | 4 +-
.../schema/BrokerSegmentMetadataCacheTest.java | 89 +-
.../org.apache.druid.quidem.SqlQuidemTest/join.iq | 4 +-
.../simple.iq | 4 +-
.../testCommaJoinLeftFunction.iq | 8 +-
...ataSources@all_disabled@NullHandling=default.iq | 8 +-
...ineDataSources@all_disabled@NullHandling=sql.iq | 8 +-
...DataSources@all_enabled@NullHandling=default.iq | 8 +-
...lineDataSources@all_enabled@NullHandling=sql.iq | 8 +-
...lineDataSources@default@NullHandling=default.iq | 8 +-
...woInlineDataSources@default@NullHandling=sql.iq | 8 +-
...n-value-column_disabled@NullHandling=default.iq | 8 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 8 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 8 +-
...es@filter-rewrites-disabled@NullHandling=sql.iq | 8 +-
...Sources@filter-rewrites@NullHandling=default.iq | 8 +-
...DataSources@filter-rewrites@NullHandling=sql.iq | 8 +-
...aSources@join-to-filter@NullHandling=default.iq | 8 +-
...eDataSources@join-to-filter@NullHandling=sql.iq | 8 +-
...inCastLeft@all_disabled@NullHandling=default.iq | 8 +-
...erJoinCastLeft@all_disabled@NullHandling=sql.iq | 8 +-
...oinCastLeft@all_enabled@NullHandling=default.iq | 8 +-
...nerJoinCastLeft@all_enabled@NullHandling=sql.iq | 8 +-
...nerJoinCastLeft@default@NullHandling=default.iq | 8 +-
...stInnerJoinCastLeft@default@NullHandling=sql.iq | 8 +-
...n-value-column_disabled@NullHandling=default.iq | 8 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 8 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 8 +-
...ft@filter-rewrites-disabled@NullHandling=sql.iq | 8 +-
...astLeft@filter-rewrites@NullHandling=default.iq | 8 +-
...oinCastLeft@filter-rewrites@NullHandling=sql.iq | 8 +-
...CastLeft@join-to-filter@NullHandling=default.iq | 8 +-
...JoinCastLeft@join-to-filter@NullHandling=sql.iq | 8 +-
.../testInnerJoinLeftFunction@all_disabled.iq | 8 +-
.../testInnerJoinLeftFunction@all_enabled.iq | 8 +-
.../[email protected] | 8 +-
...LeftFunction@filter-on-value-column_disabled.iq | 8 +-
[email protected] | 8 +-
.../[email protected] | 8 +-
.../[email protected] | 8 +-
...rectAccess@all_disabled@NullHandling=default.iq | 12 +-
...ftDirectAccess@all_disabled@NullHandling=sql.iq | 12 +-
...irectAccess@all_enabled@NullHandling=default.iq | 12 +-
...eftDirectAccess@all_enabled@NullHandling=sql.iq | 12 +-
...eftDirectAccess@default@NullHandling=default.iq | 12 +-
...ithLeftDirectAccess@default@NullHandling=sql.iq | 12 +-
...n-value-column_disabled@NullHandling=default.iq | 12 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 12 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 12 +-
...ss@filter-rewrites-disabled@NullHandling=sql.iq | 12 +-
...tAccess@filter-rewrites@NullHandling=default.iq | 12 +-
...irectAccess@filter-rewrites@NullHandling=sql.iq | 12 +-
...ctAccess@join-to-filter@NullHandling=default.iq | 12 +-
...DirectAccess@join-to-filter@NullHandling=sql.iq | 12 +-
...rectAccess@all_disabled@NullHandling=default.iq | 12 +-
...ftDirectAccess@all_disabled@NullHandling=sql.iq | 12 +-
...irectAccess@all_enabled@NullHandling=default.iq | 12 +-
...eftDirectAccess@all_enabled@NullHandling=sql.iq | 12 +-
...eftDirectAccess@default@NullHandling=default.iq | 12 +-
...ithLeftDirectAccess@default@NullHandling=sql.iq | 12 +-
...n-value-column_disabled@NullHandling=default.iq | 12 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 12 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 12 +-
...ss@filter-rewrites-disabled@NullHandling=sql.iq | 12 +-
...tAccess@filter-rewrites@NullHandling=default.iq | 12 +-
...irectAccess@filter-rewrites@NullHandling=sql.iq | 12 +-
...ctAccess@join-to-filter@NullHandling=default.iq | 12 +-
...DirectAccess@join-to-filter@NullHandling=sql.iq | 12 +-
.../testInnerJoinQueryOfLookup@all_disabled.iq | 4 +-
.../testInnerJoinQueryOfLookup@all_enabled.iq | 4 +-
.../[email protected] | 4 +-
...ueryOfLookup@filter-on-value-column_disabled.iq | 4 +-
[email protected] | 4 +-
.../[email protected] | 4 +-
.../[email protected] | 4 +-
...InnerJoinQueryOfLookupRemovable@all_disabled.iq | 8 +-
...tInnerJoinQueryOfLookupRemovable@all_enabled.iq | 8 +-
.../[email protected] | 8 +-
...kupRemovable@filter-on-value-column_disabled.iq | 8 +-
[email protected] | 8 +-
[email protected] | 8 +-
[email protected] | 8 +-
...meseriesWithFloorOnTime@NullHandling=default.iq | 4 +-
...OfTimeseriesWithFloorOnTime@NullHandling=sql.iq | 4 +-
...AggregateMultipleValues@NullHandling=default.iq | 4 +-
...thNoAggregateMultipleValues@NullHandling=sql.iq | 4 +-
...meseriesWithFloorOnTime@NullHandling=default.iq | 4 +-
...OnTimeseriesWithFloorOnTime@NullHandling=sql.iq | 4 +-
...inWithInputRefCondition@NullHandling=default.iq | 4 +-
...stJoinWithInputRefCondition@NullHandling=sql.iq | 4 +-
...rectAccess@all_disabled@NullHandling=default.iq | 12 +-
...ftDirectAccess@all_disabled@NullHandling=sql.iq | 12 +-
...irectAccess@all_enabled@NullHandling=default.iq | 12 +-
...eftDirectAccess@all_enabled@NullHandling=sql.iq | 12 +-
...eftDirectAccess@default@NullHandling=default.iq | 12 +-
...ithLeftDirectAccess@default@NullHandling=sql.iq | 12 +-
...n-value-column_disabled@NullHandling=default.iq | 12 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 12 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 12 +-
...ss@filter-rewrites-disabled@NullHandling=sql.iq | 12 +-
...tAccess@filter-rewrites@NullHandling=default.iq | 12 +-
...irectAccess@filter-rewrites@NullHandling=sql.iq | 12 +-
...ctAccess@join-to-filter@NullHandling=default.iq | 12 +-
...DirectAccess@join-to-filter@NullHandling=sql.iq | 12 +-
...rectAccess@all_disabled@NullHandling=default.iq | 12 +-
...ftDirectAccess@all_disabled@NullHandling=sql.iq | 12 +-
...irectAccess@all_enabled@NullHandling=default.iq | 12 +-
...eftDirectAccess@all_enabled@NullHandling=sql.iq | 12 +-
...eftDirectAccess@default@NullHandling=default.iq | 12 +-
...ithLeftDirectAccess@default@NullHandling=sql.iq | 12 +-
...n-value-column_disabled@NullHandling=default.iq | 12 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 12 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 12 +-
...ss@filter-rewrites-disabled@NullHandling=sql.iq | 12 +-
...tAccess@filter-rewrites@NullHandling=default.iq | 12 +-
...irectAccess@filter-rewrites@NullHandling=sql.iq | 12 +-
...ctAccess@join-to-filter@NullHandling=default.iq | 12 +-
...DirectAccess@join-to-filter@NullHandling=sql.iq | 12 +-
...rectAccess@all_disabled@NullHandling=default.iq | 12 +-
...ftDirectAccess@all_disabled@NullHandling=sql.iq | 12 +-
...irectAccess@all_enabled@NullHandling=default.iq | 12 +-
...eftDirectAccess@all_enabled@NullHandling=sql.iq | 12 +-
...eftDirectAccess@default@NullHandling=default.iq | 12 +-
...ithLeftDirectAccess@default@NullHandling=sql.iq | 12 +-
...n-value-column_disabled@NullHandling=default.iq | 12 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 12 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 12 +-
...ss@filter-rewrites-disabled@NullHandling=sql.iq | 12 +-
...tAccess@filter-rewrites@NullHandling=default.iq | 12 +-
...irectAccess@filter-rewrites@NullHandling=sql.iq | 12 +-
...ctAccess@join-to-filter@NullHandling=default.iq | 12 +-
...DirectAccess@join-to-filter@NullHandling=sql.iq | 12 +-
...tJoinSubqueryWithSelectorFilter@all_disabled.iq | 4 +-
...ftJoinSubqueryWithSelectorFilter@all_enabled.iq | 4 +-
[email protected] | 4 +-
...lectorFilter@filter-on-value-column_disabled.iq | 4 +-
[email protected] | 4 +-
[email protected] | 4 +-
[email protected] | 4 +-
...ractionFns@all_disabled@NullHandling=default.iq | 4 +-
...hExtractionFns@all_disabled@NullHandling=sql.iq | 4 +-
...tractionFns@all_enabled@NullHandling=default.iq | 4 +-
...thExtractionFns@all_enabled@NullHandling=sql.iq | 4 +-
...thExtractionFns@default@NullHandling=default.iq | 4 +-
...ryWithExtractionFns@default@NullHandling=sql.iq | 4 +-
...n-value-column_disabled@NullHandling=default.iq | 4 +-
...er-on-value-column_disabled@NullHandling=sql.iq | 4 +-
...ilter-rewrites-disabled@NullHandling=default.iq | 4 +-
...ns@filter-rewrites-disabled@NullHandling=sql.iq | 4 +-
...tionFns@filter-rewrites@NullHandling=default.iq | 4 +-
...tractionFns@filter-rewrites@NullHandling=sql.iq | 4 +-
...ctionFns@join-to-filter@NullHandling=default.iq | 4 +-
...xtractionFns@join-to-filter@NullHandling=sql.iq | 4 +-
...lColumnOnMVFilterJoinExpression@all_disabled.iq | 12 +-
...alColumnOnMVFilterJoinExpression@all_enabled.iq | 12 +-
[email protected] | 12 +-
...inExpression@filter-on-value-column_disabled.iq | 12 +-
[email protected] | 12 +-
[email protected] | 12 +-
[email protected] | 12 +-
...mnOnMVFilterMultiJoinExpression@all_disabled.iq | 20 +-
...umnOnMVFilterMultiJoinExpression@all_enabled.iq | 20 +-
[email protected] | 20 +-
...inExpression@filter-on-value-column_disabled.iq | 20 +-
[email protected] | 20 +-
[email protected] | 20 +-
[email protected] | 20 +-
...herAggregatorsUsingJoin@NullHandling=default.iq | 4 +-
...ndOtherAggregatorsUsingJoin@NullHandling=sql.iq | 4 +-
...indowingWithScanAndSort@NullHandling=default.iq | 4 +-
...estWindowingWithScanAndSort@NullHandling=sql.iq | 4 +-
.../calcite/tests/window/WindowOpReorder.sqlTest | 16 +-
.../calcite/tests/window/aggregateConstant.sqlTest | 2 +-
.../tests/window/allBoundsCombination.sqlTest | 38 +
.../tests/window/defaultBoundCurrentRow.sqlTest | 65 +
.../tests/window/duplicateAggregation.sqlTest | 10 +
.../calcite/tests/window/no_grouping.sqlTest | 28 +-
.../calcite/tests/window/no_grouping2.sqlTest | 2 +-
.../calcite/tests/window/range_handling.sqlTest | 17 +-
.../calcite/tests/window/rank_handling.sqlTest | 3 +
.../calcite/tests/window/simpleSum.sqlTest | 9 +-
.../calcite/tests/window/virtualColumns.sqlTest | 2 +-
.../wikipediaAggregationsMultipleOrdering.sqlTest | 13 +-
...kipediaAggregationsMultipleOrderingDesc.sqlTest | 2 +-
.../window/wikipediaCumulativeOrdered.sqlTest | 11 +-
.../window/wikipediaFramedAggregations.sqlTest | 12 +-
.../tests/window/wikipediaSimplePartition.sqlTest | 2 +-
.../wikipediaSimplePartitionInitialSort.sqlTest | 2 +-
.../tests/window/windowInsideSubquery.sqlTest | 19 +
.../tests/window/windowed_long_null.sqlTest | 4 +-
.../empty_and_non_empty_over/wikipedia_query_1.e | 14 +
.../empty_and_non_empty_over/wikipedia_query_1.q | 8 +
.../empty_and_non_empty_over/wikipedia_query_2.e | 14 +
.../empty_and_non_empty_over/wikipedia_query_2.q | 8 +
.../empty_and_non_empty_over/wikipedia_query_3.e | 16 +
.../empty_and_non_empty_over/wikipedia_query_3.q | 23 +
.../empty_over_clause/multiple_empty_over_1.e | 13 +
.../empty_over_clause/multiple_empty_over_1.q | 7 +
.../empty_over_clause/single_empty_over_1.e | 13 +
.../empty_over_clause/single_empty_over_1.q | 4 +
.../empty_over_clause/single_empty_over_2.e | 13 +
.../empty_over_clause/single_empty_over_2.q | 4 +
.../multiple_windows/wikipedia_query_1.e | 13 +
.../multiple_windows/wikipedia_query_1.q | 6 +
.../wikipedia_query_1_named_windows.e | 13 +
.../wikipedia_query_1_named_windows.q | 9 +
.../multiple_over_different_partition_column.e | 13 +
.../multiple_over_different_partition_column.q | 7 +
.../multiple_over_multiple_partition_columns_1.e | 9 +
.../multiple_over_multiple_partition_columns_1.q | 7 +
.../multiple_over_multiple_partition_columns_2.e | 74 +
.../multiple_over_multiple_partition_columns_2.q | 7 +
.../multiple_over_same_partition_column.e | 13 +
.../multiple_over_same_partition_column.q | 7 +
.../over_clause_only_partitioning/single_over_1.e | 13 +
.../over_clause_only_partitioning/single_over_1.q | 6 +
.../over_clause_only_partitioning/single_over_2.e | 13 +
.../over_clause_only_partitioning/single_over_2.q | 6 +
.../single_over_multiple_partition_columns.e | 13 +
.../single_over_multiple_partition_columns.q | 6 +
.../multiple_over_different_sort_column.e | 13 +
.../multiple_over_different_sort_column.q | 7 +
.../multiple_over_multiple_sort_columns_1.e | 9 +
.../multiple_over_multiple_sort_columns_1.q | 7 +
.../multiple_over_multiple_sort_columns_2.e | 74 +
.../multiple_over_multiple_sort_columns_2.q | 7 +
.../multiple_over_same_sort_column.e | 13 +
.../multiple_over_same_sort_column.q | 7 +
.../over_clause_only_sorting/single_over_1.e | 13 +
.../over_clause_only_sorting/single_over_1.q | 6 +
.../over_clause_only_sorting/single_over_2.e | 13 +
.../over_clause_only_sorting/single_over_2.q | 6 +
.../single_over_multiple_sort_columns.e | 13 +
.../single_over_multiple_sort_columns.q | 6 +
.../partition_by_array/wikipedia_query_1.e | 13 +
.../partition_by_array/wikipedia_query_1.q | 6 +
.../partition_by_array/wikipedia_query_2.e | 13 +
.../partition_by_array/wikipedia_query_2.q | 6 +
.../partition_by_array/wikipedia_query_3.e | 13 +
.../partition_by_array/wikipedia_query_3.q | 6 +
.../wikipedia_query_1.e | 15 +
.../wikipedia_query_1.q | 7 +
.../wikipedia_query_2.e | 15 +
.../wikipedia_query_2.q | 9 +
.../same_window_across_columns/wikipedia_query_1.e | 15 +
.../same_window_across_columns/wikipedia_query_1.q | 6 +
.../wikipedia_query_1_named_window.e | 15 +
.../wikipedia_query_1_named_window.q | 7 +
.../shuffle_columns/wikipedia_query_1.e | 15 +
.../shuffle_columns/wikipedia_query_1.q | 5 +
.../shuffle_columns/wikipedia_query_1_shuffle_1.e | 15 +
.../shuffle_columns/wikipedia_query_1_shuffle_1.q | 5 +
.../shuffle_columns/wikipedia_query_2.e | 16 +
.../shuffle_columns/wikipedia_query_2.q | 9 +
.../shuffle_columns/wikipedia_query_2_shuffle_1.e | 16 +
.../shuffle_columns/wikipedia_query_2_shuffle_1.q | 9 +
.../e2e-tests/component/datasources/overview.ts | 4 +-
.../e2e-tests/component/load-data/data-loader.ts | 4 +-
web-console/package-lock.json | 514 +++---
web-console/package.json | 16 +-
web-console/script/licenses | 5 +
web-console/src/blueprint-overrides/_index.scss | 1 +
.../_segmented-control.scss} | 13 +-
.../blueprint-overrides/_special-switch-modes.scss | 10 +-
.../src/blueprint-overrides/common/_colors.scss | 1 +
.../src/blueprint-overrides/common/_variables.scss | 2 +-
.../__snapshots__/action-cell.spec.tsx.snap | 3 +-
.../components/action-cell/action-cell.spec.tsx | 2 +-
.../src/components/action-cell/action-cell.tsx | 14 +-
.../__snapshots__/action-icon.spec.tsx.snap | 3 +-
.../__snapshots__/array-input.spec.tsx.snap | 12 +-
.../src/components/array-input/array-input.tsx | 7 +-
.../__snapshots__/array-mode-swtich.spec.tsx.snap | 16 +-
.../__snapshots__/auto-form.spec.tsx.snap | 80 +-
web-console/src/components/auto-form/auto-form.tsx | 39 +-
.../__snapshots__/center-message.spec.tsx.snap | 2 +-
.../components/center-message/center-message.tsx | 4 +-
.../__snapshots__/clearable-input.spec.tsx.snap | 11 +-
.../date-range-selector/date-range-selector.tsx | 74 -
.../fancy-numeric-input.spec.tsx.snap | 18 +-
.../form-group-with-info.spec.tsx.snap | 16 +-
.../form-group-with-info/form-group-with-info.tsx | 7 +-
.../__snapshots__/form-json-selector.spec.tsx.snap | 24 +-
.../__snapshots__/formatted-input.spec.tsx.snap | 10 +-
.../components/formatted-input/formatted-input.tsx | 7 +-
.../__snapshots__/header-bar.spec.tsx.snap | 135 +-
.../src/components/header-bar/header-bar.tsx | 22 +-
.../__snapshots__/restricted-mode.spec.tsx.snap | 20 +-
.../header-bar/restricted-mode/restricted-mode.tsx | 7 +-
.../__snapshots__/interval-input.spec.tsx.snap | 16 +-
.../components/interval-input/interval-input.tsx | 26 +-
.../__snapshots__/json-collapse.spec.tsx.snap | 12 +-
.../__snapshots__/menu-checkbox.spec.tsx.snap | 18 +-
.../__snapshots__/menu-tristate.spec.tsx.snap | 164 +-
.../__snapshots__/more-button.spec.tsx.snap | 20 +-
.../components/more-button/more-button.spec.tsx | 4 +-
.../src/components/more-button/more-button.tsx | 7 +-
.../record-table-pane/record-table-pane.tsx | 10 +-
.../__snapshots__/rule-editor.spec.tsx.snap | 561 ++++---
.../__snapshots__/segment-timeline.spec.tsx.snap | 178 +--
.../segment-timeline/segment-timeline.scss | 3 +-
.../segment-timeline/segment-timeline.spec.tsx | 4 +-
.../segment-timeline/segment-timeline.tsx | 249 +--
.../segment-timeline/stacked-bar-chart.tsx | 7 +-
.../__snapshots__/show-json.spec.tsx.snap | 14 +-
.../show-log/__snapshots__/show-log.spec.tsx.snap | 19 +-
web-console/src/components/show-log/show-log.tsx | 4 +-
.../__snapshots__/show-value.spec.tsx.snap | 8 +-
.../__snapshots__/suggestible-input.spec.tsx.snap | 32 +-
.../suggestible-input/suggestible-input.tsx | 7 +-
.../__snapshots__/suggestion-menu.spec.tsx.snap | 84 +-
.../__snapshots__/table-cell.spec.tsx.snap | 6 +-
.../table-column-selector.spec.tsx.snap | 12 +-
.../table-column-selector.tsx | 7 +-
.../table-filterable-cell.scss | 2 +-
.../table-filterable-cell.tsx | 7 +-
.../__snapshots__/timed-button.spec.tsx.snap | 21 +-
.../src/components/timed-button/timed-button.tsx | 7 +-
.../__snapshots__/warning-checklist.spec.tsx.snap | 12 +-
.../__snapshots__/about-dialog.spec.tsx.snap | 49 +-
.../__snapshots__/alert-dialog.spec.tsx.snap | 30 +-
.../async-action-dialog.spec.tsx.snap | 30 +-
.../compaction-config-dialog.spec.tsx.snap | 444 +++---
.../compaction-config-dialog.tsx | 7 +-
.../datasource-table-action-dialog.spec.tsx.snap | 70 +-
.../__snapshots__/doctor-dialog.spec.tsx.snap | 50 +-
.../edit-context-dialog.spec.tsx.snap | 43 +-
.../__snapshots__/history-dialog.spec.tsx.snap | 80 +-
.../__snapshots__/index-spec-dialog.spec.tsx.snap | 40 +-
.../__snapshots__/lookup-edit-dialog.spec.tsx.snap | 70 +-
.../lookup-table-action-dialog.spec.tsx.snap | 63 +-
.../__snapshots__/retention-dialog.spec.tsx.snap | 1355 ++++++++--------
.../dialogs/retention-dialog/retention-dialog.scss | 18 +-
.../dialogs/retention-dialog/retention-dialog.tsx | 112 +-
.../segment-table-action-dialog.spec.tsx.snap | 84 +-
.../__snapshots__/show-value-dialog.spec.tsx.snap | 50 +-
.../__snapshots__/snitch-dialog.spec.tsx.snap | 92 +-
.../__snapshots__/spec-dialog.spec.tsx.snap | 86 +-
.../__snapshots__/status-dialog.spec.tsx.snap | 43 +-
.../supervisor-table-action-dialog.spec.tsx.snap | 98 +-
.../supervisor-statistics-table.spec.tsx.snap | 30 +-
.../table-action-dialog.spec.tsx.snap | 48 +-
.../table-action-dialog/table-action-dialog.tsx | 7 +-
.../task-table-action-dialog.spec.tsx.snap | 98 +-
.../execution/execution-ingest-complete.mock.ts | 2 -
.../execution/execution-ingest-error.mock.ts | 2 -
.../src/druid-models/execution/execution.spec.ts | 3 -
web-console/src/druid-models/stages/stages.mock.ts | 1 -
web-console/src/druid-models/stages/stages.spec.ts | 6 +-
web-console/src/druid-models/stages/stages.ts | 59 +-
web-console/src/entry.scss | 5 +-
web-console/src/{entry.ts => entry.tsx} | 15 +-
web-console/src/react-table/react-table-inputs.tsx | 7 +-
.../react-table-pagination.tsx | 7 +-
web-console/src/setup-tests.ts | 6 +
web-console/src/utils/basic-action.tsx | 8 +-
web-console/src/utils/date.ts | 14 +-
web-console/src/utils/general.spec.ts | 10 +
web-console/src/utils/general.tsx | 6 +-
web-console/src/utils/table-helpers.ts | 6 +-
.../__snapshots__/datasources-view.spec.tsx.snap | 13 +-
.../views/datasources-view/datasources-view.tsx | 5 +-
.../explore-view/control-pane/aggregates-input.tsx | 7 +-
.../explore-view/control-pane/columns-input.scss | 4 +-
.../explore-view/control-pane/columns-input.tsx | 7 +-
.../explore-view/control-pane/control-pane.scss | 4 +-
.../explore-view/control-pane/control-pane.tsx | 14 +-
.../explore-view/control-pane/options-input.tsx | 7 +-
.../filter-pane/filter-menu/filter-menu.scss | 4 +-
.../values-filter-control.tsx | 6 +-
.../views/explore-view/filter-pane/filter-pane.tsx | 11 +-
.../generic-output-table/generic-output-table.tsx | 13 +-
.../modules/time-chart-echarts-module.ts | 7 +-
.../explore-view/resource-pane/resource-pane.tsx | 16 +-
.../explore-view/source-pane/source-pane.scss | 4 +-
.../views/explore-view/source-pane/source-pane.tsx | 7 +-
.../explore-view/tile-picker/tile-picker.scss | 6 +-
.../views/explore-view/tile-picker/tile-picker.tsx | 11 +-
.../__snapshots__/datasources-card.spec.tsx.snap | 7 +-
.../__snapshots__/home-view-card.spec.tsx.snap | 7 +-
.../__snapshots__/lookups-card.spec.tsx.snap | 7 +-
.../__snapshots__/segments-card.spec.tsx.snap | 7 +-
.../__snapshots__/services-card.spec.tsx.snap | 7 +-
.../__snapshots__/status-card.spec.tsx.snap | 7 +-
.../views/home-view/status-card/status-card.tsx | 6 +-
.../__snapshots__/supervisors-card.spec.tsx.snap | 7 +-
.../__snapshots__/tasks-card.spec.tsx.snap | 7 +-
.../__snapshots__/load-data-view.spec.tsx.snap | 152 +-
.../__snapshots__/example-picker.spec.tsx.snap | 22 +-
.../__snapshots__/form-editor.spec.tsx.snap | 34 +-
.../src/views/load-data-view/load-data-view.tsx | 18 +-
.../__snapshots__/lookups-view.spec.tsx.snap | 2 +-
.../src/views/lookups-view/lookups-view.tsx | 1 +
.../__snapshots__/segments-view.spec.tsx.snap | 21 +-
.../src/views/segments-view/segments-view.tsx | 1 +
.../__snapshots__/services-view.spec.tsx.snap | 23 +-
.../src/views/services-view/services-view.tsx | 2 +-
.../column-actions/column-actions.tsx | 11 +-
.../column-editor/column-editor.tsx | 6 +-
.../destination-form/destination-form.tsx | 6 +-
.../schema-step/column-list/column-list.tsx | 11 +-
.../schema-step/preview-table/preview-table.tsx | 7 +-
.../schema-step/schema-step.tsx | 18 +-
.../__snapshots__/supervisors-view.spec.tsx.snap | 36 +-
.../views/supervisors-view/supervisors-view.tsx | 8 +-
.../__snapshots__/tasks-view.spec.tsx.snap | 34 +-
web-console/src/views/tasks-view/tasks-view.tsx | 1 +
.../__snapshots__/column-tree.spec.tsx.snap | 67 +-
.../__snapshots__/complex-menu-items.spec.tsx.snap | 89 +-
.../__snapshots__/number-menu-items.spec.tsx.snap | 543 ++++---
.../__snapshots__/string-menu-items.spec.tsx.snap | 543 ++++---
.../__snapshots__/time-menu-items.spec.tsx.snap | 543 ++++---
.../workbench-view/column-tree/column-tree.tsx | 49 +-
.../destination-pages-pane.tsx | 7 +-
.../execution-details-pane.spec.tsx.snap | 9 -
.../execution-error-pane.spec.tsx.snap | 4 +-
.../execution-progress-bar-pane.spec.tsx.snap | 10 +-
.../execution-stages-pane.spec.tsx.snap | 1 -
.../execution-stages-pane.tsx | 24 +-
.../execution-submit-dialog.spec.tsx.snap | 24 +-
.../execution-summary-panel.tsx | 7 +-
.../execution-timer-panel.spec.tsx.snap | 28 +-
.../__snapshots__/explain-dialog.spec.tsx.snap | 108 +-
.../explain-dialog/explain-dialog.spec.tsx | 2 -
.../flexible-query-input/flexible-query-input.tsx | 7 +-
.../__snapshots__/max-tasks-button.spec.tsx.snap | 43 +-
.../max-tasks-button/max-tasks-button.tsx | 46 +-
.../query-parameters-dialog.spec.tsx.snap | 164 +-
.../query-parameters-dialog.tsx | 6 +-
.../views/workbench-view/query-tab/query-tab.tsx | 11 +-
.../recent-query-task-panel.tsx | 7 +-
.../result-table-pane/result-table-pane.tsx | 11 +-
.../views/workbench-view/run-panel/run-panel.tsx | 90 +-
.../workbench-history-dialog.tsx | 7 +-
.../src/views/workbench-view/workbench-view.tsx | 30 +-
web-console/unified-console.html | 2 +-
web-console/webpack.config.js | 13 +-
website/.spelling | 28 +-
website/sidebars.json | 4 +-
976 files changed, 18329 insertions(+), 22529 deletions(-)
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/GroupByDeserializationBenchmark.java
create mode 100644 docs/release-info/migr-ansi-sql-null.md
copy
extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/{execution/TaskTypePodTemplateSelectStrategy.java
=> taskadapter/PodTemplateWithName.java} (52%)
create mode 100644
extensions-contrib/kubernetes-overlord-extensions/src/test/java/org/apache/druid/k8s/overlord/common/PodTemplateWithNameTest.java
copy
extensions-contrib/kubernetes-overlord-extensions/src/test/resources/{expectedNoopJob.yaml
=> expectedNoopJobBase.yaml} (96%)
copy
extensions-contrib/kubernetes-overlord-extensions/src/test/resources/{expectedNoopJobTlsEnabled.yaml
=> expectedNoopJobTlsEnabledBase.yaml} (96%)
copy
indexing-service/src/test/java/org/apache/druid/indexing/firehose/WindowedSegmentIdTest.java
=>
extensions-contrib/spectator-histogram/src/test/java/org/apache/druid/spectator/histogram/SpectatorHistogramIndexBasedComplexColumnTest.java
(56%)
create mode 100644
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/K8sDruidLeaderSelectorProvider.java
rename
server/src/main/java/org/apache/druid/segment/realtime/firehose/EventReceiver.java
=>
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorFactoryTest.java
(62%)
rename
extensions-core/mysql-metadata-storage/src/main/java/org/apache/druid/{firehose/sql/MySQLFirehoseDatabaseConnector.java
=> metadata/input/MySQLInputSourceDatabaseConnector.java} (91%)
rename
extensions-core/mysql-metadata-storage/src/test/java/org/apache/druid/{firehose/sql/MySQLFirehoseDatabaseConnectorTest.java
=> metadata/input/MySQLInputSourceDatabaseConnectorTest.java} (92%)
rename
extensions-core/postgresql-metadata-storage/src/main/java/org/apache/druid/{firehose/PostgresqlFirehoseDatabaseConnector.java
=> metadata/input/PostgresqlInputSourceDatabaseConnector.java} (87%)
rename
extensions-core/postgresql-metadata-storage/src/test/java/org/apache/druid/{firehose/PostgresqlFirehoseDatabaseConnectorTest.java
=> metadata/input/PostgresqlInputSourceDatabaseConnectorTest.java} (90%)
rename
server/src/test/java/org/apache/druid/segment/realtime/firehose/IngestSegmentFirehoseTest.java
=>
indexing-hadoop/src/test/java/org/apache/druid/indexer/hadoop/DatasourceRecordReaderSegmentReaderTest.java
(92%)
delete mode 100644
indexing-service/src/main/java/org/apache/druid/guice/IndexingServiceFirehoseModule.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/{RetrieveSegmentsByIdAction.java
=> RetrieveUpgradedFromSegmentIdsAction.java} (60%)
copy
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/{RetrieveSegmentsByIdAction.java
=> RetrieveUpgradedToSegmentIdsAction.java} (60%)
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentInsertAction.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/{TaskAuditLogConfig.java
=> UpgradedFromSegmentsResponse.java} (71%)
rename
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/{TaskAuditLogConfig.java
=> UpgradedToSegmentsResponse.java} (70%)
rename indexing-service/src/main/java/org/apache/druid/indexing/{firehose =>
input}/WindowedSegmentId.java (98%)
copy
indexing-service/src/main/java/org/apache/druid/indexing/overlord/{TaskMaster.java
=> DruidOverlord.java} (56%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskQueryTool.java
delete mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/TaskStorageQueryAdapter.java
copy
indexing-service/src/{test/java/org/apache/druid/indexing/test/TestDataSegmentKiller.java
=> main/java/org/apache/druid/indexing/overlord/http/TaskStateLookup.java}
(66%)
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/TestFirehose.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/actions/SegmentInsertActionTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/BatchAppenderatorsTest.java
delete mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/TasksTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/TuningConfigBuilder.java
rename indexing-service/src/test/java/org/apache/druid/indexing/{firehose =>
input}/WindowedSegmentIdTest.java (96%)
delete mode 100644
integration-tests/src/main/java/org/apache/druid/testing/clients/EventReceiverFirehoseTestClient.java
create mode 100644 licenses/bin/@fontsource-open-sans.OFL
create mode 100644 licenses/bin/react-innertext.MIT
create mode 100644 licenses/bin/react-uid.MIT
create mode 100644
processing/src/main/java/org/apache/druid/collections/CircularList.java
delete mode 100644
processing/src/main/java/org/apache/druid/data/input/Firehose.java
delete mode 100644
processing/src/main/java/org/apache/druid/data/input/FirehoseFactory.java
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnDoubleAggregatorWrapper.java
=> ObjectColumnDoubleAggregatorWrapper.java} (93%)
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnDoubleBufferAggregatorWrapper.java
=> ObjectColumnDoubleBufferAggregatorWrapper.java} (93%)
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnFloatAggregatorWrapper.java
=> ObjectColumnFloatAggregatorWrapper.java} (93%)
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnFloatBufferAggregatorWrapper.java
=> ObjectColumnFloatBufferAggregatorWrapper.java} (93%)
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnLongAggregatorWrapper.java
=> ObjectColumnLongAggregatorWrapper.java} (93%)
rename
processing/src/main/java/org/apache/druid/query/aggregation/{StringColumnLongBufferAggregatorWrapper.java
=> ObjectColumnLongBufferAggregatorWrapper.java} (93%)
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/ResultRowObjectMapperDecoratorUtil.java
create mode 100644
processing/src/test/java/org/apache/druid/collections/CircularListTest.java
create mode 100644
processing/src/test/java/org/apache/druid/metadata/MetadataStorageActionHandlerTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/groupby/ComplexDimensionGroupByQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/WindowFrameTest.java
delete mode 100644
server/src/main/java/org/apache/druid/guice/FirehoseModule.java
rename
server/src/main/java/org/apache/druid/metadata/{SQLFirehoseDatabaseConnector.java
=> SQLInputSourceDatabaseConnector.java} (98%)
copy server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/ChatHandler.java (95%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/ChatHandlerProvider.java (97%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/ChatHandlerResource.java (98%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/ChatHandlers.java (97%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/NoopChatHandlerProvider.java (96%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/ServiceAnnouncingChatHandlerProvider.java (98%)
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/WindowedStorageAdapter.java (96%)
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorImpl.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/ClippedFirehoseFactory.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/EventReceiverFirehoseFactory.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/FixedCountFirehoseFactory.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/IngestSegmentFirehose.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/PredicateFirehose.java
delete mode 100644
server/src/main/java/org/apache/druid/segment/realtime/firehose/TimedShutoffFirehoseFactory.java
rename server/src/main/java/org/apache/druid/segment/realtime/{firehose =>
}/package-info.java (94%)
rename
server/src/main/java/org/apache/druid/server/coordinator/compact/{NewestSegmentFirstIterator.java
=> DataSourceCompactibleSegmentIterator.java} (82%)
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/compact/PriorityBasedCompactionSegmentIterator.java
create mode 100644
server/src/main/java/org/apache/druid/server/coordinator/config/DataSourceCompactionConfigBuilder.java
create mode 100644
server/src/main/java/org/apache/druid/server/http/CompactionConfigUpdateRequest.java
delete mode 100644
server/src/main/java/org/apache/druid/server/metrics/EventReceiverFirehoseMetric.java
delete mode 100644
server/src/main/java/org/apache/druid/server/metrics/EventReceiverFirehoseMonitor.java
delete mode 100644
server/src/main/java/org/apache/druid/server/metrics/EventReceiverFirehoseRegister.java
delete mode 100644
server/src/test/java/org/apache/druid/guice/FirehoseModuleTest.java
rename server/src/test/java/org/apache/druid/segment/realtime/{firehose =>
}/ChatHandlerResourceTest.java (97%)
rename server/src/test/java/org/apache/druid/segment/realtime/{firehose =>
}/ServiceAnnouncingChatHandlerProviderTest.java (99%)
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/AppenderatorsTest.java
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{ClosedSegmentsSinksBatchAppenderatorDriverTest.java
=> BatchAppenderatorDriverTest.java} (97%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{ClosedSegmentsSinksBatchAppenderatorTest.java
=> BatchAppenderatorTest.java} (91%)
rename
server/src/test/java/org/apache/druid/segment/realtime/appenderator/{ClosedSegmensSinksBatchAppenderatorTester.java
=> BatchAppenderatorTester.java} (95%)
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/OpenAndClosedSegmentsAppenderatorTester.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/OpenAndClosedSegmentsBatchAppenderatorDriverTest.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/appenderator/OpenAndClosedSegmentsBatchAppenderatorTest.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/firehose/EventReceiverFirehoseIdleTest.java
delete mode 100644
server/src/test/java/org/apache/druid/segment/realtime/firehose/EventReceiverFirehoseTest.java
copy
server/src/{main/java/org/apache/druid/server/coordinator/CompactionConfigValidationResult.java
=>
test/java/org/apache/druid/server/coordinator/CoordinatorCompactionConfigTest.java}
(57%)
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/compact/CompactionStatusTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/coordinator/compact/DataSourceCompactibleSegmentIteratorTest.java
delete mode 100644
server/src/test/java/org/apache/druid/server/coordinator/compact/NewestSegmentFirstIteratorTest.java
create mode 100644
services/src/test/java/org/apache/druid/cli/CoordinatorOverlordRedirectInfoTest.java
rename
server/src/main/java/org/apache/druid/segment/realtime/firehose/ChatHandler.java
=>
sql/src/main/java/org/apache/druid/sql/calcite/aggregation/NativelySupportsDistinct.java
(64%)
create mode 100644
sql/src/test/resources/calcite/tests/window/allBoundsCombination.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/defaultBoundCurrentRow.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/duplicateAggregation.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/windowInsideSubquery.sqlTest
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_3.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_and_non_empty_over/wikipedia_query_3.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/multiple_empty_over_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/multiple_empty_over_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/single_empty_over_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/single_empty_over_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/single_empty_over_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/empty_over_clause/single_empty_over_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/multiple_windows/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/multiple_windows/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/multiple_windows/wikipedia_query_1_named_windows.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/multiple_windows/wikipedia_query_1_named_windows.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_different_partition_column.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_different_partition_column.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_multiple_partition_columns_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_multiple_partition_columns_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_multiple_partition_columns_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_multiple_partition_columns_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_same_partition_column.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/multiple_over_same_partition_column.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_multiple_partition_columns.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_partitioning/single_over_multiple_partition_columns.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_different_sort_column.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_different_sort_column.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_multiple_sort_columns_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_multiple_sort_columns_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_multiple_sort_columns_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_multiple_sort_columns_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_same_sort_column.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/multiple_over_same_sort_column.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_multiple_sort_columns.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/over_clause_only_sorting/single_over_multiple_sort_columns.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_3.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_array/wikipedia_query_3.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_multiple_columns/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_multiple_columns/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_multiple_columns/wikipedia_query_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/partition_by_multiple_columns/wikipedia_query_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/same_window_across_columns/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/same_window_across_columns/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/same_window_across_columns/wikipedia_query_1_named_window.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/same_window_across_columns/wikipedia_query_1_named_window.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_1_shuffle_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_1_shuffle_1.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_2.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_2.q
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_2_shuffle_1.e
create mode 100644
sql/src/test/resources/drill/window/queries/druid_queries/shuffle_columns/wikipedia_query_2_shuffle_1.q
rename
web-console/src/{components/date-range-selector/date-range-selector.scss =>
blueprint-overrides/_segmented-control.scss} (84%)
delete mode 100644
web-console/src/components/date-range-selector/date-range-selector.tsx
rename web-console/src/{entry.ts => entry.tsx} (93%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
