This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.postgresql-postgresql-42.5.1
in repository https://gitbox.apache.org/repos/asf/druid.git
discard 43be49de97 bump postgresql from 42.4.1 to 42.5.1
add b091b32f21 Fixes reindexing bug with filter on long column (#13386)
add db7c29c6f9 Correction to firehose migration doc (#13423)
add 656b6cdf62 Add MetricsVerifier to simplify verification of metric
values in tests (#13442)
add 58c896ea0b ServiceClient: More robust redirect handling. (#13413)
add b12e5f300e Add filter in cloud object input source for backward
compatibility (#13437)
add a2d5e335f3 Web console: Index spec dialog (#13425)
add 4b58f5f23c fix KafkaInputFormat with nested columns by delegating to
underlying inputRow map instead of eagerly copying (#13406)
add 37b8d4861c fix issues with nested data conversion (#13407)
add d8f4353c43 Web console: be more robust to aux queries failing and
improve kill tasks (#13431)
add 100a2aa4a2 Update and document experimental features (#13348)
add edd076ca69 Remove duplicate FrameRowTooLargeException.java (#13441)
add 4ed6255bdf Convert errors based on implicit type conversion in multi
value arrays to parse exception in MSQ (#13366)
add 79df11c16c Improve unit test coverage for MSQ (#13398)
add 5c520e0cf9 Update LDAP configuration docs (#13245)
add 50963edcae Fix compile error in MSQSelectTest. (#13456)
add 291ded22d5 Update experimental features doc (#13452)
add 8ff1b2d5d4 Revert "Add filter in cloud object input source for
backward compatibility (#13437)" (#13450)
add af164cbc10 Fix an issue with WorkerSketchFetcher not terminating on
shutdown (#13459)
add 6ba35f6d59 update org.bouncycastle:bcprov-jdk15on 1.68 to 1.69 (#13440)
add cc2e4a80ff doc: add a basic JDBC tutorial (#13343)
add 2fdcfffe40 don't render duration if aggregated (#13455)
add 2f3b97194f Fix harcoded version in pom file (#13460)
add 8395273099 Add unit tests for MSQ ingestion faults (#13439)
add f6f625ee08 MSQ Reindex IT (#13433)
add cc307e4c29 Fix needless task shutdown on leader switch (#13411)
add 138a6de507 Update nested columns docs (#13461)
add 30498c1f98 Update gha & travis checks (#13412)
add b76ff16d00 SQL test framework extensions (#13426)
add 78c1a2bd66 Remove limit from timeseries (#13457)
add 9177419628 Unnest functionality for Druid (#13268)
add 45a8fa280c Add SegmentAllocationQueue to batch SegmentAllocateActions
(#13369)
add 10bec54acc Switching emitter. This will allow for a per feed emitter
designation. (#13363)
add 65945a686f Docs: Update docs for coordinator dynamic config (#13494)
add 658a9c2d35 Early stop on failed start (Alternative to #13087) (#13258)
add fda0a1aadd Set chatAsync default to true. (#13491)
add 136322d13b clean install before license checks (#13502)
add cf472162a6 fix issue with jetty graceful shutdown of data servers when
druid.serverview.type=http (#13499)
add 83261f9641 Starting on Window Functions (#13458)
add 37d8833125 fix bug with broker parallel merge metrics emitting, add
wall time, fast/slow partition time metrics (#13420)
add b25cf216d5 Better error message when theta_sketch_intersect is used on
scalar expression (#13508)
add c7229fc787 Limit max batch size for segment allocation, add docs
(#13503)
add 9679f6a9b5 Web console: add arrayOfDoublesSketch and other small fixes
(#13486)
add b56855b837 Update to native ingestion doc (#13482)
add 69951273b8 Fix typo in metric name (#13521)
add fbf76ad8f5 Remove stray reference to fix OOM while merging sketches
(#13475)
add d85fb8cc4e Web console: improve compaction status display (#13523)
add 91ef9872ec MSQ: Improve TooManyBuckets error message, improve error
docs. (#13525)
add d8e27eaab4 update error anchors (#13527)
add 013a12e86f Enhanced MSQ table functions (#13360)
add 55814888f5 MSQ: Only look at sqlInsertSegmentGranularity on the outer
query. (#13537)
add 4ebdfe226d Druid automated quickstart (#13365)
add 7002ecd303 add protobuf flattener, direct to plain java conversion for
faster flattening (#13519)
add 5a3d79a5d5 Removing unused exec service. (#13541)
add 8e386072e9 Druid automated quickstart: zookeeper in service list
(#13550)
add de5a4bafcb Zero-copy local deep storage. (#13394)
add 7682b0b6b1 Analysis refactor (#13501)
add 58a3acc2c4 Add InputStats to track bytes processed by a task (#13520)
add 35c983a351 Use template file for adding table functions grammar
(#13553)
add 2729e25295 Link to java docs (#13478)
add 089d8da561 Support Framing for Window Aggregations (#13514)
add 2b605aa9cf Multiple fixes for the MSQ stats merging piece which
(#13463)
add 97bc0220c7 Update task memory computation in start-druid (#13563)
add 49cbfdff83 Fix cool nested column bug caused by not properly
validating that global id is present in global dictionary before lookup up
local id (#13561)
add 431a1195ca Suppress CVE-2022-1471 from snakeyaml (#13557)
add d6949b1b79 Track input processedBytes with MSQ ingestion (#13559)
add 668d1fad6b docs: notebook only for API tutorial (#13345)
add 7f3c117e3a SQL: Improve docs around casts. (#13466)
add 9ae7a36ccd improve nested column storage format for broader
compatibility (#13568)
add d9e5245ff0 allow string dimension indexer to handle byte[] as base64
strings (#13573)
add f42722e627 Set monotonically increasing worker capacity in
start-druid-main (#13581)
add 1cc9bc9af9 Suppress CVE-2022-45685 and CVE-2022-45693 from
jettison-1.3 (#13585)
add d9c27d6102 docs: add index page and related stuff for jupyter
tutorials (#13342)
add 639decdf2e fix preview droping out of MSQ mode (#13586)
add e23abc710a Web console: default max workers to cluster capacity and
simplify live reports (#13577)
add e34e56295f Suppress CVE-2022-1278, CVE-2022-2048, CVE-2022-3509,
CVE-2022-40152 (#13590)
add 09d8b16447 Document shouldFinalize for sketches that have the
parameter (#13524)
add ee890965f4 LocalInputSource: Serialize File paths without forcing
resolution. (#13534)
add 07597c687d Docs: Remove large data file (#13595)
add 0efd0879a8 Unify the handling of HTTP between SQL and Native (#13564)
add c1e2656644 Fix scope of dependencies in protobuf-extensions pom
(#13593)
add 6c44dd8175 perf: core/TextReader for faster json ingestion (#13545)
add df55768535 Add CodeQL workflow (#13477)
add fd63e5a514 fix issue with jdbc and query metrics (#13608)
add 7b92b85168 Unify DummyRequest with MockHttpServletRequest (#13602)
add 0d97e658b2 Docs: Update quickstart instructions (#13611)
add af05cfa78c Fix shutdown in httpRemote task runner (#13558)
add 78ae0b7533 Upgrade to netty 4.1.86.Final to address CVEs (#13604)
add c2b93b7941 bump postgresql from 42.4.1 to 42.5.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 (43be49de97)
\
N -- N -- N
refs/heads/dependabot/maven/org.postgresql-postgresql-42.5.1 (c2b93b7941)
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:
...r_message.sh => analyze_dependencies_script.sh} | 3 +
...enerate_license.sh => license_checks_script.sh} | 16 +-
.github/scripts/setup_generate_license.sh | 4 +
.github/workflows/codeql-config.yml | 3 +
.github/workflows/codeql.yml | 63 +
.github/workflows/static-checks.yml | 253 ++-
.gitignore | 1 +
.travis.yml | 144 --
.../druid/benchmark/JsonLineReaderBenchmark.java | 174 +++
core/pom.xml | 4 +
.../druid/data/input/BytesCountingInputEntity.java | 123 ++
.../apache/druid/data/input/InputSourceReader.java | 7 +-
.../org/apache/druid/data/input/InputStats.java | 20 +-
.../org/apache/druid/data/input/TextReader.java | 15 +-
.../druid/data/input/impl/FastLineIterator.java | 163 ++
.../impl/FirehoseToInputSourceReaderAdaptor.java | 3 +-
.../data/input/impl/HttpInputSourceConfig.java | 2 +-
.../input/impl/InputEntityIteratingReader.java | 7 +-
.../druid/data/input/impl/LocalInputSource.java | 43 +-
.../input/impl/TimedShutoffInputSourceReader.java | 5 +-
.../apache/druid/guice/DruidSecondaryModule.java | 1 +
.../apache/druid/java/util/common/FileUtils.java | 49 +
.../apache/druid/java/util/common/Intervals.java | 29 +
.../org/apache/druid/java/util/common/Pair.java | 3 +-
.../apache/druid/java/util/common/StringUtils.java | 37 +-
.../guava/ParallelMergeCombiningSequence.java | 77 +-
.../util/common/parsers/FlattenerJsonProvider.java | 65 +-
.../util/common/parsers/JSONFlattenerMaker.java | 18 +-
.../java/util/common/parsers/ObjectFlatteners.java | 13 +-
.../java/util/emitter/core/SwitchingEmitter.java | 167 ++
.../org/apache/druid/query/QueryException.java | 122 +-
.../apache/druid/query/QueryTimeoutException.java | 7 +-
.../druid/segment/column/TypeStrategies.java | 26 +-
.../apache/druid/segment/column/TypeStrategy.java | 9 +-
.../java/org/apache/druid/utils/RuntimeInfo.java | 2 +
.../data/input/BytesCountingInputEntityTest.java | 145 ++
.../data/input/impl/FastLineIteratorTest.java | 250 +++
.../input/impl/InputEntityIteratingReaderTest.java | 13 +-
.../druid/data/input/impl/InputStatsImpl.java | 24 +-
.../data/input/impl/LocalInputSourceTest.java | 30 +-
.../druid/java/util/common/FileUtilsTest.java | 41 +
.../druid/java/util/common/IntervalsTest.java | 81 +
.../common/parsers/FlattenerJsonProviderTest.java | 146 ++
.../util/common/parsers/ObjectFlattenersTest.java | 14 +-
.../util/emitter/core/SwitchingEmitterTest.java | 153 ++
.../druid/java/util/metrics/MetricsVerifier.java | 98 ++
.../java/util/metrics/StubServiceEmitter.java | 38 +-
.../org/apache/druid/math/expr/FunctionTest.java | 3 +-
.../org/apache/druid/query/QueryExceptionTest.java | 67 +-
.../druid/query/QueryTimeoutExceptionTest.java | 24 +-
.../druid/segment/column/TypeStrategiesTest.java | 10 +-
docs/assets/files/kttm-nested-data.json.tgz | Bin 24955539 -> 0 bytes
docs/configuration/index.md | 18 +-
docs/dependencies/deep-storage.md | 45 +-
docs/development/experimental-features.md | 60 +
.../extensions-core/datasketches-hll.md | 32 +-
.../extensions-core/datasketches-kll.md | 30 +-
.../extensions-core/datasketches-quantiles.md | 31 +-
.../extensions-core/datasketches-theta.md | 36 +-
.../extensions-core/datasketches-tuple.md | 75 +-
.../extensions-core/druid-basic-security.md | 420 ++++-
docs/development/extensions-core/druid-lookups.md | 3 -
.../extensions-core/kafka-supervisor-reference.md | 6 +-
.../extensions-core/kinesis-ingestion.md | 6 +-
docs/ingestion/data-formats.md | 4 +-
docs/ingestion/migrate-from-firehose-ingestion.md | 2 +-
docs/ingestion/native-batch.md | 3 +-
docs/ingestion/schema-design.md | 9 +-
docs/ingestion/tasks.md | 33 +-
docs/multi-stage-query/concepts.md | 3 +-
docs/multi-stage-query/known-issues.md | 8 +-
docs/multi-stage-query/reference.md | 227 ++-
docs/operations/auth-ldap.md | 295 ++--
docs/operations/metrics.md | 10 +-
docs/operations/python.md | 49 +
docs/operations/security-overview.md | 75 +-
docs/operations/single-server.md | 34 +-
docs/querying/lookups.md | 4 +-
docs/querying/nested-columns.md | 20 +-
docs/querying/sql-data-types.md | 37 +-
docs/querying/sql-jdbc.md | 121 +-
docs/querying/sql-translation.md | 11 +-
docs/tutorials/cluster.md | 5 +-
docs/tutorials/index.md | 51 +-
docs/tutorials/tutorial-batch-hadoop.md | 8 +-
docs/tutorials/tutorial-jdbc.md | 31 +
docs/tutorials/tutorial-jupyter-index.md | 71 +
docs/tutorials/tutorial-kafka.md | 7 +-
examples/bin/generate-example-metrics | 2 +-
examples/bin/run-druid | 46 +-
examples/bin/start-druid | 35 +
examples/bin/start-druid-main.py | 642 ++++++++
examples/bin/supervise | 98 +-
examples/bin/verify-java | 3 +
examples/conf/druid/auto/_common/common.jvm.config | 7 +
.../_common/common.runtime.properties | 0
.../large => auto}/_common/log4j2.xml | 0
examples/conf/druid/auto/broker/runtime.properties | 41 +
.../coordinator-overlord/runtime.properties | 0
.../conf/druid/auto/historical/runtime.properties | 35 +
.../conf/druid/auto/indexer/runtime.properties | 34 +
.../druid/auto/middleManager/runtime.properties | 36 +
examples/conf/druid/auto/router/runtime.properties | 28 +
examples/quickstart/jupyter-notebooks/README.md | 89 ++
.../jupyter-notebooks/api-tutorial.ipynb | 494 ++++++
.../data/input/aliyun/OssInputSourceTest.java | 10 +-
.../CompressedBigDecimalMaxSqlAggregatorTest.java | 10 -
.../CompressedBigDecimalMinSqlAggregatorTest.java | 9 -
.../CompressedBigDecimalSqlAggregatorTestBase.java | 18 +-
.../CompressedBigDecimalSumSqlAggregatorTest.java | 10 -
.../kubernetes-overlord-extensions/pom.xml | 2 +-
.../materializedview/DataSourceOptimizer.java | 4 +-
.../sql/TDigestSketchSqlAggregatorTest.java | 25 +-
.../data/input/avro/GenericAvroJsonProvider.java | 93 +-
.../datasketches/hll/HllSketchModule.java | 2 -
.../quantiles/DoublesSketchModule.java | 1 -
.../sql/ThetaSketchSetBaseOperatorConversion.java | 2 +
.../hll/sql/HllSketchSqlAggregatorTest.java | 51 +-
.../sql/DoublesSketchSqlAggregatorTest.java | 35 +-
.../theta/sql/ThetaSketchSqlAggregatorTest.java | 82 +-
.../bloom/sql/BloomFilterSqlAggregatorTest.java | 54 +-
.../query/filter/sql/BloomDimFilterSqlTest.java | 45 +-
.../server/http/catalog/CatalogResourceTest.java | 39 +-
.../google/GoogleCloudStorageInputSourceTest.java | 10 +-
.../druid/storage/hdfs/HdfsDataSegmentPusher.java | 2 -
.../inputsource/hdfs/HdfsInputSourceTest.java | 24 +-
...dBucketsHistogramQuantileSqlAggregatorTest.java | 27 +-
.../histogram/sql/QuantileSqlAggregatorTest.java | 25 +-
.../data/input/kafkainput/KafkaInputReader.java | 177 ++-
.../input/kafkainput/KafkaInputFormatTest.java | 7 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 642 ++------
.../kafka/supervisor/KafkaSupervisorTest.java | 48 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 1608 ++++++--------------
.../kinesis/supervisor/KinesisSupervisorTest.java | 5 +
extensions-core/kubernetes-extensions/pom.xml | 2 +-
.../apache/druid/msq/counters/ChannelCounters.java | 5 +
.../org/apache/druid/msq/exec/ControllerImpl.java | 19 +-
.../msq/exec/ExceptionWrappingWorkerClient.java | 14 +-
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 29 +-
.../apache/druid/msq/exec/WorkerSketchFetcher.java | 96 +-
.../org/apache/druid/msq/guice/MSQSqlModule.java | 12 +-
.../msq/indexing/CountableInputSourceReader.java | 5 +-
.../druid/msq/indexing/MSQControllerTask.java | 17 -
.../druid/msq/indexing/WorkerChatHandler.java | 49 +-
.../msq/indexing/error/TooManyBucketsFault.java | 2 +-
.../org/apache/druid/msq/input/NilInputSource.java | 3 +-
.../input/external/ExternalInputSliceReader.java | 6 +-
.../druid/msq/kernel/worker/WorkerStageKernel.java | 3 +-
.../apache/druid/msq/querykit/DataSourcePlan.java | 18 +-
.../druid/msq/querykit/InputNumberDataSource.java | 7 +
.../apache/druid/msq/querykit/QueryKitUtils.java | 15 +-
.../groupby/GroupByPostShuffleFrameProcessor.java | 14 +-
.../GroupByPostShuffleFrameProcessorFactory.java | 3 +-
.../msq/querykit/groupby/GroupByQueryKit.java | 11 +-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 7 +-
.../scan/ScanQueryFrameProcessorFactory.java | 3 +-
.../druid/msq/querykit/scan/ScanQueryKit.java | 3 +-
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 1 +
.../statistics/ClusterByStatisticsSnapshot.java | 4 +
.../druid/msq/util/MultiStageQueryContext.java | 2 +-
.../org/apache/druid/msq/exec/MSQFaultsTest.java | 351 +++++
.../org/apache/druid/msq/exec/MSQInsertTest.java | 112 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 18 +-
.../org/apache/druid/msq/exec/MSQSelectTest.java | 71 +-
.../org/apache/druid/msq/exec/WorkerImplTest.java | 54 +
.../msq/exec/WorkerSketchFetcherAutoModeTest.java | 39 +-
.../druid/msq/exec/WorkerSketchFetcherTest.java | 136 +-
.../druid/msq/indexing/WorkerChatHandlerTest.java | 254 ++++
.../druid/msq/indexing/error/MSQWarningsTest.java | 4 +-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 4 +-
.../druid/msq/test/CounterSnapshotBuilder.java | 75 +
.../org/apache/druid/msq/test/MSQTestBase.java | 179 ++-
.../apache/druid/msq/test/MSQTestFileUtils.java | 74 +
.../msq/test/MSQTestOverlordServiceClient.java | 1 -
.../resources/unparseable-mv-string-array.json | 3 +
.../orc-extensions/example/test_simple.orc | Bin 0 -> 506 bytes
.../data/input/orc/OrcStructJsonProvider.java | 114 +-
.../apache/druid/data/input/orc/OrcReaderTest.java | 39 +
.../parquet/simple/ParquetGroupJsonProvider.java | 104 +-
extensions-core/protobuf-extensions/pom.xml | 22 +-
.../data/input/protobuf/ProtobufConverter.java | 244 +++
.../input/protobuf/ProtobufFlattenerMaker.java | 114 ++
.../data/input/protobuf/ProtobufInputFormat.java | 9 +-
.../data/input/protobuf/ProtobufJsonProvider.java | 79 +
.../druid/data/input/protobuf/ProtobufReader.java | 60 +-
.../data/input/protobuf/ProtoTestEventWrapper.java | 1156 +++++++-------
.../input/protobuf/ProtobufInputFormatTest.java | 257 +++-
.../input/protobuf/ProtobufInputRowParserTest.java | 23 +-
.../data/input/protobuf/ProtobufReaderTest.java | 14 +-
.../src/test/resources/ProtoTest.proto | 7 +-
.../src/test/resources/prototest.desc | Bin 998 -> 1040 bytes
.../druid/data/input/s3/S3InputSourceTest.java | 10 +-
.../variance/sql/VarianceSqlAggregatorTest.java | 32 +-
.../org/apache/druid/query/sql/SleepSqlTest.java | 35 +-
.../apache/druid/indexing/common/TaskToolbox.java | 18 +-
.../common/actions/LocalTaskActionClient.java | 20 +-
.../common/actions/SegmentAllocateAction.java | 18 +
.../common/actions/SegmentAllocateRequest.java | 77 +
.../common/actions/SegmentAllocateResult.java | 34 +-
.../common/actions/SegmentAllocationQueue.java | 744 +++++++++
.../druid/indexing/common/actions/TaskAction.java | 12 +
.../indexing/common/actions/TaskActionToolbox.java | 32 +
.../common/stats/DropwizardRowIngestionMeters.java | 18 +
.../common/stats/TaskRealtimeMetricsMonitor.java | 2 +-
.../common/task/AbstractBatchIndexTask.java | 2 +-
.../parallel/ParallelIndexSupervisorTask.java | 20 +-
.../indexing/input/DruidSegmentInputFormat.java | 22 +-
.../druid/indexing/input/DruidSegmentReader.java | 17 +-
.../input/DruidTombstoneSegmentReader.java | 15 +-
.../druid/indexing/input/GeneratorInputSource.java | 3 +-
.../overlord/SingleTaskBackgroundRunner.java | 2 +-
.../druid/indexing/overlord/TaskLockbox.java | 324 +++-
.../apache/druid/indexing/overlord/TaskMaster.java | 20 +-
.../indexing/overlord/config/TaskLockConfig.java | 16 +
.../overlord/hrtr/HttpRemoteTaskRunner.java | 7 +-
.../SeekableStreamIndexTaskRunner.java | 2 +-
.../indexing/seekablestream/StreamChunkParser.java | 19 +-
.../supervisor/SeekableStreamSupervisor.java | 17 +-
.../SeekableStreamSupervisorTuningConfig.java | 2 +-
.../actions/SegmentAllocateActionBuilder.java | 138 ++
.../common/actions/SegmentAllocateActionTest.java | 102 +-
.../common/actions/SegmentAllocationQueueTest.java | 366 +++++
.../indexing/common/actions/TaskActionTestKit.java | 28 +-
.../AppenderatorDriverRealtimeIndexTaskTest.java | 56 +-
.../common/task/CompactionTaskParallelRunTest.java | 45 +-
.../indexing/common/task/CompactionTaskTest.java | 28 +-
.../druid/indexing/common/task/IndexTaskTest.java | 111 +-
.../indexing/common/task/ParseExceptionReport.java | 71 +
.../AbstractParallelIndexSupervisorTaskTest.java | 14 +-
.../MultiPhaseParallelIndexingRowStatsTest.java | 8 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 29 +-
.../input/DruidSegmentInputFormatTest.java | 3 +-
.../indexing/input/DruidSegmentReaderTest.java | 494 +++---
.../druid/indexing/overlord/TaskLifecycleTest.java | 10 +-
.../druid/indexing/overlord/TaskQueueTest.java | 140 ++
.../overlord/hrtr/HttpRemoteTaskRunnerTest.java | 68 +-
.../druid/indexing/overlord/http/OverlordTest.java | 4 +-
.../RecordSupplierInputSourceTest.java | 15 +-
.../SeekableStreamIndexTaskTestBase.java | 217 ++-
.../SeekableStreamSupervisorStateTest.java | 2 +
.../TestIndexerMetadataStorageCoordinator.java | 14 +
integration-tests-ex/cases/pom.xml | 2 +-
.../testsEx/msq/AbstractITSQLBasedIngestion.java | 75 +-
.../apache/druid/testsEx/msq/ITMSQReindexTest.java | 83 +
.../testsEx/msq/ITSQLBasedBatchIngestion.java | 20 +-
.../{batch-index => }/json_path_index_queries.json | 0
.../{batch-index => }/msq_inline.sql | 0
.../{batch-index => }/sparse_column_msq.json | 0
.../{batch-index => }/sparse_column_msq.sql | 0
...wikipedia_combining_firehose_index_queries.json | 0
...ql => wikipedia_combining_input_source_msq.sql} | 27 +-
.../wikipedia_http_inputsource_msq.sql | 0
.../wikipedia_http_inputsource_queries.json | 0
.../{batch-index => }/wikipedia_index_msq.sql | 0
.../{batch-index => }/wikipedia_index_queries.json | 0
.../wikipedia_index_queries_with_transform.json | 0
.../wikipedia_index_task_with_transform.sql | 0
.../wikipedia_merge_index_msq.sql | 20 +
.../wikipedia_merge_index_queries.json | 42 +
.../wikipedia_merge_reindex_msq.sql | 17 +
.../multi-stage-query/wikipedia_reindex_msq.sql | 24 +
.../wikipedia_reindex_queries.json | 66 +
.../wikipedia_reindex_queries_with_transforms.json | 79 +
.../wikipedia_reindex_with_transform_msq.sql | 27 +
.../druid/testing/utils/DataLoaderHelper.java | 6 +
.../druid/testing/utils/SqlTestQueryHelper.java | 2 +-
.../apache/druid/tests/query/ITSqlCancelTest.java | 11 +-
licenses.yaml | 3 +-
owasp-dependency-check-suppressions.xml | 9 +
pom.xml | 9 +-
.../read/columnar/ComplexFrameColumnReader.java | 14 +-
.../read/columnar/DoubleFrameColumnReader.java | 12 +-
.../read/columnar/FloatFrameColumnReader.java | 12 +-
.../frame/read/columnar/LongFrameColumnReader.java | 12 +-
.../org/apache/druid/frame/write/FrameWriter.java | 4 +-
.../druid/frame/write/RowBasedFrameWriter.java | 10 +-
.../frame/write/columnar/ColumnarFrameWriter.java | 12 +-
.../write/columnar/ComplexFrameColumnWriter.java | 90 +-
...ameColumnWriter.java => ComplexFrameMaker.java} | 48 +-
.../write/columnar/DoubleFrameColumnWriter.java | 55 +-
...rameColumnWriter.java => DoubleFrameMaker.java} | 49 +-
.../write/columnar/FloatFrameColumnWriter.java | 55 +-
...FrameColumnWriter.java => FloatFrameMaker.java} | 49 +-
.../write/columnar/LongFrameColumnWriter.java | 55 +-
...gFrameColumnWriter.java => LongFrameMaker.java} | 49 +-
.../org/apache/druid/guice/ExtensionsConfig.java | 2 +
.../org/apache/druid/guice/ExtensionsLoader.java | 1 +
.../org/apache/druid/guice/ExtensionsModule.java | 4 +-
.../java/org/apache/druid/guice/ModulesConfig.java | 2 +
.../apache/druid/guice/StartupInjectorBuilder.java | 17 +
.../apache/druid/jackson/DefaultObjectMapper.java | 2 +
.../apache/druid/query/BadJsonQueryException.java | 3 +-
.../druid/query/BadQueryContextException.java | 8 +-
.../java/org/apache/druid/query/BaseQuery.java | 4 +-
.../java/org/apache/druid/query/DataSource.java | 15 +-
.../apache/druid/query/DefaultQueryMetrics.java | 21 +
.../org/apache/druid/query/InlineDataSource.java | 15 +-
.../org/apache/druid/query/JoinDataSource.java | 54 +-
.../org/apache/druid/query/LookupDataSource.java | 7 +
.../main/java/org/apache/druid/query/Queries.java | 3 +-
.../main/java/org/apache/druid/query/Query.java | 20 +-
.../query/QueryCapacityExceededException.java | 14 +-
.../org/apache/druid/query/QueryDataSource.java | 14 +
.../druid/query/QueryInterruptedException.java | 23 +-
.../java/org/apache/druid/query/QueryMetrics.java | 24 +
.../druid/query/QueryUnsupportedException.java | 5 +-
.../query/ResourceLimitExceededException.java | 6 +-
.../org/apache/druid/query/TableDataSource.java | 7 +
.../org/apache/druid/query/UnionDataSource.java | 8 +
.../org/apache/druid/query/UnionQueryRunner.java | 2 +-
.../org/apache/druid/query/UnnestDataSource.java | 220 +++
.../druid/query/context/ResponseContext.java | 87 +-
.../query/expression/NestedDataExpressions.java | 9 +-
.../query/operator/LimitedRowsAndColumns.java | 115 ++
.../query/operator/NaivePartitioningOperator.java | 100 ++
.../operator/NaivePartitioningOperatorFactory.java | 68 +
.../org/apache/druid/query/operator/Operator.java | 93 ++
.../druid/query/operator/OperatorFactory.java | 59 +
.../druid/query/operator/OperatorSequence.java | 125 ++
.../operator/SegmentToRowsAndColumnsOperator.java} | 59 +-
.../druid/query/operator/SequenceOperator.java | 87 ++
.../query/operator/WindowOperatorFactory.java | 68 +
.../druid/query/operator/WindowOperatorQuery.java | 167 ++
.../WindowOperatorQueryQueryRunnerFactory.java | 55 +
.../WindowOperatorQueryQueryToolChest.java | 191 +++
.../query/operator/WindowProcessorOperator.java | 67 +
.../query/operator/window/ComposingProcessor.java | 78 +
.../druid/query/operator/window/Processor.java | 84 +
.../operator/window/WindowAggregateProcessor.java | 131 ++
.../druid/query/operator/window/WindowFrame.java | 123 ++
.../window/WindowFramedAggregateProcessor.java | 99 ++
.../window/ranking/WindowCumeDistProcessor.java | 60 +
.../window/ranking/WindowDenseRankProcessor.java | 59 +
.../window/ranking/WindowPercentileProcessor.java | 106 ++
.../window/ranking/WindowRankProcessor.java | 108 ++
.../window/ranking/WindowRankingProcessorBase.java | 103 ++
.../window/ranking/WindowRowNumberProcessor.java | 131 ++
.../window/value/ShiftedColumnAccessorBase.java | 130 ++
.../window/value/WindowFirstProcessor.java} | 35 +-
.../operator/window/value/WindowLastProcessor.java | 53 +
.../window/value/WindowOffsetProcessor.java | 89 ++
.../window/value/WindowValueProcessorBase.java | 103 ++
.../druid/query/planning/DataSourceAnalysis.java | 131 +-
.../query/rowsandcols/AppendableMapOfColumns.java | 92 ++
.../query/rowsandcols/ArrayListRowsAndColumns.java | 125 ++
.../rowsandcols/MapOfColumnsRowsAndColumns.java | 108 ++
.../rowsandcols/OnHeapCumulativeAggregatable.java | 48 +
.../druid/query/rowsandcols/RowsAndColumns.java | 114 ++
.../druid/query/rowsandcols/column/Column.java | 63 +
.../query/rowsandcols/column/ColumnAccessor.java | 104 ++
.../column/ColumnAccessorBasedColumn.java | 29 +-
.../rowsandcols/column/ConstantObjectColumn.java | 103 ++
.../rowsandcols/column/DoubleArrayColumn.java | 101 ++
.../query/rowsandcols/column/IntArrayColumn.java | 101 ++
.../rowsandcols/column/NullColumnAccessor.java} | 62 +-
.../rowsandcols/column/ObjectArrayColumn.java | 81 +
.../column/ObjectColumnAccessorBase.java | 121 ++
.../semantic/AppendableRowsAndColumns.java} | 38 +-
.../semantic/ColumnSelectorFactoryMaker.java | 24 +-
.../DefaultColumnSelectorFactoryMaker.java | 223 +++
.../semantic/DefaultFramedOnHeapAggregatable.java | 581 +++++++
.../semantic/DefaultGroupPartitioner.java | 76 +
.../semantic/DefaultOnHeapAggregatable.java | 108 ++
.../semantic/DefaultSortedGroupPartitioner.java | 94 ++
.../semantic/FramedOnHeapAggregatable.java | 57 +
.../rowsandcols/semantic/GroupPartitioner.java | 43 +
.../rowsandcols/semantic/OnHeapAggregatable.java | 47 +
.../semantic/SortedGroupPartitioner.java | 56 +
.../query/search/DefaultSearchQueryMetrics.java | 18 +
.../org/apache/druid/segment/ArrayListSegment.java | 126 ++
.../segment/BaseSingleValueDimensionSelector.java | 1 -
.../druid/segment/NestedDataColumnIndexer.java | 6 +-
.../java/org/apache/druid/segment/Segment.java | 5 +-
.../druid/segment/StringDimensionIndexer.java | 4 +
.../segment/UnnestColumnValueSelectorCursor.java | 336 ++++
.../druid/segment/UnnestDimensionCursor.java | 415 +++++
.../druid/segment/UnnestSegmentReference.java | 115 ++
.../apache/druid/segment/UnnestStorageAdapter.java | 234 +++
.../column/ObjectStrategyComplexTypeStrategy.java | 4 +-
.../data/BlockLayoutColumnarDoublesSupplier.java | 6 +
.../data/BlockLayoutColumnarFloatsSupplier.java | 6 +
.../data/BlockLayoutColumnarLongsSupplier.java | 8 +
.../druid/segment/generator/DataGenerator.java | 3 +-
.../incremental/NoopRowIngestionMeters.java | 2 +-
.../segment/incremental/RowIngestionMeters.java | 16 +-
.../incremental/RowIngestionMetersTotals.java | 13 +-
...onMeters.java => SimpleRowIngestionMeters.java} | 32 +-
.../nested/CompressedNestedDataComplexColumn.java | 30 +-
.../GlobalDictionaryEncodedFieldColumnWriter.java | 2 +-
.../segment/nested/NestedDataColumnSerializer.java | 33 +-
.../segment/nested/NestedDataColumnSupplier.java | 55 +-
.../druid/segment/nested/NestedDataColumnV3.java | 82 +
.../druid/segment/nested/NestedDataColumnV4.java | 84 +
.../NestedFieldLiteralColumnIndexSupplier.java | 98 +-
.../NestedFieldLiteralDictionaryEncodedColumn.java | 145 +-
.../druid/segment/nested/NestedPathFinder.java | 2 +-
.../segment/nested/StructuredDataProcessor.java | 73 +-
.../transform/TransformingInputSourceReader.java | 5 +-
.../druid/frame/testutil/FrameSequenceBuilder.java | 2 +-
.../druid/guice/StartupInjectorBuilderTest.java | 138 ++
.../expression/NestedDataExpressionsTest.java | 4 +-
.../query/groupby/GroupByQueryRunnerTest.java | 3 +-
.../druid/query/operator/InlineScanOperator.java | 73 +
.../operator/NaivePartitioningOperatorTest.java | 105 ++
.../druid/query/operator/OperatorSequenceTest.java | 56 +
.../druid/query/operator/SequenceOperatorTest.java | 56 +
.../query/operator/WindowOperatorQueryTest.java | 124 ++
.../operator/WindowProcessorOperatorTest.java | 66 +
.../operator/window/ComposingProcessorTest.java | 74 +
.../operator/window/RowsAndColumnsHelper.java | 268 ++++
.../window/WindowAggregateProcessorTest.java | 115 ++
.../window/WindowFramedAggregateProcessorTest.java | 94 ++
.../ranking/WindowCumeDistProcessorTest.java | 53 +
.../ranking/WindowDenseRankProcessorTest.java | 54 +
.../ranking/WindowPercentileProcessorTest.java | 84 +
.../window/ranking/WindowRankProcessorTest.java | 84 +
.../ranking/WindowRowNumberProcessorTest.java | 61 +
.../window/value/WindowFirstProcessorTest.java | 80 +
.../window/value/WindowLagProcessorTest.java | 77 +
.../window/value/WindowLastProcessorTest.java | 78 +
.../window/value/WindowLeadProcessorTest.java | 76 +
.../query/planning/DataSourceAnalysisTest.java | 84 +-
.../rowsandcols/ArrayListRowsAndColumnsTest.java | 70 +
.../rowsandcols/AsOnlyTestRowsAndColumns.java | 63 +
.../MapOfColumnsRowsAndColumnsTest.java | 76 +
.../query/rowsandcols/NoAsRowsAndColumns.java} | 50 +-
.../query/rowsandcols/RowsAndColumnsTestBase.java | 103 ++
.../column/NullColumnAccessorTest.java} | 24 +-
.../semantic/AppendableRowsAndColumnsTest.java | 63 +
.../semantic/FramedOnHeapAggregatableTest.java | 459 ++++++
.../semantic/OnHeapAggregatableTest.java | 72 +
.../rowsandcols/semantic/SemanticTestBase.java | 88 ++
.../semantic/SortedGroupPartitionerTest.java | 103 ++
.../druid/query/scan/NestedDataScanQueryTest.java | 9 +-
.../druid/query/scan/ScanQueryRunnerTest.java | 3 +-
.../timeseries/TimeseriesQueryRunnerTest.java | 6 +-
.../java/org/apache/druid/segment/ListCursor.java | 228 +++
.../druid/segment/NestedDataColumnIndexerTest.java | 4 +-
.../druid/segment/StringDimensionIndexerTest.java | 18 +
.../UnnestColumnValueSelectorCursorTest.java | 632 ++++++++
.../druid/segment/UnnestStorageAdapterTest.java | 399 +++++
...impleRowIngestionMeters.java => RowMeters.java} | 71 +-
...Test.java => SimpleRowIngestionMetersTest.java} | 23 +-
.../apache/druid/segment/join/NoopDataSource.java | 8 +
.../nested/NestedDataColumnSupplierTest.java | 191 ++-
.../NestedFieldLiteralColumnIndexSupplierTest.java | 274 ++++
.../src/test/resources/nested_segment_v3/index.zip | Bin 0 -> 3381 bytes
server/pom.xml | 3 +-
.../druid/catalog/model/ModelProperties.java | 198 ++-
.../druid/catalog/model/ParameterizedDefn.java | 34 +-
.../druid/catalog/model/PropertyAttributes.java | 110 ++
.../org/apache/druid/catalog/model/TableDefn.java | 2 +-
.../druid/catalog/model/TableDefnRegistry.java | 6 +-
.../model/table/AbstractDatasourceDefn.java | 9 +-
.../catalog/model/table/ExternalTableDefn.java | 46 +-
.../catalog/model/table/ExternalTableSpec.java | 30 +-
.../druid/catalog/model/table/HttpTableDefn.java | 28 +-
.../druid/catalog/model/table/InlineTableDefn.java | 34 +-
.../druid/catalog/model/table/InputFormats.java | 37 +-
.../druid/catalog/model/table/LocalTableDefn.java | 25 +-
.../org/apache/druid/client/BrokerServerView.java | 2 +-
.../druid/client/CachingClusteredClient.java | 20 +-
.../apache/druid/client/JsonParserIterator.java | 33 +-
.../org/apache/druid/client/ServerViewUtil.java | 2 +-
.../apache/druid/client/cache/CaffeineCache.java | 2 +-
.../org/apache/druid/curator/CuratorModule.java | 42 +
.../org/apache/druid/guice/AnnouncerModule.java | 2 +-
.../apache/druid/guice/DruidInjectorBuilder.java | 26 +-
.../druid/guice/QueryRunnerFactoryModule.java | 13 +-
.../apache/druid/guice/QueryToolChestModule.java | 13 +-
.../org/apache/druid/guice/StorageNodeModule.java | 2 +-
.../IndexerMetadataStorageCoordinator.java | 22 +
.../indexing/overlord/SegmentCreateRequest.java | 78 +
.../IndexerSQLMetadataStorageCoordinator.java | 594 +++++++-
.../org/apache/druid/metadata/input/SqlReader.java | 4 +-
.../java/org/apache/druid/rpc/ServiceClient.java | 6 +-
.../org/apache/druid/rpc/ServiceClientImpl.java | 237 ++-
.../druid/rpc/ServiceNotAvailableException.java | 9 +-
.../druid/segment/InlineSegmentWrangler.java | 16 +-
.../join/BroadcastTableJoinableFactory.java | 2 +-
.../segment/loading/LocalDataSegmentKiller.java | 15 +-
.../segment/loading/LocalDataSegmentPuller.java | 68 +-
.../segment/loading/LocalDataSegmentPusher.java | 106 +-
.../loading/LocalDataSegmentPusherConfig.java | 8 +
.../appenderator/SinkQuerySegmentWalker.java | 12 +-
.../UnifiedIndexerAppenderatorsManager.java | 4 +-
.../apache/druid/server/ClientInfoResource.java | 3 +-
.../druid/server/ClientQuerySegmentWalker.java | 55 +-
.../druid/server/LocalQuerySegmentWalker.java | 13 +-
.../org/apache/druid/server/QueryResource.java | 386 +++--
.../org/apache/druid/server/QueryResultPusher.java | 418 +++++
.../org/apache/druid/server/SegmentManager.java | 2 +-
.../coordination/BatchDataSegmentAnnouncer.java | 8 +
.../server/coordination/ChangeRequestHistory.java | 19 +
.../druid/server/coordination/ServerManager.java | 21 +-
.../apache/druid/server/emitter/EmitterModule.java | 1 +
.../server/emitter/SwitchingEmitterConfig.java | 34 +-
.../server/emitter/SwitchingEmitterModule.java | 82 +
.../PreResponseAuthorizationCheckFilter.java | 3 +-
.../druid/catalog/model/PropertyDefnTest.java | 26 +-
.../catalog/model/table/BaseExternTableTest.java} | 23 +-
.../catalog/model/table/HttpInputTableTest.java | 71 +-
.../druid/catalog/model/table/InlineTableTest.java | 6 +-
.../druid/catalog/model/table/LocalTableTest.java | 63 +-
.../apache/druid/client/BrokerServerViewTest.java | 17 +-
.../druid/client/JsonParserIteratorTest.java | 2 +-
.../org/apache/druid/client/SimpleServerView.java | 2 +-
.../apache/druid/curator/CuratorModuleTest.java | 2 +-
.../druid/guice/DruidInjectorBuilderTest.java | 308 ++++
.../apache/druid/guice/StorageNodeModuleTest.java | 2 +-
.../overlord/SegmentCreateRequestTest.java | 24 +-
.../initialization/SwitchingEmitterModuleTest.java | 114 ++
.../IndexerSQLMetadataStorageCoordinatorTest.java | 269 ++--
.../SQLMetadataStorageActionHandlerTest.java | 24 +-
.../apache/druid/metadata/input/SqlEntityTest.java | 76 +-
.../druid/metadata/input/SqlInputSourceTest.java | 116 +-
.../apache/druid/metadata/input/SqlTestUtils.java | 45 +-
.../apache/druid/rpc/ServiceClientImplTest.java | 102 +-
.../loading/LocalDataSegmentKillerTest.java | 88 +-
.../loading/LocalDataSegmentPusherTest.java | 132 +-
...heManager.java => NoopSegmentCacheManager.java} | 20 +-
.../realtime/firehose/SqlFirehoseFactoryTest.java | 54 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 1 -
.../org/apache/druid/server/QueryResourceTest.java | 594 +++-----
.../org/apache/druid/server/QueryStackTests.java | 6 +-
.../apache/druid/server/SegmentManagerTest.java | 3 +-
.../apache/druid/server/StatusResourceTest.java | 7 +-
.../server/TestClusterQuerySegmentWalker.java | 20 +-
.../coordination/ChangeRequestHistoryTest.java | 41 +
.../coordination/SegmentLoadDropHandlerTest.java | 57 +-
.../server/coordination/ServerManagerTest.java | 51 +-
.../server/coordinator/LoadQueuePeonTest.java | 6 +-
.../simulate/BalancingStrategiesTest.java | 12 +-
.../simulate/CoordinatorSimulation.java | 7 +-
.../simulate/CoordinatorSimulationBaseTest.java | 88 +-
.../simulate/CoordinatorSimulationBuilder.java | 6 +-
.../coordinator/simulate/SegmentLoadingTest.java | 4 +-
.../server/metrics/TaskCountStatsMonitorTest.java | 15 +-
.../metrics/TaskSlotCountStatsMonitorTest.java | 15 +-
.../metrics/WorkerTaskCountStatsMonitorTest.java | 59 +-
.../druid/server/mocks/ExceptionalInputStream.java | 38 +-
.../druid/server/mocks/MockAsyncContext.java | 137 ++
.../druid/server/mocks/MockHttpServletRequest.java | 361 ++---
.../server/mocks/MockHttpServletResponse.java | 324 ++++
.../server/AsyncQueryForwardingServletTest.java | 36 +-
sql/pom.xml | 67 +-
sql/src/main/codegen/config.fmpp | 3 +
sql/src/main/codegen/includes/from.ftl | 349 +++++
.../org/apache/druid/sql/AbstractStatement.java | 11 +
.../java/org/apache/druid/sql/DirectStatement.java | 6 +-
.../org/apache/druid/sql/PreparedStatement.java | 9 +-
.../org/apache/druid/sql/SqlPlanningException.java | 7 +-
.../druid/sql/avatica/DruidJdbcResultSet.java | 6 +-
.../druid/sql/calcite/expression/Expressions.java | 7 +-
.../sql/calcite/expression/WindowSqlAggregate.java | 70 +
.../CatalogExternalTableOperatorConversion.java | 170 +++
.../druid/sql/calcite/external/ExtendOperator.java | 75 +
.../sql/calcite/external/ExternalDataSource.java | 7 +
.../external/ExternalOperatorConversion.java | 17 +-
.../sql/calcite/external/ExternalTableMacro.java | 134 +-
.../druid/sql/calcite/external/Externals.java | 278 ++++
.../calcite/external/FunctionParameterImpl.java | 81 +
.../calcite/external/HttpOperatorConversion.java | 22 +-
.../calcite/external/InlineOperatorConversion.java | 22 +-
.../calcite/external/LocalOperatorConversion.java | 24 +-
.../sql/calcite/external/ParameterizeOperator.java | 69 +
.../external/UserDefinedTableMacroFunction.java | 261 ++++
.../sql/calcite/planner/CalciteRulesManager.java | 11 +-
.../sql/calcite/planner/DruidOperatorTable.java | 25 +-
.../druid/sql/calcite/planner/DruidPlanner.java | 16 +-
.../druid/sql/calcite/planner/DruidTypeSystem.java | 2 +
.../druid/sql/calcite/planner/IngestHandler.java | 1 +
.../druid/sql/calcite/planner/NoOpPlannerHook.java | 52 +-
.../sql/calcite/planner/PlannerCaptureHook.java | 78 +
.../druid/sql/calcite/planner/PlannerFactory.java | 7 +-
.../druid/sql/calcite/planner/PlannerHook.java | 43 +
.../druid/sql/calcite/planner/QueryHandler.java | 5 +
.../sql/calcite/planner/SqlStatementHandler.java | 1 +
.../apache/druid/sql/calcite/rel/DruidQuery.java | 92 +-
.../druid/sql/calcite/rel/PartialDruidQuery.java | 80 +-
.../apache/druid/sql/calcite/rel/Windowing.java | 344 +++++
.../apache/druid/sql/calcite/rule/DruidRules.java | 121 +-
.../druid/sql/calcite/rule/GroupByRules.java | 3 +-
.../druid/sql/calcite/run/NativeQueryMaker.java | 12 +-
.../druid/sql/calcite/table/ExternalTable.java | 20 +-
.../druid/sql/calcite/view/DruidViewMacro.java | 5 +-
.../java/org/apache/druid/sql/guice/SqlModule.java | 3 +
.../org/apache/druid/sql/http/SqlResource.java | 364 +++--
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 12 +
.../druid/sql/calcite/BaseCalciteQueryTest.java | 127 +-
.../druid/sql/calcite/CalciteIngestionDmlTest.java | 80 +
.../druid/sql/calcite/CalciteInsertDmlTest.java | 5 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 36 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 2 +
.../druid/sql/calcite/CalciteWindowQueryTest.java | 218 +++
.../druid/sql/calcite/CatalogIngestionTest.java | 327 ++++
.../apache/druid/sql/calcite/QueryTestBuilder.java | 56 +-
.../apache/druid/sql/calcite/QueryTestRunner.java | 320 +++-
.../druid/sql/calcite/QueryVerification.java | 55 +
.../org/apache/druid/sql/calcite/SqlSchema.java | 145 ++
.../schema/SegmentDataCacheConcurrencyTest.java | 4 +-
.../druid/sql/calcite/util/BasicTestModule.java | 65 +
.../calcite/util/CalciteTestInjectorBuilder.java | 46 -
.../sql/calcite/util/QueryFrameworkUtils.java | 1 +
.../druid/sql/calcite/util/QueryLogHook.java | 13 +-
.../util/SpecificSegmentsQuerySegmentWalker.java | 1 -
.../druid/sql/calcite/util/SqlTestFramework.java | 143 +-
.../druid/sql/calcite/util/TestDataBuilder.java | 575 ++++---
.../org/apache/druid/sql/http/SqlResourceTest.java | 428 +++---
.../expected/ingest/httpExtern-logicalPlan.txt | 3 +
.../ingest/insertFromExternal-logicalPlan.txt | 3 +
.../ingest/insertWithClusteredBy-logicalPlan.txt | 4 +
.../ingest/insertWithPartitionedBy-logicalPlan.txt | 3 +
.../expected/ingest/localExtern-logicalPlan.txt | 3 +
.../tests/wikiticker-2015-09-12-sampled.jgz | Bin
.../calcite/tests/window/simpleSum.sqlTest | 26 +
.../window/wikipediaCumulativeOrdered.sqlTest | 1029 +++++++++++++
.../window/wikipediaFramedAggregations.sqlTest | 1008 ++++++++++++
.../tests/window/wikipediaSimplePartition.sqlTest | 1020 +++++++++++++
web-console/lib/keywords.js | 3 +
web-console/script/create-sql-docs.js | 4 +-
web-console/src/bootstrap/react-table-defaults.tsx | 4 +-
.../src/components/auto-form/auto-form.scss | 12 +-
web-console/src/components/auto-form/auto-form.tsx | 55 +-
.../src/components/braced-text/braced-text.tsx | 6 +-
.../form-group-with-info/form-group-with-info.scss | 14 +
.../__snapshots__/header-bar.spec.tsx.snap | 1 +
.../src/components/header-bar/header-bar.spec.tsx | 2 +-
.../src/components/header-bar/header-bar.tsx | 2 +-
.../__snapshots__/rule-editor.spec.tsx.snap | 192 ++-
.../components/rule-editor/rule-editor.spec.tsx | 10 +-
.../src/components/rule-editor/rule-editor.tsx | 2 +-
.../segment-timeline/segment-timeline.spec.tsx | 2 +-
.../segment-timeline/segment-timeline.tsx | 4 +-
.../table-clickable-cell/table-clickable-cell.scss | 4 +
.../table-clickable-cell/table-clickable-cell.tsx | 11 +-
.../warning-checklist/warning-checklist.tsx | 18 +-
web-console/src/console-application.tsx | 25 +-
.../async-action-dialog/async-action-dialog.tsx | 2 +-
.../compaction-dialog/compaction-dialog.scss | 5 +
.../compaction-dialog/compaction-dialog.tsx | 27 +-
.../__snapshots__/index-spec-dialog.spec.tsx.snap | 317 ++++
.../index-spec-dialog.scss} | 4 +-
.../index-spec-dialog/index-spec-dialog.spec.tsx} | 28 +-
.../index-spec-dialog.tsx} | 53 +-
web-console/src/dialogs/index.ts | 1 +
.../kill-datasource-dialog.tsx | 110 ++
.../__snapshots__/retention-dialog.spec.tsx.snap | 6 +-
.../compaction-config/compaction-config.tsx | 29 +-
.../compaction-status/compaction-status.spec.ts | 151 +-
.../compaction-status/compaction-status.ts | 39 +-
.../coordinator-dynamic-config.tsx | 13 +-
.../src/druid-models/execution/execution.ts | 4 +-
.../src/druid-models/index-spec/index-spec.tsx | 158 ++
web-console/src/druid-models/index.ts | 1 +
.../ingest-query-pattern/ingest-query-pattern.ts | 3 +-
.../druid-models/ingestion-spec/ingestion-spec.tsx | 120 +-
.../src/druid-models/metric-spec/metric-spec.tsx | 43 +
.../druid-models/query-context/query-context.tsx | 5 +-
.../workbench-query/workbench-query-part.ts | 4 +-
.../workbench-query/workbench-query.spec.ts | 3 +-
.../workbench-query/workbench-query.ts | 29 +-
web-console/src/{utils => helpers}/capabilities.ts | 48 +-
web-console/src/helpers/capacity.ts | 6 +-
.../src/helpers/execution/sql-task-execution.ts | 9 +-
web-console/src/helpers/index.ts | 1 +
web-console/src/helpers/spec-conversion.spec.ts | 6 +
web-console/src/helpers/spec-conversion.ts | 5 +
web-console/src/hooks/index.ts | 1 +
.../use-clock.ts} | 32 +-
web-console/src/links.ts | 2 +-
web-console/src/react-table/react-table-extra.scss | 4 +
web-console/src/utils/index.tsx | 1 -
web-console/src/utils/load-rule.ts | 32 +-
web-console/src/variables.scss | 2 +-
.../__snapshots__/datasources-view.spec.tsx.snap | 2 +-
.../datasources-view/datasources-view.spec.tsx | 2 +-
.../views/datasources-view/datasources-view.tsx | 447 +++---
.../__snapshots__/home-view.spec.tsx.snap | 12 +
.../datasources-card/datasources-card.spec.tsx | 2 +-
.../datasources-card/datasources-card.tsx | 5 +-
.../home-view/home-view-card/home-view-card.scss | 2 +-
web-console/src/views/home-view/home-view.spec.tsx | 2 +-
web-console/src/views/home-view/home-view.tsx | 2 +-
.../home-view/lookups-card/lookups-card.spec.tsx | 2 +-
.../views/home-view/lookups-card/lookups-card.tsx | 3 +-
.../home-view/segments-card/segments-card.spec.tsx | 2 +-
.../home-view/segments-card/segments-card.tsx | 3 +-
.../home-view/services-card/services-card.spec.tsx | 2 +-
.../home-view/services-card/services-card.tsx | 3 +-
.../supervisors-card/supervisors-card.spec.tsx | 2 +-
.../supervisors-card/supervisors-card.tsx | 3 +-
.../views/home-view/tasks-card/tasks-card.spec.tsx | 2 +-
.../src/views/home-view/tasks-card/tasks-card.tsx | 112 +-
.../views/ingestion-view/ingestion-view.spec.tsx | 2 +-
.../src/views/ingestion-view/ingestion-view.tsx | 5 +-
.../__snapshots__/segments-view.spec.tsx.snap | 28 +-
.../src/views/segments-view/segments-view.spec.tsx | 2 +-
.../src/views/segments-view/segments-view.tsx | 49 +-
.../src/views/services-view/services-view.spec.tsx | 3 +-
.../src/views/services-view/services-view.tsx | 218 +--
.../ingestion-progress-dialog.tsx | 25 +-
.../sql-data-loader-view/sql-data-loader-view.tsx | 75 +-
.../capacity-alert/capacity-alert.tsx | 6 +-
.../connect-external-data-dialog.tsx | 18 +-
.../execution-error-pane.spec.tsx.snap | 2 +-
.../execution-error-pane/execution-error-pane.tsx | 4 +-
.../execution-stages-pane.spec.tsx.snap | 16 +-
.../execution-stages-pane.scss | 5 -
.../execution-stages-pane.tsx | 160 +-
.../workbench-view/helper-query/helper-query.tsx | 12 +-
.../input-source-step/example-inputs.ts | 3 +
.../input-source-step/input-source-step.tsx | 12 +-
.../__snapshots__/max-tasks-button.spec.tsx.snap | 83 +-
.../max-tasks-button/max-tasks-button.spec.tsx | 4 +-
.../max-tasks-button/max-tasks-button.tsx | 38 +-
.../views/workbench-view/query-tab/query-tab.tsx | 13 +-
.../recent-query-task-panel.tsx | 11 +-
.../views/workbench-view/run-panel/run-panel.tsx | 132 +-
.../src/views/workbench-view/workbench-view.tsx | 21 +-
website/.spelling | 16 +
website/sidebars.json | 6 +-
722 files changed, 39142 insertions(+), 10117 deletions(-)
rename .github/scripts/{display_dependency_analysis_error_message.sh =>
analyze_dependencies_script.sh} (92%)
copy .github/scripts/{setup_generate_license.sh => license_checks_script.sh}
(60%)
create mode 100644 .github/workflows/codeql-config.yml
create mode 100644 .github/workflows/codeql.yml
create mode 100644
benchmarks/src/test/java/org/apache/druid/benchmark/JsonLineReaderBenchmark.java
create mode 100644
core/src/main/java/org/apache/druid/data/input/BytesCountingInputEntity.java
copy
processing/src/test/java/org/apache/druid/frame/write/FrameRowTooLargeExceptionTest.java
=> core/src/main/java/org/apache/druid/data/input/InputStats.java (69%)
create mode 100644
core/src/main/java/org/apache/druid/data/input/impl/FastLineIterator.java
copy
extensions-core/orc-extensions/src/main/java/org/apache/druid/data/input/orc/OrcStructJsonProvider.java
=>
core/src/main/java/org/apache/druid/java/util/common/parsers/FlattenerJsonProvider.java
(63%)
create mode 100644
core/src/main/java/org/apache/druid/java/util/emitter/core/SwitchingEmitter.java
create mode 100644
core/src/test/java/org/apache/druid/data/input/BytesCountingInputEntityTest.java
create mode 100644
core/src/test/java/org/apache/druid/data/input/impl/FastLineIteratorTest.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> core/src/test/java/org/apache/druid/data/input/impl/InputStatsImpl.java
(69%)
create mode 100644
core/src/test/java/org/apache/druid/java/util/common/IntervalsTest.java
create mode 100644
core/src/test/java/org/apache/druid/java/util/common/parsers/FlattenerJsonProviderTest.java
create mode 100644
core/src/test/java/org/apache/druid/java/util/emitter/core/SwitchingEmitterTest.java
create mode 100644
core/src/test/java/org/apache/druid/java/util/metrics/MetricsVerifier.java
delete mode 100644 docs/assets/files/kttm-nested-data.json.tgz
create mode 100644 docs/development/experimental-features.md
create mode 100644 docs/operations/python.md
create mode 100644 docs/tutorials/tutorial-jdbc.md
create mode 100644 docs/tutorials/tutorial-jupyter-index.md
create mode 100755 examples/bin/start-druid
create mode 100644 examples/bin/start-druid-main.py
create mode 100644 examples/conf/druid/auto/_common/common.jvm.config
copy examples/conf/druid/{cluster => auto}/_common/common.runtime.properties
(100%)
copy examples/conf/druid/{single-server/large => auto}/_common/log4j2.xml
(100%)
create mode 100644 examples/conf/druid/auto/broker/runtime.properties
copy examples/conf/druid/{cluster/master =>
auto}/coordinator-overlord/runtime.properties (100%)
create mode 100644 examples/conf/druid/auto/historical/runtime.properties
create mode 100644 examples/conf/druid/auto/indexer/runtime.properties
create mode 100644 examples/conf/druid/auto/middleManager/runtime.properties
create mode 100644 examples/conf/druid/auto/router/runtime.properties
create mode 100644 examples/quickstart/jupyter-notebooks/README.md
create mode 100644 examples/quickstart/jupyter-notebooks/api-tutorial.ipynb
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQFaultsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/WorkerImplTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/WorkerChatHandlerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/CounterSnapshotBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestFileUtils.java
create mode 100644
extensions-core/multi-stage-query/src/test/resources/unparseable-mv-string-array.json
create mode 100644 extensions-core/orc-extensions/example/test_simple.orc
create mode 100644
extensions-core/protobuf-extensions/src/main/java/org/apache/druid/data/input/protobuf/ProtobufConverter.java
create mode 100644
extensions-core/protobuf-extensions/src/main/java/org/apache/druid/data/input/protobuf/ProtobufFlattenerMaker.java
create mode 100644
extensions-core/protobuf-extensions/src/main/java/org/apache/druid/data/input/protobuf/ProtobufJsonProvider.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateRequest.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateResult.java
(57%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocationQueue.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/actions/SegmentAllocateActionBuilder.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/actions/SegmentAllocationQueueTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/ParseExceptionReport.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/msq/ITMSQReindexTest.java
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/json_path_index_queries.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/msq_inline.sql (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/sparse_column_msq.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/sparse_column_msq.sql (100%)
copy integration-tests-ex/cases/src/test/resources/{indexer =>
multi-stage-query}/wikipedia_combining_firehose_index_queries.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index/wikipedia_merge_index_task.sql
=> wikipedia_combining_input_source_msq.sql} (64%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_http_inputsource_msq.sql (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_http_inputsource_queries.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_index_msq.sql (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_index_queries.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_index_queries_with_transform.json (100%)
rename
integration-tests-ex/cases/src/test/resources/multi-stage-query/{batch-index =>
}/wikipedia_index_task_with_transform.sql (100%)
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_msq.sql
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_index_queries.json
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_merge_reindex_msq.sql
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_reindex_msq.sql
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_reindex_queries.json
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_reindex_queries_with_transforms.json
create mode 100644
integration-tests-ex/cases/src/test/resources/multi-stage-query/wikipedia_reindex_with_transform_msq.sql
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{ComplexFrameColumnWriter.java
=> ComplexFrameMaker.java} (73%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{DoubleFrameColumnWriter.java
=> DoubleFrameMaker.java} (75%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{FloatFrameColumnWriter.java
=> FloatFrameMaker.java} (75%)
copy
processing/src/main/java/org/apache/druid/frame/write/columnar/{LongFrameColumnWriter.java
=> LongFrameMaker.java} (75%)
create mode 100644
processing/src/main/java/org/apache/druid/query/UnnestDataSource.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/LimitedRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/NaivePartitioningOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/NaivePartitioningOperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/Operator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/OperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/OperatorSequence.java
copy processing/src/main/java/org/apache/druid/{guice/ModulesConfig.java =>
query/operator/SegmentToRowsAndColumnsOperator.java} (50%)
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/SequenceOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQuery.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQueryQueryRunnerFactory.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowOperatorQueryQueryToolChest.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/WindowProcessorOperator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ComposingProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/WindowAggregateProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/WindowFrame.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/WindowFramedAggregateProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowCumeDistProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowDenseRankProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowPercentileProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRankProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRankingProcessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/ranking/WindowRowNumberProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/ShiftedColumnAccessorBase.java
copy
processing/src/main/java/org/apache/druid/query/{BadJsonQueryException.java =>
operator/window/value/WindowFirstProcessor.java} (53%)
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowLastProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowOffsetProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/operator/window/value/WindowValueProcessorBase.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/AppendableMapOfColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/ArrayListRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/MapOfColumnsRowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/OnHeapCumulativeAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/RowsAndColumns.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/Column.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ColumnAccessor.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ColumnAccessorBasedColumn.java
(68%)
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ConstantObjectColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/DoubleArrayColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/IntArrayColumn.java
copy
processing/src/{test/java/org/apache/druid/segment/incremental/SimpleRowIngestionMeters.java
=>
main/java/org/apache/druid/query/rowsandcols/column/NullColumnAccessor.java}
(51%)
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ObjectArrayColumn.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/column/ObjectColumnAccessorBase.java
copy processing/src/main/java/org/apache/druid/{guice/ModulesConfig.java =>
query/rowsandcols/semantic/AppendableRowsAndColumns.java} (52%)
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/ColumnSelectorFactoryMaker.java
(58%)
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultColumnSelectorFactoryMaker.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultFramedOnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultOnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/DefaultSortedGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/FramedOnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/GroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/OnHeapAggregatable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/rowsandcols/semantic/SortedGroupPartitioner.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ArrayListSegment.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/UnnestColumnValueSelectorCursor.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/UnnestDimensionCursor.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/UnnestSegmentReference.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/UnnestStorageAdapter.java
rename
processing/src/main/java/org/apache/druid/segment/incremental/{MutableRowIngestionMeters.java
=> SimpleRowIngestionMeters.java} (81%)
create mode 100644
processing/src/main/java/org/apache/druid/segment/nested/NestedDataColumnV3.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/nested/NestedDataColumnV4.java
create mode 100644
processing/src/test/java/org/apache/druid/guice/StartupInjectorBuilderTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/InlineScanOperator.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/NaivePartitioningOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/OperatorSequenceTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/SequenceOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/WindowOperatorQueryTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/WindowProcessorOperatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ComposingProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/RowsAndColumnsHelper.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/WindowAggregateProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/WindowFramedAggregateProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowCumeDistProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowDenseRankProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowPercentileProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowRankProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/ranking/WindowRowNumberProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowFirstProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLagProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLastProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/operator/window/value/WindowLeadProcessorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/ArrayListRowsAndColumnsTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/AsOnlyTestRowsAndColumns.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/MapOfColumnsRowsAndColumnsTest.java
copy processing/src/{main/java/org/apache/druid/guice/ModulesConfig.java =>
test/java/org/apache/druid/query/rowsandcols/NoAsRowsAndColumns.java} (54%)
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/RowsAndColumnsTestBase.java
copy
processing/src/test/java/org/apache/druid/{frame/write/FrameRowTooLargeExceptionTest.java
=> query/rowsandcols/column/NullColumnAccessorTest.java} (56%)
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/AppendableRowsAndColumnsTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/FramedOnHeapAggregatableTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/OnHeapAggregatableTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/SemanticTestBase.java
create mode 100644
processing/src/test/java/org/apache/druid/query/rowsandcols/semantic/SortedGroupPartitionerTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/ListCursor.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/UnnestColumnValueSelectorCursorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/UnnestStorageAdapterTest.java
rename
processing/src/test/java/org/apache/druid/segment/incremental/{SimpleRowIngestionMeters.java
=> RowMeters.java} (50%)
rename
processing/src/test/java/org/apache/druid/segment/incremental/{MutableRowIngestionMetersTest.java
=> SimpleRowIngestionMetersTest.java} (58%)
create mode 100644 processing/src/test/resources/nested_segment_v3/index.zip
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/PropertyAttributes.java
create mode 100644
server/src/main/java/org/apache/druid/indexing/overlord/SegmentCreateRequest.java
create mode 100644
server/src/main/java/org/apache/druid/server/QueryResultPusher.java
rename
processing/src/main/java/org/apache/druid/frame/write/FrameRowTooLargeException.java
=>
server/src/main/java/org/apache/druid/server/emitter/SwitchingEmitterConfig.java
(56%)
create mode 100644
server/src/main/java/org/apache/druid/server/emitter/SwitchingEmitterModule.java
copy
server/src/{main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> test/java/org/apache/druid/catalog/model/table/BaseExternTableTest.java}
(62%)
create mode 100644
server/src/test/java/org/apache/druid/guice/DruidInjectorBuilderTest.java
rename
processing/src/test/java/org/apache/druid/frame/write/FrameRowTooLargeExceptionTest.java
=>
server/src/test/java/org/apache/druid/indexing/overlord/SegmentCreateRequestTest.java
(54%)
create mode 100644
server/src/test/java/org/apache/druid/initialization/SwitchingEmitterModuleTest.java
rename
server/src/test/java/org/apache/druid/segment/loading/{CacheTestSegmentCacheManager.java
=> NoopSegmentCacheManager.java} (75%)
copy processing/src/main/java/org/apache/druid/guice/ModulesConfig.java =>
server/src/test/java/org/apache/druid/server/mocks/ExceptionalInputStream.java
(54%)
create mode 100644
server/src/test/java/org/apache/druid/server/mocks/MockAsyncContext.java
rename
extensions-core/druid-catalog/src/test/java/org/apache/druid/server/http/catalog/DummyRequest.java
=>
server/src/test/java/org/apache/druid/server/mocks/MockHttpServletRequest.java
(52%)
create mode 100644
server/src/test/java/org/apache/druid/server/mocks/MockHttpServletResponse.java
create mode 100644 sql/src/main/codegen/includes/from.ftl
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/expression/WindowSqlAggregate.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/CatalogExternalTableOperatorConversion.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/ExtendOperator.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/Externals.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/FunctionParameterImpl.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
sql/src/main/java/org/apache/druid/sql/calcite/external/HttpOperatorConversion.java
(62%)
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
sql/src/main/java/org/apache/druid/sql/calcite/external/InlineOperatorConversion.java
(61%)
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
sql/src/main/java/org/apache/druid/sql/calcite/external/LocalOperatorConversion.java
(57%)
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/ParameterizeOperator.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/external/UserDefinedTableMacroFunction.java
copy processing/src/main/java/org/apache/druid/guice/ModulesConfig.java =>
sql/src/main/java/org/apache/druid/sql/calcite/planner/NoOpPlannerHook.java
(51%)
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/PlannerCaptureHook.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/PlannerHook.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/rel/Windowing.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteWindowQueryTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CatalogIngestionTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/QueryVerification.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/SqlSchema.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/util/BasicTestModule.java
create mode 100644
sql/src/test/resources/calcite/expected/ingest/httpExtern-logicalPlan.txt
create mode 100644
sql/src/test/resources/calcite/expected/ingest/insertFromExternal-logicalPlan.txt
create mode 100644
sql/src/test/resources/calcite/expected/ingest/insertWithClusteredBy-logicalPlan.txt
create mode 100644
sql/src/test/resources/calcite/expected/ingest/insertWithPartitionedBy-logicalPlan.txt
create mode 100644
sql/src/test/resources/calcite/expected/ingest/localExtern-logicalPlan.txt
copy examples/quickstart/tutorial/wikiticker-2015-09-12-sampled.json.gz =>
sql/src/test/resources/calcite/tests/wikiticker-2015-09-12-sampled.jgz (100%)
create mode 100644
sql/src/test/resources/calcite/tests/window/simpleSum.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/wikipediaCumulativeOrdered.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/wikipediaFramedAggregations.sqlTest
create mode 100644
sql/src/test/resources/calcite/tests/window/wikipediaSimplePartition.sqlTest
create mode 100644
web-console/src/dialogs/index-spec-dialog/__snapshots__/index-spec-dialog.spec.tsx.snap
copy web-console/src/dialogs/{compaction-dialog/compaction-dialog.scss =>
index-spec-dialog/index-spec-dialog.scss} (96%)
copy web-console/src/{views/datasources-view/datasources-view.spec.tsx =>
dialogs/index-spec-dialog/index-spec-dialog.spec.tsx} (59%)
copy web-console/src/dialogs/{compaction-dialog/compaction-dialog.tsx =>
index-spec-dialog/index-spec-dialog.tsx} (59%)
create mode 100644
web-console/src/dialogs/kill-datasource-dialog/kill-datasource-dialog.tsx
create mode 100644 web-console/src/druid-models/index-spec/index-spec.tsx
rename web-console/src/{utils => helpers}/capabilities.ts (86%)
copy
web-console/src/{components/form-group-with-info/form-group-with-info.scss =>
hooks/use-clock.ts} (65%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
