apache / paimon
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 2,421 files with 222,301 lines of code.
    • 2 files changed more than 100 times (3,424 lines of code)
    • 12 files changed 51-100 times (8,930 lines of code)
    • 74 files changed 21-50 times (20,935 lines of code)
    • 507 files changed 6-20 times (66,385 lines of code)
    • 1,826 files changed 1-5 times (122,627 lines of code)
1% | 4% | 9% | 29% | 55%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 2,421 files with 222,301 lines of code.
    • 5 files changed by more than 25 contributors (6,010 lines of code)
    • 69 files changed by 11-25 contributors (21,187 lines of code)
    • 243 files changed by 6-10 contributors (37,603 lines of code)
    • 1,255 files changed by 2-5 contributors (115,085 lines of code)
    • 849 files changed by 1 contributor (42,416 lines of code)
2% | 9% | 16% | 51% | 19%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, scala, txt, md, xml, html, properties, yaml, js, sh, sql, svg, g4, orc, scss, gitignore, css, gitmodules, json, toml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java1% | 4% | 8% | 30% | 54%
yaml0% | 0% | 86% | 0% | 13%
scala0% | 0% | 8% | 25% | 66%
g40% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
paimon-common6% | 0% | 1% | 21% | 70%
paimon-core<1% | 7% | 16% | 34% | 40%
paimon-flink0% | 4% | 5% | 37% | 52%
paimon-hive0% | 23% | 0% | 44% | 32%
paimon-open-api0% | 0% | 88% | 0% | 11%
paimon-spark0% | 0% | 14% | 25% | 59%
paimon-format0% | 0% | 4% | 32% | 62%
paimon-arrow0% | 0% | 0% | 39% | 60%
paimon-filesystems0% | 0% | 0% | 13% | 86%
paimon-codegen0% | 0% | 0% | 8% | 91%
paimon-benchmark0% | 0% | 0% | 0% | 100%
paimon-service0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
paimon-bundle0% | 0% | 0% | 0% | 100%
paimon-codegen-loader0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 2825 236 2023-07-04 2025-04-29 149 44 zhangjunemail@126.com jingsonglee0@gmail.com
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 599 61 2023-03-17 2025-04-29 108 25 lzljs3620320@aliyun.com jingsonglee0@gmail.com
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 1523 74 2023-03-17 2025-04-28 98 35 lzljs3620320@aliyun.com gavin9402@163.com
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 505 53 2023-03-17 2025-04-28 88 26 lzljs3620320@aliyun.com 1346652787@qq.com
AbstractFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 417 25 2023-03-17 2025-04-29 69 24 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 1426 74 2023-03-17 2025-03-26 68 25 lzljs3620320@aliyun.com lining.jln@alibaba-inc.com
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 1384 49 2023-03-17 2025-03-27 61 22 lzljs3620320@aliyun.com tsreaper96@gmail.com
SnapshotManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 591 29 2023-03-17 2025-04-09 59 28 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
FlinkSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 322 12 2023-03-17 2025-04-06 58 23 lzljs3620320@aliyun.com tsreaper96@gmail.com
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 488 7 2023-03-17 2025-04-06 57 22 lzljs3620320@aliyun.com tsreaper96@gmail.com
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 543 95 2023-03-17 2025-04-11 57 16 lzljs3620320@aliyun.com jingsonglee0@gmail.com
KeyValueFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 392 8 2023-03-17 2025-04-10 54 19 lzljs3620320@aliyun.com tsreaper96@gmail.com
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 773 44 2023-03-17 2025-04-17 54 19 lzljs3620320@aliyun.com 49636787+vox-vox-vox@users....
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 566 16 2023-03-17 2025-02-20 51 26 lzljs3620320@aliyun.com tsreaper96@gmail.com
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 436 39 2023-03-17 2025-04-08 49 12 lzljs3620320@aliyun.com tsreaper96@gmail.com
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 420 69 2023-03-17 2025-04-28 47 16 lzljs3620320@aliyun.com 1346652787@qq.com
SnapshotReaderImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 493 38 2023-06-14 2025-04-08 47 15 jingsonglee0@gmail.com tsreaper96@gmail.com
SparkCatalog.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 476 19 2023-03-17 2025-04-21 44 20 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
FileStoreLookupFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup
 346 18 2023-03-17 2025-04-18 41 14 lzljs3620320@aliyun.com yuri.zhouyunfeng@outlook.com
RESTCatalog.java
in paimon-core/src/main/java/org/apache/paimon/rest
 966 55 2024-11-28 2025-04-30 41 6 jinglining0@gmail.com jingsonglee0@gmail.com
TagManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 325 22 2023-06-02 2025-01-03 40 14 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
KeyValueFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 213 9 2023-03-17 2025-04-10 38 17 lzljs3620320@aliyun.com tsreaper96@gmail.com
AppendOnlyWriter.java
in paimon-core/src/main/java/org/apache/paimon/append
 430 39 2023-03-17 2025-03-03 38 16 lzljs3620320@aliyun.com jingsonglee0@gmail.com
AppendOnlyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 118 9 2023-03-17 2025-04-21 37 13 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FileSystemCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 152 20 2023-03-17 2025-02-27 36 16 lzljs3620320@aliyun.com hongli.wwj@gmail.com
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 479 26 2023-03-17 2025-04-10 36 15 lzljs3620320@aliyun.com tsreaper96@gmail.com
FlinkSinkBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 302 15 2023-03-17 2025-04-21 35 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
PaimonCommand.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands
 213 12 2023-06-25 2025-05-03 34 9 biyan900116@gmail.com 42907416+zhongyujiang@users...
PartialUpdateMergeFunction.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 582 18 2023-03-17 2025-04-22 34 15 lzljs3620320@aliyun.com suxuannan95@gmail.com
RESTCatalogController.java
in paimon-open-api/src/main/java/org/apache/paimon/open/api
 871 30 2024-11-28 2025-04-28 33 5 jinglining0@gmail.com 1346652787@qq.com
rest-catalog-open-api.yaml
in paimon-open-api
 2136 - 2024-11-28 2025-04-28 33 5 jinglining0@gmail.com 1346652787@qq.com
Table.java
in paimon-core/src/main/java/org/apache/paimon/table
 97 4 2023-03-17 2025-05-01 32 14 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
DataTableSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 146 8 2023-03-18 2025-01-17 32 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
TableCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 299 25 2023-03-17 2025-03-27 32 9 lzljs3620320@aliyun.com tsreaper96@gmail.com
OrphanFilesClean.java
in paimon-core/src/main/java/org/apache/paimon/operation
 382 21 2023-11-30 2025-04-23 31 14 33053040+yuzelin@users.nore... jingsonglee0@gmail.com
PaimonSparkWriter.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands
 400 9 2024-03-22 2025-05-06 31 9 biyan900116@gmail.com zouxinyu.zxy@alibaba-inc.com
PrimaryKeyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 151 11 2023-10-24 2025-04-10 30 12 jingsonglee0@gmail.com tsreaper96@gmail.com
CompactAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 266 12 2023-03-17 2025-04-25 30 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 187 12 2023-09-12 2024-12-18 29 9 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
ReadonlyTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 215 30 2023-03-17 2025-03-03 29 13 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 325 22 2023-03-17 2025-02-17 29 14 lzljs3620320@aliyun.com yuri.zhouyunfeng@outlook.com
SparkProcedures.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 79 3 2023-08-25 2025-03-26 28 16 programgeek@163.com lining.jln@alibaba-inc.com
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 370 28 2023-03-17 2025-03-31 28 12 lzljs3620320@aliyun.com 1185807945@qq.com
FilesTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 415 26 2023-03-17 2025-02-19 28 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
CompactProcedure.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure
 499 13 2023-11-16 2025-04-21 28 12 41894543+leaves12138@users.... jingsonglee0@gmail.com
SnapshotReader.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 71 1 2023-06-14 2025-04-08 27 6 jingsonglee0@gmail.com tsreaper96@gmail.com
DeleteFromPaimonTableCommand.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands
 114 4 2023-11-22 2025-04-12 27 6 biyan900116@gmail.com jingsonglee0@gmail.com
FileIO.java
in paimon-common/src/main/java/org/apache/paimon/fs
 396 18 2023-03-17 2025-04-02 27 11 lzljs3620320@aliyun.com jingsonglee0@gmail.com
BranchManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 57 6 2024-01-17 2025-04-08 26 13 45089228+taozex@users.norep... lixin58688@163.com
FileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 85 3 2023-03-17 2025-04-08 26 6 lzljs3620320@aliyun.com tsreaper96@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 2825 236 2023-07-04 2025-04-29 149 44 zhangjunemail@126.com jingsonglee0@gmail.com
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 1523 74 2023-03-17 2025-04-28 98 35 lzljs3620320@aliyun.com gavin9402@163.com
SnapshotManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 591 29 2023-03-17 2025-04-09 59 28 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 505 53 2023-03-17 2025-04-28 88 26 lzljs3620320@aliyun.com 1346652787@qq.com
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 566 16 2023-03-17 2025-02-20 51 26 lzljs3620320@aliyun.com tsreaper96@gmail.com
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 599 61 2023-03-17 2025-04-29 108 25 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 1426 74 2023-03-17 2025-03-26 68 25 lzljs3620320@aliyun.com lining.jln@alibaba-inc.com
AbstractFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 417 25 2023-03-17 2025-04-29 69 24 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 322 12 2023-03-17 2025-04-06 58 23 lzljs3620320@aliyun.com tsreaper96@gmail.com
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 1384 49 2023-03-17 2025-03-27 61 22 lzljs3620320@aliyun.com tsreaper96@gmail.com
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 488 7 2023-03-17 2025-04-06 57 22 lzljs3620320@aliyun.com tsreaper96@gmail.com
SparkCatalog.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 476 19 2023-03-17 2025-04-21 44 20 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
KeyValueFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 392 8 2023-03-17 2025-04-10 54 19 lzljs3620320@aliyun.com tsreaper96@gmail.com
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 773 44 2023-03-17 2025-04-17 54 19 lzljs3620320@aliyun.com 49636787+vox-vox-vox@users....
KeyValueFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 213 9 2023-03-17 2025-04-10 38 17 lzljs3620320@aliyun.com tsreaper96@gmail.com
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 543 95 2023-03-17 2025-04-11 57 16 lzljs3620320@aliyun.com jingsonglee0@gmail.com
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 420 69 2023-03-17 2025-04-28 47 16 lzljs3620320@aliyun.com 1346652787@qq.com
AppendOnlyWriter.java
in paimon-core/src/main/java/org/apache/paimon/append
 430 39 2023-03-17 2025-03-03 38 16 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FileSystemCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 152 20 2023-03-17 2025-02-27 36 16 lzljs3620320@aliyun.com hongli.wwj@gmail.com
SparkProcedures.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 79 3 2023-08-25 2025-03-26 28 16 programgeek@163.com lining.jln@alibaba-inc.com
SnapshotReaderImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 493 38 2023-06-14 2025-04-08 47 15 jingsonglee0@gmail.com tsreaper96@gmail.com
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 479 26 2023-03-17 2025-04-10 36 15 lzljs3620320@aliyun.com tsreaper96@gmail.com
PartialUpdateMergeFunction.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 582 18 2023-03-17 2025-04-22 34 15 lzljs3620320@aliyun.com suxuannan95@gmail.com
OrcFileFormat.java
in paimon-format/src/main/java/org/apache/paimon/format/orc
 158 9 2023-03-17 2025-02-17 24 15 lzljs3620320@aliyun.com fengxiangyu.fxy@bytedance.com
ParquetReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet
 468 22 2023-03-17 2025-03-05 24 15 lzljs3620320@aliyun.com hongli.wwj@gmail.com
FileStoreLookupFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup
 346 18 2023-03-17 2025-04-18 41 14 lzljs3620320@aliyun.com yuri.zhouyunfeng@outlook.com
TagManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 325 22 2023-06-02 2025-01-03 40 14 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
Table.java
in paimon-core/src/main/java/org/apache/paimon/table
 97 4 2023-03-17 2025-05-01 32 14 lzljs3620320@aliyun.com zouxinyu.zxy@alibaba-inc.com
OrphanFilesClean.java
in paimon-core/src/main/java/org/apache/paimon/operation
 382 21 2023-11-30 2025-04-23 31 14 33053040+yuzelin@users.nore... jingsonglee0@gmail.com
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 325 22 2023-03-17 2025-02-17 29 14 lzljs3620320@aliyun.com yuri.zhouyunfeng@outlook.com
FieldAggregator.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate
 25 4 2023-03-17 2024-11-05 17 14 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
AppendOnlyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 118 9 2023-03-17 2025-04-21 37 13 lzljs3620320@aliyun.com jingsonglee0@gmail.com
ReadonlyTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 215 30 2023-03-17 2025-03-03 29 13 lzljs3620320@aliyun.com jingsonglee0@gmail.com
BranchManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 57 6 2024-01-17 2025-04-08 26 13 45089228+taozex@users.norep... lixin58688@163.com
CommitterOperator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 181 13 2023-03-17 2025-03-03 23 13 lzljs3620320@aliyun.com 41894543+leaves12138@users....
SystemTableLoader.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 60 2 2023-03-17 2024-12-27 23 13 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
PartitionExpire.java
in paimon-core/src/main/java/org/apache/paimon/operation
 136 5 2023-03-17 2025-04-07 22 13 lzljs3620320@aliyun.com 135721692+askwang@users.nor...
TypeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 331 11 2023-03-17 2025-03-31 20 13 lzljs3620320@aliyun.com 1668926294@qq.com
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 436 39 2023-03-17 2025-04-08 49 12 lzljs3620320@aliyun.com tsreaper96@gmail.com
FlinkSinkBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 302 15 2023-03-17 2025-04-21 35 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
DataTableSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 146 8 2023-03-18 2025-01-17 32 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
CompactAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 266 12 2023-03-17 2025-04-25 30 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
PrimaryKeyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 151 11 2023-10-24 2025-04-10 30 12 jingsonglee0@gmail.com tsreaper96@gmail.com
CompactProcedure.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure
 499 13 2023-11-16 2025-04-21 28 12 41894543+leaves12138@users.... jingsonglee0@gmail.com
FilesTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 415 26 2023-03-17 2025-02-19 28 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 370 28 2023-03-17 2025-03-31 28 12 lzljs3620320@aliyun.com 1185807945@qq.com
DataFileMeta.java
in paimon-core/src/main/java/org/apache/paimon/io
 518 36 2023-03-17 2025-02-12 26 12 lzljs3620320@aliyun.com neuyilan@163.com
MergeTreeWriter.java
in paimon-core/src/main/java/org/apache/paimon/mergetree
 326 21 2023-03-17 2025-03-03 26 12 lzljs3620320@aliyun.com fengxiangyu.fxy@bytedance.com
FileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 99 8 2023-03-17 2025-04-11 26 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
TableWriteImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 218 28 2023-03-17 2024-08-25 25 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
VectorizedRleValuesReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 803 47 2025-01-24 2025-01-24 1 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
ParquetVectorUpdaterFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 679 79 2025-01-24 2025-02-10 2 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
RecordReaderUtils.java
in paimon-format/src/main/java/org/apache/orc/impl
 593 38 2024-05-29 2024-05-29 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
GenericVariantBuilder.java
in paimon-common/src/main/java/org/apache/paimon/data/variant
 499 31 2024-12-17 2024-12-17 1 1 zouxinyu.zxy@alibaba-inc.com zouxinyu.zxy@alibaba-inc.com
GenericVariantUtil.java
in paimon-common/src/main/java/org/apache/paimon/data/variant
 412 26 2024-12-17 2024-12-17 1 1 zouxinyu.zxy@alibaba-inc.com zouxinyu.zxy@alibaba-inc.com
GenericVariant.java
in paimon-common/src/main/java/org/apache/paimon/data/variant
 384 31 2024-12-17 2024-12-23 2 1 zouxinyu.zxy@alibaba-inc.com zouxinyu.zxy@alibaba-inc.com
FileBasedPrivilegeManager.java
in paimon-core/src/main/java/org/apache/paimon/privilege
 376 24 2024-04-29 2024-04-29 1 1 tsreaper96@gmail.com tsreaper96@gmail.com
AbstractPagedInputView.java
in paimon-common/src/main/java/org/apache/paimon/data
 370 27 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
AppendCompactCoordinator.java
in paimon-core/src/main/java/org/apache/paimon/append
 360 30 2025-04-21 2025-04-21 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
ZIndexer.java
in paimon-common/src/main/java/org/apache/paimon/sort/zorder
 328 31 2025-02-11 2025-02-11 1 1 zjureel@gmail.com zjureel@gmail.com
NumberSequenceRowSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 302 27 2024-09-24 2024-09-24 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
NoticeFileChecker.java
in tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck
 299 9 2023-11-23 2023-11-23 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
AbstractPagedOutputView.java
in paimon-common/src/main/java/org/apache/paimon/data
 276 24 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
VectorizedColumnReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 267 8 2025-01-24 2025-02-10 2 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
ViewChange.java
in paimon-core/src/main/java/org/apache/paimon/view
 266 33 2025-03-26 2025-03-26 1 1 lining.jln@alibaba-inc.com lining.jln@alibaba-inc.com
BytesMap.java
in paimon-core/src/main/java/org/apache/paimon/hash
 265 17 2024-11-11 2024-11-11 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
FlinkCalciteClasses.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils
 262 49 2024-06-24 2024-06-24 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
RocksDBOptions.java
in paimon-core/src/main/java/org/apache/paimon/lookup
 260 2 2023-10-27 2023-12-25 3 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
VectorizedPlainValuesReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 250 30 2025-01-24 2025-01-24 1 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
JarFileChecker.java
in tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck
 249 17 2023-11-23 2023-11-23 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
ParquetWriter.java
in paimon-format/src/main/java/org/apache/parquet/hadoop
 249 33 2024-06-03 2025-04-21 3 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
BitSliceIndexRoaringBitmap.java
in paimon-common/src/main/java/org/apache/paimon/utils
 246 17 2024-11-08 2024-12-04 2 1 tanjialiang1997@gmail.com tanjialiang1997@gmail.com
LoserTree.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 244 16 2023-04-27 2023-05-10 2 1 69444450+liming30@users.nor... 69444450+liming30@users.nor...
QuickSort.java
in paimon-core/src/main/java/org/apache/paimon/sort
 240 6 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
DataTypeCasts.java
in paimon-common/src/main/java/org/apache/paimon/types
 228 14 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
RewriteFileIndexSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 224 32 2024-06-20 2024-06-20 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
BytesHashMap.java
in paimon-core/src/main/java/org/apache/paimon/hash
 222 30 2024-11-11 2024-11-11 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
