File tree
2,168 files changed
+132964
-36853
lines changed- .github/workflows
- scripts
- .mvn
- wrapper
- compatibility-verifier
- multi-stage-query-engine-test-suite/config
- sample-test-suite/config
- config
- contrib/pinot-druid-benchmark
- docker/images
- pinot-base/pinot-base-build
- pinot-presto
- pinot
- etc/jmx_prometheus_javaagent/configs
- examples/docker/table-configs
- helm
- pinot
- templates
- broker
- controller
- minion-stateless
- minion
- server
- pinot-broker
- src
- main/java/org/apache/pinot/broker
- api/resources
- broker
- helix
- cursors
- grpc
- querylog
- queryquota
- requesthandler
- routing
- segmentpartition
- segmentpruner
- test/java/org/apache/pinot/broker
- api/resources
- broker
- failuredetector
- querylog
- queryquota
- requesthandler
- pinot-clients
- pinot-java-client
- src
- main/java/org/apache/pinot/client
- grpc
- utils
- test/java/org/apache/pinot/client
- utils
- pinot-jdbc-client
- src
- main/java/org/apache/pinot/client
- controller
- response
- examples
- grpc
- utils
- test/java/org/apache/pinot/client
- pinot-common
- src
- main
- java/org/apache/pinot
- common
- assignment
- auth
- collections
- compression
- concurrency
- config/provider
- cursors
- datablock
- datatable
- exception
- failuredetector
- function
- scalar
- array
- regexp
- string
- messages
- metadata
- segment
- metrics
- protocols
- request
- context
- predicate
- response
- broker
- encoder
- restlet/resources
- segment/generation
- tier
- utils
- config
- fetcher
- grpc
- helix
- http
- request
- tls
- version
- sql/parsers
- rewriter
- proto
- test/java/org/apache/pinot
- common
- assignment
- compression
- exception
- failuredetector
- function
- scalar
- regexp
- metadata
- metrics
- prometheus
- dropwizard
- yammer
- protocols
- response
- broker
- encoder
- restlet/resources
- tier
- utils
- config
- fetcher
- http
- request
- sql/parsers
- thrift
- pinot-compatibility-verifier
- src/main/java/org/apache/pinot/compat
- pinot-connectors
- pinot-flink-connector
- src
- main/java/org/apache/pinot/connector/flink/sink
- test/resources/fixtures
- pinot-spark-2-connector
- pinot-spark-3-connector
- src
- main/scala/org/apache/pinot/connector/spark/v3/datasource
- test/scala/org/apache/pinot/connector/spark/v3/datasource
- pinot-spark-common
- src
- main/scala/org/apache/pinot/connector/spark/common
- reader
- test/scala/org/apache/pinot/connector/spark/common
- pinot-controller
- src
- main
- java/org/apache/pinot/controller
- api
- access
- resources
- upload
- cursors
- helix
- core
- assignment/instance
- minion
- generator
- realtime
- segment
- rebalance
- tenant
- relocation
- retention
- strategy
- util
- recommender/data
- writer
- util
- validation
- resources
- app
- components
- Homepage
- Operations
- RebalanceServer
- RebalanceServerConfigurationOptions
- RebalanceServerConfigurationOptionLabel
- RebalanceServerResponses
- Query
- interfaces
- pages
- requests
- utils
- test
- java/org/apache/pinot/controller
- api
- access
- resources
- upload
- helix
- core
- assignment/instance
- cleanup
- minion
- realtime
- segment
- rebalance
- retention
- util
- util
- validation
- resources/memory_estimation
- pinot-core
- src
- main/java/org/apache/pinot
- core
- accounting
- auth
- common
- datablock
- datatable
- data
- manager
- offline
- provider
- realtime
- table
- geospatial/transform/function
- minion
- operator
- blocks
- results
- combine
- merger
- dociditerators
- docvalsets
- filter
- query
- streaming
- timeseries
- transform
- function
- transformer/datetime
- plan
- maker
- query
- aggregation
- function
- array
- distinct
- funnel
- window
- groupby
- config
- distinct
- dictionary
- raw
- table
- executor
- sql
- optimizer/filter
- postaggregation
- reduce
- request
- context
- utils
- scheduler
- fcfs
- selection
- utils
- routing
- segment/processing
- aggregator
- framework
- genericrow
- mapper
- reducer
- startree/plan
- transport
- grpc
- server/routing/stats
- util
- trace
- server/realtime
- test
- java/org/apache/pinot
- core
- accounting
- auth
- common
- datablock
- datatable
- data
- function
- manager
- offline
- realtime
- table
- function
- geospatial/transform
- function
- minion
- operator
- combine
- filter
- transform
- function
- transformer/datetime
- plan/maker
- query
- aggregation
- function
- distinct
- groupby
- executor
- optimizer
- filter
- pruner
- reduce
- scheduler
- realtime
- impl/fakestream
- stream
- segment/processing/aggregator
- transport
- server/routing/stats
- util
- queries
- resources
- data
- pinot-distribution
- pinot-integration-test-base
- src/test/java/org/apache/pinot/integration/tests
- pinot-integration-tests
- src/test
- java/org/apache/pinot/integration/tests
- cursors
- custom
- plugin/minion/tasks
- realtime/utils
- tpch
- window/utils
- resources
- pinot-minion
- src
- main/java/org/apache/pinot/minion
- api/resources
- event
- taskfactory
- test/java/org/apache/pinot/minion
- api/resources
- event
- pinot-perf
- src/main/java/org/apache/pinot/perf
- aggregation
- pinot-plugins
- assembly-descriptor
- pinot-batch-ingestion
- pinot-batch-ingestion-common
- src/main/java/org/apache/pinot/plugin/ingestion/batch/common
- pinot-batch-ingestion-hadoop
- src/main/java/org/apache/pinot/plugin/ingestion/batch/hadoop
- pinot-batch-ingestion-spark-2.4
- src/main/java/org/apache/pinot/plugin/ingestion/batch/spark
- pinot-batch-ingestion-spark-3
- src/main/java/org/apache/pinot/plugin/ingestion/batch/spark3
- pinot-batch-ingestion-spark-base
- src/main/java/org/apache/pinot/plugin/ingestion/batch/spark/common
- pinot-batch-ingestion-standalone
- src/main/java/org/apache/pinot/plugin/ingestion/batch/standalone
- pinot-environment
- pinot-azure
- pinot-file-system
- pinot-adls
- src
- main/java/org/apache/pinot/plugin/filesystem
- test/java/org/apache/pinot/plugin/filesystem/test
- pinot-gcs
- src/main/java/org/apache/pinot/plugin/filesystem
- pinot-hdfs
- pinot-s3
- src
- main/java/org/apache/pinot/plugin/filesystem
- test/java/org/apache/pinot/plugin/filesystem
- pinot-input-format
- pinot-avro-base
- src
- main/java/org/apache/pinot/plugin/inputformat/avro
- test/java/org/apache/pinot/plugin/inputformat/avro
- pinot-avro
- pinot-clp-log
- src
- main/java/org/apache/pinot/plugin/inputformat/clplog
- test/java/org/apache/pinot/plugin/inputformat/clplog
- pinot-confluent-avro
- pinot-confluent-json
- src
- main/java/org/apache/pinot/plugin/inputformat/json/confluent
- test/java/org/apache/pinot/plugin/inputformat/json/confluent
- kafka/schemaregistry
- pinot-confluent-protobuf
- src
- main/java/org/apache/pinot/plugin/inputformat/protobuf
- test
- java/org/apache/pinot/plugin/inputformat/protobuf
- kafka/schemaregistry
- resources
- pinot-csv
- src
- main/java/org/apache/pinot/plugin/inputformat/csv
- test
- java/org/apache/pinot/plugin/inputformat/csv
- resources
- pinot-json
- src/main/java/org/apache/pinot/plugin/inputformat/json
- pinot-orc
- pinot-parquet
- src
- main/java/org/apache/pinot/plugin/inputformat/parquet
- test/java/org/apache/pinot/plugin/inputformat/parquet
- pinot-protobuf
- src/main/java/org/apache/pinot/plugin/inputformat/protobuf
- pinot-thrift
- src/main/java/org/apache/pinot/plugin/inputformat/thrift
- pinot-metrics
- pinot-compound-metrics
- src/main/java/org/apache/pinot/plugin/metrics/compound
- pinot-dropwizard
- src/main/java/org/apache/pinot/plugin/metrics/dropwizard
- pinot-yammer
- src/main/java/org/apache/pinot/plugin/metrics/yammer
- pinot-minion-tasks
- pinot-minion-builtin-tasks
- src
- main/java/org/apache/pinot/plugin/minion/tasks
- mergerollup
- purge
- realtimetoofflinesegments
- refreshsegment
- segmentgenerationandpush
- upsertcompaction
- upsertcompactmerge
- test/java/org/apache/pinot/plugin/minion/tasks
- mergerollup
- purge
- realtimetoofflinesegments
- upsertcompaction
- upsertcompactmerge
- pinot-segment-uploader
- pinot-segment-uploader-default
- pinot-segment-writer
- pinot-segment-writer-file-based
- src/main/java/org/apache/pinot/plugin/segmentwriter/filebased
- pinot-stream-ingestion
- pinot-kafka-2.0
- src
- main/java/org/apache/pinot/plugin/stream/kafka20
- server
- test/java/org/apache/pinot/plugin/stream/kafka20
- utils
- pinot-kafka-3.0
- src
- main/java/org/apache/pinot/plugin/stream/kafka30
- test/java/org/apache/pinot/plugin/stream/kafka30
- utils
- pinot-kafka-base
- src
- main/java/org/apache/pinot/plugin/stream/kafka
- test/java/org/apache/pinot/plugin/stream/kafka/utils
- pinot-kinesis
- src
- main/java/org/apache/pinot/plugin/stream/kinesis
- test/java/org/apache/pinot/plugin/stream/kinesis
- pinot-pulsar
- src
- main/java/org/apache/pinot/plugin/stream/pulsar
- test/java/org/apache/pinot/plugin/stream/pulsar
- pinot-timeseries-lang
- pinot-timeseries-m3ql
- src/main/java/org/apache/pinot/tsdb/m3ql
- operator
- parser
- plan
- time
- pinot-query-planner
- src
- main/java/org/apache/pinot
- calcite
- rel
- hint
- logical
- rules
- traits
- sql/fun
- query
- catalog
- context
- function
- parser
- utils
- planner
- explain
- logical
- physical
- colocated
- v2
- mapping
- nodes
- opt
- rules
- plannode
- serde
- routing
- test
- java/org/apache/pinot
- calcite/rel/rules
- query
- planner
- logical
- physical/v2
- mapping
- opt
- rules
- serde
- testutils
- resources/queries
- pinot-query-runtime
- src
- main/java/org/apache/pinot/query
- mailbox
- channel
- runtime
- blocks
- executor
- operator
- exchange
- groupby
- join
- operands
- utils
- window
- aggregate
- range
- value
- plan
- pipeline
- server
- timeseries
- serde
- service
- dispatch
- timeseries
- server
- test
- java/org/apache/pinot/query
- mailbox
- runtime
- blocks
- executor
- operator
- exchange
- plan/pipeline
- queries
- timeseries
- serde
- service
- dispatch
- server
- testutils
- resources
- queries
- pinot-segment-local
- src
- main/java/org/apache/pinot/segment/local
- customobject
- data/manager
- dedup
- function
- indexsegment
- immutable
- mutable
- io
- reader/impl
- util
- writer/impl
- realtime
- converter
- stats
- impl
- forward
- geospatial
- json
- vector
- writer
- recordtransformer
- enricher
- clp
- function
- segment
- creator
- impl
- fwd
- inv
- geospatial
- text
- stats
- text
- vector
- lucene99
- index
- bloom
- converter
- dictionary
- forward
- fst
- inverted
- json
- loader
- defaultcolumn
- invertedindex
- map
- range
- readers
- forward
- json
- text
- text
- vector
- readers
- store
- startree/v2/builder
- upsert
- merger
- columnar
- utils
- nativefst
- test
- java/org/apache/pinot/segment/local
- dedup
- indexsegment/mutable
- io
- reader/impl
- util
- writer/impl
- realtime
- converter
- impl/dictionary
- recordtransformer
- segment
- creator
- impl
- index
- bloom
- creator
- inv
- dictionary
- forward
- mutable
- fst
- inverted
- loader
- readers
- forward
- text
- readerwriter
- reader
- writer
- readers
- store
- upsert
- utils
- fst
- nativefst
- resources/data
- pinot-segment-spi
- src
- main/java/org/apache/pinot/segment/spi
- creator
- name
- index
- mutable
- reader
- startree
- memory
- unsafe
- partition
- store
- test/java/org/apache/pinot/segment/spi
- index
- memory
- partition
- pinot-server
- src
- main/java/org/apache/pinot/server
- api/resources
- conf
- predownload
- starter
- helix
- worker
- test
- java/org/apache/pinot/server
- api
- predownload
- resources/data
- pinot-spi
- src
- main/java/org/apache/pinot/spi
- accounting
- config
- instance
- provider
- table
- ingestion
- user
- cursors
- data
- readers
- env
- exception
- executor
- filesystem
- ingestion/batch
- spec
- metrics
- plugin
- query
- recordenricher
- recordtransformer
- enricher
- secretstore
- stream
- tasks
- trace
- utils
- builder
- hash
- retry
- test
- java/org/apache/pinot/spi
- config
- data
- env
- executor
- plugin
- stream
- tasks
- utils
- resources
- pinot-timeseries
- pinot-timeseries-planner
- src
- main/java/org/apache/pinot/tsdb/planner
- physical
- test/java/org/apache/pinot/tsdb/planner
- pinot-timeseries-spi
- src
- main/java/org/apache/pinot/tsdb/spi
- plan
- serde
- series
- builders
- test/java/org/apache/pinot/tsdb/spi
- plan
- serde
- series
- pinot-tools
- src
- main
- java/org/apache/pinot/tools
- admin
- command
- filesystem
- filesystem
- perf
- segment/converter
- resources
- conf
- examples
- batch/githubComplexTypeEvents
- minions/stream/githubEvents
- stream
- airlineStats/docker
- dailySales
- rawdata
- test/java/org/apache/pinot/tools/admin/command
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,168 files changed
+132964
-36853
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
34 | | - | |
35 | 34 | | |
36 | 35 | | |
37 | | - | |
38 | | - | |
39 | | - | |
40 | 36 | | |
| 37 | + | |
| 38 | + | |
41 | 39 | | |
42 | | - | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
58 | 58 | | |
59 | 59 | | |
60 | 60 | | |
61 | | - | |
| 61 | + | |
62 | 62 | | |
63 | 63 | | |
64 | 64 | | |
| |||
112 | 112 | | |
113 | 113 | | |
114 | 114 | | |
115 | | - | |
| 115 | + | |
116 | 116 | | |
117 | 117 | | |
118 | 118 | | |
| |||
134 | 134 | | |
135 | 135 | | |
136 | 136 | | |
137 | | - | |
| 137 | + | |
138 | 138 | | |
139 | 139 | | |
140 | 140 | | |
| |||
152 | 152 | | |
153 | 153 | | |
154 | 154 | | |
155 | | - | |
| 155 | + | |
156 | 156 | | |
157 | 157 | | |
158 | 158 | | |
159 | 159 | | |
160 | 160 | | |
| 161 | + | |
161 | 162 | | |
162 | 163 | | |
163 | 164 | | |
| |||
202 | 203 | | |
203 | 204 | | |
204 | 205 | | |
205 | | - | |
| 206 | + | |
206 | 207 | | |
207 | 208 | | |
208 | 209 | | |
| |||
219 | 220 | | |
220 | 221 | | |
221 | 222 | | |
222 | | - | |
| 223 | + | |
223 | 224 | | |
224 | 225 | | |
225 | 226 | | |
| |||
232 | 233 | | |
233 | 234 | | |
234 | 235 | | |
235 | | - | |
| 236 | + | |
236 | 237 | | |
237 | 238 | | |
238 | 239 | | |
239 | 240 | | |
240 | 241 | | |
| 242 | + | |
241 | 243 | | |
242 | 244 | | |
243 | 245 | | |
244 | 246 | | |
245 | 247 | | |
246 | 248 | | |
247 | 249 | | |
248 | | - | |
| 250 | + | |
249 | 251 | | |
250 | 252 | | |
251 | 253 | | |
| |||
259 | 261 | | |
260 | 262 | | |
261 | 263 | | |
262 | | - | |
| 264 | + | |
263 | 265 | | |
264 | 266 | | |
265 | 267 | | |
266 | 268 | | |
267 | 269 | | |
| 270 | + | |
268 | 271 | | |
269 | 272 | | |
270 | 273 | | |
| |||
277 | 280 | | |
278 | 281 | | |
279 | 282 | | |
280 | | - | |
| 283 | + | |
281 | 284 | | |
282 | 285 | | |
283 | 286 | | |
| |||
333 | 336 | | |
334 | 337 | | |
335 | 338 | | |
336 | | - | |
| 339 | + | |
337 | 340 | | |
338 | 341 | | |
339 | 342 | | |
| |||
407 | 410 | | |
408 | 411 | | |
409 | 412 | | |
410 | | - | |
| 413 | + | |
411 | 414 | | |
412 | 415 | | |
413 | 416 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
21 | | - | |
22 | 21 | | |
23 | | - | |
| 22 | + | |
24 | 23 | | |
25 | | - | |
26 | | - | |
27 | | - | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
28 | 33 | | |
29 | 34 | | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
30 | 41 | | |
31 | 42 | | |
| 43 | + | |
32 | 44 | | |
33 | 45 | | |
34 | 46 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| 6 | + | |
6 | 7 | | |
7 | 8 | | |
8 | 9 | | |
| |||
56 | 57 | | |
57 | 58 | | |
58 | 59 | | |
| 60 | + | |
Lines changed: 9 additions & 10 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
19 | 19 | | |
20 | 20 | | |
21 | 21 | | |
22 | | - | |
| 22 | + | |
| 23 | + | |
23 | 24 | | |
24 | | - | |
| 25 | + | |
25 | 26 | | |
26 | 27 | | |
27 | 28 | | |
28 | | - | |
29 | | - | |
30 | | - | |
31 | | - | |
32 | | - | |
33 | 29 | | |
34 | | - | |
35 | | - | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
36 | 35 | | |
37 | 36 | | |
38 | 37 | | |
| |||
45 | 44 | | |
46 | 45 | | |
47 | 46 | | |
48 | | - | |
| 47 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
26 | | - | |
| 25 | + | |
| 26 | + | |
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
| |||
Lines changed: 3 additions & 13 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | 1 | | |
3 | 2 | | |
4 | 3 | | |
| |||
15 | 14 | | |
16 | 15 | | |
17 | 16 | | |
18 | | - | |
19 | | - | |
20 | | - | |
21 | | - | |
22 | | - | |
23 | | - | |
24 | | - | |
25 | | - | |
26 | | - | |
27 | | - | |
28 | | - | |
29 | | - | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
139 | 139 | | |
140 | 140 | | |
141 | 141 | | |
142 | | - | |
| 142 | + | |
143 | 143 | | |
144 | 144 | | |
145 | 145 | | |
| |||
165 | 165 | | |
166 | 166 | | |
167 | 167 | | |
168 | | - | |
| 168 | + | |
169 | 169 | | |
170 | 170 | | |
171 | 171 | | |
172 | 172 | | |
173 | | - | |
| 173 | + | |
174 | 174 | | |
175 | 175 | | |
176 | 176 | | |
| |||
0 commit comments