File tree
4,726 files changed
+293120
-143761
lines changed- .github
- config
- scripts
- workflows
- benchmarks
- src/test/java/org/apache/druid
- benchmark
- frame
- indexing
- lookup
- query
- timecompare
- server/coordinator
- cloud
- aws-common
- gcp-common
- codestyle
- dev
- distribution
- bin
- docker
- src/assembly
- docs
- api-reference
- assets
- configuration
- data-management
- design
- extensions-contrib
- development
- extensions-contrib
- extensions-core
- ingestion
- multi-stage-query
- operations
- querying
- release-info
- tutorials
- druid-operator
- apis/druid/v1alpha1
- chart
- crds
- templates
- config
- crd
- bases
- patches
- default
- manager
- prometheus
- rbac
- samples
- controllers
- druid
- ext
- testdata
- ingestion
- docs
- api_specifications
- images
- e2e
- configs
- examples
- aws
- hack
- api-docs
- template
- pkg
- druidapi
- http
- util
- tutorials/druid-on-kind
- embedded-tests
- src/test
- java/org/apache/druid/testing/embedded
- auth
- azure
- catalog
- compact
- docker
- gcs
- indexer
- indexing
- autoscaler
- k8s
- lookup
- mariadb
- minio
- msq
- psql
- query
- schema
- server
- resources
- META-INF/services
- data
- avro
- csv
- json
- orc
- parquet
- protobuf
- tsv
- indexer
- ldap-configs
- manifests
- multi-stage-query
- sql
- examples
- bin
- conf/druid
- auto/_common
- cluster/_common
- single-server
- large/_common
- medium/_common
- micro-quickstart/_common
- nano-quickstart/_common
- small/_common
- xlarge/_common
- quickstart/tutorial/hadoop/docker
- extensions-contrib
- aliyun-oss-extensions
- src/main/java/org/apache/druid/storage/aliyun
- ambari-metrics-emitter
- cassandra-storage
- cloudfiles-extensions
- compressed-bigdecimal
- src
- main/java/org/apache/druid/compressedbigdecimal
- aggregator
- max
- min
- sum
- serde
- test/java/org/apache/druid/compressedbigdecimal
- aggregator
- max
- min
- sum
- ddsketch
- distinctcount
- dropwizard-emitter
- src/main/resources
- druid-deltalake-extensions
- src/test/java/org/apache/druid/delta/input
- druid-exact-count-bitmap
- src
- main
- java/org/apache/druid/query/aggregation/exact/count/bitmap64
- sql
- resources/META-INF/services
- test/java/org/apache/druid/query/aggregation/exact/count/bitmap64
- sql
- druid-iceberg-extensions
- src
- main/java/org/apache/druid/iceberg/filter
- test/java/org/apache/druid/iceberg/filter
- druid-ranger-security
- gce-extensions
- graphite-emitter
- grpc-query
- src
- main/java/org/apache/druid/grpc/server
- test/java/org/apache/druid/grpc
- influx-extensions
- src/main/java/org/apache/druid/data/input/influx
- influxdb-emitter
- kafka-emitter
- src
- main/java/org/apache/druid/emitter/kafka
- test/java/org/apache/druid/emitter/kafka
- materialized-view-maintenance
- src
- main/java/org/apache/druid/indexing/materializedview
- test/java/org/apache/druid/indexing/materializedview
- materialized-view-selection
- momentsketch
- moving-average-query
- src/test/java/org/apache/druid/query/movingaverage
- averagers
- opentelemetry-emitter
- opentsdb-emitter
- src/main/resources
- prometheus-emitter
- src
- main
- java/org/apache/druid/emitter/prometheus
- resources
- test/java/org/apache/druid/emitter/prometheus
- rabbit-stream-indexing-service
- src
- main/java/org/apache/druid/indexing/rabbitstream
- supervisor
- test/java/org/apache/druid/indexing/rabbitstream
- supervisor
- redis-cache
- spectator-histogram
- src
- main/java/org/apache/druid/spectator/histogram
- test/java/org/apache/druid/spectator/histogram
- sqlserver-metadata-storage
- src
- main/java/org/apache/druid/metadata
- test/java/org/apache/druid/metadata/storage/sqlserver
- statsd-emitter
- src/main/resources
- tdigestsketch
- thrift-extensions
- time-min-max
- virtual-columns
- extensions-core
- avro-extensions
- src/test/java/org/apache/druid/data/input
- azure-extensions
- src
- main/java/org/apache/druid/storage/azure
- test/java/org/apache/druid/storage/azure
- datasketches
- src
- main/java/org/apache/druid/query/aggregation/datasketches
- hll
- sql
- theta
- sql
- test/java/org/apache/druid
- query/aggregation/datasketches
- hll/sql
- theta/sql
- tuple
- segment
- druid-aws-rds-extensions
- druid-basic-security
- src
- main/java/org/apache/druid/security/basic
- authentication/db/cache
- authorization
- db/cache
- endpoint
- test/java/org/apache/druid/security/basic
- authentication/db/cache
- authorization/db/cache
- druid-bloom-filter
- src/test/java/org/apache/druid/query/aggregation/bloom/sql
- druid-catalog
- src
- main/java/org/apache/druid/catalog/sync
- test/java/org/apache/druid/catalog
- compact
- storage
- druid-kerberos
- src
- main/java/org/apache/druid/security/kerberos
- test/java/org/apache/druid/security/kerberos
- druid-pac4j
- src
- main/java/org/apache/druid/security/pac4j
- test/java/org/apache/druid/security/pac4j
- druid-testcontainers
- src/main/java/org/apache/druid/testing
- ec2-extensions
- google-extensions
- src/main/java/org/apache/druid/storage/google
- hdfs-storage
- src/main/java/org/apache/druid/storage/hdfs
- tasklog
- histogram
- kafka-extraction-namespace
- src
- main/java/org/apache/druid/query/lookup
- test/java/org/apache/druid/query/lookup
- kafka-indexing-service
- src
- main/java/org/apache/druid
- data/input/kafkainput
- indexing/kafka
- supervisor
- test/java/org/apache/druid
- data/input/kafkainput
- indexing/kafka
- simulate
- supervisor
- test
- kinesis-indexing-service
- src
- main/java/org/apache/druid/indexing/kinesis
- supervisor
- test/java/org/apache/druid/indexing/kinesis
- supervisor
- kubernetes-extensions
- kubernetes-overlord-extensions
- src
- main/java/org/apache/druid/k8s/overlord
- common
- httpclient
- jdk
- okhttp
- vertx
- execution
- taskadapter
- test
- java/org/apache/druid/k8s/overlord
- common
- httpclient
- jdk
- okhttp
- execution
- taskadapter
- resources
- lookups-cached-global
- src
- main/java/org/apache/druid/server/lookup/namespace
- test/java/org/apache/druid/server/lookup/namespace
- cache
- lookups-cached-single
- multi-stage-query
- src
- main
- java/org/apache/druid/msq
- dart
- guice
- worker
- exec
- indexing
- processor
- kernel
- logical
- querykit
- common
- groupby
- results
- scan
- resources
- META-INF/services
- test
- java/org/apache/druid/msq
- exec
- indexing
- destination
- kernel
- querykit
- common
- results
- test
- util
- quidem/org.apache.druid.msq.quidem.MSQQuidemTest
- mysql-metadata-storage
- src/main/java/org/apache/druid/metadata
- orc-extensions
- src/test/java/org/apache/druid/data/input/orc
- parquet-extensions
- src
- main/java/org/apache/parquet/avro
- test/java/org/apache/druid/data/input/parquet
- postgresql-metadata-storage
- src/main/java/org/apache/druid/metadata
- protobuf-extensions
- src
- main/java/org/apache/druid/data/input/protobuf
- test
- java/org/apache/druid/data/input/protobuf
- resources
- s3-extensions
- src
- main/java/org/apache/druid
- catalog/model/table
- data/input/s3
- storage/s3
- test/java/org/apache/druid
- catalog/model/table
- data/input/s3
- storage/s3
- simple-client-sslcontext
- stats
- testing-tools
- src
- main
- java/org/apache/druid
- guice
- query/expressions
- testing
- cli
- cluster
- overlord
- task
- metrics
- resources/META-INF/services
- test/java/org/apache/druid/guice
- hooks
- indexing-hadoop
- src
- main
- java/org/apache/druid/indexer
- resources
- test/java/org/apache/druid/indexer
- hadoop
- indexing-service
- src
- main/java/org/apache/druid
- guice
- indexer
- indexing
- common
- actions
- config
- stats
- task
- batch/parallel
- compact
- input
- overlord
- config
- duty
- hrtr
- http
- sampler
- setup
- supervisor
- seekablestream
- common
- supervisor
- autoscaler
- worker/shuffle
- metadata
- test/java/org/apache/druid
- guice
- indexing
- common
- actions
- config
- task
- batch/parallel
- concurrent
- compact
- input
- overlord
- duty
- hrtr
- http
- sampler
- setup
- supervisor
- autoscaler
- scheduledbatch
- seekablestream
- supervisor
- autoscaler
- test
- worker
- shuffle
- metadata
- integration-tests-ex
- cases
- assets
- cluster
- AzureDeepStorage
- BackwardCompatibilityMain
- BatchIndex
- Common
- environment-configs
- GcsDeepStorage
- HighAvailability
- MultiStageQueryWithMM
- MultiStageQuery
- Query
- S3DeepStorage
- Security
- resources
- data/batch_index
- hadoop_tsv
- json
- src/test
- java/org/apache/druid/testsEx
- BackwardCompatibilityMain
- auth
- catalog
- categories
- cluster
- config
- indexer
- leadership
- msq
- query
- utils
- resources
- catalog
- cluster
- AzureDeepStorage
- BackwardCompatibilityMain
- BatchIndex
- Common
- GcsDeepStorage
- HighAvailability
- queries
- InputSource
- MultiStageQueryWithMM
- MultiStageQuery
- Query
- S3DeepStorage
- Security
- config-test
- indexer
- query
- docs
- image
- docker
- tools
- src/main
- java/org/apache/druid/testing
- tools
- utils
- resources/META-INF/services
- integration-tests
- docker
- environment-configs
- override-examples
- service-supervisords
- test-data
- script
- src
- main
- java/org/apache/druid
- cli
- server/coordination
- testing
- clients
- guice
- utils
- resources
- test
- java/org/apache/druid/tests
- api
- coordinator/duty
- hadoop
- indexer
- leadership
- parallelized
- query
- security
- resources
- api
- hadoop
- indexer
- queries
- results
- stream/data
- licenses/bin
- multi-stage-query
- src
- main
- java/org/apache/druid
- catalog/sql
- msq
- counters
- dart
- controller
- http
- messages
- sql
- guice
- worker
- http
- exec
- std
- guice
- indexing
- cleaner
- client
- destination
- error
- processor
- report
- input
- external
- inline
- lookup
- stage
- table
- kernel
- controller
- worker
- logical
- stages
- querykit
- common
- groupby
- results
- scan
- rpc
- shuffle
- input
- output
- sql
- entity
- resources
- statistics
- serde
- util
- resources
- test
- java/org/apache/druid
- msq
- counters
- dart
- controller
- http
- messages
- sql
- worker
- http
- exec
- indexing
- client
- destination
- error
- report
- input
- external
- inline
- lookup
- stage
- table
- kernel
- controller
- querykit
- common
- results
- scan
- quidem
- rpc
- shuffle
- output
- sql
- entity
- resources
- statistics
- serde
- test
- util
- sql
- avatica
- calcite
- quidem/org.apache.druid.msq.quidem.MSQQuidemTest
- resources
- multipleFiles
- org.apache.druid.msq.indexing.MSQSpecCompatTest
- processing
- src
- main/java/org/apache/druid
- collections
- common
- config
- exception
- data/input
- impl
- error
- frame
- allocation
- channel
- field
- key
- processor
- read
- columnar
- segment
- columnar
- row
- write
- columnar
- guice
- indexer
- partitions
- report
- jackson
- java/util
- common
- concurrent
- granularity
- io/smoosh
- jackson
- lifecycle
- emitter
- core
- service
- metrics
- cgroups
- math/expr
- vector
- metadata
- query
- aggregation
- post
- dimension
- expression
- filter
- groupby
- epinephelinae
- column
- vector
- http
- metadata
- metadata
- operator
- rowsandcols
- concrete
- scan
- search
- timeboundary
- timeseries
- topn
- segment
- column
- data
- file
- filter
- generator
- incremental
- index
- join
- table
- loading
- nested
- projections
- serde
- cell
- shim
- transform
- vector
- virtual
- tasklogs
- timeline
- partition
- utils
- test
- java/org/apache/druid
- collections
- common
- exception
- guava
- data/input/impl
- error
- frame
- channel
- field
- file
- key
- processor
- test
- segment
- testutil
- write
- granularity
- guice
- hll
- indexer/partitions
- jackson
- java/util
- common
- io/smoosh
- emitter
- core
- service
- metrics
- cgroups
- math/expr
- vector
- metadata
- query
- aggregation
- firstlast
- first
- last
- post
- datasourcemetadata
- dimension
- expression
- extraction
- groupby
- metadata
- operator
- policy
- rowsandcols/concrete
- scan
- timeboundary
- timeseries
- topn
- segment
- column
- data
- filter
- generator
- incremental
- join
- table
- nested
- projections
- serde
- shim
- vector
- virtual
- sql/calcite/util
- tasklogs
- timeline
- partition
- utils
- resources
- META-INF/services
- cgroupv2
- quidem-ut
- src
- main/java/org/apache/druid/quidem
- test/quidem/org.apache.druid.quidem.QTest/qaAggFuncs
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
4,726 files changed
+293120
-143761
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
64 | | - | |
| 64 | + | |
65 | 65 | | |
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
69 | 69 | | |
70 | | - | |
| 70 | + | |
71 | 71 | | |
72 | 72 | | |
73 | 73 | | |
| |||
94 | 94 | | |
95 | 95 | | |
96 | 96 | | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
69 | 69 | | |
70 | 70 | | |
71 | 71 | | |
72 | | - | |
| 72 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
23 | | - | |
24 | | - | |
25 | | - | |
26 | | - | |
27 | | - | |
28 | 23 | | |
29 | 24 | | |
30 | 25 | | |
| |||
72 | 67 | | |
73 | 68 | | |
74 | 69 | | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
17 | 17 | | |
18 | 18 | | |
19 | 19 | | |
20 | | - | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
21 | 26 | | |
22 | 27 | | |
23 | 28 | | |
24 | | - | |
25 | 29 | | |
26 | 30 | | |
0 commit comments