Commit 9625e56
committed
File tree
- .github
- scripts
- workflows
- benchmarks
- src/test/java/org/apache/druid
- benchmark
- frame
- query
- server/coordinator
- timeline
- cloud
- aws-common
- src
- main/java/org/apache/druid/common/aws
- test/java/org/apache/druid/common/aws
- gcp-common
- codestyle
- dev
- distribution
- bin
- docker
- src/assembly
- docs
- api-reference
- configuration
- data-management
- design
- 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
- compact
- consul
- docker
- gcs
- hdfs
- iceberg
- indexer
- indexing
- autoscaler
- k8s
- kinesis
- mariadb
- minio
- msq
- oss
- psql
- query
- schema
- server
- tools
- utils
- resources
- META-INF/services
- indexer
- manifests
- tls
- tls
- examples
- bin
- conf/druid
- auto
- _common
- broker
- coordinator-overlord
- indexer
- middleManager
- cluster
- _common
- data
- indexer
- middleManager
- master/coordinator-overlord
- query/broker
- single-server
- large
- _common
- broker
- coordinator-overlord
- middleManager
- medium
- _common
- broker
- coordinator-overlord
- middleManager
- micro-quickstart
- _common
- broker
- coordinator-overlord
- middleManager
- nano-quickstart
- _common
- broker
- coordinator-overlord
- middleManager
- small
- _common
- broker
- coordinator-overlord
- middleManager
- xlarge
- _common
- broker
- coordinator-overlord
- middleManager
- tools
- _common
- dump-segment
- quickstart
- protobuf
- tutorial
- extensions-contrib
- aliyun-oss-extensions
- src/main/java/org/apache/druid/storage/aliyun
- ambari-metrics-emitter
- src/test/java/org/apache/druid/emitter/ambari/metrics
- cassandra-storage
- src/main/java/org/apache/druid/storage/cassandra
- cloudfiles-extensions
- src/main/java/org/apache/druid/storage/cloudfiles
- compressed-bigdecimal
- src/test
- java/org/apache/druid/compressedbigdecimal
- aggregator
- max
- min
- sum
- resources
- consul-extensions
- src
- main
- java/org/apache/druid/consul/discovery
- resources/META-INF/services
- test
- java/org/apache/druid/consul/discovery
- resources/tls
- ddsketch
- src/test/java/org/apache/druid/query/aggregation/ddsketch
- distinctcount
- dropwizard-emitter
- src/main/resources
- druid-deltalake-extensions
- druid-exact-count-bitmap
- src/test/java/org/apache/druid/query/aggregation/exact/count/bitmap64/sql
- druid-iceberg-extensions
- src
- main/java/org/apache/druid/iceberg/input
- test/java/org/apache/druid/iceberg/input
- druid-ranger-security
- gce-extensions
- graphite-emitter
- src/test/java/org/apache/druid/emitter/graphite
- grpc-query
- src
- main/java/org/apache/druid/grpc/server
- test/java/org/apache/druid/grpc
- server
- influx-extensions
- src
- main/java/org/apache/druid/data/input/influx
- test/java/org/apache/druid/data/input/influx
- influxdb-emitter
- src/test/java/org/apache/druid/emitter/influxdb
- kafka-emitter
- materialized-view-maintenance
- src
- main
- java/org/apache/druid/indexing/materializedview
- resources/META-INF/services
- test/java/org/apache/druid/indexing/materializedview
- materialized-view-selection
- src
- main
- java/org/apache/druid/query/materializedview
- resources/META-INF/services
- test/java/org/apache/druid/query/materializedview
- momentsketch
- src/test/java/org/apache/druid/query/aggregation/momentsketch/aggregator
- moving-average-query
- opentelemetry-emitter
- opentsdb-emitter
- src/main/resources
- prometheus-emitter
- src/main/resources
- 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
- sql
- test/java/org/apache/druid/spectator/histogram
- sql
- sqlserver-metadata-storage
- src
- main/java/org/apache/druid/metadata/storage/sqlserver
- test/java/org/apache/druid/metadata/storage/sqlserver
- statsd-emitter
- src/main/resources
- tdigestsketch
- src
- main/java/org/apache/druid/query/aggregation/tdigestsketch
- sql
- test/java/org/apache/druid/query/aggregation/tdigestsketch
- sql
- thrift-extensions
- example
- src
- main/java/org/apache/druid/data/input/thrift
- test/java/org/apache/druid/data/input/thrift
- time-min-max
- src/test/java/org/apache/druid/query/aggregation
- virtual-columns
- src/test/java/org/apache/druid/segment
- extensions-core
- avro-extensions
- src
- main/java/org/apache/druid/data/input
- avro
- test/java/org/apache/druid/data/input
- avro
- 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
- quantiles/sql
- theta/sql
- test
- java/org/apache/druid/query/aggregation/datasketches
- hll
- sql
- kll
- quantiles
- sql
- theta
- oldapi
- sql
- tuple
- sql
- resources
- oldapi
- druid-aws-rds-extensions
- src
- main/java/org/apache/druid/aws/rds
- test/java/org/apache/druid/aws/rds
- druid-basic-security
- src
- main/java/org/apache/druid/security/basic
- authentication/validator
- authorization
- test/java/org/apache/druid/security/authorization
- druid-bloom-filter
- src
- main/java/org/apache/druid/query/aggregation/bloom/sql
- test/java/org/apache/druid/query
- aggregation/bloom
- sql
- filter
- druid-catalog
- src
- main/java/org/apache/druid/catalog
- storage/sql
- sync
- test/java/org/apache/druid/catalog/compact
- druid-kerberos
- src/main/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
- ec2-extensions
- src
- main/java/org/apache/druid/indexing/overlord/autoscaling/ec2
- test/java/org/apache/druid/indexing/overlord/autoscaling/ec2
- google-extensions
- src
- main/java/org/apache/druid
- data/input/google
- storage/google
- test/java/org/apache/druid/data/input/google
- hdfs-storage
- src
- main/java/org/apache/druid
- inputsource/hdfs
- storage/hdfs
- test/java/org/apache/druid
- inputsource/hdfs
- storage/hdfs
- histogram
- src
- main/java/org/apache/druid/query/aggregation/histogram
- sql
- test/java/org/apache/druid/query/aggregation/histogram
- sql
- 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
- data/input/kinesis
- indexing/kinesis
- supervisor
- test/java/org/apache/druid
- data/input/kinesis
- indexing/kinesis
- supervisor
- kubernetes-extensions
- src
- main/java/org/apache/druid/k8s/discovery
- test/java/org/apache/druid/k8s/discovery
- kubernetes-overlord-extensions
- src
- main/java/org/apache/druid/k8s/overlord
- common
- httpclient/vertx
- execution
- taskadapter
- test
- java/org/apache/druid/k8s/overlord
- common
- httpclient
- jdk
- okhttp
- vertx
- execution
- runnerstrategy
- taskadapter
- resources
- lookups-cached-global
- lookups-cached-single
- mysql-metadata-storage
- src
- main/java/org/apache/druid/metadata/storage/mysql
- test/java/org/apache/druid/metadata
- input
- storage/mysql
- orc-extensions
- example
- src
- main/java/org/apache/druid/data/input/orc
- test/java/org/apache/druid/data/input/orc
- parquet-extensions
- example
- compat
- decimals
- flattening
- timestamps
- wiki
- src
- main/java/org/apache
- druid/data/input/parquet
- avro
- simple
- parquet/avro
- test/java/org/apache/druid/data/input/parquet
- postgresql-metadata-storage
- src
- main/java/org/apache/druid/metadata/storage/postgresql
- test/java/org/apache/druid/metadata/storage/postgresql
- protobuf-extensions
- src
- main/java/org/apache/druid/data/input/protobuf
- test/java/org/apache/druid/data/input/protobuf
- s3-extensions
- src
- main/java/org/apache/druid
- data/input/s3
- storage/s3
- output
- test/java/org/apache/druid
- data/input/s3
- storage/s3
- output
- simple-client-sslcontext
- stats
- src/test/java/org/apache/druid/query/aggregation/variance/sql
- testing-tools
- src
- main/java/org/apache/druid
- guice
- testing/cluster
- overlord
- task
- test/java/org/apache/druid/guice
- indexing-hadoop
- src
- main
- java/org/apache/druid/indexer
- hadoop
- path
- updater
- resources
- test
- java/org/apache/druid/indexer
- hadoop
- partitions
- path
- updater
- resources
- test-segment
- indexing-service
- src
- main/java/org/apache/druid
- guice
- indexing
- common
- actions
- config
- stats
- task
- batch/parallel
- compact
- input
- overlord
- config
- duty
- hrtr
- http
- sampler
- setup
- supervisor
- seekablestream
- common
- supervisor
- autoscaler
- worker
- http
- shuffle
- metadata
- test/java/org/apache/druid
- guice
- indexing
- common
- actions
- config
- stats
- task
- batch/parallel
- distribution
- compact
- input
- overlord
- duty
- hrtr
- http
- sampler
- setup
- supervisor
- autoscaler
- seekablestream
- supervisor
- autoscaler
- test
- worker
- http
- shuffle
- integration-tests-ex
- tools
- src/main
- java/org/apache/druid/testing/tools
- resources/META-INF/services
- integration-tests
- docker
- environment-configs
- override-examples
- hadoop
- test-groups
- ldap-configs
- schema-registry
- service-supervisords
- test-data
- tls
- k8s
- script
- src
- main
- java/org
- apache/druid/testing
- clients
- guice
- utils
- testng
- resources
- META-INF/services
- test
- java/org/apache/druid/tests
- coordinator/duty
- hadoop
- indexer
- parallelized
- query
- security
- resources
- data
- batch_index
- avro
- csv
- hadoop_tsv
- json
- multiple_schema_parquet
- orc
- parquet
- tsv
- broadcast
- hadoop
- indexer
- queries
- results
- stream
- data
- avro_schema_registry
- input_format
- parser
- serializer
- avro
- input_format
- parser
- serializer
- csv
- input_format
- parser
- serializer
- json
- input_format
- parser
- serializer
- protobuf_schema_registry
- input_format
- parser
- serializer
- protobuf
- input_format
- parser
- serializer
- tsv
- input_format
- parser
- serializer
- queries
- multi-stage-query
- src
- main/java/org/apache/druid/msq
- counters
- dart
- controller
- http
- messages
- sql
- guice
- worker
- http
- exec
- std
- guice
- indexing
- cleaner
- client
- destination
- error
- processor
- input
- external
- inline
- lookup
- stage
- table
- kernel
- controller
- worker
- logical
- stages
- querykit
- common
- groupby
- results
- scan
- rpc
- shuffle
- input
- output
- sql
- resources
- util
- test
- java/org/apache/druid/msq
- counters
- dart
- controller
- http
- messages
- sql
- worker
- http
- exec
- indexing
- error
- processor
- input
- external
- stage
- table
- kernel
- controller
- querykit
- common
- groupby
- results
- scan
- rpc
- shuffle
- output
- sql
- resources
- statistics
- test
- util
- quidem/org.apache.druid.msq.quidem.MSQQuidemTest
- resources
- processing
- src
- main
- java/org/apache/druid
- collections
- common
- config
- guava
- data/input
- impl
- error
- frame
- channel
- file
- processor
- read
- util
- wire
- write
- guice
- indexer/partitions
- jackson
- java/util
- common
- concurrent
- granularity
- io/smoosh
- parsers
- emitter
- core
- service
- metrics
- math/expr
- vector
- metadata
- query
- aggregation
- mean
- post
- context
- filter
- groupby
- epinephelinae
- orderby
- http
- metadata
- planning
- policy
- rowsandcols
- concrete
- semantic
- serde
- search
- timeseries
- topn
- segment
- column
- data
- file
- filter
- incremental
- index
- semantic
- join/filter
- loading
- nested
- projections
- serde
- transform
- vector
- virtual
- timeline
- partition
- utils
- resources
- test/java/org/apache/druid
- annotations
- audit
- collections
- bitmap
- fastutil
- spatial
- search
- split
- common
- config
- exception
- guava
- jackson
- semantic
- utils
- concurrent
- crypto
- data/input
- impl
- prefetch
- error
- frame
- allocation
- channel
- field
- file
- key
- processor
- manager
- test
- testutil
- util
- wire
- write
- guice
- indexer
- granularity
- partitions
- report
- io
- jackson
- java/util
- common
- concurrent
- function
- guava
- io
- smoosh
- logger
- parsers
- emitter
- core
- service
- http/client
- io
- response
- metrics
- cgroups
- js
- math/expr
- vector
- metadata
- query
- aggregation
- any
- constant
- firstlast
- first
- last
- hyperloglog
- mean
- post
- dimension
- explain
- expression
- extraction
- filter
- vector
- groupby
- epinephelinae
- collection
- column
- vector
- having
- orderby
- http
- lookup
- metadata
- monomorphicprocessing
- operator
- window
- ranking
- value
- ordering
- planning
- policy
- rowsandcols
- column
- semantic
- serde
- scan
- search
- select
- spec
- timeboundary
- timeseries
- topn
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
5 | 5 | | |
6 | 6 | | |
7 | 7 | | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
8 | 12 | | |
9 | 13 | | |
10 | 14 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
23 | 23 | | |
24 | 24 | | |
25 | 25 | | |
26 | | - | |
27 | 26 | | |
28 | 27 | | |
29 | 28 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
18 | | - | |
| 18 | + | |
19 | 19 | | |
20 | 20 | | |
21 | 21 | | |
| |||
| 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 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 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 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
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 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
21 | | - | |
| 21 | + | |
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
| |||
| 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 | + | |
| 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 | + | |
0 commit comments