File tree
820 files changed
+43216
-13195
lines changed- .github
- workflows
- scripts/pr-tests
- .mvn
- docker/images/pinot-base/pinot-base-runtime
- helm
- pinot
- templates
- broker
- controller
- minion
- server
- pinot-broker
- src
- main/java/org/apache/pinot/broker
- api/resources
- broker/helix
- requesthandler
- routing/instanceselector
- test/java/org/apache/pinot/broker
- api/resources
- broker
- queryquota
- requesthandler
- routing/instanceselector
- pinot-clients
- pinot-java-client
- src/test/java/org/apache/pinot/client
- pinot-jdbc-client
- pinot-common
- src
- main
- java/org/apache/pinot
- common
- datablock
- datatable
- function
- scalar
- arithmetic
- comparison
- metadata
- metrics
- request/context
- response
- utils
- config
- grpc
- helix
- sql/parsers
- proto
- test/java/org/apache/pinot
- common
- datablock
- data
- metrics
- utils
- config
- sql/parsers
- rewriter
- pinot-compatibility-verifier
- pinot-connectors
- pinot-flink-connector
- src
- main/java/org/apache/pinot/connector/flink
- sink
- test
- java/org/apache/pinot/connector/flink/sink
- resources
- pinot-spark-2-connector
- pinot-spark-3-connector
- documentation
- 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
- resources
- upload
- helix
- core
- assignment/segment
- realtime
- segment
- rebalance
- relocation
- util
- validation
- resources
- test/java/org/apache/pinot/controller
- api
- resources
- helix
- core
- assignment/segment
- realtime
- segment
- rebalance
- util
- validation
- pinot-core
- src
- main/java/org/apache/pinot/core
- accounting
- common
- datablock
- datatable
- data/manager
- offline
- realtime
- minion
- operator
- blocks
- results
- combine
- merger
- filter
- query
- streaming
- timeseries
- transform
- function
- plan
- maker
- query
- aggregation
- function
- utils/exprminmax
- executor
- optimizer/filter
- postaggregation
- reduce
- request
- context
- utils
- selection
- segment/processing/genericrow
- startree
- transport
- grpc
- util
- test
- java/org/apache/pinot
- core
- accounting
- common
- datablock
- datatable
- data
- function
- manager
- offline
- realtime
- function
- operator/transform/function
- query
- aggregation/function
- executor
- optimizer/filter
- postaggregation
- startree/v2
- transport
- 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
- custom
- resources
- pinot-minion
- pinot-perf
- src/main/java/org/apache/pinot/perf
- pinot-plugins
- assembly-descriptor
- src
- it/projects/simple-assembly
- src/main
- java/org/apache/pinot/it
- resources
- main/resources/assemblies
- pinot-batch-ingestion
- pinot-batch-ingestion-common
- pinot-batch-ingestion-hadoop
- pinot-batch-ingestion-spark-2.4
- pinot-batch-ingestion-spark-3
- src
- main/java/org/apache/pinot/plugin/ingestion/batch/spark3
- test/java/org/apache/pinot/plugin/ingestion/batch/spark3
- pinot-batch-ingestion-standalone
- pinot-environment
- pinot-azure
- pinot-file-system
- pinot-adls
- pinot-gcs
- 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
- pinot-confluent-avro
- 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
- src/main/java/org/apache/pinot/plugin/inputformat/orc
- pinot-parquet
- src/main/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-dropwizard
- src/main/resources
- pinot-yammer
- pinot-minion-tasks
- pinot-minion-builtin-tasks
- src
- main/java/org/apache/pinot/plugin/minion/tasks
- test/java/org/apache/pinot/plugin/minion/tasks
- pinot-segment-uploader
- pinot-segment-uploader-default
- pinot-segment-writer
- pinot-segment-writer-file-based
- pinot-stream-ingestion
- pinot-kafka-2.0
- src
- main/java/org/apache/pinot/plugin/stream/kafka20
- 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
- resources
- pinot-kafka-base
- src
- main/java/org/apache/pinot/plugin/stream/kafka
- test/java/org/apache/pinot/plugin/stream/kafka
- utils
- pinot-kinesis
- pinot-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
- rules
- sql2rel
- sql/fun
- query
- catalog
- context
- planner
- explain
- logical
- physical
- colocated
- plannode
- serde
- validation
- routing
- type
- test
- java/org/apache/pinot/query
- queries
- resources/queries
- pinot-query-runtime
- src
- main/java/org/apache/pinot/query
- mailbox
- runtime
- blocks
- operator
- plan
- pipeline
- server
- timeseries
- service
- dispatch
- timeseries
- server
- test/java/org/apache/pinot/query
- runtime
- blocks
- executor
- operator
- plan
- pipeline
- queries
- timeseries
- service
- dispatch
- server
- pinot-segment-local
- src
- main/java/org/apache/pinot/segment/local
- aggregator
- constants
- dedup
- indexsegment
- immutable
- mutable
- io/writer/impl
- realtime
- converter
- impl
- forward
- recordtransformer
- segment
- creator/impl
- fwd
- stats
- text
- index
- converter
- datasource
- dictionary
- forward
- h3
- loader
- defaultcolumn
- map
- readers
- forward
- map
- text
- vector
- vector
- readers
- store
- startree
- v2/builder
- upsert
- utils
- test/java/org/apache/pinot/segment/local
- aggregator
- dedup
- indexsegment/mutable
- realtime/converter
- recordtransformer
- segment
- creator
- index
- dictionary
- loader
- defaultcolumn
- store
- startree/v2/builder
- upsert
- utils
- pinot-segment-spi
- src/main/java/org/apache/pinot/segment/spi
- creator
- datasource
- index
- creator
- mutable
- reader
- startree
- memory
- pinot-server
- src/main/java/org/apache/pinot/server
- starter
- helix
- worker
- pinot-spi
- src
- main/java/org/apache/pinot/spi
- accounting
- config
- instance
- table
- ingestion
- data
- readers
- eventlistener/query
- executor
- ingestion/batch
- spec
- plugin
- stream
- trace
- utils
- builder
- test
- java/org/apache/pinot/spi
- config/table
- data
- plugin
- utils
- resources/plugins
- assemblybased-pinot-plugin
- pinot-dropwizard
- pinot-yammer
- pinot-timeseries
- pinot-timeseries-planner
- src/main/java/org/apache/pinot/tsdb/planner
- physical
- pinot-timeseries-spi
- src
- main/java/org/apache/pinot/tsdb/spi
- operator
- plan
- serde
- series
- builders
- test/java/org/apache/pinot/tsdb/spi/plan
- serde
- pinot-tools
- src/main
- java/org/apache/pinot/tools
- streams
- resources/examples
- batch
- clientSalaryNulls
- rawdata
- colocated/userGroups
- lookup/userGroupsDim
- rawdata
- stream/upsertMeetupRsvp
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
820 files changed
+43216
-13195
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
34 | | - | |
35 | | - | |
36 | | - | |
37 | | - | |
| 34 | + | |
38 | 35 | | |
39 | 36 | | |
| 37 | + | |
40 | 38 | | |
41 | | - | |
42 | | - | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
28 | 41 | | |
29 | 42 | | |
30 | 43 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
123 | 123 | | |
124 | 124 | | |
125 | 125 | | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
126 | 131 | | |
127 | 132 | | |
128 | 133 | | |
| |||
140 | 145 | | |
141 | 146 | | |
142 | 147 | | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
143 | 153 | | |
144 | 154 | | |
145 | 155 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | | - | |
| 36 | + | |
37 | 37 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
40 | | - | |
| 40 | + | |
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
| |||
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
| 51 | + | |
52 | 52 | | |
| 53 | + | |
| 54 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
9 | | - | |
| 9 | + | |
| 10 | + | |
10 | 11 | | |
11 | 12 | | |
12 | 13 | | |
| |||
45 | 46 | | |
46 | 47 | | |
47 | 48 | | |
48 | | - | |
| 49 | + | |
| 50 | + | |
49 | 51 | | |
50 | 52 | | |
51 | 53 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | | - | |
| 31 | + | |
32 | 32 | | |
33 | 33 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
87 | 87 | | |
88 | 88 | | |
89 | 89 | | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
90 | 99 | | |
91 | 100 | | |
92 | 101 | | |
| |||
95 | 104 | | |
96 | 105 | | |
97 | 106 | | |
98 | | - | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
99 | 110 | | |
100 | 111 | | |
101 | 112 | | |
| |||
Lines changed: 9 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
23 | | - | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
24 | 31 | | |
25 | 32 | | |
26 | 33 | | |
27 | 34 | | |
28 | | - | |
| 35 | + | |
29 | 36 | | |
30 | 37 | | |
31 | 38 | | |
| |||
0 commit comments