File tree
530 files changed
+1699
-1634
lines changed- paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark
- paimon-codegen
- src/main/scala/org/apache/paimon/codegen
- paimon-common/src
- main/java/org/apache/paimon
- annotation
- codegen/codesplit
- data
- columnar
- heap
- writable
- format
- fs
- hadoop
- io
- lookup/hash
- memory
- options
- plugin
- statistics
- table
- types
- utils
- test/java/org/apache/paimon
- codegen/codesplit
- data
- datagen
- lookup/hash
- statistics
- utils
- paimon-core/src
- main/java/org/apache/paimon
- append
- catalog
- consumer
- disk
- format
- io
- manifest
- mergetree/compact
- aggregate
- table
- query
- sink
- utils
- test/java/org/apache/paimon
- append
- disk
- format
- io
- manifest
- mergetree/compact
- table/system
- utils
- paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform
- paimon-flink
- paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
- paimon-flink-common/src
- main/java/org/apache/paimon/flink
- lookup
- procedure
- query
- shuffle
- sink
- test/java/org/apache/paimon/flink
- lookup
- source
- paimon-format/src
- main/java/org/apache/paimon/format
- avro
- orc
- parquet
- reader
- test/java/org/apache/paimon/format
- orc
- parquet
- paimon-hive
- paimon-hive-catalog/src/main/java/org/apache
- flink/table/hive
- paimon/hive
- paimon-hive-common/src
- main/java/org/apache/paimon/hive
- test/java/org/apache/paimon/hive
- paimon-hive-connector-2.3/src/test/java/org/apache/paimon/hive
- paimon-hive-connector-3.1/src
- main/java/org/apache/paimon/hive/objectinspector
- test/java/org/apache/paimon/hive
- paimon-hive-connector-common/src
- main/java/org/apache
- flink/table/store
- hive
- mapred
- paimon/hive
- mapred
- objectinspector
- utils
- test/java/org/apache/paimon/hive
- annotation
- objectinspector
- paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network
- paimon-spark
- paimon-spark-2/src
- main/java/org/apache/paimon/spark
- test/java/org/apache/paimon/spark
- paimon-spark-3.1
- src
- main/scala/org/apache
- paimon/spark
- catalyst
- analysis
- trees
- leafnode
- statistics
- spark/sql
- test/java/org/apache/paimon/spark
- paimon-spark-3.2
- src
- main/scala/org/apache
- paimon/spark
- catalyst/analysis
- statistics
- spark/sql
- execution/shim
- test
- java/org/apache/paimon/spark
- scala/org/apache
- paimon/spark
- procedure
- sql
- spark/paimon
- paimon-spark-3.3
- src
- main/scala/org/apache
- paimon/spark
- catalyst
- analysis
- optimizer
- statistics
- spark/sql/execution/shim
- test/scala/org/apache
- paimon/spark
- procedure
- sql
- spark/paimon
- paimon-spark-3.4
- src
- main/scala/org/apache
- paimon/spark/catalyst/optimizer
- spark/sql/execution/shim
- test/scala/org/apache
- paimon/spark
- procedure
- sql
- spark/paimon
- paimon-spark-3.5
- src
- main/scala/org/apache/paimon/spark/catalyst/optimizer
- test/scala/org/apache/paimon/spark
- procedure
- sql
- paimon-spark-common
- src
- main
- java/org/apache/paimon/spark
- analysis
- catalog
- procedure
- sort
- scala/org/apache
- paimon/spark
- catalog
- catalyst
- analysis
- expressions
- optimizer
- plans/logical
- commands
- execution
- extensions
- leafnode
- schema
- sources
- statistics
- util
- spark/sql
- catalyst/parser/extensions
- connector/catalog
- execution
- shim
- test
- java/org/apache/paimon/spark
- extensions
- scala/org/apache
- paimon/spark
- procedure
- sql
- spark/paimon
- tools/ci/paimon-ci-tools/src
- main/java/org/apache/paimon/tools/ci
- suffixcheck
- utils
- dependency
- shade
- test/java/org/apache/paimon/tools/ci
- licensecheck
- utils
- dependency
- shade
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
530 files changed
+1699
-1634
lines changedOriginal 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 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
2 | 9 |
| |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
8 |
| - | |
9 |
| - | |
10 |
| - | |
11 |
| - | |
12 |
| - | |
13 |
| - | |
14 |
| - | |
15 |
| - | |
16 |
| - | |
17 |
| - | |
| 10 | + | |
18 | 11 |
| |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
19 | 17 |
| |
20 | 18 |
| |
21 | 19 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
2 | 9 |
| |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
8 |
| - | |
9 |
| - | |
10 |
| - | |
11 |
| - | |
12 |
| - | |
13 |
| - | |
14 |
| - | |
15 |
| - | |
16 |
| - | |
17 |
| - | |
| 10 | + | |
18 | 11 |
| |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
19 | 17 |
| |
20 | 18 |
| |
21 | 19 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
59 | 59 |
| |
60 | 60 |
| |
61 | 61 |
| |
62 |
| - | |
63 |
| - | |
64 |
| - | |
65 |
| - | |
66 |
| - | |
67 |
| - | |
68 |
| - | |
69 |
| - | |
70 |
| - | |
71 |
| - | |
72 |
| - | |
73 |
| - | |
74 |
| - | |
75 |
| - | |
76 |
| - | |
77 |
| - | |
78 |
| - | |
79 |
| - | |
80 |
| - | |
81 | 62 |
| |
82 | 63 |
| |
83 | 64 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
18 | 19 |
| |
19 | 20 |
| |
20 | 21 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
7 | 7 |
| |
8 | 8 |
| |
9 | 9 |
| |
10 |
| - | |
| 10 | + | |
11 | 11 |
| |
12 | 12 |
| |
13 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
7 | 7 |
| |
8 | 8 |
| |
9 | 9 |
| |
10 |
| - | |
| 10 | + | |
11 | 11 |
| |
12 | 12 |
| |
13 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
8 |
| - | |
9 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 |
| - | |
4 |
| - | |
5 |
| - | |
6 |
| - | |
7 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
8 | 9 |
| |
9 |
| - | |
| 10 | + | |
10 | 11 |
| |
11 | 12 |
| |
12 | 13 |
| |
|
0 commit comments