RowRanges.java
in paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex
 218 22 2024-12-30 2025-01-06 3 1 tanjialiang1997@gmail.com tanjialiang1997@gmail.com
CopyFilesUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy
 215 10 2025-04-23 2025-04-23 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
ManifestFileMerger.java
in paimon-core/src/main/java/org/apache/paimon/operation
 215 4 2024-08-19 2024-09-10 2 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
ParquetSimpleStatsExtractor.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet
 214 5 2024-05-14 2025-03-05 2 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
SortUtil.java
in paimon-common/src/main/java/org/apache/paimon/utils
 211 19 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
SparkV2FilterConverter.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark
 210 8 2025-01-17 2025-02-08 2 1 zouxinyu.zxy@alibaba-inc.com zouxinyu.zxy@alibaba-inc.com
ParquetColumnVector.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 206 15 2025-01-24 2025-01-24 1 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
CopyMetaFilesFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy
 205 5 2025-04-23 2025-04-23 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
VectorizedDeltaBinaryPackedReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 201 20 2025-01-24 2025-01-24 1 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
OrcFilters.java
in paimon-format/src/main/java/org/apache/paimon/format/orc/filter
 200 15 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
BaseAppendFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 198 7 2025-04-21 2025-04-21 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
JavaLexer.g4
in paimon-common/src/main/antlr4
 188 - 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
OptimizedRoaringBitmap64.java
in paimon-common/src/main/java/org/apache/paimon/utils
 185 26 2025-04-17 2025-04-28 2 1 94825748+lsomeyeah@users.no... 94825748+lsomeyeah@users.no...
MonitorSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator
 184 10 2024-12-13 2024-12-20 2 1 yuri.zhouyunfeng@outlook.com yuri.zhouyunfeng@outlook.com
HadoopCompliantFileIO.java
in paimon-filesystems/paimon-gs-impl/src/main/java/org/apache/paimon/gs
 184 21 2025-03-27 2025-03-27 1 1 gkatzioura@gmail.com gkatzioura@gmail.com
NestedProjectedRowData.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 183 21 2024-12-20 2024-12-20 1 1 yuri.zhouyunfeng@outlook.com yuri.zhouyunfeng@outlook.com
BsonValueConvertor.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb
 182 24 2025-01-10 2025-03-12 2 1 lizc9@xiaopeng.com lizc9@xiaopeng.com
HadoopCompliantFileIO.java
in paimon-filesystems/paimon-azure-impl/src/main/java/org/apache/paimon/azure
 182 23 2025-04-01 2025-04-01 1 1 185451194+qining-mj@users.n... 185451194+qining-mj@users.n...
HadoopCompliantFileIO.java
in paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs
 182 23 2025-04-11 2025-04-11 1 1 185451194+qining-mj@users.n... 185451194+qining-mj@users.n...
CopyManifestFileOperator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy
 171 7 2025-04-23 2025-04-23 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
RemoveUnexistingFilesAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 164 15 2025-01-14 2025-03-27 2 1 tsreaper96@gmail.com tsreaper96@gmail.com
DebeziumAvroRecordParser.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium
 161 12 2024-08-11 2025-03-18 2 1 37063904+zhuangchong@users.... 37063904+zhuangchong@users....
InternalMapSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 157 11 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
Correlations

