This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a change to branch suppress_cves_38.0.0
in repository https://gitbox.apache.org/repos/asf/druid.git
from 897d36aea1a Merge branch 'master' of github.com:apache/druid into
suppress_cves_38.0.0
add 6a8cc4a06b5 fix: update PullDependencies to exclude netty-4 jars
(#20332)
add 80a570ae151 build(deps): bump nanoid from 3.3.16 to 3.3.19 in /website
(#20334)
add 4395ef34647 build(deps): bump aws.sdk.v2.version from 2.54.13 to
2.54.14 (#20330)
add 4dc0437e0f3 test: use a long taskDuration for bounded Kafka supervisor
tests (#20311)
add 76ddcf297e4 perf(test): Reduce compaction tests 12min and Re-sharding
test cases to reduce 6min (#20307)
add 997a2a95683 ci: cut Docker test job from 40m to 25m by building a lean
distribution (#20297)
add 97fcd37ce72 ci: do not fail unit test jobs when the JFR profiler agent
cannot be downloaded (#20318)
add e3f06eac3ec fix: per-segment timeout accounting bug (#20290)
add 899f765a39a minor: remove AsyncResources#fromFutureCloseable (#20356)
add 0eeda00c7d8 build(deps-dev): bump org.bouncycastle:bcpkix-jdk18on from
1.85 to 1.86 (#20352)
add 52c688b7cea build(deps-dev): bump
org.codehaus.mojo:animal-sniffer-maven-plugin (#20350)
add 4d6d6140c30 build(deps): bump org.bitbucket.b_c:jose4j from 0.9.6 to
0.9.7 (#20349)
add 25f56955e80 build(deps): bump org.roaringbitmap:RoaringBitmap from
1.6.21 to 1.6.23 (#20348)
add 3958b1fac49 build(deps): bump com.netflix.spectator:spectator-api
(#20347)
add 0f7071077fc build(deps): bump org.codehaus.mojo:exec-maven-plugin
(#20346)
add 8aa0c211a9d build(deps): bump
org.codehaus.mojo:build-helper-maven-plugin (#20345)
add bf77096e67a build(deps-dev): bump org.bouncycastle:bcprov-jdk18on
(#20344)
add ccca0bd7fa6 build(deps): bump opentelemetry.version from 1.65.0 to
1.66.0 (#20343)
add 480f9a85ab9 build(deps): bump netty4.version from 4.2.17.Final to
4.2.18.Final (#20342)
add ee6b0439d02 build(deps): bump aws.sdk.v2.version from 2.54.14 to
2.54.17 (#20340)
add b555785b40e fix(sql): honor Statement.setMaxRows in the Avatica JDBC
server (#19941)
add 5b1bcc11782 test: fix flaky KubernetesTaskRunnerTest start tests
(#20316)
add 9f5363cc5f3 feat: ddl statements + catalog (#19830)
add 0020a4c564d build(deps): bump at.yawk.lz4:lz4-java from 1.11.2 to
1.11.3 (#20359)
add 95f3747a080 build(deps): bump
org.apache.maven.plugins:maven-install-plugin (#20358)
add 2fed7ca11d9 build(deps-dev): bump
org.apache.maven.plugins:maven-deploy-plugin (#20357)
add b0b17848ac0 build(deps-dev): bump com.github.fppt:jedis-mock from
1.1.18 to 1.1.19 (#20365)
add 3248d73644b build(deps-dev): bump
io.github.ascopes:protobuf-maven-plugin (#20364)
add 3cbd00d9d7d build(deps): bump com.github.wnameless.json:json-flattener
(#20363)
add a007e33a762 feat: add support to push/pull/kill segments in azure deep
storage without zip compression (#20327)
add 45a4440d24f build(deps): bump bytebuddy.version from 1.18.13 to
1.18.14 (#20372)
add bf692854a30 build(deps): bump aws.sdk.v2.version from 2.54.17 to
2.54.18 (#20370)
add b2b9baedca0 build(deps): bump aws.sdk.v2.version from 2.54.18 to
2.54.19 (#20383)
add 3ce1110d202 fix: address website dependency vulnerabilities (#19814)
add 12dcc915662 fix: HyperLogLogCollector returns zero cardinality when a
single element overflows into sparse mode (#19678)
add bd234ed1767 fix(druid): handle 429/503 HTML before JSON parse in
DirectDruidClient (#20151)
add 43a0a704777 Skip unset variables in
EnvironmentVariableDynamicConfigProvider (#20381)
add 6a05dca0885 build(docker): retry bash-static download (#20368)
add 13ae31afc23 fix: use JUnit 5 assertions in HyperLogLogCollectorTest
(#20388)
add f81c3c19c9d feat: Adds an opt-in vectorized read path to the Iceberg
input source using iceberg-arrow. (#19510)
add cf84e5f1b09 fix: Web console: compaction of PB scale datasource
returning a bigint that crashes the Datasources view and get Claude to fix all
other issues like it. (#20384)
add 4eede66fcff feat: Azure SegmentRangeReader for partial loads (#20380)
add 15051a5c09b feat: add support for push/pull/kill segments in google
cloud deep storage without zip compression (#20382)
add a379ea849fd build(deps): bump com.nimbusds:nimbus-jose-jwt from 10.9.1
to 10.10 (#20397)
add a9eae5baaba build(deps-dev): bump confluent.version from 8.3.1 to
8.3.2 (#20396)
add 5146cac1370 build(deps): bump arrow.version from 15.0.2 to 19.0.0
(#20394)
add 810095aa061 build(deps): bump avatica.version from 1.28.0 to 1.29.0
(#20393)
add 8f2b9537ef8 build(deps): bump protobuf.version from 4.36.1 to 4.36.2
(#20392)
add fccd11ad7ab build(deps): bump aws.sdk.v2.version from 2.54.19 to
2.55.1 (#20391)
add 294fe36329e fix: stop replica top-up churn for completed bounded task
groups (#20387)
add ae8a5000ac4 build(deps): bump joda-time:joda-time from 2.14.3 to
2.14.4 (#20406)
add f541ae200c6 build(deps): bump org.apache:apache from 39 to 40 (#20405)
add b7b560dfd29 test: poll Broker state instead of schema refresh metrics
in QueryTestBase (#20319)
add d311319e736 test: fix flaky ReferenceCountingResourceHolderTest
cleaner checks (#20317)
add fe9dd22977f build(deps): upgrade org.apache.maven.resolver from 1.3.1
to 2.0.23 (#20386)
add bce8f60af27 ci: bump actions-timeline to an ASF-approved version and
fix dependabot.yml (#20415)
add 3f86006062b fix: Web console: sorting on columns whose accessor
returns an object (#20419)
add 27180f525ca fix: address web console dependency vulnerabilities
(#19815)
add 94e290864bf build(deps): bump de.thetaphi:forbiddenapis from 3.10 to
3.11 (#20410)
add f7fbbe74574 build(deps): bump
org.hibernate.validator:hibernate-validator (#20411)
add a01e318f96c minor: use rustfs instead of minio for s3 embedded-tests
(#20420)
add 53e814e87c6 fix: Batch deletes in DurableStorageCleaner to avoid
overlord OOM (#20425)
add 8bdc64135f8 Set a valid empty delegate if concat cursor never finds
rows (#20422)
add c7f1f0adb3f feat: Web console: update dependencies, remove npm
overrides, restore v5 chart colors (#20421)
add e117a665b02 build(deps): bump image-size from 2.0.2 to 2.0.4 in
/website (#20418)
add 0387ffa9028 fix: stabilize task queue and ingestion CI tests (#20291)
add 017c18ab6db fix: Wait for Kafka lookup startup catch-up (#19858)
add e16bbf8bdc8 fix: implement makeAggregateCombiner for momentSketch
aggregators (#20413)
add 13749ce5336 feat: Add a timeout for SQL query planning on the Broker
(#20314)
add 7a7b9f2a8a1 fix: prevent duplicate AWS SDK S3 classloading when s3 and
iceberg extensions are both loaded (#20409)
add edea417869a feat: accept LONG as an alias for BIGINT in CAST
expressions (#20402)
add d2bff3c9ec5 feat: add adaptive http pooling (#20273)
add 8da9a1b1071 minor: Pass full Task payload in TaskRunnerListener and
not just taskId (#20417)
add 1afd36ba7d4 test: seed MSQ quantiles sketch for partition tests
(#20440)
add 9cbb8698be8 docs: fix 'connot' typo in semantic index Javadoc (#20446)
add e68dd496a2c fix: Encode queryId in DirectDruidClient cancelUrl.
(#20308)
add ff97a704e21 feat: Druid JDBC driver. (#19951)
add dfe397ced3c fix: log-message typos (#20449)
add 2a644b5482f fix: guard `dutiesRunnables` with lock in DruidCoordinator
(#20408)
add 3c3eec5b1cb perf: Use Charset in StringUtils to/fromUtf8. (#20310)
add f2f26f5c15d feat: Add Kubernetes node-label dynamic config provider
(#20404)
add 697dfcce885 minor: `unannouncePropagationDelay` should be ignored for
tasks which don't support querying (#20444)
add 443688fea12 feat: add plain table base table spec for catalog wiring
(#20377)
add a3f0c577f0d refactor: use AsyncResource instead of Future to acquire
segment references (#20197)
add 85c5892d729 fix: address CodeQL nullness and type warnings (#19823)
add afa5b4e7441 test: poll sys.segments in verifyNumVisibleSegmentsIs to
fix flaky compaction tests (#20320)
add e5a09317c41 test: wait for handoff notice completion in supervisor
state test (#20453)
add 0ad366d5d4a test(web-console): handle available capacity warning in
MSQ e2e (#20443)
add bfcd037be3e fix: DECIMAL type coercion losing fractions. (#20456)
add 4f934e3a4f1 build(deps): bump @babel/core from 7.26.9 to 7.29.7 in
/website (#20427)
add d11b956bd6c feat: google cloud storage SegmentRangeReader for partial
loads (#20454)
add f45885a53b1 minor: tidy up licenses.yaml and scripts (#20400)
add 631f05de5d1 test: avoid racing supervisor history read (#20458)
add daf25972184 test: retain allocations in metric collector test (#20457)
add 46e8f93eb83 feat: Add advertisedPlaintextPort to DruidNode for sidecar
proxy support (#19598)
add 87d36ea3426 fix: Move aws-crt-client to the correct classloader
(#20468)
add a24a74e9a1b fix: update task runner test listener signatures (#20470)
add e855cd9c331 feat: Web console: upgrade to the latest and greatest
(#20448)
add 2b090310733 build(deps): bump fast-uri from 3.1.7 to 3.1.8 in /website
(#20463)
add ae37702490d build(deps): bump dompurify from 3.4.13 to 3.4.16 in
/website (#20462)
add 3e9365196f9 build(deps): bump tools.jackson.core:jackson-databind in
/benchmarks (#20461)
add 15a592e899c perf: Reduce heap footprint of loaded segments. (#20467)
add 1265b47c9a5 build(deps): bump brace-expansion from 1.1.18 to 1.1.21 in
/website (#20464)
add 205b50fcca2 test: stabilize embedded Kafka supervisor tests (#20479)
add 4c1844a101b ci: resolve Apache parent POM before worker builds (#20459)
add 87525a9c6d5 feat: add pre-ingestion filtering based on Kafka headers
(#18525)
add a758f52dfc2 fix: keep default values of proto3 fields without presence
in protobuf ingestion (#20485)
add e40df5301e8 dev: make git hooks work from linked worktrees (#20477)
add c1612677ab2 build(deps): bump joi from 17.13.7 to 17.13.8 in /website
(#20491)
add a04a72c9b69 build(deps): bump source-map-js from 1.2.1 to 1.2.2 in
/website (#20490)
add a4fcecbd3e4 build(deps): bump proxy-addr from 2.0.7 to 2.0.8 in
/website (#20489)
add 1dac0af979e build(deps): bump compression from 1.8.1 to 1.8.2 in
/website (#20488)
add 3afe2d744af build(deps): bump source-map-js from 1.2.1 to 1.2.2 in
/web-console (#20487)
add a15c45d58a7 build(deps): bump pyspark (#20486)
add 9bfa06be8ae build(deps): bump
org.apache.httpcomponents.core5:httpcore5 from 5.4.3 to 5.4.4 (#20484)
add a0d4f0239c2 build(deps-dev): bump
io.github.ascopes:protobuf-maven-plugin (#20483)
add 21f36edf54f build(deps): bump com.github.ben-manes.caffeine:caffeine
from 3.2.4 to 3.3.0 (#20482)
add 35e72caf58b build(deps): bump jackson.version from 2.22.2 to 2.22.3
(#20480)
add a38a81f1ce3 test: remove `protobuf-dynamic` dependency (#20495)
add bd61838ac04 Add the Maven wrapper and use it in CI (#20496)
add 13198981727 Fix broken compile (#20506)
add cde7404de1e test: Fix flaky EmbeddedKafkaSupervisorTest (#20519)
add 51b66c7819c build(deps): bump com.google.api:gax from 2.85.0 to 2.86.0
(#20516)
add bb9a5da89eb build(deps-dev): bump
com.google.auth:google-auth-library-credentials (#20514)
add 971f21ba94d build(deps): bump com.netflix.spectator:spectator-api
(#20515)
add 723d3a233d9 build(deps-dev): bump
com.google.api.grpc:proto-google-common-protos (#20512)
add e9cc7e8decd build(deps-dev): bump
com.google.cloud:google-cloud-storage from 2.73.0 to 2.74.0 (#20511)
add 23b8ace2a64 build(deps-dev): bump com.google.cloud:google-cloud-core
from 2.75.0 to 2.76.0 (#20510)
add 6a3f25cb0ea build(deps): bump slf4j.version from 2.0.19 to 2.0.20
(#20500)
add f69e1180099 build(deps): bump mockito.version from 5.23.0 to 5.24.0
(#20513)
add bbeb73132e5 build(deps): bump aws.sdk.v2.version from 2.55.1 to 2.55.4
(#20509)
add f967fd47835 build(deps): bump shell-quote from 1.10.0 to 1.12.0 in
/website (#20502)
add 1754a027dfe build(deps): bump shell-quote from 1.10.0 to 1.12.0 in
/web-console (#20501)
add eb43fd0458d fix: Restarted the watch after stream reset #19055 (#19056)
add 4ad1ddd2724 fix: `writeAtomically` fails for file names longer than
217 bytes (#20493)
add 4b0c28ae3f7 minor: release process (#18681)
add 3cedc8ad05c Discover Dart enabled historicals via a new
DartWorkerService instead of inferring workers solely off service == historical
(#20508)
add b6d638b067e fix: Properly compute virtual column chains post-join.
(#20538)
add bcca2884b58 feat: Web console: replace Ace with CodeMirror 6 (#20507)
add eccfab1be42 ci: stop running RAT in the parallel packaging-check build
(#20527)
add 805a5426720 test: fix flaky
ScheduledExecutorsTest.testscheduleWithFixedDelay (#20526)
add 9a792495bd7 bump zk version to fix cve (#20524)
add 7b552d0c204 build(deps): bump at.yawk.lz4:lz4-java from 1.11.3 to
1.11.4 (#20520)
add efa1513c3f7 disable-adaptive (#20542)
add 165e9b9b318 minor: Complete CollectedAsyncResource immediately on
failure. (#20504)
add 98bbcb4c7f7 feat: add rollup table base table spec for catalog wiring
(#20452)
add c59ba760d63 build(deps): bump aws.sdk.v2.version from 2.55.4 to 2.55.5
(#20531)
add 66504db822b build(deps): bump fabric8.version from 7.9.0 to 8.0.0
(#20532)
add 2144e342f19 build(deps): bump
software.amazon.kinesis:amazon-kinesis-client from 3.5.2 to 3.5.3 (#20533)
add a68ba10ef56 build(deps): bump org.apache.directory.api:api-util from
2.1.8 to 2.1.9 (#20534)
add 792196709ea build(deps): bump org.asynchttpclient:async-http-client
(#20535)
add 4072ed9e650 build(deps-dev): bump org.apache.commons:commons-lang3
(#20548)
add fc345452d75 build(deps): bump aws.sdk.v2.version from 2.55.5 to 2.55.6
(#20545)
add d3ae86730e9 build(deps): bump at.yawk.lz4:lz4-java from 1.11.4 to
1.12.0 (#20547)
add 493fcc66e81 build(deps): bump iceberg.core.version from 1.11.0 to
1.12.0 (#20546)
add 0bedd8c8054 build(deps-dev): bump handlebars from 4.7.9 to 4.7.10 in
/web-console (#20539)
add 45668be3e1c test: fix flaky
QueryVirtualStorageTest.testQueryTooMuchData (#20552)
add b2721b2cd1c fix: avoid race in
IngestionSmokeTest.test_streamLogs_ofCancelledTask (#20549)
add 585459a6239 feat!: add typed query context parameters (#20198)
add 3469a0fdaa4 feat: support ingesting Kafka messages from selected
partitions (#20474)
add bb50f29b1d7 fix: ignore TrafficCop calls once the connection is back
in the pool (#20522)
add c206beeb7f5 fix: FrameProcessorExecutor cancellation fixes (#20460)
add 308c9499965 fix: correct JSON serialization of CloneQueryMode (#20557)
add b776752ebe9 feat: simd double unary math ops (#19768)
add 7b07003ee30 Merge branch 'master' of github.com:apache/druid into
suppress_cves_38.0.0
add 4d5070b84b3 Add fail never so that all CVEs are flagged at once
No new revisions were added by this update.
Summary of changes:
.codecov.yml | 31 -
.github/dependabot.yml | 12 +
.github/scripts/analyze_dependencies_script.sh | 2 +-
.github/scripts/build-dist | 21 -
.github/scripts/create-jacoco-coverage-report.sh | 8 +-
.github/scripts/license_checks_script.sh | 2 +-
.github/scripts/openrewrite.sh | 5 +-
.github/scripts/packaging-check.sh | 18 +-
.github/scripts/run_docker-tests | 8 +-
.github/scripts/run_unit-tests | 2 +-
.github/scripts/setup_test_profiling_env.sh | 48 +-
.github/scripts/static-checks-maven.sh | 27 +-
.github/scripts/strict-compilation.sh | 2 +-
.github/scripts/test_balancing_calc | 5 +-
.github/scripts/web-checks.sh | 7 +-
.github/workflows/ci.yml | 2 +-
.github/workflows/codeql.yml | 2 +-
.github/workflows/cron-job-its.yml | 6 +-
.github/workflows/docker-tests.yml | 15 +-
.../unit-and-integration-tests-unified.yml | 4 +-
.github/workflows/worker.yml | 18 +-
.mvn/wrapper/maven-wrapper.properties | 4 +
LICENSE | 4 +
NOTICE | 12 +
README.md | 1 -
benchmarks/pom.xml | 8 +-
.../benchmark/query/SqlExpressionBenchmark.java | 57 +-
cloud/aws-common/pom.xml | 14 +
codestyle/spotbugs-exclude.xml | 11 +
distribution/asf-release-process-guide.md | 431 +-
distribution/bin/check-licenses.py | 34 +
distribution/bin/find-missing-backports.py | 10 +-
distribution/bin/generate-binary-license.py | 39 +-
distribution/bin/generate-binary-notice.py | 40 +-
distribution/bin/get-milestone-prs.py | 8 +-
distribution/bin/tag-missing-milestones.py | 14 +-
distribution/docker/Dockerfile | 8 +-
distribution/pom.xml | 33 +
distribution/src/assembly/source-assembly.xml | 1 -
docs/api-reference/api-reference.md | 3 +-
docs/configuration/index.md | 28 +
docs/development/build.md | 2 +-
docs/development/extensions-contrib/iceberg.md | 28 +
docs/development/extensions-core/azure.md | 1 +
docs/development/extensions-core/catalog.md | 270 +-
docs/development/extensions-core/google.md | 1 +
docs/development/extensions-core/k8s-jobs.md | 1 +
docs/development/extensions-core/kubernetes.md | 2 +
docs/development/extensions-core/s3.md | 2 +-
docs/ingestion/kafka-ingestion.md | 153 +
docs/operations/dynamic-config-provider.md | 98 +-
docs/operations/metrics.md | 21 +
docs/querying/dart.md | 4 +-
docs/querying/query-context-reference.md | 2 +-
docs/querying/query-context.md | 68 +-
docs/querying/scan-query.md | 2 +-
docs/querying/sql-data-types.md | 2 +-
docs/querying/sql-functions.md | 97 +
.../sql-jdbc.md => querying/sql-jdbc-avatica.md} | 33 +-
docs/querying/sql-jdbc.md | 261 +
docs/querying/sql-metadata-tables.md | 2 +-
docs/querying/sql-query-context.md | 2 +
docs/querying/sql-scalar.md | 4 +
docs/querying/sql.md | 12 +-
docs/tutorials/tutorial-jdbc.md | 6 +-
embedded-tests/pom.xml | 18 +-
.../embedded/catalog/CatalogDdlAndIngestTest.java | 722 +
.../embedded/compact/CompactionTestBase.java | 4 +-
.../docker/BaseConsulDiscoveryDockerTest.java | 10 +-
.../embedded/hdfs/HdfsToS3ParallelIndexTest.java | 14 +-
.../embedded/hdfs/S3ToHdfsParallelIndexTest.java | 10 +-
.../iceberg/IcebergRestCatalogIngestionTest.java | 38 +-
.../AbstractS3InputSourceParallelIndexTest.java | 16 +-
.../testing/embedded/indexing/IndexTaskTest.java | 108 +
.../embedded/indexing/IngestionSmokeTest.java | 90 +-
.../indexing/KafkaBoundedSupervisorTest.java | 42 +-
.../testing/embedded/indexing/MoreResources.java | 4 +-
.../indexing/StreamIndexDataFormatsTestBase.java | 51 +-
.../msq/EmbeddedDurableShuffleStorageTest.java | 8 +-
...Resource.java => S3DurableStorageResource.java} | 12 +-
.../testing/embedded/msq/S3ExternQueryTest.java | 8 +-
.../query/PartialProjectionLoadRuleQueryTest.java | 6 +-
.../query/QueryRetryOnMissingSegmentsTest.java | 3 +-
.../testing/embedded/query/QueryTestBase.java | 4 +-
.../embedded/query/QueryVirtualStorageTest.java | 12 +-
.../query/ServerManagerForQueryErrorTest.java | 3 +-
.../{minio => s3}/ITS3SQLBasedIngestionTest.java | 2 +-
.../{minio => s3}/ITS3ToS3ParallelIndexTest.java | 6 +-
.../testing/embedded/{minio => s3}/S3PerfTest.java | 20 +-
.../S3StorageResource.java} | 44 +-
.../S3StorageResourceTest.java} | 16 +-
.../S3StorageTest.java} | 8 +-
.../testing/embedded/{minio => s3}/S3TestUtil.java | 2 +-
.../server/KillSupervisorsCustomDutyTest.java | 6 -
.../embedded/tools/ProtobufEventSerializer.java | 48 +-
.../ProtobufSchemaRegistryEventSerializer.java | 11 +-
.../test/resources/data/protobuf/proto3_event.desc | Bin 0 -> 245 bytes
.../resources/data/protobuf/proto3_event.proto | 32 +
.../consul/discovery/ConsulServiceIdsTest.java | 6 +
.../main/resources/defaultMetricDimensions.json | 6 +
.../apache/druid/delta/input/DeltaInputSource.java | 3 +-
.../src/test/resources/requirements.txt | 2 +-
.../druid-iceberg-extensions/pom.xml | 25 +
.../input/IcebergArrowInputSourceReader.java | 476 +
.../apache/druid/iceberg/input/IcebergCatalog.java | 108 +-
.../druid/iceberg/input/IcebergInputSource.java | 402 +-
.../input/IcebergArrowInputSourceReaderTest.java | 614 +
.../input/IcebergInputSourceArrowModeTest.java | 427 +
.../iceberg/input/IcebergInputSourceTest.java | 26 +-
.../org/apache/druid/grpc/server/QueryDriver.java | 2 +-
.../aggregator/MomentSketchAggregatorFactory.java | 47 +
.../MomentSketchAggregatorFactoryTest.java | 37 +
.../aggregator/MomentsSketchAggregatorTest.java | 65 +
extensions-contrib/opentelemetry-emitter/pom.xml | 2 +-
.../src/main/resources/defaultMetrics.json | 5 +-
.../emitter/prometheus/PrometheusEmitter.java | 4 +-
.../src/main/resources/defaultMetrics.json | 1 +
extensions-contrib/spectator-histogram/pom.xml | 2 +-
.../main/resources/defaultMetricDimensions.json | 1 +
extensions-core/azure-extensions/pom.xml | 7 +
.../storage/azure/AzureDataSegmentKiller.java | 11 +-
.../storage/azure/AzureDataSegmentPuller.java | 66 +-
.../storage/azure/AzureDataSegmentPusher.java | 154 +-
.../apache/druid/storage/azure/AzureLoadSpec.java | 45 +
.../storage/azure/AzureSegmentRangeReader.java | 149 +
.../storage/azure/AzureDataSegmentKillerTest.java | 150 +-
.../storage/azure/AzureDataSegmentPullerTest.java | 94 +-
.../storage/azure/AzureDataSegmentPusherTest.java | 289 +-
.../druid/storage/azure/AzureLoadSpecTest.java | 88 +
.../storage/azure/AzureSegmentRangeReaderTest.java | 230 +
.../druid/catalog/guice/CatalogClientModule.java | 8 +
.../apache/druid/catalog/http/CatalogResource.java | 4 +
.../druid/catalog/http/TableEditRequest.java | 127 +-
.../org/apache/druid/catalog/http/TableEditor.java | 259 +-
.../catalog/storage/sql/SQLCatalogManager.java | 214 +-
.../druid/catalog/sync/CachedMetadataCatalog.java | 41 +
.../apache/druid/catalog/sync/CatalogClient.java | 55 +-
.../druid/catalog/sync/CatalogSqlTableWriter.java | 212 +
.../apache/druid/catalog/storage/CatalogTests.java | 3 +-
.../druid/catalog/storage/TableManagerTest.java | 80 +
.../druid/catalog/sync/CatalogCacheTest.java | 42 +
.../server/http/catalog/CatalogResourceTest.java | 81 +-
.../druid/server/http/catalog/EditorTest.java | 301 +
extensions-core/druid-pac4j/pom.xml | 2 +-
extensions-core/google-extensions/pom.xml | 4 +-
.../storage/google/GoogleDataSegmentKiller.java | 39 +-
.../storage/google/GoogleDataSegmentPuller.java | 60 +-
.../storage/google/GoogleDataSegmentPusher.java | 130 +-
.../druid/storage/google/GoogleLoadSpec.java | 41 +
.../storage/google/GoogleSegmentRangeReader.java | 132 +
.../google/GoogleTimestampVersionedDataFinder.java | 4 +-
.../google/GoogleDataSegmentKillerTest.java | 32 +
.../google/GoogleDataSegmentPullerTest.java | 52 +-
.../google/GoogleDataSegmentPusherTest.java | 200 +-
.../druid/storage/google/GoogleLoadSpecTest.java | 91 +
.../google/GoogleSegmentRangeReaderTest.java | 223 +
.../GoogleTimestampVersionedDataFinderTest.java | 4 +-
.../histogram/ApproximateHistogram.java | 2 +
.../query/lookup/KafkaLookupExtractorFactory.java | 58 +-
.../lookup/KafkaLookupExtractorFactoryTest.java | 163 +-
extensions-core/kafka-indexing-service/pom.xml | 5 +
.../druid/indexing/kafka/HeaderFilterHandler.java | 52 +
.../indexing/kafka/HeaderFilterHandlerFactory.java | 57 +
.../druid/indexing/kafka/InDimFilterHandler.java | 78 +
.../kafka/KafkaHeaderBasedFilterEvaluator.java | 193 +
.../druid/indexing/kafka/KafkaIndexTask.java | 4 +-
.../indexing/kafka/KafkaIndexTaskIOConfig.java | 56 +-
.../druid/indexing/kafka/KafkaIndexTaskModule.java | 4 +-
.../druid/indexing/kafka/KafkaRecordSupplier.java | 87 +-
.../druid/indexing/kafka/KafkaSamplerSpec.java | 5 +-
.../supervisor/KafkaHeaderBasedFilterConfig.java | 157 +
.../kafka/supervisor/KafkaIOConfigBuilder.java | 21 +-
.../indexing/kafka/supervisor/KafkaSupervisor.java | 140 +-
.../kafka/supervisor/KafkaSupervisorIOConfig.java | 108 +-
.../kafka/supervisor/KafkaSupervisorSpec.java | 4 +-
.../indexing/kafka/HeaderFilterHandlerTest.java | 79 +
.../KafkaHeaderBasedFilterConfigEvaluatorTest.java | 344 +
...afkaHeaderBasedFilterConfigIntegrationTest.java | 273 +
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 162 +-
.../kafka/KafkaRecordSupplierHeaderFilterTest.java | 488 +
.../indexing/kafka/KafkaRecordSupplierTest.java | 47 +
.../druid/indexing/kafka/KafkaSamplerSpecTest.java | 25 +
.../simulate/EmbeddedKafkaSupervisorTest.java | 205 +-
.../KafkaHeaderBasedFilterConfigTest.java | 237 +
.../supervisor/KafkaSupervisorIOConfigTest.java | 173 +-
.../kafka/supervisor/KafkaSupervisorSpecTest.java | 30 +
.../kafka/supervisor/KafkaSupervisorTest.java | 320 +-
extensions-core/kinesis-indexing-service/pom.xml | 2 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 6 +-
extensions-core/kubernetes-extensions/pom.xml | 6 +
.../druid/k8s/config/ApiNodeLabelReader.java | 126 +
.../druid/k8s/config/CachingNodeLabelReader.java | 62 +
.../config/K8sNodeLabelDynamicConfigProvider.java | 159 +
.../apache/druid/k8s/config/NodeLabelReader.java | 30 +-
.../druid/k8s/discovery/ChannelResetException.java | 25 +-
.../druid/k8s/discovery/DefaultK8sApiClient.java | 19 +-
.../druid/k8s/discovery/K8sDiscoveryModule.java | 12 +-
.../discovery/K8sDruidNodeDiscoveryProvider.java | 71 +-
.../apache/druid/k8s/discovery/WatchResult.java | 8 +-
.../K8sNodeLabelDynamicConfigProviderTest.java | 438 +
.../DefaultK8sApiClientWatchPodsTest.java | 164 +
.../K8sDruidNodeDiscoveryProviderTest.java | 135 +-
.../kubernetes-overlord-extensions/pom.xml | 54 +-
.../k8s/overlord/KubernetesPeonLifecycle.java | 20 +-
.../overlord/KubernetesPeonLifecycleFactory.java | 11 +-
.../druid/k8s/overlord/KubernetesTaskRunner.java | 4 +-
.../k8s/overlord/KubernetesTaskRunnerConfig.java | 17 +-
.../KubernetesTaskRunnerEffectiveConfig.java | 8 +
.../k8s/overlord/KubernetesTaskRunnerFactory.java | 3 +-
.../overlord/KubernetesTaskRunnerStaticConfig.java | 17 +-
.../MultipleKubernetesTaskRunnerConfig.java | 6 +-
.../MultipleKubernetesTaskRunnerFactory.java | 6 +-
.../k8s/overlord/KubernetesPeonLifecycleTest.java | 74 +
.../KubernetesTaskRunnerStaticConfigTest.java | 14 +
.../k8s/overlord/KubernetesTaskRunnerTest.java | 54 +-
.../MultipleKubernetesTaskRunnerConfigTest.java | 12 +
.../overlord/MultipleKubernetesTaskRunnerTest.java | 4 +-
extensions-core/protobuf-extensions/pom.xml | 2 +-
.../data/input/protobuf/ProtobufConverter.java | 9 +-
.../data/input/protobuf/ProtobufConverterTest.java | 59 +
.../src/test/resources/proto3_test_event.proto | 37 +
extensions-core/s3-extensions/pom.xml | 10 +-
.../druid/storage/s3/S3DataSegmentKiller.java | 5 +-
.../druid/storage/s3/S3DataSegmentPusher.java | 58 +-
.../storage/s3/S3DataSegmentPusherConfig.java | 8 -
.../java/org/apache/druid/storage/s3/S3Utils.java | 16 +-
.../apache/druid/storage/s3/RustFSContainer.java | 77 +
.../storage/s3/S3DataSegmentPusherConfigTest.java | 6 +-
.../druid/storage/s3/S3DataSegmentPusherTest.java | 223 +-
...rSideEncryptingAmazonS3MultipartUploadTest.java | 13 +-
.../storage/s3/output/S3StorageConnectorTest.java | 55 +-
hooks/install-hooks.sh | 21 +-
hooks/pre-commit | 3 +-
hooks/pre-push | 3 +-
hooks/uninstall-hooks.sh | 15 +-
indexing-service/pom.xml | 2 +-
.../common/stats/DropwizardRowIngestionMeters.java | 20 +-
.../common/stats/TaskRealtimeMetricsMonitor.java | 8 +
.../common/task/AbstractBatchIndexTask.java | 2 +-
.../druid/indexing/common/task/CompactionTask.java | 22 +-
.../parallel/ParallelIndexSupervisorTask.java | 4 +-
.../compact/OverlordCompactionScheduler.java | 13 +-
.../overlord/BaseRestorableTaskRunner.java | 10 +-
.../druid/indexing/overlord/ForkingTaskRunner.java | 24 +-
.../overlord/SingleTaskBackgroundRunner.java | 16 +-
.../indexing/overlord/TaskRunnerListener.java | 5 +-
.../druid/indexing/overlord/TaskRunnerUtils.java | 23 +-
.../indexing/overlord/ThreadingTaskRunner.java | 24 +-
.../overlord/hrtr/HttpRemoteTaskRunner.java | 29 +-
.../scheduledbatch/ScheduledBatchTaskManager.java | 7 +-
.../seekablestream/RecordSupplierInputSource.java | 10 +-
.../SeekableStreamIndexTaskRunner.java | 6 +-
.../indexing/seekablestream/StreamChunkReader.java | 27 +
.../common/OrderedPartitionableRecord.java | 32 +-
.../supervisor/SeekableStreamSupervisor.java | 45 +-
.../druid/indexing/worker/WorkerTaskManager.java | 6 +-
.../common/TaskRealtimeMetricsMonitorTest.java | 39 +
.../common/task/CompactionTaskRunBase.java | 273 +-
.../common/task/CompactionTaskRunTestCases.java | 211 +
.../indexing/common/task/CompactionTaskTest.java | 5 +-
.../druid/indexing/common/task/IndexTaskTest.java | 18 +-
.../indexing/common/task/IngestionTestBase.java | 5 +-
.../common/task/NativeCompactionTaskRunTest.java | 90 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 7 +-
...ashPartitionMultiPhaseParallelIndexingTest.java | 5 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 2 +-
.../indexing/overlord/ForkingTaskRunnerTest.java | 66 +
.../overlord/SingleTaskBackgroundRunnerTest.java | 22 +-
.../indexing/overlord/TaskQueueScaleTest.java | 26 +-
.../druid/indexing/overlord/TestTaskRunner.java | 14 +-
.../indexing/overlord/ThreadingTaskRunnerTest.java | 50 +
.../overlord/hrtr/HttpRemoteTaskRunnerTest.java | 71 +-
.../SeekableStreamIndexTaskTestBase.java | 5 +-
.../seekablestream/StreamChunkReaderTest.java | 38 +-
.../SeekableStreamSupervisorStateTest.java | 144 +-
.../indexing/worker/WorkerTaskManagerTest.java | 8 +
.../shuffle/ShuffleDataSegmentPusherTest.java | 5 +-
jdbc-driver/pom.xml | 264 +
.../java/org/apache/druid/jdbc/BooleanUtils.java | 26 +-
.../org/apache/druid/jdbc/ClientProperties.java | 214 +
.../java/org/apache/druid/jdbc/DruidArray.java | 111 +
.../org/apache/druid/jdbc/DruidConnection.java | 645 +
.../org/apache/druid/jdbc/DruidConnectionUrl.java | 267 +
.../apache/druid/jdbc/DruidDatabaseMetaData.java | 1650 +
.../org/apache/druid/jdbc/DruidJdbcDriver.java | 204 +
.../org/apache/druid/jdbc/DruidJdbcException.java | 55 +
.../DruidJdbcFeatureNotSupportedException.java | 36 +
.../apache/druid/jdbc/DruidPreparedStatement.java | 812 +
.../java/org/apache/druid/jdbc/DruidResultSet.java | 1747 +
.../apache/druid/jdbc/DruidResultSetMetaData.java | 265 +
.../java/org/apache/druid/jdbc/DruidSQLState.java | 29 +-
.../java/org/apache/druid/jdbc/DruidStatement.java | 613 +
.../apache/druid/jdbc/DruidTimestampParser.java | 170 +
.../java/org/apache/druid/jdbc/StringUtils.java | 52 +
.../org/apache/druid/jdbc/SuppressForbidden.java | 30 +-
.../org/apache/druid/jdbc/http/ColumnMetadata.java | 137 +
.../apache/druid/jdbc/http/DruidHttpClient.java | 69 +
.../druid/jdbc/http/DruidHttpClientImpl.java | 474 +
.../druid/jdbc/http/EmptyQueryResultsIterator.java | 41 +-
.../apache/druid/jdbc/http/HttpClientUtils.java | 92 +
.../druid/jdbc/http/QueryResultsIterator.java | 30 +-
.../druid/jdbc/http/QueryResultsIteratorImpl.java | 454 +
.../org/apache/druid/jdbc/http/SqlParameter.java | 29 +-
.../org/apache/druid/jdbc/http/SqlRequest.java | 69 +
.../org/apache/druid/jdbc/sql/SetStatement.java | 25 +-
.../java/org/apache/druid/jdbc/sql/SqlScanner.java | 264 +
.../resources/META-INF/services/java.sql.Driver | 4 +-
.../apache/druid/jdbc/ClientPropertiesTest.java | 61 +
.../org/apache/druid/jdbc/DruidConnectionTest.java | 239 +
.../apache/druid/jdbc/DruidConnectionUrlTest.java | 269 +
.../druid/jdbc/DruidDatabaseMetaDataTest.java | 514 +
.../org/apache/druid/jdbc/DruidJdbcDriverTest.java | 97 +
.../druid/jdbc/DruidParameterBindingTest.java | 363 +
.../druid/jdbc/DruidPreparedStatementTest.java | 263 +
.../druid/jdbc/DruidResultSetMetaDataTest.java | 110 +
.../org/apache/druid/jdbc/DruidResultSetTest.java | 719 +
.../DruidSetStatementPreparedStatementTest.java | 147 +
.../apache/druid/jdbc/DruidSetStatementTest.java | 267 +
.../org/apache/druid/jdbc/DruidStatementTest.java | 447 +
.../druid/jdbc/DruidTimestampParserTest.java | 82 +
.../apache/druid/jdbc/DruidTypeConversionTest.java | 196 +
.../java/org/apache/druid/jdbc/SqlScannerTest.java | 158 +
.../org/apache/druid/jdbc/StringUtilsTest.java | 53 +
.../jdbc/embedded/EmbeddedJdbcDriverTest.java | 741 +
.../embedded/EmbeddedSecureJdbcDriverTest.java | 234 +
.../apache/druid/jdbc/http/ColumnMetadataTest.java | 135 +
.../druid/jdbc/http/DruidHttpClientTest.java | 286 +
.../druid/jdbc/http/QueryResultsIteratorTest.java | 498 +
.../apache/druid/jdbc/http/SqlParameterTest.java | 30 +-
.../org/apache/druid/jdbc/http/SqlRequestTest.java | 82 +
.../druid/jdbc/http/TestQueryResultsIterator.java | 74 +
licenses.yaml | 1612 +-
...{@babel-code-frame.MIT => @babel-generator.MIT} | 0
...el-code-frame.MIT => @babel-helper-globals.MIT} | 0
.../bin/{safe-buffer.MIT => @babel-parser.MIT} | 4 +-
.../{@babel-code-frame.MIT => @babel-template.MIT} | 0
.../{@babel-code-frame.MIT => @babel-traverse.MIT} | 0
...-to-regexp.MIT => @codemirror-autocomplete.MIT} | 4 +-
...path-to-regexp.MIT => @codemirror-commands.MIT} | 4 +-
...path-to-regexp.MIT => @codemirror-language.MIT} | 4 +-
.../{path-to-regexp.MIT => @codemirror-search.MIT} | 4 +-
.../{path-to-regexp.MIT => @codemirror-state.MIT} | 4 +-
.../{path-to-regexp.MIT => @codemirror-view.MIT} | 4 +-
...motion-stylis.MIT => @emotion-babel-plugin.MIT} | 0
.../{babel-plugin-emotion.MIT => @emotion-css.MIT} | 0
.../bin/{create-emotion.MIT => @emotion-react.MIT} | 0
...motion-use-insertion-effect-with-fallbacks.MIT} | 0
licenses/bin/@floating-ui-core.MIT | 20 +
licenses/bin/@floating-ui-dom.MIT | 20 +
licenses/bin/@floating-ui-react-dom.MIT | 20 +
licenses/bin/@floating-ui-react.MIT | 20 +
licenses/bin/@floating-ui-utils.MIT | 20 +
licenses/bin/@fontsource-open-sans.OFL | 2 +-
...safe-buffer.MIT => @jridgewell-gen-mapping.MIT} | 8 +-
...safe-buffer.MIT => @jridgewell-resolve-uri.MIT} | 8 +-
...-buffer.MIT => @jridgewell-sourcemap-codec.MIT} | 8 +-
...fe-buffer.MIT => @jridgewell-trace-mapping.MIT} | 8 +-
...bel-plugin-syntax-jsx.MIT => @lezer-common.MIT} | 10 +-
.../{path-to-regexp.MIT => @lezer-highlight.MIT} | 4 +-
licenses/bin/{path-to-regexp.MIT => @lezer-lr.MIT} | 4 +-
...o-regexp.MIT => @marijn-find-cluster-break.MIT} | 4 +-
...t-diff-viewer.MIT => @tanstack-react-store.MIT} | 2 +-
.../{react-table.MIT => @tanstack-react-table.MIT} | 0
licenses/bin/{history.MIT => @tanstack-store.MIT} | 2 +-
.../{react-table.MIT => @tanstack-table-core.MIT} | 0
licenses/bin/@types-parse-json.MIT | 42 +-
licenses/bin/@types-prop-types.MIT | 21 -
licenses/bin/@types-react-table.MIT | 21 -
licenses/bin/ace-builds.BSD3 | 24 -
licenses/bin/agent-base.MIT | 22 +
licenses/bin/babel-plugin-macros.MIT | 2 +-
.../{es-errors.MIT => call-bind-apply-helpers.MIT} | 0
licenses/bin/{safe-buffer.MIT => crelt.MIT} | 4 +-
licenses/bin/d3-array.BSD3 | 27 -
licenses/bin/d3-array.ISC | 2 +-
licenses/bin/d3-format.BSD3 | 27 -
licenses/bin/{d3-array.ISC => d3-format.ISC} | 2 +-
licenses/bin/{d3-array.ISC => d3-time.ISC} | 0
licenses/bin/debug.MIT | 19 +-
licenses/bin/diff.BSD3 | 44 +-
.../{react-diff-viewer.MIT => dunder-proto.MIT} | 2 +-
.../bin/{es-errors.MIT => es-define-property.MIT} | 0
.../bin/{es-errors.MIT => es-object-atoms.MIT} | 0
licenses/bin/escape-string-regexp.MIT | 22 +-
.../bin/{react-diff-viewer.MIT => get-proto.MIT} | 2 +-
licenses/bin/{react-diff-viewer.MIT => gopd.MIT} | 2 +-
licenses/bin/https-proxy-agent.MIT | 22 +
licenses/bin/isarray.MIT | 21 -
.../jackson3-FastDoubleParser-ThirdParty.LICENSE | 91 +
licenses/bin/jackson3-FastDoubleParser.LICENSE | 61 +
...{safe-buffer.MIT => jackson3-Schubfach.LICENSE} | 4 +-
licenses/bin/{lodash.isequal.MIT => jsesc.MIT} | 29 +-
licenses/bin/lodash.get.MIT | 47 -
.../{react-diff-viewer.MIT => math-intrinsics.MIT} | 2 +-
licenses/bin/ms.MIT | 2 +-
licenses/bin/react-ace.MIT | 22 -
licenses/bin/react-day-picker.MIT | 2 +-
...act-uid.MIT => react-diff-viewer-continued.MIT} | 2 +-
licenses/bin/react-dom.MIT | 2 +-
licenses/bin/react-router-dom.MIT | 22 -
licenses/bin/react-router.MIT | 22 -
licenses/bin/react.MIT | 2 +-
licenses/bin/regenerator-runtime.MIT | 21 -
licenses/bin/resolve-pathname.MIT | 21 -
licenses/bin/scheduler.MIT | 2 +-
licenses/bin/{safe-buffer.MIT => style-mod.MIT} | 4 +-
licenses/bin/{history.MIT => stylis.MIT} | 2 +-
licenses/bin/{cosmiconfig.MIT => tabbable.MIT} | 0
licenses/bin/tiny-invariant.MIT | 21 -
licenses/bin/tiny-warning.MIT | 21 -
licenses/bin/toggle-selection.MIT | 21 -
licenses/bin/use-sync-external-store.MIT | 2 +-
licenses/bin/uuid.MIT | 20 +-
licenses/bin/value-equal.MIT | 21 -
licenses/bin/{safe-buffer.MIT => w3c-keyname.MIT} | 4 +-
.../msq/dart/controller/DartControllerContext.java | 30 +-
.../DartControllerContextFactoryImpl.java | 13 +-
.../msq/dart/controller/DartMessageRelays.java | 10 +-
.../msq/dart/controller/sql/DartSqlEngine.java | 1 +
.../druid/msq/dart/guice/DartWorkerModule.java | 17 +
.../druid/msq/dart/worker/DartWorkerService.java | 31 +-
.../apache/druid/msq/guice/MSQIndexingModule.java | 5 +
.../indexing/cleaner/DurableStorageCleaner.java | 22 +-
.../druid/msq/input/AcquireSegmentHandles.java | 174 +
.../druid/msq/input/AdaptedLoadableSegment.java | 132 +-
.../apache/druid/msq/input/LoadableSegment.java | 17 +-
.../druid/msq/input/LoadableSegmentUtils.java | 48 -
.../druid/msq/input/RegularLoadableSegment.java | 146 +-
.../input/external/ExternalInputSliceReader.java | 9 +-
.../druid/msq/querykit/ReadableInputQueue.java | 218 +-
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 1 +
.../msq/counters/CountersSnapshotTreeTest.java | 3 +-
.../dart/controller/DartControllerContextTest.java | 106 +-
.../msq/dart/worker/DartWorkerServiceTest.java | 65 +
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 190 +-
.../org/apache/druid/msq/exec/MSQExportTest.java | 7 +-
.../msq/indexing/DurableStorageCleanerTest.java | 40 +
.../msq/input/AdaptedLoadableSegmentTest.java | 272 +
.../msq/input/RegularLoadableSegmentTest.java | 247 +-
.../druid/msq/querykit/ReadableInputQueueTest.java | 423 +
.../querykit/scan/ScanQueryFrameProcessorTest.java | 6 +-
.../ClusterByStatisticsCollectorImplTest.java | 8 +
.../druid/msq/test/CalciteMSQTestsHelper.java | 6 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 82 +-
.../test/TestDartControllerContextFactoryImpl.java | 74 +-
mvnw | 295 +
mvnw.cmd | 189 +
pom.xml | 125 +-
processing/pom.xml | 22 +
.../druid/common/asyncresource/AsyncResources.java | 53 +-
.../common/asyncresource/CollectAsyncResource.java | 25 +-
.../input/impl/AdaptedBaseTableProjectionSpec.java | 6 +
.../data/input/impl/AggregateProjectionSpec.java | 8 +-
.../data/input/impl/BaseTableProjectionSpec.java | 145 +-
...lusteredValueGroupsBaseTableProjectionSpec.java | 9 +-
.../data/input/impl/RollupTableProjectionSpec.java | 354 +
.../druid/data/input/impl/TableProjectionSpec.java | 290 +
.../frame/processor/FrameProcessorExecutor.java | 61 +-
.../org/apache/druid/hll/HyperLogLogCollector.java | 51 +-
.../jackson/DruidDefaultSerializersModule.java | 5 +-
.../druid/jackson/StrictIntegerDeserializer.java | 59 +
.../apache/druid/java/util/common/FileUtils.java | 2 +-
.../apache/druid/java/util/common/StringUtils.java | 24 +-
.../util/common/granularity/Granularities.java | 31 +-
.../util/common/io/smoosh/SmooshedFileMapper.java | 95 +-
.../druid/java/util/common/logger/Logger.java | 2 +-
.../util/emitter/service/ServiceMetricEvent.java | 11 +
.../java/util/http/client/HttpClientConfig.java | 17 +
.../java/util/http/client/HttpClientInit.java | 8 +-
.../java/util/http/client/NettyHttpClient.java | 30 +-
.../java/util/http/client/pool/ResourcePool.java | 536 +-
.../util/http/client/pool/ResourcePoolConfig.java | 16 +
.../http/client/response/HttpResponseHandler.java | 4 +
.../druid/math/expr/ExpressionProcessing.java | 25 +-
.../math/expr/ExpressionProcessingConfig.java | 13 +-
.../java/org/apache/druid/math/expr/Function.java | 10 +-
.../SimpleVectorMathBivariateProcessorFactory.java | 8 +-
...VectorMathUnivariateDoubleProcessorFactory.java | 8 +-
...SimpleVectorMathUnivariateProcessorFactory.java | 4 +-
.../math/expr/vector/VectorMathProcessors.java | 30 +-
.../expr/vector/simd/SimdDoubleAcosProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleAsinProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleAtanProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleCbrtProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleCosProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleCoshProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleExpProcessor.java | 62 +
.../expr/vector/simd/SimdDoubleExpm1Processor.java | 60 +
.../expr/vector/simd/SimdDoubleLog10Processor.java | 60 +
.../expr/vector/simd/SimdDoubleLog1pProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleLogProcessor.java | 62 +
.../expr/vector/simd/SimdDoubleSinProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleSinhProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleTanProcessor.java | 60 +
.../expr/vector/simd/SimdDoubleTanhProcessor.java | 60 +
.../vector/simd/SimdLongToDoubleAcosProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleAsinProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleAtanProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleCbrtProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleCosProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleCoshProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleExpProcessor.java | 67 +
.../simd/SimdLongToDoubleExpm1Processor.java | 66 +
.../simd/SimdLongToDoubleLog10Processor.java | 66 +
.../simd/SimdLongToDoubleLog1pProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleLogProcessor.java | 67 +
.../vector/simd/SimdLongToDoubleSinProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleSinhProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleTanProcessor.java | 66 +
.../vector/simd/SimdLongToDoubleTanhProcessor.java | 66 +
.../math/expr/vector/simd/SimdProcessors.java | 30 +
.../expr/vector/simd/SimdSupportedBinaryOp.java | 42 +-
.../expr/vector/simd/SimdSupportedUnaryOp.java | 107 +-
.../druid/metadata/DynamicConfigProvider.java | 7 +
.../EnvironmentVariableDynamicConfigProvider.java | 12 +-
.../org/apache/druid/query/CloneQueryMode.java | 2 +
.../druid/query/ForwardingQueryProcessingPool.java | 49 +-
.../main/java/org/apache/druid/query/Query.java | 21 +-
.../java/org/apache/druid/query/QueryContext.java | 237 +-
.../apache/druid/query/QueryContextBuilder.java | 86 +
.../java/org/apache/druid/query/QueryContexts.java | 32 +-
.../druid/query/context/QueryContextParameter.java | 413 +
.../context/QueryContextParameterValidator.java | 57 +
.../query/context/QueryContextParameters.java | 197 +
.../context/constraint/ParameterConstraint.java | 29 +-
.../druid/query/context/constraint/Range.java | 106 +
.../query/context/docs/ParameterDocumentation.java | 203 +
.../docs/ParameterDocumentationGenerator.java | 249 +
.../rowsandcols/LazilyDecoratedRowsAndColumns.java | 62 +-
.../org/apache/druid/query/scan/ScanQuery.java | 9 +-
.../apache/druid/query/scan/ScanQueryConfig.java | 1 -
.../apache/druid/segment/ColumnHolderTable.java | 275 +
.../apache/druid/segment/ConcatenatingCursor.java | 13 +
.../java/org/apache/druid/segment/IndexIO.java | 260 +-
.../druid/segment/PartialQueryableIndex.java | 160 +-
.../org/apache/druid/segment/SegmentReference.java | 30 +-
.../apache/druid/segment/SimpleQueryableIndex.java | 102 +-
.../org/apache/druid/segment/VirtualColumn.java | 20 +
.../segment/column/CapabilitiesBasedFormat.java | 19 +
.../apache/druid/segment/column/ColumnBuilder.java | 13 +-
.../druid/segment/column/ColumnDescriptor.java | 26 +-
.../apache/druid/segment/column/ColumnFormat.java | 3 +
.../druid/segment/column/ConstantColumns.java | 9 +-
.../column/ImmutableColumnCapabilities.java | 188 +
.../StringDictionaryEncodedColumnFormat.java | 24 +
.../segment/file/PartialSegmentFileMapperV10.java | 91 +-
.../druid/segment/file/SegmentFileMapperV10.java | 13 +-
.../druid/segment/file/SegmentFileMetadata.java | 61 +-
.../segment/file/SegmentFileMetadataReader.java | 13 +-
.../druid/segment/file/SegmentInternalFileMap.java | 218 +
.../segment/file/SegmentInternalFileMetadata.java | 21 +
.../segment/generator/ColumnValueGenerator.java | 15 +-
.../incremental/NoopRowIngestionMeters.java | 12 +
.../segment/incremental/RowIngestionMeters.java | 22 +
.../incremental/RowIngestionMetersTotals.java | 57 +-
.../incremental/SimpleRowIngestionMeters.java | 17 +-
.../index/semantic/ArrayElementIndexes.java | 2 +-
.../druid/segment/index/semantic/ValueIndexes.java | 2 +-
.../segment/index/semantic/ValueSetIndexes.java | 2 +-
.../segment/join/HashJoinSegmentCursorFactory.java | 2 +-
.../druid/segment/join/filter/JoinableClauses.java | 39 +-
.../segment/loading/AcquireSegmentAction.java | 148 +-
.../segment/loading/AcquireSegmentResult.java | 57 +-
.../segment/loading/DeepStorageSegmentConfig.java | 73 +
.../segment/nested/NestedCommonFormatColumn.java | 23 +
.../segment/nested/NestedDataComplexTypeSerde.java | 12 +
.../druid/segment/serde/ColumnPartSerde.java | 7 +
.../segment/serde/ComplexColumnPartSerde.java | 34 +-
.../serde/DictionaryEncodedColumnPartSerde.java | 22 +
.../serde/DoubleNumericColumnPartSerde.java | 20 +
.../serde/DoubleNumericColumnPartSerdeV2.java | 21 +
.../segment/serde/FloatNumericColumnPartSerde.java | 20 +
.../serde/FloatNumericColumnPartSerdeV2.java | 21 +
.../segment/serde/LongNumericColumnPartSerde.java | 20 +
.../serde/LongNumericColumnPartSerdeV2.java | 21 +
.../druid/segment/serde/NullColumnPartSerde.java | 5 +-
.../segment/vector/ConcatenatingVectorCursor.java | 15 +
.../segment/virtual/ExpressionVirtualColumn.java | 12 +
.../segment/virtual/NestedFieldVirtualColumn.java | 20 +
.../segment/virtual/NestedMergeVirtualColumn.java | 6 +
.../segment/virtual/NestedObjectVirtualColumn.java | 6 +
.../SpecializedExpressionVirtualColumn.java | 13 +
.../resources/loggingEmitterAllowedMetrics.json | 1 +
.../ReferenceCountingResourceHolderTest.java | 14 +-
.../common/asyncresource/AsyncResourcesTest.java | 72 +-
.../asyncresource/CollectAsyncResourceTest.java | 57 +-
.../input/impl/AggregateProjectionSpecTest.java | 21 +
...eredValueGroupsBaseTableProjectionSpecTest.java | 105 +
.../input/impl/RollupTableProjectionSpecTest.java | 301 +
.../data/input/impl/TableProjectionSpecTest.java | 428 +
.../processor/FrameProcessorExecutorTest.java | 47 +-
.../apache/druid/hll/HyperLogLogCollectorTest.java | 101 +
.../druid/indexer/report/TaskReportSerdeTest.java | 9 +-
.../jackson/StrictIntegerDeserializerTest.java | 89 +
.../druid/java/util/common/FileUtilsTest.java | 8 +
.../druid/java/util/common/StringUtilsTest.java | 6 +-
.../common/concurrent/ScheduledExecutorsTest.java | 11 +-
.../common/io/smoosh/SmooshedFileMapperTest.java | 33 +
.../common/parsers/JSONFlattenerMakerTest.java | 4 +-
.../java/util/emitter/core/LoggingEmitterTest.java | 15 +
.../java/util/http/client/FriendlyServersTest.java | 201 +
.../java/util/http/client/NettyHttpClientTest.java | 250 +
.../util/http/client/pool/ResourcePoolTest.java | 901 +-
.../InputStreamFullResponseHandlerTest.java | 5 +-
.../response/ObjectOrErrorResponseHandlerTest.java | 9 +-
.../metrics/AllocationMetricCollectorTest.java | 53 +-
.../math/expr/VectorExprResultConsistencyTest.java | 62 +-
.../math/expr/vector/VectorTestAssertions.java | 76 +
.../expr/vector/simd/SimdVoMathlibParityTest.java | 426 +
...vironmentVariableDynamicConfigProviderTest.java | 18 +
.../CloneQueryModeTest.java} | 29 +-
.../query/ForwardingQueryProcessingPoolTest.java | 233 +
.../druid/query/QueryContextBuilderTest.java | 84 +
.../org/apache/druid/query/QueryContextTest.java | 118 +-
.../first/StringFirstBufferAggregatorTest.java | 8 +-
.../last/StringLastBufferAggregatorTest.java | 8 +-
.../query/context/QueryContextParameterTest.java | 320 +
.../QueryContextParameterValidatorTest.java | 53 +
.../docs/ParameterDocumentationGeneratorTest.java | 143 +
.../query/scan/ScanQueryResultOrderingTest.java | 8 +-
.../org/apache/druid/query/scan/ScanQueryTest.java | 26 +
.../druid/segment/ColumnHolderTableTest.java | 198 +
.../druid/segment/ConcatenatingCursorTest.java | 28 +
.../druid/segment/PartialQueryableIndexTest.java | 18 +
.../segment/SimpleQueryableIndexClusteredTest.java | 18 +-
.../column/CapabilitiesBasedFormatTest.java | 14 +
.../druid/segment/column/ColumnBuilderTest.java | 30 +
.../druid/segment/column/ColumnDescriptorTest.java | 27 +
.../column/ImmutableColumnCapabilitiesTest.java | 75 +
.../StringDictionaryEncodedColumnFormatTest.java | 7 +
.../segment/data/BenchmarkIndexibleWrites.java | 11 +-
.../file/PartialSegmentFileMapperV10Test.java | 67 +
.../segment/file/SegmentInternalFileMapTest.java | 113 +
.../filter/PredicateValueMatcherFactoryTest.java | 16 +-
.../druid/segment/generator/DataGeneratorTest.java | 21 +
.../druid/segment/incremental/RowMeters.java | 9 +-
.../incremental/SimpleRowIngestionMetersTest.java | 5 +-
.../join/HashJoinSegmentCursorFactoryTest.java | 96 +
.../join/table/IndexedTableJoinMatcherTest.java | 10 +-
.../segment/loading/AcquireSegmentActionTest.java | 258 +
.../loading/DeepStorageSegmentConfigTest.java | 105 +
.../NestedCommonFormatColumnFormatSpecTest.java | 14 +
.../segment/serde/ColumnPartSerdeEqualsTest.java | 93 +
.../vector/ConcatenatingVectorCursorTest.java | 29 +
.../virtual/ExpressionVirtualColumnTest.java | 12 +
.../virtual/NestedFieldVirtualColumnTest.java | 14 +
.../virtual/NestedMergeVirtualColumnTest.java | 17 +
.../virtual/NestedObjectVirtualColumnTest.java | 16 +
.../org/apache/druid/utils/CloseableUtilsTest.java | 14 +-
.../resources/loggingEmitterAllowedMetrics.json | 1 +
quidem-ut/pom.xml | 10 +-
server/pom.xml | 16 +-
.../druid/catalog/model/BaseTableColumns.java | 166 +
.../ClusteredValueGroupsBaseTableMetadata.java | 137 +-
.../org/apache/druid/catalog/model/ColumnSpec.java | 9 +-
.../org/apache/druid/catalog/model/Columns.java | 16 +-
.../catalog/model/DatasourceBaseTableMetadata.java | 2 +
.../model/RollupTableBaseTableMetadata.java | 232 +
.../catalog/model/TableBaseTableMetadata.java | 164 +
.../druid/catalog/model/table/DatasourceDefn.java | 153 +
.../org/apache/druid/client/DirectDruidClient.java | 313 +-
.../apache/druid/client/JsonParserIterator.java | 74 +-
.../apache/druid/discovery/DataServerClient.java | 3 +-
.../druid/guice/LocalDataStorageDruidModule.java | 6 +
.../druid/guice/http/DruidHttpClientConfig.java | 11 +-
.../apache/druid/guice/http/HttpClientModule.java | 22 +-
.../java/org/apache/druid/rpc/ServiceLocation.java | 2 +-
.../apache/druid/segment/indexing/DataSchema.java | 10 +-
.../segment/loading/LocalDataSegmentPusher.java | 11 +-
.../loading/LocalDataSegmentPusherConfig.java | 8 -
.../loading/PartialSegmentMetadataCacheEntry.java | 29 +-
.../druid/segment/loading/SegmentCacheEntry.java | 3 +-
.../druid/segment/loading/SegmentCacheManager.java | 17 +-
.../segment/loading/SegmentLocalCacheManager.java | 506 +-
.../segment/loading/StorageLoadingThreadPool.java | 32 +-
.../StorageLocationVirtualStorageManager.java | 22 +-
.../metadata/AbstractSegmentMetadataCache.java | 21 +-
.../java/org/apache/druid/server/DruidNode.java | 71 +-
.../org/apache/druid/server/SegmentManager.java | 21 +-
.../org/apache/druid/server/ServerManager.java | 98 +-
.../druid/server/coordinator/DruidCoordinator.java | 11 +-
.../server/emitter/SwitchingEmitterModule.java | 2 +-
.../druid/server/http/BaseDynamicConfigSyncer.java | 7 +-
.../druid/server/initialization/ServerConfig.java | 41 +-
.../jetty/CliIndexerServerModule.java | 3 +-
.../initialization/jetty/JettyServerModule.java | 2 +-
.../server/metrics/HttpClientPoolMonitor.java | 91 +
.../server/metrics/HttpClientPoolRegistry.java | 56 +
.../model/RollupTableBaseTableMetadataTest.java | 267 +
.../catalog/model/TableBaseTableMetadataTest.java | 190 +
.../catalog/model/table/DatasourceTableTest.java | 144 +-
.../apache/druid/client/DirectDruidClientTest.java | 585 +-
.../druid/client/JsonParserIteratorTest.java | 56 +
.../guice/LocalDataStorageDruidModuleTest.java | 55 +
.../guice/http/DruidHttpClientConfigTest.java | 90 +
.../guice/http/HttpClientPoolRegistrationTest.java | 69 +
.../druid/initialization/ServerConfigTest.java | 3 +-
.../org/apache/druid/rpc/MockServiceClient.java | 8 +-
.../org/apache/druid/rpc/ServiceLocationTest.java | 18 +
.../druid/segment/indexing/DataSchemaTest.java | 84 +
.../loading/LocalDataSegmentPusherTest.java | 6 +-
...gmentLocalCacheManagerAcquireLifecycleTest.java | 504 +
.../SegmentLocalCacheManagerConcurrencyTest.java | 21 +-
...SegmentLocalCacheManagerPartialAcquireTest.java | 357 +-
.../loading/SegmentLocalCacheManagerTest.java | 81 +-
.../StorageLocationVirtualStorageManagerTest.java | 91 +
.../org/apache/druid/server/DruidNodeTest.java | 125 +
.../apache/druid/server/SegmentManagerTest.java | 4 +-
.../server/coordinator/DruidCoordinatorTest.java | 9 +-
.../http/CoordinatorDynamicConfigSyncerTest.java | 42 +-
.../server/metrics/HttpClientPoolMonitorTest.java | 202 +
.../utils/ImmutableDruidDataSourceTestUtils.java | 11 +-
.../ImmutableDruidDataSourceTestUtilsTest.java | 26 +-
.../druid/test/utils/TestSegmentCacheManager.java | 6 +-
services/pom.xml | 48 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 2 +
.../java/org/apache/druid/cli/ExportMetadata.java | 12 +-
.../org/apache/druid/cli/PullDependencies.java | 61 +-
.../org/apache/druid/guice/PeonServerModule.java | 106 +
.../org/apache/druid/cli/PullDependenciesTest.java | 34 +-
.../apache/druid/guice/PeonServerModuleTest.java | 83 +
.../router/TieredBrokerHostSelectorTest.java | 7 +-
.../testing/embedded/EmbeddedClusterApis.java | 100 +-
sql/src/main/codegen/config.fmpp | 28 +
sql/src/main/codegen/includes/ddl.ftl | 270 +
sql/src/main/codegen/templates/Parser.jj | 22 +-
.../org/apache/druid/sql/AbstractStatement.java | 2 +-
.../java/org/apache/druid/sql/DirectStatement.java | 97 +-
.../org/apache/druid/sql/SqlPlanningTimeout.java | 117 +
.../java/org/apache/druid/sql/SqlQueryPlus.java | 109 +-
.../druid/sql/avatica/DruidJdbcResultSet.java | 7 +-
.../druid/sql/avatica/DruidJdbcStatement.java | 7 +-
.../builtin/EarliestLatestAnySqlAggregator.java | 14 +-
.../druid/sql/calcite/external/Externals.java | 66 +-
.../sql/calcite/parser/DruidSqlAlterTable.java | 466 +
.../calcite/parser/DruidSqlColumnDeclaration.java | 132 +
.../sql/calcite/parser/DruidSqlCreateTable.java | 219 +
.../druid/sql/calcite/parser/DruidSqlParser.java | 13 +-
.../calcite/parser/DruidSqlPropertyAssignment.java | 103 +
.../sql/calcite/parser/SqlProjectionSpec.java | 153 +
.../sql/calcite/planner/CatalogColumnTypes.java | 145 +
.../sql/calcite/planner/CatalogDdlHandler.java | 696 +
.../sql/calcite/planner/CatalogTableWriter.java | 187 +
.../sql/calcite/planner/DruidOperatorTable.java | 4 +
.../druid/sql/calcite/planner/DruidPlanner.java | 52 +-
.../druid/sql/calcite/planner/DruidTypeSystem.java | 36 +-
.../druid/sql/calcite/planner/PlannerConfig.java | 75 +-
.../druid/sql/calcite/planner/PlannerContext.java | 46 +
.../druid/sql/calcite/planner/PlannerFactory.java | 115 +-
.../druid/sql/calcite/planner/PlannerToolbox.java | 45 +
.../calcite/planner/ProjectionSpecTranslator.java | 867 +
.../ProjectionSqlEngine.java} | 85 +-
.../sql/calcite/planner/SqlStatementHandler.java | 5 +
.../druid/sql/calcite/run/EngineFeature.java | 7 +
.../druid/sql/calcite/run/NativeSqlEngine.java | 1 +
.../calcite/schema/BrokerSegmentMetadataCache.java | 37 +-
.../druid/sql/calcite/view/ViewSqlEngine.java | 1 +
.../java/org/apache/druid/sql/guice/SqlModule.java | 4 +
.../org/apache/druid/sql/http/SqlParameter.java | 52 +-
.../java/org/apache/druid/sql/http/SqlQuery.java | 17 -
.../org/apache/druid/sql/http/SqlResource.java | 4 +-
.../apache/druid/sql/SqlPlanningTimeoutTest.java | 98 +
.../org/apache/druid/sql/SqlQueryPlusTest.java | 48 +
.../org/apache/druid/sql/SqlStatementTest.java | 106 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 23 +
.../druid/sql/avatica/DruidStatementTest.java | 80 +
.../druid/sql/calcite/CalciteCatalogDdlTest.java | 1484 +
.../druid/sql/calcite/CalciteInsertDmlTest.java | 22 +
.../druid/sql/calcite/CalciteJoinQueryTest.java | 49 +
.../sql/calcite/CalciteNestedDataQueryTest.java | 34 +-
.../apache/druid/sql/calcite/CalciteQueryTest.java | 110 +-
.../druid/sql/calcite/IngestionTestSqlEngine.java | 1 +
.../apache/druid/sql/calcite/NotYetSupported.java | 4 +-
.../apache/druid/sql/calcite/QueryTestRunner.java | 4 +-
.../druid/sql/calcite/SqlTestFrameworkConfig.java | 1 +
.../sql/calcite/parser/DruidSqlDdlParserTest.java | 610 +
.../calcite/planner/CalcitePlannerModuleTest.java | 1 +
.../sql/calcite/planner/DruidTypeFactoryTest.java | 37 +
.../sql/calcite/planner/PlannerConfigTest.java | 51 +
.../schema/BrokerSegmentMetadataCacheTest.java | 165 +
.../druid/sql/calcite/util/SqlTestFramework.java | 19 +
.../org/apache/druid/sql/http/SqlResourceTest.java | 16 +
web-console/.gitignore | 12 +-
web-console/.node-version | 1 +
web-console/AGENTS.md | 104 +
web-console/README.md | 181 +-
web-console/console-config.js | 4 +-
web-console/e2e-tests/auto-compaction.spec.ts | 5 +-
.../e2e-tests/component/datasources/overview.ts | 6 +-
.../e2e-tests/component/ingestion/overview.ts | 2 +-
.../e2e-tests/component/load-data/data-loader.ts | 4 +-
web-console/e2e-tests/component/query/overview.ts | 18 +-
.../e2e-tests/component/workbench/overview.ts | 21 +-
web-console/e2e-tests/util/playwright.ts | 10 +-
web-console/eslint.config.mjs | 38 +-
web-console/jest.common.config.js | 2 +-
hooks/pre-push => web-console/mise.toml | 5 +-
web-console/package-lock.json | 41943 +++++++------------
web-console/package.json | 131 +-
web-console/pom.xml | 4 +-
web-console/script/build | 7 +
web-console/script/build-grammars.mjs | 91 +
web-console/script/build-sql-docs | 2 +-
web-console/script/clean | 6 +-
web-console/script/create-sql-docs.mjs | 136 +-
.../script/generate-blueprint-token-overrides.mjs | 119 +
web-console/script/licenses | 271 +-
web-console/script/mkcomp | 162 -
web-console/script/mv | 75 -
.../__snapshots__/make-doc-html.spec.ts.snap | 7 -
.../src/ace-completions/make-doc-html.spec.ts | 31 -
.../src/ace-completions/sql-completions.spec.ts | 332 -
web-console/src/ace-completions/sql-completions.ts | 383 -
web-console/src/ace-modes/dsql.ts | 159 -
web-console/src/ace-modes/hjson.ts | 304 -
.../src/blueprint-overrides/_blueprint.scss | 76 +
.../src/blueprint-overrides/_blueprint5-look.scss | 1104 +
.../src/blueprint-overrides/_design-tokens.scss | 212 +
web-console/src/blueprint-overrides/_index.scss | 18 +-
.../blueprint-overrides/_segmented-control.scss | 3 +
.../blueprint-overrides/_special-switch-modes.scss | 3 +
.../blueprint-overrides/common/_color-aliases.scss | 25 +
.../src/blueprint-overrides/common/_colors.scss | 7 +
.../src/blueprint-overrides/common/_variables.scss | 26 +-
.../components/button/_button-group.scss | 2 +
.../components/button/_common.scss | 18 +-
.../blueprint-overrides/components/card/_card.scss | 3 +
.../components/forms/_common.scss | 9 +-
.../components/navbar/_navbar.scss | 3 +
web-console/src/bootstrap/ace.scss | 122 -
web-console/src/bootstrap/ace.ts | 24 -
web-console/src/bootstrap/react-table-defaults.tsx | 78 -
.../__snapshots__/action-cell.spec.tsx.snap | 15 +-
.../src/components/action-cell/action-cell.scss | 2 +-
.../src/components/action-cell/action-cell.tsx | 11 +-
.../__snapshots__/action-icon.spec.tsx.snap | 15 +-
.../array-ingest-mode-switch.spec.tsx.snap | 26 +-
.../__snapshots__/array-input.spec.tsx.snap | 21 +-
.../src/components/array-input/array-input.tsx | 14 +-
.../__snapshots__/auto-form.spec.tsx.snap | 620 +-
.../src/components/auto-form/auto-form.spec.tsx | 7 +-
web-console/src/components/auto-form/auto-form.tsx | 12 +-
.../__snapshots__/braced-text.spec.tsx.snap | 16 +-
.../components/braced-text/braced-text.spec.tsx | 10 +-
.../__snapshots__/center-message.spec.tsx.snap | 4 +-
.../__snapshots__/clearable-input.spec.tsx.snap | 23 +-
.../components/clearable-input/clearable-input.tsx | 2 +-
.../__snapshots__/click-to-copy.spec.tsx.snap | 2 +-
.../src/components/click-to-copy/click-to-copy.tsx | 4 +-
web-console/src/components/code-editor/README.md | 323 +
.../components/code-editor/code-editor-theme.ts | 223 +
.../code-editor/code-editor.scss} | 64 +-
.../components/code-editor/code-editor.spec.tsx | 78 +
.../src/components/code-editor/code-editor.tsx | 396 +
.../components/code-editor/completion-doc.spec.ts | 55 +
.../src/components/code-editor/completion-doc.ts | 61 +
.../code-editor/completion-source.spec.ts | 57 +
.../components/code-editor/completion-source.ts | 109 +
.../components/code-editor/doc-markdown.spec.ts | 61 +
.../src/components/code-editor/doc-markdown.ts | 76 +
.../src/components/code-editor/error-mark.spec.ts | 87 +
.../src/components/code-editor/error-mark.ts | 100 +
.../src/components/code-editor/search-panel.tsx | 201 +
.../__snapshots__/console-table.spec.tsx.snap | 311 +
.../console-table-pagination.tsx} | 57 +-
.../page-jump-dialog/page-jump-dialog.tsx | 0
.../console-table/console-table.scss} | 189 +-
.../console-table/console-table.spec.tsx | 406 +
.../src/components/console-table/console-table.tsx | 856 +
.../console-table}/constants.ts | 0
.../console-table}/index.ts | 5 +-
.../console-table/table-filter-inputs.tsx} | 64 +-
.../deferred/__snapshots__/deferred.spec.tsx.snap | 2 +-
.../__snapshots__/druid-logo.spec.tsx.snap | 2 +-
.../src/components/druid-logo/druid-logo.scss | 4 +-
.../__snapshots__/external-link.spec.tsx.snap | 2 +-
.../fancy-numeric-input.spec.tsx.snap | 69 +-
.../fancy-numeric-input.spec.tsx | 6 +-
.../fancy-numeric-input/fancy-numeric-input.tsx | 28 +-
.../components/fancy-tab-pane/fancy-tab-pane.scss | 2 +-
.../components/fancy-tab-pane/fancy-tab-pane.tsx | 2 +-
.../form-group-with-info.spec.tsx.snap | 25 +-
.../form-group-with-info/form-group-with-info.scss | 2 +-
.../form-group-with-info/form-group-with-info.tsx | 12 +-
.../__snapshots__/form-json-selector.spec.tsx.snap | 94 +-
.../form-json-selector/form-json-selector.spec.tsx | 10 +-
.../__snapshots__/formatted-input.spec.tsx.snap | 13 +-
.../formatted-input/formatted-input.scss | 2 +-
.../components/formatted-input/formatted-input.tsx | 4 +-
.../__snapshots__/header-bar.spec.tsx.snap | 673 +-
.../src/components/header-bar/header-bar.scss | 4 +-
.../src/components/header-bar/header-bar.spec.tsx | 7 +-
.../src/components/header-bar/header-bar.tsx | 84 +-
.../__snapshots__/restricted-mode.spec.tsx.snap | 182 +-
.../restricted-mode/restricted-mode.spec.tsx | 11 +-
.../header-bar/restricted-mode/restricted-mode.tsx | 17 +-
.../__snapshots__/highlight-text.spec.tsx.snap | 10 +-
.../highlight-text/highlight-text.spec.tsx | 6 +-
web-console/src/components/index.ts | 2 +
.../__snapshots__/interval-input.spec.tsx.snap | 25 +-
.../components/interval-input/interval-input.tsx | 16 +-
.../__snapshots__/json-collapse.spec.tsx.snap | 44 +-
.../json-collapse/json-collapse.spec.tsx | 7 +-
.../src/components/json-collapse/json-collapse.tsx | 7 +-
.../__snapshots__/json-input.spec.tsx.snap | 182 +-
.../src/components/json-input/json-input.scss | 4 +
.../src/components/json-input/json-input.spec.tsx | 34 +-
.../src/components/json-input/json-input.tsx | 200 +-
.../__snapshots__/learn-more.spec.tsx.snap | 2 +-
.../loader/__snapshots__/loader.spec.tsx.snap | 2 +-
web-console/src/components/loader/loader.tsx | 2 +-
.../__snapshots__/menu-boolean.spec.tsx.snap | 98 +-
.../src/components/menu-boolean/menu-boolean.tsx | 2 +-
.../__snapshots__/menu-checkbox.spec.tsx.snap | 42 +-
.../__snapshots__/more-button.spec.tsx.snap | 36 +-
.../src/components/more-button/more-button.tsx | 10 +-
.../plural-pair-if-needed.spec.tsx.snap | 2 +-
.../__snapshots__/popover-text.spec.tsx.snap | 2 +-
.../components/portal-bubble/portal-bubble.scss | 2 +-
.../src/components/portal-bubble/portal-bubble.tsx | 4 +-
.../__snapshots__/query-error-pane.spec.tsx.snap | 4 +-
.../query-error-pane/query-error-pane.scss | 4 +-
.../query-error-pane/query-error-pane.spec.tsx | 6 +-
.../query-error-pane/query-error-pane.tsx | 10 +-
.../record-table-pane/record-table-pane.scss | 12 +-
.../record-table-pane/record-table-pane.tsx | 23 +-
.../__snapshots__/rule-editor.spec.tsx.snap | 888 +-
.../__snapshots__/tiered-replicant.spec.tsx.snap | 437 +-
.../src/components/rule-editor/rule-editor.tsx | 12 +-
.../components/rule-editor/tiered-replicant.tsx | 4 +-
.../__snapshots__/segment-timeline.spec.tsx.snap | 154 +-
.../src/components/segment-timeline/interval.ts | 17 +-
.../segment-timeline/segment-bar-chart-render.scss | 2 +-
.../segment-timeline/segment-bar-chart-render.tsx | 39 +-
.../segment-timeline/segment-bar-chart.tsx | 11 +-
.../segment-timeline/segment-timeline.scss | 2 +-
.../segment-timeline/segment-timeline.spec.tsx | 2 +-
.../segment-timeline/segment-timeline.tsx | 57 +-
.../show-json-or-stages.spec.tsx.snap | 20 +-
.../show-json-or-stages/show-json-or-stages.scss | 4 +
.../show-json-or-stages/show-json-or-stages.tsx | 29 +-
.../__snapshots__/show-json.spec.tsx.snap | 20 +-
.../src/components/show-json/show-json.scss | 4 +
web-console/src/components/show-json/show-json.tsx | 29 +-
.../show-log/__snapshots__/show-log.spec.tsx.snap | 22 +-
web-console/src/components/show-log/show-log.tsx | 15 +-
.../__snapshots__/show-value.spec.tsx.snap | 10 +-
.../src/components/show-value/show-value.tsx | 4 +-
.../__snapshots__/splitter-layout.spec.tsx.snap | 2 +-
.../__snapshots__/suggestible-input.spec.tsx.snap | 49 +-
.../suggestible-input/suggestible-input.tsx | 14 +-
.../__snapshots__/suggestion-menu.spec.tsx.snap | 52 +-
.../supervisor-history-panel.spec.tsx.snap | 2 +-
.../supervisor-history-panel.scss | 2 +-
.../table-cell-unparseable.spec.tsx.snap | 2 +-
.../table-cell-unparseable.scss | 2 +-
.../__snapshots__/table-cell.spec.tsx.snap | 28 +-
.../src/components/table-cell/table-cell.scss | 2 +-
.../table-clickable-cell/table-clickable-cell.scss | 2 +-
.../table-column-selector.spec.tsx.snap | 21 +-
.../table-column-selector.scss | 2 +-
.../table-column-selector.tsx | 12 +-
.../table-filterable-cell.scss | 2 +-
.../table-filterable-cell.tsx | 8 +-
.../__snapshots__/timed-button.spec.tsx.snap | 71 +-
.../components/timed-button/timed-button.spec.tsx | 6 +-
.../src/components/timed-button/timed-button.tsx | 10 +-
.../timezone-menu-items.spec.tsx.snap | 687 +-
.../timezone-menu-items.spec.tsx | 21 +-
.../__snapshots__/view-control-bar.spec.tsx.snap | 2 +-
.../view-control-bar/view-control-bar.scss | 2 +-
.../__snapshots__/warning-checklist.spec.tsx.snap | 17 +-
web-console/src/console-application.scss | 2 +-
web-console/src/console-application.tsx | 198 +-
web-console/src/contexts/sql-functions-context.tsx | 6 +-
.../__snapshots__/about-dialog.spec.tsx.snap | 69 +-
.../__snapshots__/alert-dialog.spec.tsx.snap | 30 +-
.../async-action-dialog.spec.tsx.snap | 30 +-
.../broker-dynamic-config-dialog.scss | 2 +-
.../compaction-config-dialog.spec.tsx.snap | 4646 +-
.../compaction-config-dialog.scss | 2 +-
.../compaction-config-dialog.spec.tsx | 18 +-
.../compaction-config-dialog.tsx | 6 +-
.../compaction-dynamic-config-dialog.tsx | 2 +-
.../compaction-history-dialog.scss | 2 +-
.../compaction-history-dialog.tsx | 17 +-
...coordinator-dynamic-config-dialog.spec.tsx.snap | 128 +-
.../coordinator-dynamic-config-dialog.scss | 2 +-
.../coordinator-dynamic-config-dialog.spec.tsx | 6 +-
.../datasource-table-action-dialog.spec.tsx.snap | 117 +-
.../datasource-columns-table.spec.tsx.snap | 1300 +-
.../datasource-columns-table.scss | 2 +-
.../datasource-columns-table.spec.tsx | 18 +-
.../datasource-columns-table.tsx | 11 +-
.../src/dialogs/diff-dialog/diff-dialog.scss | 4 +-
.../src/dialogs/diff-dialog/diff-dialog.tsx | 4 +-
.../__snapshots__/doctor-dialog.spec.tsx.snap | 70 +-
.../src/dialogs/doctor-dialog/doctor-dialog.scss | 2 +-
.../edit-context-dialog.spec.tsx.snap | 142 +-
.../edit-context-dialog/edit-context-dialog.scss | 2 +-
.../__snapshots__/history-dialog.spec.tsx.snap | 102 +-
.../src/dialogs/history-dialog/history-dialog.scss | 2 +-
.../__snapshots__/index-spec-dialog.spec.tsx.snap | 1360 +-
.../index-spec-dialog/index-spec-dialog.scss | 2 +-
.../index-spec-dialog/index-spec-dialog.spec.tsx | 12 +-
.../__snapshots__/lookup-edit-dialog.spec.tsx.snap | 780 +-
.../lookup-edit-dialog/lookup-edit-dialog.scss | 2 +-
.../lookup-edit-dialog/lookup-edit-dialog.spec.tsx | 6 +-
.../lookup-edit-dialog/lookup-edit-dialog.tsx | 2 +-
.../lookup-table-action-dialog.spec.tsx.snap | 100 +-
.../lookup-values-table.spec.tsx.snap | 2 +-
.../lookup-values-table/lookup-values-table.scss | 2 +-
.../lookup-values-table/lookup-values-table.tsx | 9 +-
.../overload-dynamic-config-dialog.spec.tsx.snap | 128 +-
.../overload-dynamic-config-dialog.spec.tsx | 6 +-
.../overlord-dynamic-config-dialog.scss | 2 +-
.../__snapshots__/retention-dialog.spec.tsx.snap | 452 +-
.../dialogs/retention-dialog/retention-dialog.scss | 2 +-
.../dialogs/retention-dialog/retention-dialog.tsx | 2 +-
.../segment-table-action-dialog.spec.tsx.snap | 135 +-
.../service-properties-table.scss | 2 +-
.../service-properties-table.tsx | 11 +-
.../__snapshots__/show-value-dialog.spec.tsx.snap | 70 +-
.../show-value-dialog/show-value-dialog.scss | 5 +-
.../show-value-dialog/show-value-dialog.tsx | 21 +-
.../__snapshots__/snitch-dialog.spec.tsx.snap | 130 +-
.../src/dialogs/snitch-dialog/snitch-dialog.scss | 2 +-
.../src/dialogs/snitch-dialog/snitch-dialog.tsx | 8 +-
.../__snapshots__/spec-dialog.spec.tsx.snap | 286 +-
.../src/dialogs/spec-dialog/spec-dialog.scss | 4 +-
.../src/dialogs/spec-dialog/spec-dialog.tsx | 33 +-
.../__snapshots__/status-dialog.spec.tsx.snap | 53 +-
.../src/dialogs/status-dialog/status-dialog.scss | 4 +-
.../src/dialogs/status-dialog/status-dialog.tsx | 14 +-
.../supervisor-reset-offsets-dialog.scss | 2 +-
.../supervisor-table-action-dialog.spec.tsx.snap | 169 +-
.../auto-scaler-panel/auto-scaler-panel.tsx | 3 +
.../supervisor-statistics-table.spec.tsx.snap | 1297 +-
.../supervisor-statistics-table.scss | 2 +-
.../supervisor-statistics-table.spec.tsx | 18 +-
.../supervisor-statistics-table.tsx | 28 +-
.../supervisor-to-sql-dialog.scss | 2 +-
.../supervisor-to-sql-dialog.tsx | 18 +-
.../table-action-dialog.spec.tsx.snap | 68 +-
.../table-action-dialog/table-action-dialog.scss | 2 +-
.../table-action-dialog/table-action-dialog.tsx | 10 +-
.../task-table-action-dialog.spec.tsx.snap | 169 +-
.../web-console-config-dialog.tsx | 2 +-
.../compaction-status/compaction-status.ts | 19 +-
.../src/druid-models/execution/execution.spec.ts | 2 +-
.../src/druid-models/execution/execution.ts | 12 +-
web-console/src/druid-models/filter/filter.tsx | 4 +-
.../ingestion-spec/ingestion-spec.spec.ts | 62 +
.../druid-models/ingestion-spec/ingestion-spec.tsx | 46 +-
web-console/src/druid-models/stages/stages.ts | 131 +-
.../supervisor-status/supervisor-status.ts | 59 +-
.../workbench-query/workbench-query.spec.ts | 10 +-
.../workbench-query/workbench-query.ts | 6 +-
.../editor-completion.ts} | 26 +-
.../hjson-completions.spec.ts | 107 +-
.../hjson-completions.ts | 81 +-
.../hjson-context.spec.ts | 432 +-
.../src/editor-completions/hjson-context.ts | 235 +
.../src/editor-completions/sql-completions.spec.ts | 358 +
.../src/editor-completions/sql-completions.ts | 417 +
.../editor-languages/dsql-keywords.ts} | 0
web-console/src/editor-languages/dsql-tokens.ts | 74 +
web-console/src/editor-languages/dsql.grammar | 96 +
web-console/src/editor-languages/dsql.ts | 104 +
.../src/editor-languages/editor-languages.spec.ts | 226 +
.../editor-languages/editor-tags.ts} | 10 +-
web-console/src/editor-languages/hjson-tokens.ts | 183 +
web-console/src/editor-languages/hjson.grammar | 95 +
web-console/src/editor-languages/hjson.ts | 87 +
web-console/src/entry.scss | 18 +-
web-console/src/entry.tsx | 5 -
.../__snapshots__/spec-conversion.spec.ts.snap | 2 +-
web-console/src/helpers/capabilities.ts | 2 +-
web-console/src/helpers/spec-conversion.ts | 4 +-
.../src/helpers/supervisor-conversion.spec.ts | 8 +-
web-console/src/hooks/use-constant.ts | 15 +-
web-console/src/hooks/use-last-defined-deep.ts | 15 +-
web-console/src/hooks/use-last-defined.ts | 13 +-
web-console/src/hooks/use-memo-with-previous.ts | 14 +-
web-console/src/hooks/use-query-manager.ts | 46 +-
web-console/src/index.ts | 1 -
web-console/src/react-table/react-table-extra.scss | 70 -
.../react-table-pagination.scss | 22 -
web-console/src/setup-tests.ts | 5 +-
.../src/singletons/ace-editor-state-cache.ts | 46 -
web-console/src/singletons/toaster.ts | 25 +-
web-console/src/test-utils/completion-context.ts | 42 +
web-console/src/test-utils/snapshot-serializer.ts | 79 +
web-console/src/test-utils/stub-component.tsx | 96 +
web-console/src/utils/base64-url.ts | 2 +-
web-console/src/utils/download.ts | 4 +-
web-console/src/utils/druid-query.spec.ts | 24 +-
web-console/src/utils/druid-query.ts | 26 +-
.../utils/echarts-theme.ts} | 27 +-
web-console/src/utils/explain.ts | 2 +-
web-console/src/utils/general.spec.ts | 38 +-
web-console/src/utils/general.tsx | 54 +-
web-console/src/utils/hash-routing.spec.ts | 56 +
web-console/src/utils/hash-routing.ts | 53 +
web-console/src/utils/hjson-context.ts | 408 -
web-console/src/utils/index.tsx | 2 +-
.../src/utils/mouse-tooltip/mouse-tooltip.scss | 2 +-
web-console/src/utils/sampler.ts | 11 +-
web-console/src/utils/shallow-renderer.ts | 41 -
web-console/src/utils/sql.spec.ts | 416 +-
web-console/src/utils/sql.ts | 15 +-
.../src/utils/table-filters/table-filter.spec.ts | 4 +-
.../src/utils/table-filters/table-filter.ts | 8 +-
.../src/utils/table-filters/table-filters.ts | 6 +-
web-console/src/utils/table-helpers.ts | 8 +-
web-console/src/variables.scss | 12 +-
.../__snapshots__/datasources-view.spec.tsx.snap | 698 +-
.../views/datasources-view/datasources-view.scss | 4 +-
.../datasources-view/datasources-view.spec.tsx | 13 +-
.../views/datasources-view/datasources-view.tsx | 114 +-
.../components/column-picker/column-picker.tsx | 15 +-
.../components/column-value/column-value.tsx | 4 +-
.../components/control-pane/control-pane.scss | 2 +-
.../components/control-pane/control-pane.tsx | 17 +-
.../components/control-pane/expression-menu.scss | 2 +-
.../components/control-pane/expression-menu.tsx | 13 +-
.../components/control-pane/measure-menu.scss | 2 +-
.../components/control-pane/measure-menu.tsx | 13 +-
.../control-pane/named-expressions-input.scss | 2 +-
.../control-pane/named-expressions-input.tsx | 23 +-
.../components/control-pane/options-input.tsx | 18 +-
.../droppable-container/droppable-container.scss | 2 +-
.../droppable-container/droppable-container.tsx | 81 +-
.../components/error-boundary/error-boundary.scss | 2 +-
.../explore-header-ber/explore-header-bar.scss | 4 +-
.../explore-header-ber/explore-header-bar.tsx | 53 +-
.../contains-filter-control.tsx | 5 +-
.../filter-pane/filter-menu/filter-menu.tsx | 15 +-
.../regexp-filter-control.tsx | 5 +-
.../values-filter-control.tsx | 3 +-
.../components/filter-pane/filter-pane.scss | 2 +-
.../components/filter-pane/filter-pane.tsx | 62 +-
.../generic-output-table/generic-output-table.scss | 12 +-
.../generic-output-table/generic-output-table.tsx | 44 +-
.../components/helper-table/helper-table.tsx | 15 +-
.../components/module-pane/module-pane.scss | 2 +-
.../components/module-pane/module-pane.tsx | 17 +-
.../components/module-picker/module-picker.scss | 2 +-
.../components/module-picker/module-picker.tsx | 17 +-
.../components/preview-pane/preview-pane.tsx | 13 +-
.../resource-pane/column-dialog/column-dialog.scss | 2 +-
.../resource-pane/column-dialog/column-dialog.tsx | 3 +-
.../measure-dialog/measure-dialog.scss | 2 +-
.../measure-dialog/measure-dialog.tsx | 3 +-
.../nested-column-dialog/nested-column-dialog.scss | 2 +-
.../components/resource-pane/resource-pane.scss | 2 +-
.../components/resource-pane/resource-pane.tsx | 32 +-
.../components/source-pane/source-pane.tsx | 17 +-
.../components/sql-input/sql-input.tsx | 118 +-
.../src/views/explore-view/explore-view.scss | 2 +-
.../src/views/explore-view/explore-view.tsx | 20 +-
.../src/views/explore-view/models/measure.ts | 2 +-
.../modules/bar-chart-module/bar-chart-module.tsx | 118 +-
.../grouping-table-module.tsx | 2 +-
.../multi-axis-chart-module.tsx | 162 +-
.../modules/pie-chart-module/pie-chart-module.tsx | 136 +-
.../time-chart-module/continuous-chart-render.scss | 2 +-
.../time-chart-module/continuous-chart-render.tsx | 26 +-
.../continuous-chart-single-render.scss | 2 +-
.../continuous-chart-single-render.tsx | 12 +-
.../time-chart-module/time-chart-module.tsx | 14 +-
.../utils/__snapshots__/table-query.spec.ts.snap | 2 +-
.../explore-view/utils/filter-pattern-helpers.ts | 3 +-
.../src/views/explore-view/utils/table-query.ts | 4 +-
.../__snapshots__/home-view.spec.tsx.snap | 550 +-
.../__snapshots__/datasources-card.spec.tsx.snap | 20 +-
.../__snapshots__/home-view-card.spec.tsx.snap | 20 +-
.../home-view/home-view-card/home-view-card.scss | 4 +-
web-console/src/views/home-view/home-view.scss | 2 +-
web-console/src/views/home-view/home-view.spec.tsx | 15 +-
.../__snapshots__/lookups-card.spec.tsx.snap | 20 +-
.../__snapshots__/segments-card.spec.tsx.snap | 20 +-
.../__snapshots__/services-card.spec.tsx.snap | 20 +-
.../__snapshots__/status-card.spec.tsx.snap | 20 +-
.../__snapshots__/supervisors-card.spec.tsx.snap | 20 +-
.../__snapshots__/tasks-card.spec.tsx.snap | 20 +-
.../__snapshots__/load-data-view.spec.tsx.snap | 969 +-
.../__snapshots__/example-picker.spec.tsx.snap | 30 +-
.../example-picker/example-picker.tsx | 2 +-
.../__snapshots__/filter-table.spec.tsx.snap | 3549 +-
.../load-data-view/filter-table/filter-table.scss | 8 +-
.../load-data-view/filter-table/filter-table.tsx | 16 +-
.../__snapshots__/form-editor.spec.tsx.snap | 52 +-
.../load-data-view/form-editor/form-editor.scss | 2 +-
.../src/views/load-data-view/load-data-view.scss | 8 +-
.../views/load-data-view/load-data-view.spec.tsx | 21 +-
.../src/views/load-data-view/load-data-view.tsx | 54 +-
.../__snapshots__/parse-data-table.spec.tsx.snap | 3986 +-
.../parse-data-table/parse-data-table.scss | 8 +-
.../parse-data-table/parse-data-table.tsx | 15 +-
.../__snapshots__/parse-time-table.spec.tsx.snap | 3545 +-
.../parse-time-table/parse-time-table.tsx | 21 +-
.../__snapshots__/schema-table.spec.tsx.snap | 3549 +-
.../load-data-view/schema-table/schema-table.scss | 8 +-
.../load-data-view/schema-table/schema-table.tsx | 22 +-
.../__snapshots__/transform-table.spec.tsx.snap | 3549 +-
.../transform-table/transform-table.scss | 8 +-
.../transform-table/transform-table.tsx | 16 +-
.../__snapshots__/lookups-view.spec.tsx.snap | 386 +-
.../src/views/lookups-view/lookups-view.scss | 2 +-
.../src/views/lookups-view/lookups-view.spec.tsx | 13 +-
.../src/views/lookups-view/lookups-view.tsx | 9 +-
.../__snapshots__/segments-view.spec.tsx.snap | 749 +-
.../src/views/segments-view/segments-view.scss | 4 +-
.../src/views/segments-view/segments-view.spec.tsx | 13 +-
.../src/views/segments-view/segments-view.tsx | 22 +-
.../__snapshots__/services-view.spec.tsx.snap | 649 +-
.../__snapshots__/fill-indicator.spec.tsx.snap | 2 +-
.../src/views/services-view/services-view.scss | 4 +-
.../src/views/services-view/services-view.spec.tsx | 15 +-
.../src/views/services-view/services-view.tsx | 47 +-
.../column-actions/column-actions.scss | 2 +-
.../column-actions/column-actions.tsx | 16 +-
.../column-editor/column-editor.scss | 2 +-
.../column-editor/column-editor.tsx | 18 +-
.../destination-form/destination-form.tsx | 2 +-
.../expression-editor-dialog.scss | 2 +-
.../expression-editor-dialog.tsx | 2 +-
.../ingestion-progress-dialog.scss | 2 +-
.../ingestion-progress-dialog.tsx | 4 +-
.../schema-step/column-list/column-list.scss | 2 +-
.../schema-step/column-list/column-list.tsx | 18 +-
.../expression-entry/expression-entry.scss | 2 +-
.../schema-step/preview-error/preview-error.scss | 2 +-
.../schema-step/preview-table/preview-table.scss | 12 +-
.../schema-step/preview-table/preview-table.tsx | 19 +-
.../rollup-analysis-pane/rollup-analysis-pane.scss | 2 +-
.../rollup-analysis-pane/rollup-analysis-pane.tsx | 11 +-
.../schema-step/schema-step.scss | 2 +-
.../schema-step/schema-step.tsx | 87 +-
.../sql-data-loader-view/sql-data-loader-view.scss | 2 +-
.../sql-data-loader-view/sql-data-loader-view.tsx | 2 +-
.../title-frame/title-frame.scss | 2 +-
.../__snapshots__/supervisors-view.spec.tsx.snap | 618 +-
.../views/supervisors-view/supervisors-view.scss | 6 +-
.../supervisors-view/supervisors-view.spec.tsx | 13 +-
.../views/supervisors-view/supervisors-view.tsx | 47 +-
.../__snapshots__/tasks-view.spec.tsx.snap | 546 +-
web-console/src/views/tasks-view/tasks-view.scss | 6 +-
.../src/views/tasks-view/tasks-view.spec.tsx | 13 +-
web-console/src/views/tasks-view/tasks-view.tsx | 16 +-
.../__snapshots__/column-tree.spec.tsx.snap | 504 +-
.../__snapshots__/complex-menu-items.spec.tsx.snap | 48 +-
.../__snapshots__/number-menu-items.spec.tsx.snap | 298 +-
.../__snapshots__/string-menu-items.spec.tsx.snap | 298 +-
.../__snapshots__/time-menu-items.spec.tsx.snap | 298 +-
.../workbench-view/column-tree/column-tree.scss | 4 +-
.../column-tree/column-tree.spec.tsx | 6 +-
.../workbench-view/column-tree/column-tree.tsx | 197 +-
.../connect-external-data-dialog.scss | 2 +-
.../current-dart-panel/current-dart-panel.scss | 2 +-
.../current-dart-panel/current-dart-panel.tsx | 29 +-
.../destination-pages-dialog.scss | 2 +-
.../destination-pages-pane.scss | 2 +-
.../destination-pages-pane.tsx | 23 +-
.../execution-details-dialog.scss | 2 +-
.../execution-details-pane.spec.tsx.snap | 2936 +-
.../execution-details-pane.spec.tsx | 11 +-
.../execution-details-pane.tsx | 12 +-
.../execution-error-pane.spec.tsx.snap | 66 +-
.../execution-error-pane/execution-error-pane.scss | 2 +-
.../execution-error-pane.spec.tsx | 7 +-
.../execution-progress-bar-pane.spec.tsx.snap | 45 +-
.../execution-progress-bar-pane.scss | 2 +-
.../execution-progress-bar-pane.spec.tsx | 7 +-
.../execution-stages-pane.spec.tsx.snap | 1038 +-
.../execution-stages-pane.scss | 4 +-
.../execution-stages-pane.spec.tsx | 7 +-
.../execution-stages-pane.tsx | 81 +-
.../execution-submit-dialog.spec.tsx.snap | 190 +-
.../execution-submit-dialog.scss | 2 +-
.../execution-submit-dialog.spec.tsx | 6 +-
.../execution-submit-dialog.tsx | 6 +-
.../execution-summary-panel.tsx | 28 +-
.../execution-timer-panel.spec.tsx.snap | 70 +-
.../execution-timer-panel.tsx | 4 +-
.../execution-warnings-pane/warning-callout.tsx | 2 +-
.../__snapshots__/explain-dialog.spec.tsx.snap | 1008 +-
.../explain-dialog/explain-dialog.scss | 6 +-
.../explain-dialog/explain-dialog.spec.tsx | 19 +-
.../explain-dialog/explain-dialog.tsx | 22 +-
.../flexible-query-input.spec.tsx.snap | 93 +-
.../flexible-query-input/flexible-query-input.scss | 47 +-
.../flexible-query-input/flexible-query-input.tsx | 338 +-
.../flexible-query-input/sub-query-markers.spec.ts | 76 +
.../flexible-query-input/sub-query-markers.ts | 185 +
.../ingest-success-pane.spec.tsx.snap | 10 +-
.../ingest-success-pane/ingest-success-pane.scss | 2 +-
.../ingest-success-pane.spec.tsx | 7 +-
.../input-format-step/input-format-step.scss | 2 +-
.../input-format-step/input-format-step.tsx | 10 +-
.../input-source-step/input-source-step.scss | 2 +-
.../input-source-step/input-source-step.tsx | 17 +-
.../__snapshots__/max-tasks-button.spec.tsx.snap | 189 +-
.../max-tasks-button/max-tasks-button.spec.tsx | 7 +-
.../max-tasks-button/max-tasks-button.tsx | 12 +-
.../workbench-view/metadata-change-detector.tsx | 6 +-
.../query-parameters-dialog.spec.tsx.snap | 1764 +-
.../query-parameters-dialog.scss | 2 +-
.../query-parameters-dialog.spec.tsx | 10 +-
.../query-parameters-dialog.tsx | 16 +-
.../views/workbench-view/query-tab/query-tab.scss | 2 +-
.../views/workbench-view/query-tab/query-tab.tsx | 77 +-
.../recent-query-task-panel.scss | 2 +-
.../recent-query-task-panel.tsx | 24 +-
.../result-table-pane/result-table-pane.scss | 12 +-
.../result-table-pane/result-table-pane.tsx | 35 +-
.../__snapshots__/run-panel.spec.tsx.snap | 97 +-
.../views/workbench-view/run-panel/run-panel.tsx | 33 +-
.../workbench-history-dialog.scss | 2 +-
.../workbench-history-dialog.tsx | 35 +-
.../src/views/workbench-view/workbench-view.scss | 2 +-
.../src/views/workbench-view/workbench-view.tsx | 62 +-
web-console/tsconfig.json | 9 +-
web-console/typings/react-shallow-renderer.d.ts | 25 -
.../navbar/_navbar.scss => typings/styles.d.ts} | 7 +-
web-console/unified-console.html | 2 +-
web-console/webpack.config.mjs | 39 +-
.../aggOWnFn_30.e => website/.node-version | 0
website/.spelling | 21 +
website/README.md | 4 +-
hooks/pre-push => website/mise.toml | 5 +-
website/package-lock.json | 352 +-
website/package.json | 11 +-
website/redirects.js | 9 +-
website/sidebars.json | 11 +-
1336 files changed, 100875 insertions(+), 72572 deletions(-)
delete mode 100644 .codecov.yml
delete mode 100755 .github/scripts/build-dist
create mode 100644 .mvn/wrapper/maven-wrapper.properties
rename docs/{api-reference/sql-jdbc.md => querying/sql-jdbc-avatica.md} (85%)
create mode 100644 docs/querying/sql-jdbc.md
create mode 100644
embedded-tests/src/test/java/org/apache/druid/testing/embedded/catalog/CatalogDdlAndIngestTest.java
rename
embedded-tests/src/test/java/org/apache/druid/testing/embedded/msq/{MinIODurableStorageResource.java
=> S3DurableStorageResource.java} (85%)
rename embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio
=> s3}/ITS3SQLBasedIngestionTest.java (96%)
rename embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio
=> s3}/ITS3ToS3ParallelIndexTest.java (90%)
rename embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio
=> s3}/S3PerfTest.java (94%)
rename
embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio/MinIOStorageResource.java
=> s3/S3StorageResource.java} (79%)
rename
embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio/MinIOStorageResourceTest.java
=> s3/S3StorageResourceTest.java} (84%)
rename
embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio/MinIOStorageTest.java
=> s3/S3StorageTest.java} (84%)
rename embedded-tests/src/test/java/org/apache/druid/testing/embedded/{minio
=> s3}/S3TestUtil.java (99%)
create mode 100644
embedded-tests/src/test/resources/data/protobuf/proto3_event.desc
create mode 100644
embedded-tests/src/test/resources/data/protobuf/proto3_event.proto
create mode 100644
extensions-contrib/druid-iceberg-extensions/src/main/java/org/apache/druid/iceberg/input/IcebergArrowInputSourceReader.java
create mode 100644
extensions-contrib/druid-iceberg-extensions/src/test/java/org/apache/druid/iceberg/input/IcebergArrowInputSourceReaderTest.java
create mode 100644
extensions-contrib/druid-iceberg-extensions/src/test/java/org/apache/druid/iceberg/input/IcebergInputSourceArrowModeTest.java
create mode 100644
extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureSegmentRangeReader.java
create mode 100644
extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureLoadSpecTest.java
create mode 100644
extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureSegmentRangeReaderTest.java
create mode 100644
extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogSqlTableWriter.java
create mode 100644
extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/GoogleSegmentRangeReader.java
create mode 100644
extensions-core/google-extensions/src/test/java/org/apache/druid/storage/google/GoogleLoadSpecTest.java
create mode 100644
extensions-core/google-extensions/src/test/java/org/apache/druid/storage/google/GoogleSegmentRangeReaderTest.java
create mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/HeaderFilterHandler.java
create mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/HeaderFilterHandlerFactory.java
create mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/InDimFilterHandler.java
create mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaHeaderBasedFilterEvaluator.java
create mode 100644
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaHeaderBasedFilterConfig.java
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/HeaderFilterHandlerTest.java
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaHeaderBasedFilterConfigEvaluatorTest.java
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaHeaderBasedFilterConfigIntegrationTest.java
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/KafkaRecordSupplierHeaderFilterTest.java
create mode 100644
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaHeaderBasedFilterConfigTest.java
create mode 100644
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/config/ApiNodeLabelReader.java
create mode 100644
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/config/CachingNodeLabelReader.java
create mode 100644
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/config/K8sNodeLabelDynamicConfigProvider.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/config/NodeLabelReader.java
(66%)
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/ChannelResetException.java
(66%)
create mode 100644
extensions-core/kubernetes-extensions/src/test/java/org/apache/druid/k8s/config/K8sNodeLabelDynamicConfigProviderTest.java
create mode 100644
extensions-core/kubernetes-extensions/src/test/java/org/apache/druid/k8s/discovery/DefaultK8sApiClientWatchPodsTest.java
create mode 100644
extensions-core/protobuf-extensions/src/test/java/org/apache/druid/data/input/protobuf/ProtobufConverterTest.java
create mode 100644
extensions-core/protobuf-extensions/src/test/resources/proto3_test_event.proto
create mode 100644
extensions-core/s3-extensions/src/test/java/org/apache/druid/storage/s3/RustFSContainer.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/CompactionTaskRunTestCases.java
create mode 100644 jdbc-driver/pom.xml
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> jdbc-driver/src/main/java/org/apache/druid/jdbc/BooleanUtils.java (67%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/ClientProperties.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidArray.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidConnection.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidConnectionUrl.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidDatabaseMetaData.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidJdbcDriver.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidJdbcException.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidJdbcFeatureNotSupportedException.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidPreparedStatement.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidResultSet.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidResultSetMetaData.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidSQLState.java (61%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidStatement.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/DruidTimestampParser.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/StringUtils.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> jdbc-driver/src/main/java/org/apache/druid/jdbc/SuppressForbidden.java (63%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/ColumnMetadata.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/DruidHttpClient.java
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/DruidHttpClientImpl.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/EmptyQueryResultsIterator.java
(54%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/HttpClientUtils.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/QueryResultsIterator.java
(60%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/QueryResultsIteratorImpl.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> jdbc-driver/src/main/java/org/apache/druid/jdbc/http/SqlParameter.java (65%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/http/SqlRequest.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=> jdbc-driver/src/main/java/org/apache/druid/jdbc/sql/SetStatement.java (66%)
create mode 100644
jdbc-driver/src/main/java/org/apache/druid/jdbc/sql/SqlScanner.java
copy hooks/pre-push =>
jdbc-driver/src/main/resources/META-INF/services/java.sql.Driver (91%)
mode change 100755 => 100644
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/ClientPropertiesTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidConnectionTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidConnectionUrlTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidDatabaseMetaDataTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidJdbcDriverTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidParameterBindingTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidPreparedStatementTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidResultSetMetaDataTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidResultSetTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidSetStatementPreparedStatementTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidSetStatementTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidStatementTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidTimestampParserTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/DruidTypeConversionTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/SqlScannerTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/StringUtilsTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/embedded/EmbeddedJdbcDriverTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/embedded/EmbeddedSecureJdbcDriverTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/http/ColumnMetadataTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/http/DruidHttpClientTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/http/QueryResultsIteratorTest.java
copy
processing/src/test/java/org/apache/druid/segment/column/ColumnBuilderTest.java
=> jdbc-driver/src/test/java/org/apache/druid/jdbc/http/SqlParameterTest.java
(52%)
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/http/SqlRequestTest.java
create mode 100644
jdbc-driver/src/test/java/org/apache/druid/jdbc/http/TestQueryResultsIterator.java
copy licenses/bin/{@babel-code-frame.MIT => @babel-generator.MIT} (100%)
copy licenses/bin/{@babel-code-frame.MIT => @babel-helper-globals.MIT} (100%)
copy licenses/bin/{safe-buffer.MIT => @babel-parser.MIT} (94%)
copy licenses/bin/{@babel-code-frame.MIT => @babel-template.MIT} (100%)
copy licenses/bin/{@babel-code-frame.MIT => @babel-traverse.MIT} (100%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-autocomplete.MIT} (91%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-commands.MIT} (91%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-language.MIT} (91%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-search.MIT} (91%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-state.MIT} (91%)
copy licenses/bin/{path-to-regexp.MIT => @codemirror-view.MIT} (91%)
rename licenses/bin/{@emotion-stylis.MIT => @emotion-babel-plugin.MIT} (100%)
rename licenses/bin/{babel-plugin-emotion.MIT => @emotion-css.MIT} (100%)
rename licenses/bin/{create-emotion.MIT => @emotion-react.MIT} (100%)
rename licenses/bin/{emotion.MIT =>
@emotion-use-insertion-effect-with-fallbacks.MIT} (100%)
create mode 100644 licenses/bin/@floating-ui-core.MIT
create mode 100644 licenses/bin/@floating-ui-dom.MIT
create mode 100644 licenses/bin/@floating-ui-react-dom.MIT
create mode 100644 licenses/bin/@floating-ui-react.MIT
create mode 100644 licenses/bin/@floating-ui-utils.MIT
copy licenses/bin/{safe-buffer.MIT => @jridgewell-gen-mapping.MIT} (92%)
copy licenses/bin/{safe-buffer.MIT => @jridgewell-resolve-uri.MIT} (92%)
copy licenses/bin/{safe-buffer.MIT => @jridgewell-sourcemap-codec.MIT} (92%)
copy licenses/bin/{safe-buffer.MIT => @jridgewell-trace-mapping.MIT} (92%)
rename licenses/bin/{babel-plugin-syntax-jsx.MIT => @lezer-common.MIT} (85%)
copy licenses/bin/{path-to-regexp.MIT => @lezer-highlight.MIT} (92%)
copy licenses/bin/{path-to-regexp.MIT => @lezer-lr.MIT} (92%)
rename licenses/bin/{path-to-regexp.MIT => @marijn-find-cluster-break.MIT}
(92%)
copy licenses/bin/{react-diff-viewer.MIT => @tanstack-react-store.MIT} (96%)
copy licenses/bin/{react-table.MIT => @tanstack-react-table.MIT} (100%)
copy licenses/bin/{history.MIT => @tanstack-store.MIT} (96%)
rename licenses/bin/{react-table.MIT => @tanstack-table-core.MIT} (100%)
delete mode 100644 licenses/bin/@types-prop-types.MIT
delete mode 100644 licenses/bin/@types-react-table.MIT
delete mode 100644 licenses/bin/ace-builds.BSD3
create mode 100644 licenses/bin/agent-base.MIT
copy licenses/bin/{es-errors.MIT => call-bind-apply-helpers.MIT} (100%)
copy licenses/bin/{safe-buffer.MIT => crelt.MIT} (94%)
delete mode 100644 licenses/bin/d3-array.BSD3
delete mode 100644 licenses/bin/d3-format.BSD3
copy licenses/bin/{d3-array.ISC => d3-format.ISC} (95%)
copy licenses/bin/{d3-array.ISC => d3-time.ISC} (100%)
copy licenses/bin/{react-diff-viewer.MIT => dunder-proto.MIT} (96%)
copy licenses/bin/{es-errors.MIT => es-define-property.MIT} (100%)
copy licenses/bin/{es-errors.MIT => es-object-atoms.MIT} (100%)
copy licenses/bin/{react-diff-viewer.MIT => get-proto.MIT} (96%)
copy licenses/bin/{react-diff-viewer.MIT => gopd.MIT} (96%)
create mode 100644 licenses/bin/https-proxy-agent.MIT
delete mode 100644 licenses/bin/isarray.MIT
create mode 100644 licenses/bin/jackson3-FastDoubleParser-ThirdParty.LICENSE
create mode 100644 licenses/bin/jackson3-FastDoubleParser.LICENSE
copy licenses/bin/{safe-buffer.MIT => jackson3-Schubfach.LICENSE} (94%)
rename licenses/bin/{lodash.isequal.MIT => jsesc.MIT} (52%)
delete mode 100644 licenses/bin/lodash.get.MIT
rename licenses/bin/{react-diff-viewer.MIT => math-intrinsics.MIT} (96%)
delete mode 100644 licenses/bin/react-ace.MIT
rename licenses/bin/{react-uid.MIT => react-diff-viewer-continued.MIT} (97%)
delete mode 100644 licenses/bin/react-router-dom.MIT
delete mode 100644 licenses/bin/react-router.MIT
delete mode 100644 licenses/bin/regenerator-runtime.MIT
delete mode 100644 licenses/bin/resolve-pathname.MIT
copy licenses/bin/{safe-buffer.MIT => style-mod.MIT} (93%)
rename licenses/bin/{history.MIT => stylis.MIT} (96%)
copy licenses/bin/{cosmiconfig.MIT => tabbable.MIT} (100%)
delete mode 100644 licenses/bin/tiny-invariant.MIT
delete mode 100644 licenses/bin/tiny-warning.MIT
delete mode 100644 licenses/bin/toggle-selection.MIT
delete mode 100644 licenses/bin/value-equal.MIT
rename licenses/bin/{safe-buffer.MIT => w3c-keyname.MIT} (93%)
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerService.java
(54%)
create mode 100644
multi-stage-query/src/main/java/org/apache/druid/msq/input/AcquireSegmentHandles.java
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/dart/worker/DartWorkerServiceTest.java
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/input/AdaptedLoadableSegmentTest.java
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/querykit/ReadableInputQueueTest.java
create mode 100755 mvnw
create mode 100644 mvnw.cmd
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/RollupTableProjectionSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/data/input/impl/TableProjectionSpec.java
create mode 100644
processing/src/main/java/org/apache/druid/jackson/StrictIntegerDeserializer.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleAcosProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleAsinProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleAtanProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleCbrtProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleCosProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleCoshProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleExpProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleExpm1Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLog10Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLog1pProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleLogProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleSinProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleSinhProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleTanProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdDoubleTanhProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleAcosProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleAsinProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleAtanProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleCbrtProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleCosProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleCoshProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleExpProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleExpm1Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleLog10Processor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleLog1pProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleLogProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleSinProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleSinhProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleTanProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/math/expr/vector/simd/SimdLongToDoubleTanhProcessor.java
create mode 100644
processing/src/main/java/org/apache/druid/query/QueryContextBuilder.java
create mode 100644
processing/src/main/java/org/apache/druid/query/context/QueryContextParameter.java
create mode 100644
processing/src/main/java/org/apache/druid/query/context/QueryContextParameterValidator.java
create mode 100644
processing/src/main/java/org/apache/druid/query/context/QueryContextParameters.java
copy
server/src/main/java/org/apache/druid/segment/loading/LocalDataSegmentPusherConfig.java
=>
processing/src/main/java/org/apache/druid/query/context/constraint/ParameterConstraint.java
(65%)
create mode 100644
processing/src/main/java/org/apache/druid/query/context/constraint/Range.java
create mode 100644
processing/src/main/java/org/apache/druid/query/context/docs/ParameterDocumentation.java
create mode 100644
processing/src/main/java/org/apache/druid/query/context/docs/ParameterDocumentationGenerator.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ColumnHolderTable.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/column/ImmutableColumnCapabilities.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/file/SegmentInternalFileMap.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/loading/DeepStorageSegmentConfig.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/RollupTableProjectionSpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/data/input/impl/TableProjectionSpecTest.java
create mode 100644
processing/src/test/java/org/apache/druid/jackson/StrictIntegerDeserializerTest.java
create mode 100644
processing/src/test/java/org/apache/druid/java/util/http/client/NettyHttpClientTest.java
create mode 100644
processing/src/test/java/org/apache/druid/math/expr/vector/VectorTestAssertions.java
create mode 100644
processing/src/test/java/org/apache/druid/math/expr/vector/simd/SimdVoMathlibParityTest.java
copy
processing/src/test/java/org/apache/druid/{segment/column/ColumnBuilderTest.java
=> query/CloneQueryModeTest.java} (50%)
create mode 100644
processing/src/test/java/org/apache/druid/query/ForwardingQueryProcessingPoolTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/QueryContextBuilderTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/context/QueryContextParameterTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/context/QueryContextParameterValidatorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/query/context/docs/ParameterDocumentationGeneratorTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/ColumnHolderTableTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/column/ImmutableColumnCapabilitiesTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/file/SegmentInternalFileMapTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/loading/AcquireSegmentActionTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/loading/DeepStorageSegmentConfigTest.java
create mode 100644
processing/src/test/java/org/apache/druid/segment/serde/ColumnPartSerdeEqualsTest.java
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/BaseTableColumns.java
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/RollupTableBaseTableMetadata.java
create mode 100644
server/src/main/java/org/apache/druid/catalog/model/TableBaseTableMetadata.java
create mode 100644
server/src/main/java/org/apache/druid/server/metrics/HttpClientPoolMonitor.java
create mode 100644
server/src/main/java/org/apache/druid/server/metrics/HttpClientPoolRegistry.java
create mode 100644
server/src/test/java/org/apache/druid/catalog/model/RollupTableBaseTableMetadataTest.java
create mode 100644
server/src/test/java/org/apache/druid/catalog/model/TableBaseTableMetadataTest.java
create mode 100644
server/src/test/java/org/apache/druid/guice/http/DruidHttpClientConfigTest.java
create mode 100644
server/src/test/java/org/apache/druid/guice/http/HttpClientPoolRegistrationTest.java
create mode 100644
server/src/test/java/org/apache/druid/segment/loading/SegmentLocalCacheManagerAcquireLifecycleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/metrics/HttpClientPoolMonitorTest.java
copy
processing/src/test/java/org/apache/druid/segment/column/ColumnBuilderTest.java
=>
server/src/test/java/org/apache/druid/test/utils/ImmutableDruidDataSourceTestUtilsTest.java
(61%)
create mode 100644
services/src/main/java/org/apache/druid/guice/PeonServerModule.java
create mode 100644
services/src/test/java/org/apache/druid/guice/PeonServerModuleTest.java
create mode 100644 sql/src/main/codegen/includes/ddl.ftl
create mode 100644
sql/src/main/java/org/apache/druid/sql/SqlPlanningTimeout.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlAlterTable.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlColumnDeclaration.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlCreateTable.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/DruidSqlPropertyAssignment.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/parser/SqlProjectionSpec.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogColumnTypes.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogDdlHandler.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/CatalogTableWriter.java
create mode 100644
sql/src/main/java/org/apache/druid/sql/calcite/planner/ProjectionSpecTranslator.java
copy sql/src/main/java/org/apache/druid/sql/calcite/{view/ViewSqlEngine.java
=> planner/ProjectionSqlEngine.java} (57%)
create mode 100644
sql/src/test/java/org/apache/druid/sql/SqlPlanningTimeoutTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/CalciteCatalogDdlTest.java
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/parser/DruidSqlDdlParserTest.java
create mode 100644 web-console/.node-version
create mode 100644 web-console/AGENTS.md
copy hooks/pre-push => web-console/mise.toml (91%)
mode change 100755 => 100644
create mode 100755 web-console/script/build-grammars.mjs
create mode 100644 web-console/script/generate-blueprint-token-overrides.mjs
delete mode 100755 web-console/script/mkcomp
delete mode 100755 web-console/script/mv
delete mode 100644
web-console/src/ace-completions/__snapshots__/make-doc-html.spec.ts.snap
delete mode 100644 web-console/src/ace-completions/make-doc-html.spec.ts
delete mode 100644 web-console/src/ace-completions/sql-completions.spec.ts
delete mode 100644 web-console/src/ace-completions/sql-completions.ts
delete mode 100644 web-console/src/ace-modes/dsql.ts
delete mode 100644 web-console/src/ace-modes/hjson.ts
create mode 100644 web-console/src/blueprint-overrides/_blueprint.scss
create mode 100644 web-console/src/blueprint-overrides/_blueprint5-look.scss
create mode 100644 web-console/src/blueprint-overrides/_design-tokens.scss
delete mode 100644 web-console/src/bootstrap/ace.scss
delete mode 100644 web-console/src/bootstrap/ace.ts
delete mode 100644 web-console/src/bootstrap/react-table-defaults.tsx
create mode 100644 web-console/src/components/code-editor/README.md
create mode 100644 web-console/src/components/code-editor/code-editor-theme.ts
copy
web-console/src/{views/explore-view/components/control-pane/measure-menu.scss
=> components/code-editor/code-editor.scss} (62%)
create mode 100644 web-console/src/components/code-editor/code-editor.spec.tsx
create mode 100644 web-console/src/components/code-editor/code-editor.tsx
create mode 100644
web-console/src/components/code-editor/completion-doc.spec.ts
create mode 100644 web-console/src/components/code-editor/completion-doc.ts
create mode 100644
web-console/src/components/code-editor/completion-source.spec.ts
create mode 100644 web-console/src/components/code-editor/completion-source.ts
create mode 100644 web-console/src/components/code-editor/doc-markdown.spec.ts
create mode 100644 web-console/src/components/code-editor/doc-markdown.ts
create mode 100644 web-console/src/components/code-editor/error-mark.spec.ts
create mode 100644 web-console/src/components/code-editor/error-mark.ts
create mode 100644 web-console/src/components/code-editor/search-panel.tsx
create mode 100644
web-console/src/components/console-table/__snapshots__/console-table.spec.tsx.snap
rename
web-console/src/{react-table/react-table-pagination/react-table-pagination.tsx
=>
components/console-table/console-table-pagination/console-table-pagination.tsx}
(75%)
rename web-console/src/{react-table/react-table-pagination =>
components/console-table/console-table-pagination}/page-jump-dialog/page-jump-dialog.tsx
(100%)
rename web-console/src/{react-table/react-table-base-styles.scss =>
components/console-table/console-table.scss} (63%)
create mode 100644
web-console/src/components/console-table/console-table.spec.tsx
create mode 100644 web-console/src/components/console-table/console-table.tsx
rename web-console/src/{react-table => components/console-table}/constants.ts
(100%)
rename web-console/src/{react-table => components/console-table}/index.ts (85%)
rename web-console/src/{react-table/react-table-inputs.tsx =>
components/console-table/table-filter-inputs.tsx} (79%)
rename web-console/src/{ace-completions/make-doc-html.ts =>
editor-completions/editor-completion.ts} (51%)
rename web-console/src/{ace-completions =>
editor-completions}/hjson-completions.spec.ts (56%)
rename web-console/src/{ace-completions =>
editor-completions}/hjson-completions.ts (63%)
rename web-console/src/{utils => editor-completions}/hjson-context.spec.ts
(51%)
create mode 100644 web-console/src/editor-completions/hjson-context.ts
create mode 100644 web-console/src/editor-completions/sql-completions.spec.ts
create mode 100644 web-console/src/editor-completions/sql-completions.ts
rename web-console/{lib/keywords.ts => src/editor-languages/dsql-keywords.ts}
(100%)
create mode 100644 web-console/src/editor-languages/dsql-tokens.ts
create mode 100644 web-console/src/editor-languages/dsql.grammar
create mode 100644 web-console/src/editor-languages/dsql.ts
create mode 100644 web-console/src/editor-languages/editor-languages.spec.ts
copy web-console/{console-config.js => src/editor-languages/editor-tags.ts}
(75%)
create mode 100644 web-console/src/editor-languages/hjson-tokens.ts
create mode 100644 web-console/src/editor-languages/hjson.grammar
create mode 100644 web-console/src/editor-languages/hjson.ts
delete mode 100644 web-console/src/react-table/react-table-extra.scss
delete mode 100644
web-console/src/react-table/react-table-pagination/react-table-pagination.scss
delete mode 100644 web-console/src/singletons/ace-editor-state-cache.ts
create mode 100644 web-console/src/test-utils/completion-context.ts
create mode 100644 web-console/src/test-utils/snapshot-serializer.ts
create mode 100644 web-console/src/test-utils/stub-component.tsx
copy web-console/{jest.common.config.js => src/utils/echarts-theme.ts} (56%)
create mode 100644 web-console/src/utils/hash-routing.spec.ts
create mode 100644 web-console/src/utils/hash-routing.ts
delete mode 100644 web-console/src/utils/hjson-context.ts
delete mode 100644 web-console/src/utils/shallow-renderer.ts
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/sub-query-markers.spec.ts
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/sub-query-markers.ts
delete mode 100644 web-console/typings/react-shallow-renderer.d.ts
copy web-console/{src/blueprint-overrides/components/navbar/_navbar.scss =>
typings/styles.d.ts} (86%)
copy sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_30.e =>
website/.node-version (100%)
copy hooks/pre-push => website/mise.toml (91%)
mode change 100755 => 100644
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
