Commit 33f2677
authored
File tree
1,849 files changed
+90201
-22029
lines changed- .github/workflows
- docs
- content
- append-table
- cdc-ingestion
- concepts
- spec
- engines
- filesystems
- flink
- learn-paimon
- maintenance
- migration
- primary-key-table
- merge-engine
- program-api
- project
- spark
- layouts/shortcodes/generated
- static/img
- paimon-arrow
- src
- main/java/org/apache/paimon/arrow
- converter
- reader
- vector
- writer
- test/java/org/apache/paimon/arrow
- converter
- vector
- paimon-benchmark
- paimon-cluster-benchmark
- src/main/java/org/apache/paimon/benchmark
- metric/cpu
- paimon-micro-benchmarks
- src/test/java/org/apache/paimon/benchmark
- bitmap
- cache
- lookup
- paimon-bundle
- paimon-codegen-loader
- paimon-codegen
- src
- main
- java/org/apache/paimon/codegen
- scala/org/apache/paimon/codegen
- test/java/org/apache/paimon/codegen
- paimon-common
- src
- main
- java/org/apache/paimon
- casting
- client
- codegen
- compression
- data
- columnar
- heap
- safe
- serializer
- variant
- factories
- fileindex
- bitmap
- bloomfilter
- bsi
- format
- fs
- hadoop
- io
- cache
- lineage
- lookup
- hash
- sort
- memory
- options
- predicate
- reader
- sort/hilbert
- statistics
- table
- types
- utils
- resources/META-INF
- services
- test/java/org/apache/paimon
- casting
- data
- variant
- fileindex
- bitmapindex
- bsi
- format
- fs
- io/cache
- lookup/sort
- utils
- paimon-core
- src
- main
- java/org/apache/paimon
- append
- catalog
- codegen
- compact
- consumer
- crosspartition
- deletionvectors
- disk
- format
- hash
- iceberg
- manifest
- metadata
- migrate
- index
- io
- jdbc
- lookup
- manifest
- mergetree
- compact
- aggregate
- factory
- localmerge
- metastore
- metrics
- migrate
- operation
- metrics
- partition
- actions
- privilege
- rest
- auth
- exceptions
- requests
- responses
- schema
- sort
- zorder
- stats
- table
- object
- query
- sink
- source
- snapshot
- splitread
- system
- tag
- utils
- view
- resources/META-INF
- services
- test
- java/org/apache/paimon
- append
- catalog
- codegen
- crosspartition
- deletionvectors/append
- format
- hash
- iceberg
- migrate
- index
- io
- jdbc
- manifest
- mergetree
- compact
- aggregate
- metrics
- operation
- metrics
- privilege
- rest
- auth
- schema
- stats
- table
- sink
- source
- snapshot
- system
- tag
- utils
- resources
- META-INF/services
- compatibility
- paimon-docs
- src/main/java/org/apache/paimon/docs/configuration
- paimon-e2e-tests
- src/test
- java/org/apache/paimon/tests
- resources-filtered
- paimon-filesystems
- paimon-hadoop-shaded
- paimon-oss-impl
- src/main/java/org/apache/paimon/oss
- paimon-oss
- paimon-s3-impl
- src/main/java/org/apache/paimon/s3
- paimon-s3
- paimon-flink
- paimon-flink-1.15
- src
- main/java/org/apache
- flink
- api
- common
- functions
- serialization
- connector
- sink2
- source
- streaming
- api/functions/sink/v2
- runtime/streamrecord
- table/catalog
- paimon/flink
- source
- table
- utils
- test/java/org/apache/paimon/flink
- paimon-flink-1.16
- src
- main/java/org/apache
- flink
- api
- common
- functions
- serialization
- connector/sink2
- streaming
- api/functions/sink/v2
- runtime/streamrecord
- table/catalog
- paimon/flink
- utils
- test/java/org/apache/paimon/flink/iceberg
- paimon-flink-1.17
- src
- main/java/org/apache
- flink
- api
- common
- functions
- serialization
- connector/sink2
- streaming
- api/functions/sink/v2
- runtime/streamrecord
- table/catalog
- paimon/flink
- utils
- test/java/org/apache/paimon/flink/iceberg
- paimon-flink-1.18
- src
- main/java/org/apache
- flink
- api
- common
- functions
- serialization
- connector/sink2
- streaming
- api/functions/sink/v2
- runtime/streamrecord
- table/catalog
- paimon/flink
- procedure
- utils
- test/java/org/apache/paimon/flink
- iceberg
- procedure
- paimon-flink-1.19
- src
- main/java/org/apache/flink/table/catalog
- test/java/org/apache/paimon/flink
- iceberg
- paimon-flink-1.20
- paimon-flink-action
- paimon-flink-cdc
- src
- main
- java/org/apache/paimon/flink
- action/cdc
- format
- aliyun
- debezium
- dms
- kafka
- mongodb
- strategy
- mysql
- postgres
- pulsar
- watermark
- kafka
- sink/cdc
- resources/META-INF/services
- test
- java/org/apache/paimon/flink
- action/cdc
- format/aliyun
- kafka
- mongodb
- mysql
- postgres
- sink/cdc
- resources
- kafka
- aliyun/table/event
- aws-dms
- database
- include/topic0
- prefixsuffix
- topic0
- topic1
- schemaevolution
- topic0
- topic1
- table
- computedcolumn
- schemaevolution
- startupmode
- watermark
- debezium/table/schema/schemaevolution
- mysql
- paimon-flink-common
- src
- main
- java/org/apache/paimon/flink
- action
- clone
- compact
- changelog
- format
- log
- lookup
- metrics
- orphan
- procedure
- query
- service
- shuffle
- sink
- index
- partition
- sorter
- source
- align
- assigners
- metrics
- operator
- table
- utils
- resources/META-INF/services
- test
- java/org/apache/paimon/flink
- action
- compact
- changelog
- iceberg
- lookup
- procedure
- sink
- partition
- sorter
- source
- align
- operator
- statistics
- util
- resources/META-INF/services
- paimon-format
- src
- main/java/org/apache
- orc/impl
- paimon/format
- avro
- orc
- filter
- reader
- writer
- parquet
- position
- reader
- type
- writer
- parquet
- filter2/predicate
- hadoop
- internal/filter2/columnindex
- test/java/org/apache/paimon/format
- avro
- orc
- writer
- parquet
- paimon-hive
- paimon-hive-catalog
- src
- main
- java/org/apache/paimon
- hive
- migrate
- pool
- iceberg
- resources/META-INF/services
- test/java/org/apache/paimon/hive
- pool
- paimon-hive-common
- src/main/java/org/apache/paimon/hive
- paimon-hive-connector-2.1-cdh-6.3
- paimon-hive-connector-2.1
- paimon-hive-connector-2.2
- paimon-hive-connector-2.3
- src/test/java/org/apache/paimon
- hive
- iceberg
- paimon-hive-connector-3.1
- src/test/java/org/apache/paimon
- hive
- iceberg
- paimon-hive-connector-common
- src
- main/java/org/apache/paimon/hive
- objectinspector
- utils
- test/java/org/apache/paimon
- hive
- procedure
- iceberg
- paimon-open-api
- src/main
- java/org/apache/paimon/open/api
- config
- resources
- paimon-service
- paimon-service-client
- src/main/java/org/apache/paimon/service/network
- paimon-service-runtime
- paimon-spark
- paimon-spark-3.1
- src
- main/scala/org/apache
- paimon/spark/catalyst/analysis
- spark/sql
- test/java/org/apache/paimon/spark
- paimon-spark-3.2
- src
- main/scala/org/apache
- paimon/spark
- catalyst/analysis
- spark/sql/catalyst/parser/extensions
- test/scala/org/apache/paimon/spark/sql
- paimon-spark-3.3
- src
- main/scala/org/apache
- paimon/spark/catalyst/analysis
- spark/sql/catalyst/parser/extensions
- test/scala/org/apache/paimon/spark
- sql
- paimon-spark-3.4
- src/test/scala/org/apache/paimon/spark
- sql
- paimon-spark-3.5
- src/test/scala/org/apache/paimon/spark/sql
- paimon-spark-4.0
- src
- main/scala/org/apache/paimon/spark/catalyst/optimizer
- test
- resources
- scala/org/apache/paimon/spark
- procedure
- sql
- paimon-spark-common
- src
- main
- antlr4/org.apache.spark.sql.catalyst.parser.extensions
- java/org/apache/paimon/spark
- catalog
- procedure
- utils
- scala/org/apache
- paimon/spark
- aggregate
- catalyst
- analysis
- expressions
- optimizer
- plans/logical
- commands
- data
- execution
- extensions
- leafnode
- orphan
- schema
- sources
- statistics
- util
- spark/sql
- catalyst/parser/extensions
- connector/catalog
- paimon
- shims
- test
- java/org/apache/paimon/spark
- scala/org/apache/paimon/spark/sql
- paimon-spark-ut
- src/test
- java/org/apache/paimon/spark
- extensions
- resources
- META-INF/services
- scala/org/apache
- paimon/spark
- procedure
- sql
- spark/sql/paimon
- paimon-spark3-common
- src/main
- resources/META-INF/services
- scala/org/apache
- paimon/spark
- catalyst
- analysis
- parser/extensions
- commands
- data
- spark/sql/paimon/shims
- paimon-spark4-common
- src/main
- resources/META-INF/services
- scala/org/apache
- paimon/spark
- catalyst
- analysis
- parser/extensions
- data
- spark/sql/paimon/shims
- paimon-test-utils
- tools
- ci/paimon-ci-tools
- maven
- releasing
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,849 files changed
+90201
-22029
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
64 | 64 | | |
65 | 65 | | |
66 | 66 | | |
67 | | - | |
| 67 | + | |
68 | 68 | | |
69 | 69 | | |
File renamed without changes.
Lines changed: 7 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
16 | 16 | | |
17 | 17 | | |
18 | 18 | | |
19 | | - | |
| 19 | + | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| |||
52 | 52 | | |
53 | 53 | | |
54 | 54 | | |
55 | | - | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
56 | 61 | | |
57 | 62 | | |
| 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 | + | |
| 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 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
16 | 16 | | |
17 | 17 | | |
18 | 18 | | |
19 | | - | |
| 19 | + | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| |||
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
56 | | - | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
57 | 62 | | |
58 | 63 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
17 | 17 | | |
18 | 18 | | |
19 | 19 | | |
| 20 | + | |
20 | 21 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
270 | 270 | | |
271 | 271 | | |
272 | 272 | | |
| 273 | + | |
| 274 | + | |
| 275 | + | |
| 276 | + | |
| 277 | + | |
273 | 278 | | |
274 | 279 | | |
275 | 280 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
37 | | - | |
| 37 | + | |
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
41 | | - | |
| 41 | + | |
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
| |||
67 | 67 | | |
68 | 68 | | |
69 | 69 | | |
70 | | - | |
| 70 | + | |
71 | 71 | | |
72 | 72 | | |
73 | 73 | | |
74 | | - | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
75 | 77 | | |
76 | | - | |
77 | | - | |
78 | | - | |
79 | 78 | | |
80 | 79 | | |
81 | 80 | | |
| |||
0 commit comments