File Size vs. Number of Changes: 2422 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 114 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 88 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 88 lines of code y: 2 # changes paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 32 lines of code y: 3 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 111 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 188 lines of code y: 14 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 400 lines of code y: 31 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 151 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 39 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 19 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWriteBuilder.scala x: 22 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWriteRequirement.scala x: 44 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 62 lines of code y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 213 lines of code y: 34 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util/OptionUtils.scala x: 81 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 97 lines of code y: 32 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/CreateOrReplaceTagExec.scala x: 51 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 201 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 966 lines of code y: 41 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 61 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 22 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 171 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 6 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java x: 21 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/BearTokenAuthProvider.java x: 18 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProvider.java x: 115 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java x: 49 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java x: 38 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 76 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFTokenLoader.java x: 5 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/RESTAuthFunction.java x: 15 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalog/functions/PaimonFunctions.scala x: 104 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 599 lines of code y: 108 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 40 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 26 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTimestampStartingScanner.java x: 35 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromWatermarkStartingScanner.java x: 43 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 222 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 189 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/table/system/TableIndexesTable.java x: 189 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 54 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 2825 lines of code y: 149 # changes paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 417 lines of code y: 69 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 136 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 100 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 125 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 122 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java x: 116 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/index/DeletionVectorMeta.java x: 69 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/UpdatePaimonTableCommand.scala x: 114 lines of code y: 19 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 184 lines of code y: 4 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 337 lines of code y: 16 # changes paimon-common/src/main/java/org/apache/paimon/utils/OptimizedRoaringBitmap64.java x: 185 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 505 lines of code y: 88 # changes paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 420 lines of code y: 47 # changes paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 235 lines of code y: 23 # changes paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java x: 241 lines of code y: 23 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTUtil.java x: 97 lines of code y: 6 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 1523 lines of code y: 98 # changes paimon-open-api/rest-catalog-open-api.yaml x: 2136 lines of code y: 33 # changes paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 871 lines of code y: 33 # changes paimon-format/src/main/java/org/apache/paimon/format/OrcOptions.java x: 26 lines of code y: 7 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/AbstractOrcColumnVector.java x: 74 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcArrayColumnVector.java x: 34 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcMapColumnVector.java x: 38 lines of code y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/writer/RowDataVectorizer.java x: 34 lines of code y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 102 lines of code y: 8 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReaderFactory.scala x: 29 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 71 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 266 lines of code y: 30 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 292 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 343 lines of code y: 9 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 75 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/DynamicPartitionLoader.java x: 94 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ListCloneFilesFunction.java x: 129 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/RollbackToProcedure.java x: 47 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RollbackProcedure.java x: 101 lines of code y: 4 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RollbackToTimestampProcedure.java x: 77 lines of code y: 2 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowUtils.java x: 213 lines of code y: 7 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/OneElementFieldVectorGenerator.java x: 39 lines of code y: 3 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriter.java x: 51 lines of code y: 4 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactory.java x: 6 lines of code y: 2 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java x: 149 lines of code y: 4 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 656 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 382 lines of code y: 31 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 375 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CloneActionFactory.java x: 45 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneFilesFunction.java x: 72 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneProcessFunction.java x: 61 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneUtils.java x: 119 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CommitTableOperator.java x: 66 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/DataFileInfo.java x: 26 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CloneProcedure.java x: 65 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CopyFilesActionFactory.java x: 69 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyDataFileOperator.java x: 95 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyFilesUtil.java x: 215 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 171 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 205 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopySourceBuilder.java x: 89 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CopyFilesProcedure.java x: 79 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 128 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 366 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 217 lines of code y: 17 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 582 lines of code y: 34 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 476 lines of code y: 44 # changes paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 135 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java x: 360 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendCompactTask.java x: 111 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendPreCommitCompactCoordinator.java x: 46 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/append/MultiTableAppendCompactTask.java x: 34 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java x: 144 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 162 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 198 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 118 lines of code y: 37 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/MultiTableCompactionTaskSerializer.java x: 83 lines of code y: 3 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 108 lines of code y: 13 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 187 lines of code y: 21 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 230 lines of code y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendPreCommitCompactCoordinatorOperator.java x: 137 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendPreCommitCompactWorkerOperator.java x: 83 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendTableCompactBuilder.java x: 102 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendTableCompactor.java x: 156 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/MultiTableScanBase.java x: 91 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendBypassCompactWorkerOperator.java x: 47 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendCompactWorkerOperator.java x: 81 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 162 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlySingleTableCompactionWorkerOperator.java x: 39 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java x: 159 lines of code y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactionTaskTypeInfo.java x: 56 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 302 lines of code y: 35 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCompactionTaskTypeInfo.java x: 70 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataHashPartitionChannelComputer.java x: 29 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperator.java x: 81 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperatorFactory.java x: 27 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CombinedTableCompactorSourceBuilder.java x: 111 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAppendCompactStreamSource.java x: 97 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 499 lines of code y: 28 # changes paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 1271 lines of code y: 8 # changes paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 249 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java x: 199 lines of code y: 4 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala x: 124 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 205 lines of code y: 16 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 279 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/BucketExpression.scala x: 58 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 346 lines of code y: 41 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/partitioner/ShuffleStrategy.java x: 7 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 187 lines of code y: 8 # changes paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/HadoopCompliantFileIO.java x: 219 lines of code y: 2 # changes paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/JindoFileIO.java x: 288 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 773 lines of code y: 54 # changes paimon-common/src/main/java/org/apache/paimon/utils/RoaringBitmap32.java x: 129 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 671 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java x: 148 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/KeyAndBucketExtractor.java x: 21 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 225 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/sort/SpillChannelManager.java x: 48 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java x: 286 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala x: 114 lines of code y: 27 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 314 lines of code y: 18 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 147 lines of code y: 22 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriterImpl.java x: 50 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 364 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 88 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/io/RowDataRollingFileWriter.java x: 75 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 55 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 239 lines of code y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 164 lines of code y: 18 # changes paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs/HadoopCompliantFileIO.java x: 182 lines of code y: 1 # changes paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs/OBSFileIO.java x: 125 lines of code y: 1 # changes paimon-filesystems/paimon-obs/src/main/java/org/apache/paimon/obs/OBSLoader.java x: 55 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/DataTable.java x: 25 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java x: 253 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 99 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 543 lines of code y: 57 # changes paimon-core/src/main/java/org/apache/paimon/table/system/CompactBucketsTable.java x: 210 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 265 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 157 lines of code y: 19 # changes paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/PurgeFilesProcedure.java x: 15 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/PurgeFilesProcedure.java x: 21 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java x: 222 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/table/source/KeyValueTableRead.java x: 111 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceReader.java x: 78 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionFactory.java x: 111 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 344 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/QueryServiceProcedure.java x: 28 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/service/QueryAddressRegister.java x: 58 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 215 lines of code y: 14 # changes paimon-flink/paimon-flink1-common/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/SinkFunction.java x: 3 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 213 lines of code y: 38 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 479 lines of code y: 36 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 392 lines of code y: 54 # changes paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 122 lines of code y: 22 # changes paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketFileStoreWrite.java x: 83 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyFileStoreTable.java x: 151 lines of code y: 30 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/PostponeBucketRowKeyExtractor.java x: 12 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/postpone/PostponeBucketCompactSplitSource.java x: 143 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 132 lines of code y: 22 # changes paimon-core/src/main/java/org/apache/paimon/utils/StatsCollectorFactories.java x: 58 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 591 lines of code y: 59 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 190 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 163 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 57 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/utils/CatalogBranchManager.java x: 70 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/utils/FileSystemBranchManager.java x: 175 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 436 lines of code y: 49 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 85 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 71 lines of code y: 27 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 493 lines of code y: 47 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 246 lines of code y: 17 # changes paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java x: 136 lines of code y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ExpirePartitionsProcedure.java x: 82 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ExpireSnapshotsProcedure.java x: 60 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ExpirePartitionsProcedure.java x: 101 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 8 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java x: 282 lines of code y: 12 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndex.java x: 318 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/utils/ThreadPoolUtils.java x: 158 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 488 lines of code y: 57 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTask.java x: 308 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 322 lines of code y: 58 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScanner.java x: 55 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java x: 157 lines of code y: 22 # changes paimon-open-api/rest-management-api.yaml x: 320 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/KeyValue.java x: 133 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 396 lines of code y: 27 # changes paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 295 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergDataFileMeta.java x: 218 lines of code y: 7 # changes paimon-filesystems/paimon-azure-impl/src/main/java/org/apache/paimon/azure/AzureFileIO.java x: 113 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 97 lines of code y: 17 # changes paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 370 lines of code y: 28 # changes paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 331 lines of code y: 20 # changes paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java x: 221 lines of code y: 9 # changes paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 269 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDeltaStartingScanner.java x: 136 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsAction.java x: 43 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldAggregatorFactory.java x: 39 lines of code y: 4 # changes paimon-filesystems/paimon-gs-impl/src/main/java/org/apache/paimon/gs/HadoopCompliantFileIO.java x: 184 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 1384 lines of code y: 61 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 88 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java x: 131 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageLegacyV2Serializer.java x: 151 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java x: 136 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 299 lines of code y: 32 # changes paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 421 lines of code y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveUnexistingFilesAction.java x: 164 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTaskSerializer.java x: 77 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/postpone/RemovePostponeBucketFilesOperator.java x: 32 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/postpone/RewritePostponeBucketCommittableOperator.java x: 121 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RewriteFileIndexSink.java x: 321 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcSimpleStatsExtractor.java x: 220 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala x: 130 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/procedure/SparkRemoveUnexistingFiles.scala x: 98 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 188 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 146 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestList.java x: 96 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 284 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScan.java x: 37 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java x: 34 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java x: 161 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTObjectMapper.java x: 6 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java x: 197 lines of code y: 23 # changes paimon-common/src/main/java/org/apache/paimon/utils/ParallelExecution.java x: 156 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/view/ViewChange.java x: 266 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 1426 lines of code y: 68 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkProcedures.java x: 79 lines of code y: 28 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/catalog/SupportView.java x: 61 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDone.java x: 188 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDoneTrigger.java x: 175 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDiffStartingScanner.java x: 116 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 108 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/CatalogEnvironment.java x: 88 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/rest/responses/GetDatabaseResponse.java x: 55 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/rest/responses/GetTableResponse.java x: 73 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/rest/responses/GetViewResponse.java x: 46 lines of code y: 3 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/extensions/PaimonSparkSessionExtensions.scala x: 40 lines of code y: 19 # changes paimon-spark/paimon-spark4-common/src/main/scala/org/apache/spark/sql/paimon/shims/Spark4Shim.scala x: 65 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolution.java x: 233 lines of code y: 4 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScanBuilder.scala x: 105 lines of code y: 11 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/aggregate/LocalAggregator.scala x: 98 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java x: 191 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/utils/HintFileUtils.java x: 94 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/RollbackHelper.java x: 160 lines of code y: 12 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexWriter.java x: 13 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndexMeta.java x: 247 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFileIndexWriter.java x: 289 lines of code y: 3 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/AbstractRecordParser.java x: 86 lines of code y: 2 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/aliyun/AliyunRecordParser.java x: 171 lines of code y: 4 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/canal/CanalRecordParser.java x: 162 lines of code y: 10 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumAvroRecordParser.java x: 161 lines of code y: 2 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/strategy/MongoVersionStrategy.java x: 107 lines of code y: 7 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java x: 215 lines of code y: 15 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 82 lines of code y: 8 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcParsingProcessFunction.java x: 32 lines of code y: 4 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java x: 57 lines of code y: 9 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcRecord.java x: 73 lines of code y: 4 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/RichEventParser.java x: 42 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/MultiAwareBucketTableScan.java x: 65 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java x: 306 lines of code y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 83 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareBatchSource.java x: 110 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java x: 110 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/FormatTable.java x: 273 lines of code y: 8 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveTableUtils.java x: 86 lines of code y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkSource.scala x: 89 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java x: 303 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java x: 175 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/manifest/PartitionEntry.java x: 138 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java x: 172 lines of code y: 11 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionManagement.scala x: 120 lines of code y: 21 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java x: 264 lines of code y: 23 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/schema/JdbcSchemaUtils.java x: 133 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 348 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 262 lines of code y: 5 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 505 lines of code y: 7 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionBase.java x: 222 lines of code y: 17 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 345 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/source/splitread/IncrementalDiffSplitRead.java x: 183 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactTask.java x: 130 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/heap/HeapBytesVector.java x: 83 lines of code y: 6 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/BsonValueConvertor.java x: 182 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthSignature.java x: 150 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/migrate/Migrator.java x: 6 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateTableProcedure.java x: 71 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 268 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMapType.java x: 92 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/heap/HeapRowVector.java x: 31 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 344 lines of code y: 19 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexFormat.java x: 241 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/Changelog.java x: 102 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestFile.java x: 220 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java x: 158 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/tag/Tag.java x: 179 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java x: 179 lines of code y: 19 # changes paimon-common/src/main/java/org/apache/paimon/format/SimpleStatsExtractor.java x: 19 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 468 lines of code y: 24 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSimpleStatsExtractor.java x: 214 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 69 lines of code y: 25 # changes paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStore.java x: 182 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 28 lines of code y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsAction.java x: 47 lines of code y: 8 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonAnalyzeTableColumnCommand.scala x: 127 lines of code y: 11 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonTruncateTableCommand.scala x: 25 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/crosspartition/IndexBootstrap.java x: 118 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/index/HashIndexMaintainer.java x: 88 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 234 lines of code y: 18 # changes paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java x: 238 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/stats/StatsFileHandler.java x: 45 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 215 lines of code y: 29 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromSnapshotStartingScanner.java x: 39 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupFileStoreTable.java x: 112 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 430 lines of code y: 38 # changes paimon-core/src/main/java/org/apache/paimon/compact/CompactManager.java x: 17 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 326 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/UniversalCompaction.java x: 192 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/utils/RecordWriter.java x: 16 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/utils/MathUtils.java x: 63 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 181 lines of code y: 23 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/BatchWriteGeneratorTagOperator.java x: 117 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 75 lines of code y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreMultiCommitter.java x: 207 lines of code y: 18 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 124 lines of code y: 21 # changes paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 152 lines of code y: 36 # changes paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java x: 394 lines of code y: 21 # changes paimon-core/src/main/java/org/apache/paimon/operation/metrics/CompactionMetrics.java x: 192 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/TableMigrationUtils.java x: 81 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedSourceReader.java x: 65 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 143 lines of code y: 21 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 597 lines of code y: 6 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncTableActionBase.java x: 168 lines of code y: 15 # changes paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 297 lines of code y: 14 # changes paimon-common/src/main/java/org/apache/paimon/data/GenericMap.java x: 76 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 393 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileStoreSource.java x: 62 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java x: 213 lines of code y: 23 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 566 lines of code y: 51 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactActionFactory.java x: 116 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java x: 106 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeFunction.java x: 58 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupChangelogMergeFunctionWrapper.java x: 153 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 63 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyTableUtils.java x: 63 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/utils/OffsetRow.java x: 101 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java x: 129 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/index/PartitionIndex.java x: 115 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/BucketProcessor.scala x: 189 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AggregationFieldsTable.java x: 189 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 151 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 169 lines of code y: 23 # changes paimon-core/src/main/java/org/apache/paimon/table/system/CatalogOptionsTable.java x: 144 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java x: 157 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 415 lines of code y: 28 # changes paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 158 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 167 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java x: 272 lines of code y: 21 # changes paimon-core/src/main/java/org/apache/paimon/table/system/StatisticTable.java x: 166 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java x: 234 lines of code y: 21 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/MigrateDatabaseProcedure.java x: 105 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/SystemTableSource.java x: 111 lines of code y: 16 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/OrcFileFormat.java x: 158 lines of code y: 24 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java x: 255 lines of code y: 21 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/writer/FieldWriterFactory.java x: 270 lines of code y: 3 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java x: 35 lines of code y: 23 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java x: 421 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/DynamicBucketSink.java x: 71 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 325 lines of code y: 29 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 105 lines of code y: 5 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala x: 76 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 518 lines of code y: 26 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/LocationHelper.java x: 17 lines of code y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/OrcWriterFactory.java x: 78 lines of code y: 10 # changes paimon-common/src/main/java/org/apache/paimon/sort/zorder/ZIndexer.java x: 328 lines of code y: 1 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java x: 89 lines of code y: 9 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java x: 94 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionFactory.java x: 53 lines of code y: 9 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/ParquetVectorUpdaterFactory.java x: 679 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedColumnReader.java x: 267 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneAction.java x: 174 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergConversions.java x: 123 lines of code y: 4 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java x: 167 lines of code y: 16 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkFilterConverter.java x: 165 lines of code y: 14 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala x: 102 lines of code y: 23 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScanBuilder.scala x: 23 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScan.scala x: 126 lines of code y: 15 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonSplitScan.scala x: 41 lines of code y: 8 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonMergeIntoBase.scala x: 103 lines of code y: 6 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 259 lines of code y: 13 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/converter/Arrow2PaimonVectorConverter.java x: 470 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/MapColumnVector.java x: 5 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/heap/HeapIntVector.java x: 92 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/writable/WritableColumnVector.java x: 21 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/writable/WritableIntVector.java x: 11 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/utils/VectorMappingUtils.java x: 342 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedDeltaBinaryPackedReader.java x: 201 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedPlainValuesReader.java x: 250 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedRleValuesReader.java x: 803 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedColumnReader.java x: 200 lines of code y: 7 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java x: 575 lines of code y: 8 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDecimalVector.java x: 199 lines of code y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 529 lines of code y: 10 # changes paimon-format/src/main/java/org/apache/orc/OrcConf.java x: 466 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java x: 186 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/operation/LocalOrphanFilesClean.java x: 240 lines of code y: 11 # changes paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java x: 88 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveOrphanFilesAction.java x: 39 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java x: 81 lines of code y: 11 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/procedure/SparkOrphanFilesClean.scala x: 197 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java x: 315 lines of code y: 7 # changes paimon-filesystems/paimon-s3-impl/src/main/java/org/apache/paimon/s3/HadoopCompliantFileIO.java x: 213 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java x: 68 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java x: 56 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 249 lines of code y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 146 lines of code y: 32 # changes paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 344 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommit.java x: 34 lines of code y: 17 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetFileFormat.java x: 63 lines of code y: 14 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java x: 360 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 286 lines of code y: 19 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 545 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java x: 80 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMetadata.java x: 263 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupStreamingReader.java x: 120 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java x: 329 lines of code y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/NoPrimaryKeyLookupTable.java x: 105 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyLookupTable.java x: 108 lines of code y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 82 lines of code y: 14 # changes paimon-common/src/main/java/org/apache/paimon/casting/CastExecutors.java x: 167 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 390 lines of code y: 17 # changes paimon-common/src/main/java/org/apache/paimon/format/FormatReaderFactory.java x: 19 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/operation/RawFileSplitRead.java x: 206 lines of code y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/format/CompactedChangelogFormatReaderFactory.java x: 180 lines of code y: 4 # changes paimon-format/src/main/java/org/apache/orc/impl/RecordReaderImpl.java x: 1426 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex/RowRanges.java x: 218 lines of code y: 3 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala x: 95 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 190 lines of code y: 18 # changes paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java x: 325 lines of code y: 40 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AutoTagForSavepointCommitterOperator.java x: 188 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java x: 111 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 60 lines of code y: 23 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala x: 302 lines of code y: 14 # changes paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 59 lines of code y: 17 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 595 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 261 lines of code y: 14 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 136 lines of code y: 18 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFileMetaSerializer.java x: 61 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 231 lines of code y: 24 # changes paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java x: 215 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntry.java x: 139 lines of code y: 16 # changes paimon-core/src/main/java/org/apache/paimon/manifest/SimpleFileEntry.java x: 145 lines of code y: 4 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 323 lines of code y: 14 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 319 lines of code y: 16 # changes paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowFieldTypeConversion.java x: 143 lines of code y: 2 # changes paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 690 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 358 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 229 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java x: 196 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/data/NestedRow.java x: 256 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 205 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRow.java x: 167 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariant.java x: 384 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 781 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/sort/hilbert/HilbertIndexer.java x: 244 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypeDefaultVisitor.java x: 89 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/types/InternalRowToSizeVisitor.java x: 257 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/utils/KeyProjectedRow.java x: 118 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowWrapper.java x: 255 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/parquet/filter2/predicate/ParquetFilters.java x: 234 lines of code y: 5 # changes paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 233 lines of code y: 14 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/FixedLenBytesColumnReader.java x: 33 lines of code y: 9 # changes paimon-common/src/main/java/org/apache/paimon/utils/FileIOUtils.java x: 209 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta08Serializer.java x: 108 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/utils/FormatReaderMapping.java x: 229 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java x: 312 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileStoreSource.java x: 84 lines of code y: 20 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSource.java x: 56 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/LogHybridSourceFactory.java x: 117 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSource.java x: 80 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java x: 206 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 304 lines of code y: 26 # changes paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/CompactDatabaseProcedure.java x: 91 lines of code y: 4 # changes paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java x: 139 lines of code y: 8 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/MessageQueueSyncTableActionBase.java x: 41 lines of code y: 14 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 20 lines of code y: 15 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 13 lines of code y: 13 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseAction.java x: 34 lines of code y: 16 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 187 lines of code y: 29 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 71 lines of code y: 23 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableAction.java x: 13 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 86 lines of code y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DeleteAction.java x: 65 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DeleteTagAction.java x: 17 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/TableActionBase.java x: 59 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactDatabaseProcedure.java x: 76 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MergeIntoProcedure.java x: 148 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 85 lines of code y: 19 # changes paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolutions.java x: 65 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/utils/ObjectsCache.java x: 115 lines of code y: 10 # changes paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantBuilder.java x: 499 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantUtil.java x: 412 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcUtils.java x: 457 lines of code y: 3 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcMultiplexRecordChannelComputer.java x: 67 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MultiTablesReadOperator.java x: 145 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/types/DataField.java x: 140 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java x: 97 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java x: 92 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/source/DeletionFile.java x: 153 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/partition/PartitionPredicate.java x: 190 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/AbstractPaimonSparkSqlExtensionsParser.scala x: 189 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/operation/SnapshotDeletion.java x: 69 lines of code y: 15 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/AbstractColumnReader.java x: 267 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/utils/BitSliceIndexRoaringBitmap.java x: 246 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 115 lines of code y: 17 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactory.java x: 15 lines of code y: 11 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/RunLengthDecoder.java x: 265 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/lookup/sort/SortLookupStoreReader.java x: 131 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/DataCatalogTable.java x: 141 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalog.java x: 423 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/FlinkCatalogPropertiesUtil.java x: 185 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LocalMergeOperator.java x: 198 lines of code y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSinkBuilder.java x: 43 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonStatistics.scala x: 106 lines of code y: 15 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/optimizer/MergePaimonScalarSubqueriesBase.scala x: 304 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sorter/SortUtils.java x: 153 lines of code y: 12 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 275 lines of code y: 20 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileRecordReader.java x: 38 lines of code y: 11 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 483 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/hash/BytesHashMap.java x: 222 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/hash/BytesMap.java x: 265 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/bsi/BitSliceIndexBitmapFileIndex.java x: 334 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexPredicate.java x: 126 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 133 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java x: 25 lines of code y: 17 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java x: 22 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java x: 100 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java x: 135 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/options/OptionsUtils.java x: 255 lines of code y: 6 # changes paimon-codegen/src/main/java/org/apache/paimon/codegen/CodeGeneratorImpl.java x: 42 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java x: 357 lines of code y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/PreAssignSplitAssigner.java x: 123 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/statistics/StatisticsHelperBase.scala x: 75 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 220 lines of code y: 23 # changes paimon-common/src/main/java/org/apache/paimon/utils/BinaryStringUtils.java x: 265 lines of code y: 4 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java x: 414 lines of code y: 6 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java x: 239 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 21 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StartingScanner.java x: 44 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/NumberSequenceRowSource.java x: 302 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 50 lines of code y: 14 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/utils/TableMigrationUtils.java x: 59 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/consumer/Consumer.java x: 51 lines of code y: 10 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/MigrateTableProcedure.java x: 113 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeTreeCompactRewriter.java x: 65 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeTreeCompactRewriter.java x: 155 lines of code y: 18 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 237 lines of code y: 16 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresActionUtils.java x: 158 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java x: 347 lines of code y: 11 # changes paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexOptions.java x: 180 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ProcedureBase.java x: 79 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/DeleteTagProcedure.java x: 26 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java x: 131 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java x: 249 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 209 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 265 lines of code y: 11 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 436 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/FieldWriterFactory.java x: 210 lines of code y: 3 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/DataFormat.java x: 15 lines of code y: 8 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 284 lines of code y: 16 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarActionUtils.java x: 347 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 218 lines of code y: 25 # changes paimon-core/src/main/java/org/apache/paimon/sort/AbstractBinaryExternalMerger.java x: 131 lines of code y: 5 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java x: 229 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSinkBase.java x: 139 lines of code y: 12 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcPredicateFunctionVisitor.java x: 177 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/LookupLevels.java x: 287 lines of code y: 17 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 590 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/options/MemorySize.java x: 272 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/stats/Statistics.java x: 150 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryArrayWriter.java x: 195 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDataColumnReaderFactory.java x: 154 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/utils/PartitionPathUtils.java x: 162 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/source/RawFile.java x: 96 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 173 lines of code y: 20 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetFileFormatFactory.java x: 13 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactRewriter.java x: 92 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/DataTableScan.java x: 4 lines of code y: 3 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 82 lines of code y: 15 # changes paimon-format/src/main/java/org/apache/orc/impl/RecordReaderUtils.java x: 593 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/sort/SparkHilbertUDF.java x: 194 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 278 lines of code y: 5 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/format/DebeziumEvent.java x: 177 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/privilege/FileBasedPrivilegeManager.java x: 376 lines of code y: 1 # changes paimon-common/src/main/antlr4/JavaParser.g4 x: 520 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 207 lines of code y: 11 # changes paimon-format/src/main/java/org/apache/orc/OrcFile.java x: 854 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/orc/impl/WriterImpl.java x: 821 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 133 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java x: 142 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReaderWithMinHeap.java x: 156 lines of code y: 2 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputSplit.java x: 109 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/LookupUtils.java x: 86 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/CodeRewriter.java x: 4 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/DeclarationRewriter.java x: 169 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/fs/Path.java x: 200 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 436 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/plugin/ComponentClassLoader.java x: 171 lines of code y: 7 # changes paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2506 lines of code y: 4 # changes paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/LocationKeyExtractor.java x: 107 lines of code y: 9 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveDeserializer.java x: 221 lines of code y: 4 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonStringObjectInspector.java x: 33 lines of code y: 6 # changes paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network/NetworkServer.java x: 236 lines of code y: 4 # changes paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network/ServerConnection.java x: 316 lines of code y: 3 # changes paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network/AbstractServerHandler.java x: 239 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java x: 5 lines of code y: 5 # changes tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck/JarFileChecker.java x: 249 lines of code y: 1 # changes tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck/NoticeFileChecker.java x: 299 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 5 lines of code y: 15 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java x: 197 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LoserTree.java x: 244 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowData.java x: 252 lines of code y: 3 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java x: 250 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryString.java x: 734 lines of code y: 2 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java x: 748 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/Preconditions.java x: 114 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/Projection.java x: 265 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/sort/BinaryIndexedSortable.java x: 171 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/sort/QuickSort.java x: 240 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/SortUtil.java x: 211 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/options/StructuredOptionsSplitter.java x: 129 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypeCasts.java x: 228 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedInputView.java x: 370 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedOutputView.java x: 276 lines of code y: 1 # changes
149.0
# changes
  min: 1.0
  average: 5.01
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 149.0
0 2825.0
lines of code
min: 2.0 | average: 91.83 | 25th percentile: 22.0 | median: 49.0 | 75th percentile: 105.25 | max: 2825.0

Number of Contributors vs. Number of Changes: 2422 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 4 # contributors y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 5 # contributors y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 2 # contributors y: 2 # changes paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 # contributors y: 3 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 6 # contributors y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 3 # contributors y: 14 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 9 # contributors y: 31 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 # contributors y: 1 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 3 # contributors y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 9 # contributors y: 34 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util/OptionUtils.scala x: 4 # contributors y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 14 # contributors y: 32 # changes paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 7 # contributors y: 16 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 6 # contributors y: 41 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 5 # contributors y: 13 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 4 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 3 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProvider.java x: 4 # contributors y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 25 # contributors y: 108 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 7 # contributors y: 12 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTimestampStartingScanner.java x: 6 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 5 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 9 # contributors y: 16 # changes paimon-core/src/main/java/org/apache/paimon/table/system/TableIndexesTable.java x: 3 # contributors y: 4 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 4 # contributors y: 7 # changes paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 44 # contributors y: 149 # changes paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 24 # contributors y: 69 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 5 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 6 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java x: 4 # contributors y: 14 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/UpdatePaimonTableCommand.scala x: 5 # contributors y: 19 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 8 # contributors y: 16 # changes paimon-common/src/main/java/org/apache/paimon/utils/OptimizedRoaringBitmap64.java x: 1 # contributors y: 2 # changes paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 26 # contributors y: 88 # changes paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 16 # contributors y: 47 # changes paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 7 # contributors y: 23 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 35 # contributors y: 98 # changes paimon-open-api/rest-catalog-open-api.yaml x: 5 # contributors y: 33 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/AbstractOrcColumnVector.java x: 5 # contributors y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcMapColumnVector.java x: 6 # contributors y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/writer/RowDataVectorizer.java x: 6 # contributors y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReaderFactory.scala x: 2 # contributors y: 6 # changes paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 3 # contributors y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 12 # contributors y: 30 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/DynamicPartitionLoader.java x: 3 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 14 # contributors y: 31 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 5 # contributors y: 7 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 7 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 3 # contributors y: 6 # changes paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 10 # contributors y: 17 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 15 # contributors y: 34 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 20 # contributors y: 44 # changes paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 11 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 13 # contributors y: 37 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 7 # contributors y: 13 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 10 # contributors y: 21 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 9 # contributors y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendBypassCompactWorkerOperator.java x: 2 # contributors y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendCompactWorkerOperator.java x: 3 # contributors y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 6 # contributors y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java x: 8 # contributors y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 12 # contributors y: 35 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperator.java x: 2 # contributors y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperatorFactory.java x: 2 # contributors y: 4 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 12 # contributors y: 28 # changes paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 1 # contributors y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 11 # contributors y: 16 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 14 # contributors y: 41 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 19 # contributors y: 54 # changes paimon-common/src/main/java/org/apache/paimon/utils/RoaringBitmap32.java x: 6 # contributors y: 12 # changes paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 5 # contributors y: 12 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala x: 6 # contributors y: 27 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 5 # contributors y: 18 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 10 # contributors y: 22 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 12 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 10 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 12 # contributors y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 10 # contributors y: 18 # changes paimon-core/src/main/java/org/apache/paimon/table/DataTable.java x: 7 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java x: 6 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 12 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 16 # contributors y: 57 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionFactory.java x: 11 # contributors y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 8 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 17 # contributors y: 38 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 15 # contributors y: 36 # changes paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 28 # contributors y: 59 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 8 # contributors y: 13 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 9 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 13 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 12 # contributors y: 49 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 6 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 15 # contributors y: 47 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 8 # contributors y: 17 # changes paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java x: 13 # contributors y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 22 # contributors y: 57 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 23 # contributors y: 58 # changes paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java x: 4 # contributors y: 22 # changes paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 11 # contributors y: 27 # changes paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 4 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 9 # contributors y: 17 # changes paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 13 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 22 # contributors y: 61 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 10 # contributors y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 9 # contributors y: 32 # changes paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 8 # contributors y: 18 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala x: 5 # contributors y: 10 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 8 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 7 # contributors y: 15 # changes paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 8 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScan.java x: 8 # contributors y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java x: 9 # contributors y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java x: 8 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java x: 10 # contributors y: 23 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 25 # contributors y: 68 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkProcedures.java x: 16 # contributors y: 28 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 11 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/CatalogEnvironment.java x: 3 # contributors y: 12 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/extensions/PaimonSparkSessionExtensions.scala x: 6 # contributors y: 19 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScanBuilder.scala x: 5 # contributors y: 11 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/canal/CanalRecordParser.java x: 4 # contributors y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 7 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java x: 6 # contributors y: 15 # changes paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java x: 4 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/rest/requests/CommitTableRequest.java x: 1 # contributors y: 4 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionManagement.scala x: 8 # contributors y: 21 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionBase.java x: 7 # contributors y: 17 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 6 # contributors y: 13 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 12 # contributors y: 16 # changes paimon-core/src/main/java/org/apache/paimon/rest/LoggingInterceptor.java x: 2 # contributors y: 1 # changes paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthSignature.java x: 3 # contributors y: 2 # changes paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 2 # contributors y: 7 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 8 # contributors y: 19 # changes paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java x: 9 # contributors y: 15 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 15 # contributors y: 24 # changes paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 11 # contributors y: 25 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsAction.java x: 7 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 4 # contributors y: 18 # changes paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java x: 9 # contributors y: 20 # changes paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 13 # contributors y: 29 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 16 # contributors y: 38 # changes paimon-core/src/main/java/org/apache/paimon/utils/RecordWriter.java x: 7 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 13 # contributors y: 23 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreMultiCommitter.java x: 11 # contributors y: 18 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 11 # contributors y: 21 # changes paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 16 # contributors y: 36 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 12 # contributors y: 21 # changes paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 10 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 26 # contributors y: 51 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactActionFactory.java x: 8 # contributors y: 11 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java x: 9 # contributors y: 23 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 14 # contributors y: 29 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala x: 4 # contributors y: 23 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScanBuilder.scala x: 3 # contributors y: 10 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScan.scala x: 3 # contributors y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 12 # contributors y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 12 # contributors y: 32 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataBuilder.java x: 4 # contributors y: 3 # changes paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 10 # contributors y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/NoPrimaryKeyLookupTable.java x: 5 # contributors y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyLookupTable.java x: 5 # contributors y: 15 # changes paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java x: 14 # contributors y: 40 # changes paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 10 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 9 # contributors y: 24 # changes paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java x: 3 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java x: 6 # contributors y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSource.java x: 11 # contributors y: 15 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 4 # contributors y: 15 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 4 # contributors y: 13 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 9 # contributors y: 29 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 8 # contributors y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/TableActionBase.java x: 4 # contributors y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactDatabaseProcedure.java x: 7 # contributors y: 10 # changes paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 7 # contributors y: 19 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/DeleteBranchProcedure.java x: 5 # contributors y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 9 # contributors y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sorter/SortUtils.java x: 8 # contributors y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 10 # contributors y: 16 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java x: 14 # contributors y: 17 # changes paimon-core/src/main/java/org/apache/paimon/compact/CompactTask.java x: 8 # contributors y: 7 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/statistics/StatisticsHelperBase.scala x: 1 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 12 # contributors y: 23 # changes paimon-common/src/main/java/org/apache/paimon/compression/BlockCompressionFactory.java x: 1 # contributors y: 5 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 2 # contributors y: 9 # changes paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 6 # contributors y: 16 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 12 # contributors y: 25 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 9 # contributors y: 18 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 7 # contributors y: 20 # changes
149.0
# changes
  min: 1.0
  average: 5.01
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 149.0
0 44.0
# contributors
min: 1.0 | average: 3.09 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 44.0

Number of Contributors vs. File Size: 2422 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 4 # contributors y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 5 # contributors y: 88 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 2 # contributors y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 # contributors y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 6 # contributors y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 3 # contributors y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 9 # contributors y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 # contributors y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 # contributors y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 # contributors y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 3 # contributors y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 9 # contributors y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util/OptionUtils.scala x: 4 # contributors y: 81 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 # contributors y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 14 # contributors y: 97 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/CreateOrReplaceTagExec.scala x: 2 # contributors y: 51 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 7 # contributors y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 6 # contributors y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 5 # contributors y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 4 # contributors y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 3 # contributors y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 2 # contributors y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java x: 2 # contributors y: 21 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java x: 3 # contributors y: 49 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFECSTokenLoader.java x: 2 # contributors y: 90 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java x: 2 # contributors y: 38 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 2 # contributors y: 76 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalog/functions/PaimonFunctions.scala x: 2 # contributors y: 104 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 25 # contributors y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 7 # contributors y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 3 # contributors y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTimestampStartingScanner.java x: 6 # contributors y: 35 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 5 # contributors y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 9 # contributors y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 4 # contributors y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 44 # contributors y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 24 # contributors y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 2 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 5 # contributors y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 6 # contributors y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 5 # contributors y: 122 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 4 # contributors y: 184 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 8 # contributors y: 337 lines of code paimon-common/src/main/java/org/apache/paimon/utils/OptimizedRoaringBitmap64.java x: 1 # contributors y: 185 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 26 # contributors y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 16 # contributors y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 7 # contributors y: 235 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 35 # contributors y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 5 # contributors y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 5 # contributors y: 871 lines of code paimon-format/src/main/java/org/apache/paimon/format/OrcOptions.java x: 4 # contributors y: 26 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/AbstractOrcColumnVector.java x: 5 # contributors y: 74 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcArrayColumnVector.java x: 5 # contributors y: 34 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 3 # contributors y: 102 lines of code paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 3 # contributors y: 71 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 12 # contributors y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 7 # contributors y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 5 # contributors y: 343 lines of code paimon-core/src/main/java/org/apache/paimon/utils/CompressUtils.java x: 1 # contributors y: 23 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/DynamicPartitionLoader.java x: 3 # contributors y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ListCloneFilesFunction.java x: 2 # contributors y: 129 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RollbackProcedure.java x: 4 # contributors y: 101 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowUtils.java x: 4 # contributors y: 213 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/OneElementFieldVectorGenerator.java x: 3 # contributors y: 39 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java x: 4 # contributors y: 149 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 3 # contributors y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 14 # contributors y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 5 # contributors y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneFilesFunction.java x: 1 # contributors y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneProcessFunction.java x: 1 # contributors y: 61 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneUtils.java x: 1 # contributors y: 119 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyDataFileOperator.java x: 1 # contributors y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyFilesUtil.java x: 1 # contributors y: 215 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 # contributors y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 # contributors y: 205 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CopyFilesProcedure.java x: 1 # contributors y: 79 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 7 # contributors y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 3 # contributors y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 10 # contributors y: 217 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 15 # contributors y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 20 # contributors y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 11 # contributors y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java x: 1 # contributors y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactTask.java x: 1 # contributors y: 111 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java x: 1 # contributors y: 144 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 2 # contributors y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 # contributors y: 198 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 13 # contributors y: 118 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 7 # contributors y: 108 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 10 # contributors y: 187 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 9 # contributors y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendTableCompactor.java x: 1 # contributors y: 156 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendCompactWorkerOperator.java x: 3 # contributors y: 81 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 6 # contributors y: 162 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java x: 8 # contributors y: 159 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 12 # contributors y: 302 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 12 # contributors y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 6 # contributors y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 1 # contributors y: 249 lines of code paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java x: 2 # contributors y: 199 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala x: 4 # contributors y: 124 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 11 # contributors y: 205 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 2 # contributors y: 279 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/BucketExpression.scala x: 2 # contributors y: 58 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 14 # contributors y: 346 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/partitioner/ShuffleStrategy.java x: 1 # contributors y: 7 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 5 # contributors y: 187 lines of code paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/HadoopCompliantFileIO.java x: 2 # contributors y: 219 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 19 # contributors y: 773 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 4 # contributors y: 671 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java x: 6 # contributors y: 148 lines of code paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 5 # contributors y: 225 lines of code paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java x: 4 # contributors y: 286 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala x: 6 # contributors y: 114 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 5 # contributors y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 10 # contributors y: 147 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 12 # contributors y: 364 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 10 # contributors y: 88 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataRollingFileWriter.java x: 11 # contributors y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 8 # contributors y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 12 # contributors y: 239 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 10 # contributors y: 164 lines of code paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs/OBSFileIO.java x: 1 # contributors y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/table/DataTable.java x: 7 # contributors y: 25 lines of code paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java x: 6 # contributors y: 253 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 12 # contributors y: 99 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 16 # contributors y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/CompactBucketsTable.java x: 2 # contributors y: 210 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 5 # contributors y: 265 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 5 # contributors y: 157 lines of code paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/PurgeFilesProcedure.java x: 3 # contributors y: 15 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/KeyValueTableRead.java x: 5 # contributors y: 111 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceReader.java x: 7 # contributors y: 78 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FormatCatalogTable.java x: 3 # contributors y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionFactory.java x: 11 # contributors y: 111 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 2 # contributors y: 344 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LogSinkFunction.java x: 3 # contributors y: 10 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 8 # contributors y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 17 # contributors y: 213 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 15 # contributors y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 19 # contributors y: 392 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 12 # contributors y: 122 lines of code paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyFileStoreTable.java x: 12 # contributors y: 151 lines of code paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 10 # contributors y: 132 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 28 # contributors y: 591 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 8 # contributors y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 9 # contributors y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 13 # contributors y: 57 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 12 # contributors y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 6 # contributors y: 85 lines of code paimon-core/src/main/java/org/apache/paimon/operation/ManifestsReader.java x: 2 # contributors y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 6 # contributors y: 71 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 15 # contributors y: 493 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 4 # contributors y: 70 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 5 # contributors y: 47 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 8 # contributors y: 246 lines of code paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java x: 13 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 4 # contributors y: 8 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java x: 6 # contributors y: 282 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndex.java x: 2 # contributors y: 318 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ThreadPoolUtils.java x: 4 # contributors y: 158 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 22 # contributors y: 488 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTask.java x: 4 # contributors y: 308 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 23 # contributors y: 322 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScanner.java x: 7 # contributors y: 55 lines of code paimon-open-api/rest-management-api.yaml x: 3 # contributors y: 320 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 11 # contributors y: 396 lines of code paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 4 # contributors y: 295 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergDataFileMeta.java x: 3 # contributors y: 218 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 9 # contributors y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 12 # contributors y: 370 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 13 # contributors y: 331 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java x: 6 # contributors y: 221 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 5 # contributors y: 269 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDeltaStartingScanner.java x: 3 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldAggregatorFactory.java x: 4 # contributors y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 22 # contributors y: 1384 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageLegacyV2Serializer.java x: 3 # contributors y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java x: 6 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 9 # contributors y: 299 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 8 # contributors y: 421 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RewriteFileIndexSink.java x: 4 # contributors y: 321 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala x: 5 # contributors y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 8 # contributors y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 7 # contributors y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestList.java x: 7 # contributors y: 96 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 8 # contributors y: 284 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScan.java x: 8 # contributors y: 37 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java x: 9 # contributors y: 34 lines of code paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java x: 10 # contributors y: 197 lines of code paimon-core/src/main/java/org/apache/paimon/view/ViewChange.java x: 1 # contributors y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 25 # contributors y: 1426 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkProcedures.java x: 16 # contributors y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDone.java x: 7 # contributors y: 188 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDoneTrigger.java x: 5 # contributors y: 175 lines of code paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolution.java x: 3 # contributors y: 233 lines of code paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java x: 6 # contributors y: 191 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndexMeta.java x: 5 # contributors y: 247 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumJsonRecordParser.java x: 2 # contributors y: 187 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java x: 7 # contributors y: 215 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresRecordParser.java x: 5 # contributors y: 292 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java x: 3 # contributors y: 159 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/MultiAwareBucketTableScan.java x: 4 # contributors y: 65 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java x: 10 # contributors y: 306 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java x: 6 # contributors y: 303 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java x: 7 # contributors y: 175 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java x: 4 # contributors y: 172 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionManagement.scala x: 8 # contributors y: 120 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java x: 7 # contributors y: 264 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 9 # contributors y: 348 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 4 # contributors y: 262 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 5 # contributors y: 505 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 6 # contributors y: 345 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 12 # contributors y: 224 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 2 # contributors y: 268 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/heap/HeapRowVector.java x: 6 # contributors y: 31 lines of code paimon-core/src/main/java/org/apache/paimon/operation/TagDeletion.java x: 6 # contributors y: 89 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexFormat.java x: 2 # contributors y: 241 lines of code paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java x: 6 # contributors y: 179 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 15 # contributors y: 468 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetUtil.java x: 6 # contributors y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 4 # contributors y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java x: 9 # contributors y: 238 lines of code paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 13 # contributors y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullStartingScanner.java x: 5 # contributors y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupFileStoreTable.java x: 2 # contributors y: 112 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 16 # contributors y: 430 lines of code paimon-core/src/main/java/org/apache/paimon/compact/CompactManager.java x: 5 # contributors y: 17 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 12 # contributors y: 326 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/UniversalCompaction.java x: 5 # contributors y: 192 lines of code paimon-core/src/main/java/org/apache/paimon/utils/RecordWriter.java x: 7 # contributors y: 16 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 13 # contributors y: 181 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 9 # contributors y: 75 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 11 # contributors y: 124 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 16 # contributors y: 152 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 12 # contributors y: 143 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 5 # contributors y: 597 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 8 # contributors y: 297 lines of code paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 10 # contributors y: 393 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileStoreSource.java x: 8 # contributors y: 62 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 26 # contributors y: 566 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/SortBufferWriteBuffer.java x: 4 # contributors y: 223 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupChangelogMergeFunctionWrapper.java x: 8 # contributors y: 153 lines of code paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyTableUtils.java x: 7 # contributors y: 63 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 10 # contributors y: 169 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/CatalogOptionsTable.java x: 5 # contributors y: 144 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 12 # contributors y: 415 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 7 # contributors y: 158 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 8 # contributors y: 167 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java x: 11 # contributors y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java x: 10 # contributors y: 272 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcFileFormat.java x: 15 # contributors y: 158 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java x: 12 # contributors y: 255 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/FieldWriterFactory.java x: 3 # contributors y: 270 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 14 # contributors y: 325 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 12 # contributors y: 518 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/LocationHelper.java x: 6 # contributors y: 17 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/TBPropertiesLocationHelper.java x: 7 # contributors y: 67 lines of code paimon-common/src/main/java/org/apache/paimon/sort/zorder/ZIndexer.java x: 1 # contributors y: 328 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/sort/SparkZOrderUDF.java x: 3 # contributors y: 287 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java x: 4 # contributors y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionFactory.java x: 6 # contributors y: 53 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/ParquetVectorUpdaterFactory.java x: 1 # contributors y: 679 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedColumnReader.java x: 1 # contributors y: 267 lines of code paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneAction.java x: 2 # contributors y: 174 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SynchronizationActionBase.java x: 11 # contributors y: 167 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScan.scala x: 3 # contributors y: 126 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 10 # contributors y: 259 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/converter/Arrow2PaimonVectorConverter.java x: 2 # contributors y: 470 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/MapColumnVector.java x: 5 # contributors y: 5 lines of code paimon-common/src/main/java/org/apache/paimon/utils/VectorMappingUtils.java x: 3 # contributors y: 342 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedRleValuesReader.java x: 1 # contributors y: 803 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java x: 5 # contributors y: 575 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 9 # contributors y: 529 lines of code paimon-format/src/main/java/org/apache/orc/OrcConf.java x: 4 # contributors y: 466 lines of code paimon-core/src/main/java/org/apache/paimon/operation/LocalOrphanFilesClean.java x: 6 # contributors y: 240 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java x: 8 # contributors y: 81 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java x: 10 # contributors y: 120 lines of code paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 9 # contributors y: 344 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java x: 7 # contributors y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 10 # contributors y: 286 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 4 # contributors y: 545 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMetadata.java x: 2 # contributors y: 263 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java x: 10 # contributors y: 329 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 7 # contributors y: 390 lines of code paimon-format/src/main/java/org/apache/orc/impl/RecordReaderImpl.java x: 3 # contributors y: 1426 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 10 # contributors y: 59 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 9 # contributors y: 595 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 10 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntry.java x: 7 # contributors y: 139 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 8 # contributors y: 323 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 9 # contributors y: 319 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 3 # contributors y: 690 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryArray.java x: 3 # contributors y: 468 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 4 # contributors y: 358 lines of code paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java x: 4 # contributors y: 196 lines of code paimon-common/src/main/java/org/apache/paimon/data/NestedRow.java x: 3 # contributors y: 256 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 3 # contributors y: 205 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariant.java x: 1 # contributors y: 384 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 3 # contributors y: 781 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkRowWrapper.java x: 3 # contributors y: 255 lines of code paimon-format/src/main/java/org/apache/parquet/filter2/predicate/ParquetFilters.java x: 5 # contributors y: 234 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/FixedLenBytesColumnReader.java x: 8 # contributors y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/LogHybridSourceFactory.java x: 7 # contributors y: 117 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSource.java x: 11 # contributors y: 80 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java x: 6 # contributors y: 206 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 8 # contributors y: 304 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MergeIntoProcedure.java x: 5 # contributors y: 148 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantBuilder.java x: 1 # contributors y: 499 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantUtil.java x: 1 # contributors y: 412 lines of code paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcUtils.java x: 2 # contributors y: 457 lines of code paimon-core/src/main/java/org/apache/paimon/partition/PartitionPredicate.java x: 3 # contributors y: 190 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/AbstractColumnReader.java x: 7 # contributors y: 267 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactory.java x: 8 # contributors y: 15 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalog.java x: 4 # contributors y: 423 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 9 # contributors y: 26 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/LocalMergeOperator.java x: 7 # contributors y: 198 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/optimizer/MergePaimonScalarSubqueriesBase.scala x: 2 # contributors y: 304 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java x: 4 # contributors y: 143 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 3 # contributors y: 483 lines of code paimon-spark/paimon-spark-common/src/main/antlr4/org.apache.spark.sql.catalyst.parser.extensions/PaimonSqlExtensions.g4 x: 2 # contributors y: 233 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java x: 14 # contributors y: 25 lines of code paimon-common/src/main/java/org/apache/paimon/options/OptionsUtils.java x: 4 # contributors y: 255 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSplitEnumerator.java x: 9 # contributors y: 115 lines of code paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java x: 5 # contributors y: 357 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 12 # contributors y: 220 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/TableStatsUtil.java x: 2 # contributors y: 250 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java x: 5 # contributors y: 414 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java x: 3 # contributors y: 239 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/NumberSequenceRowSource.java x: 1 # contributors y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 9 # contributors y: 50 lines of code paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java x: 7 # contributors y: 347 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 8 # contributors y: 265 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/AvroSchemaConverter.java x: 5 # contributors y: 211 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 3 # contributors y: 436 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarActionUtils.java x: 4 # contributors y: 347 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcPredicateFunctionVisitor.java x: 6 # contributors y: 177 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/LookupLevels.java x: 7 # contributors y: 287 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 4 # contributors y: 590 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 5 # contributors y: 528 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/RewriteFileIndexSource.java x: 1 # contributors y: 224 lines of code paimon-format/src/main/java/org/apache/orc/impl/RecordReaderUtils.java x: 1 # contributors y: 593 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 4 # contributors y: 278 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/FileBasedPrivilegeManager.java x: 1 # contributors y: 376 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSink.java x: 10 # contributors y: 26 lines of code paimon-common/src/main/antlr4/JavaParser.g4 x: 2 # contributors y: 520 lines of code paimon-format/src/main/java/org/apache/orc/OrcFile.java x: 2 # contributors y: 854 lines of code paimon-format/src/main/java/org/apache/orc/impl/PhysicalFsWriter.java x: 2 # contributors y: 595 lines of code paimon-format/src/main/java/org/apache/orc/impl/WriterImpl.java x: 2 # contributors y: 821 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/SortCodeGenerator.scala x: 3 # contributors y: 290 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 4 # contributors y: 436 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 3 # contributors y: 2506 lines of code tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck/NoticeFileChecker.java x: 1 # contributors y: 299 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 9 # contributors y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LoserTree.java x: 1 # contributors y: 244 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryString.java x: 2 # contributors y: 734 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java x: 3 # contributors y: 748 lines of code
2825.0
lines of code
  min: 2.0
  average: 91.83
  25th percentile: 22.0
  median: 49.0
  75th percentile: 105.25
  max: 2825.0
0 44.0
# contributors
min: 1.0 | average: 3.09 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 44.0