apache / incubator-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 1,188 files with 98,720 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 4 files changed 21-50 times (1,281 lines of code)
    • 142 files changed 6-20 times (22,815 lines of code)
    • 1,042 files changed 1-5 times (74,624 lines of code)
0% | 0% | 1% | 23% | 75%
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 1,188 files with 98,720 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 3 files changed by 11-25 contributors (1,257 lines of code)
    • 61 files changed by 6-10 contributors (11,542 lines of code)
    • 622 files changed by 2-5 contributors (59,648 lines of code)
    • 502 files changed by 1 contributor (26,273 lines of code)
0% | 1% | 11% | 60% | 26%
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, md, xml, html, txt, scala, properties, yml, sh, svg, sql, yaml, js, scss, orc, gitignore, g4, css, json, toml, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 1% | 23% | 75%
scala0% | 0% | 0% | 9% | 90%
g40% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
yaml0% | 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-flink0% | 0% | 4% | 31% | 64%
paimon-core0% | 0% | 1% | 32% | 66%
paimon-common0% | 0% | 0% | 11% | 88%
paimon-hive0% | 0% | 0% | 50% | 49%
paimon-spark0% | 0% | 0% | 60% | 39%
paimon-format0% | 0% | 0% | 4% | 95%
paimon-benchmark0% | 0% | 0% | 0% | 100%
paimon-filesystems0% | 0% | 0% | 0% | 100%
paimon-codegen0% | 0% | 0% | 0% | 100%
tools0% | 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
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 369 27 2023-03-17 2023-08-07 26 9 lzljs3620320@aliyun.com jingsonglee0@gmail.com
MySqlDebeziumJsonEventParser.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 389 13 2023-04-03 2023-08-08 26 9 tsreaper96@gmail.com zhangjunemail@126.com
MySqlSyncTableAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 192 6 2023-04-03 2023-08-08 22 8 tsreaper96@gmail.com 37063904+zhuangchong@users....
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 331 14 2023-04-14 2023-08-03 21 12 tsreaper96@gmail.com 33053040+yuzelin@users.nore...
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 707 54 2023-03-17 2023-07-31 20 10 lzljs3620320@aliyun.com 41894543+leaves12138@users....
FlinkSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 178 7 2023-03-17 2023-08-07 18 10 lzljs3620320@aliyun.com 60029759+monsterchenzhuo@us...
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 341 54 2023-03-17 2023-08-07 17 5 lzljs3620320@aliyun.com jingsonglee0@gmail.com
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 617 35 2023-03-17 2023-07-31 17 12 lzljs3620320@aliyun.com zhangjunemail@126.com
AbstractFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 183 14 2023-03-17 2023-08-01 15 6 lzljs3620320@aliyun.com biyan900116@gmail.com
HiveSchema.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive
 259 10 2023-03-17 2023-07-29 15 8 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 309 9 2023-03-17 2023-08-07 15 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
StoreSinkWriteImpl.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 190 15 2023-03-17 2023-08-04 14 8 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
ChangelogWithKeyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 234 13 2023-03-17 2023-08-07 14 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 234 4 2023-03-17 2023-07-27 14 9 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
SnapshotManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 248 16 2023-03-17 2023-07-07 14 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
KeyValueFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 263 7 2023-03-17 2023-07-29 14 9 lzljs3620320@aliyun.com 41894543+leaves12138@users....
MySqlActionUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 302 7 2023-04-14 2023-08-08 14 8 tsreaper96@gmail.com 37063904+zhuangchong@users....
Action.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 4 - 2023-03-17 2023-07-11 13 8 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
MySqlSchema.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 109 7 2023-04-14 2023-08-03 13 5 tsreaper96@gmail.com 33053040+yuzelin@users.nore...
PaimonInputFormat.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred
 113 2 2023-03-18 2023-07-25 13 7 lzljs3620320@aliyun.com tsreaper96@gmail.com
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 163 13 2023-03-17 2023-08-02 13 10 lzljs3620320@aliyun.com zjureel@gmail.com
DataTableSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 251 14 2023-03-18 2023-07-25 13 8 lzljs3620320@aliyun.com 1059789585@qq.com
AppendOnlyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 120 8 2023-03-17 2023-08-02 12 7 lzljs3620320@aliyun.com zjureel@gmail.com
FileStoreExpireImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 151 6 2023-03-17 2023-07-06 12 5 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
FileStoreLookupFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup
 183 11 2023-03-17 2023-07-24 12 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 229 17 2023-03-17 2023-07-27 12 8 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 354 21 2023-03-17 2023-08-04 12 7 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 822 22 2023-03-17 2023-07-24 12 7 lzljs3620320@aliyun.com 1525565289@qq.com
ActionBase.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 33 2 2023-03-17 2023-07-25 11 6 lzljs3620320@aliyun.com zjureel@gmail.com
FlinkSinkBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 79 9 2023-03-17 2023-08-07 11 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
CompactAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 85 7 2023-03-17 2023-07-11 11 6 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
SparkTable.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 100 8 2023-03-17 2023-08-01 11 6 lzljs3620320@aliyun.com biyan900116@gmail.com
CompactorSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 105 9 2023-03-17 2023-06-09 11 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
PaimonMetaHook.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive
 130 8 2023-03-18 2023-08-04 11 7 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
AbstractInnerTableScan.java
in paimon-core/src/main/java/org/apache/paimon/table/source
 136 6 2023-04-04 2023-08-07 11 5 33053040+yuzelin@users.nore... jingsonglee0@gmail.com
TableWriteImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 138 21 2023-03-17 2023-08-04 11 8 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
InnerStreamTableScanImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source
 196 11 2023-04-04 2023-07-27 11 6 33053040+yuzelin@users.nore... 69444450+liming30@users.nor...
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 308 29 2023-03-17 2023-07-21 11 6 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
FileStoreSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 22 2 2023-03-17 2023-06-25 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
StaticFileStoreSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 59 5 2023-03-17 2023-06-27 10 8 lzljs3620320@aliyun.com 41894543+leaves12138@users....
ContinuousFileStoreSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 62 5 2023-03-17 2023-07-27 10 7 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
StoreCompactOperator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 98 7 2023-03-17 2023-08-01 10 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
OrcFileFormat.java
in paimon-format/src/main/java/org/apache/paimon/format/orc
 138 9 2023-03-17 2023-07-19 10 7 lzljs3620320@aliyun.com 1026688210@qq.com
FlinkCdcSyncDatabaseSinkBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc
 140 11 2023-04-13 2023-08-07 10 5 tsreaper96@gmail.com jingsonglee0@gmail.com
ManifestFile.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 143 7 2023-03-17 2023-07-05 10 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
ChangelogValueCountFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 160 12 2023-03-17 2023-08-07 10 5 lzljs3620320@aliyun.com jingsonglee0@gmail.com
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 166 28 2023-03-17 2023-07-31 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
TableCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 169 14 2023-03-17 2023-07-19 10 4 lzljs3620320@aliyun.com jingsonglee0@gmail.com
ContinuousFileSplitEnumerator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 193 19 2023-03-17 2023-08-04 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 298 22 2023-03-17 2023-08-07 10 5 lzljs3620320@aliyun.com jingsonglee0@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
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 331 14 2023-04-14 2023-08-03 21 12 tsreaper96@gmail.com 33053040+yuzelin@users.nore...
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 617 35 2023-03-17 2023-07-31 17 12 lzljs3620320@aliyun.com zhangjunemail@126.com
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 309 9 2023-03-17 2023-08-07 15 12 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 707 54 2023-03-17 2023-07-31 20 10 lzljs3620320@aliyun.com 41894543+leaves12138@users....
FlinkSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 178 7 2023-03-17 2023-08-07 18 10 lzljs3620320@aliyun.com 60029759+monsterchenzhuo@us...
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 163 13 2023-03-17 2023-08-02 13 10 lzljs3620320@aliyun.com zjureel@gmail.com
MySqlDebeziumJsonEventParser.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 389 13 2023-04-03 2023-08-08 26 9 tsreaper96@gmail.com zhangjunemail@126.com
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 369 27 2023-03-17 2023-08-07 26 9 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 234 4 2023-03-17 2023-07-27 14 9 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
KeyValueFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 263 7 2023-03-17 2023-07-29 14 9 lzljs3620320@aliyun.com 41894543+leaves12138@users....
MySqlSyncTableAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 192 6 2023-04-03 2023-08-08 22 8 tsreaper96@gmail.com 37063904+zhuangchong@users....
HiveSchema.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive
 259 10 2023-03-17 2023-07-29 15 8 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
StoreSinkWriteImpl.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 190 15 2023-03-17 2023-08-04 14 8 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
MySqlActionUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 302 7 2023-04-14 2023-08-08 14 8 tsreaper96@gmail.com 37063904+zhuangchong@users....
DataTableSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 251 14 2023-03-18 2023-07-25 13 8 lzljs3620320@aliyun.com 1059789585@qq.com
Action.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 4 - 2023-03-17 2023-07-11 13 8 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 229 17 2023-03-17 2023-07-27 12 8 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
TableWriteImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 138 21 2023-03-17 2023-08-04 11 8 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
StaticFileStoreSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 59 5 2023-03-17 2023-06-27 10 8 lzljs3620320@aliyun.com 41894543+leaves12138@users....
AbstractFlinkTableFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 217 9 2023-03-18 2023-08-02 8 8 lzljs3620320@aliyun.com zjureel@gmail.com
ChangelogWithKeyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 234 13 2023-03-17 2023-08-07 14 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
PaimonInputFormat.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred
 113 2 2023-03-18 2023-07-25 13 7 lzljs3620320@aliyun.com tsreaper96@gmail.com
FileStoreLookupFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup
 183 11 2023-03-17 2023-07-24 12 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 354 21 2023-03-17 2023-08-04 12 7 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 822 22 2023-03-17 2023-07-24 12 7 lzljs3620320@aliyun.com 1525565289@qq.com
AppendOnlyFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 120 8 2023-03-17 2023-08-02 12 7 lzljs3620320@aliyun.com zjureel@gmail.com
CompactorSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 105 9 2023-03-17 2023-06-09 11 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
PaimonMetaHook.java
in paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive
 130 8 2023-03-18 2023-08-04 11 7 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
ContinuousFileSplitEnumerator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 193 19 2023-03-17 2023-08-04 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
ContinuousFileStoreSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 62 5 2023-03-17 2023-07-27 10 7 lzljs3620320@aliyun.com 69444450+liming30@users.nor...
FileStoreSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 22 2 2023-03-17 2023-06-25 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
StoreCompactOperator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 98 7 2023-03-17 2023-08-01 10 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 166 28 2023-03-17 2023-07-31 10 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
OrcFileFormat.java
in paimon-format/src/main/java/org/apache/paimon/format/orc
 138 9 2023-03-17 2023-07-19 10 7 lzljs3620320@aliyun.com 1026688210@qq.com
StaticFileStoreSplitEnumerator.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 58 8 2023-03-17 2023-06-27 9 7 lzljs3620320@aliyun.com 41894543+leaves12138@users....
SystemTableSource.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 86 8 2023-03-17 2023-07-07 9 7 lzljs3620320@aliyun.com jingsonglee0@gmail.com
StoreSinkWrite.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 43 1 2023-03-17 2023-07-27 9 7 lzljs3620320@aliyun.com 33053040+yuzelin@users.nore...
HiveTypeUtils.java
in paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive
 215 26 2023-03-17 2023-07-29 9 7 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
SparkCatalog.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 370 20 2023-03-17 2023-07-27 8 7 lzljs3620320@aliyun.com zjureel@gmail.com
FlinkTableSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 191 11 2023-03-18 2023-07-03 7 7 lzljs3620320@aliyun.com taokelu@bytedance.com
AbstractFileStore.java
in paimon-core/src/main/java/org/apache/paimon
 183 14 2023-03-17 2023-08-01 15 6 lzljs3620320@aliyun.com biyan900116@gmail.com
SnapshotManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 248 16 2023-03-17 2023-07-07 14 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
FlinkSinkBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 79 9 2023-03-17 2023-08-07 11 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
CompactAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 85 7 2023-03-17 2023-07-11 11 6 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
ActionBase.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 33 2 2023-03-17 2023-07-25 11 6 lzljs3620320@aliyun.com zjureel@gmail.com
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 308 29 2023-03-17 2023-07-21 11 6 lzljs3620320@aliyun.com 37063904+zhuangchong@users....
InnerStreamTableScanImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source
 196 11 2023-04-04 2023-07-27 11 6 33053040+yuzelin@users.nore... 69444450+liming30@users.nor...
SparkTable.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 100 8 2023-03-17 2023-08-01 11 6 lzljs3620320@aliyun.com biyan900116@gmail.com
ManifestFile.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 143 7 2023-03-17 2023-07-05 10 6 lzljs3620320@aliyun.com jingsonglee0@gmail.com
AppendOnlyFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 150 4 2023-03-17 2023-07-11 9 6 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
MemorySegmentUtils.java
in paimon-common/src/main/java/org/apache/paimon/memory
 770 64 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
RowCompactedSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 529 55 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
JavaParser.g4
in paimon-common/src/main/antlr4
 520 - 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
SysInfoLinux.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 504 29 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
FieldReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/avro
 385 55 2023-07-05 2023-07-05 1 1 jingsonglee0@gmail.com jingsonglee0@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
FlinkFactoryUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories
 346 18 2023-04-03 2023-04-03 1 1 48040205+alibaba-hzy@users.... 48040205+alibaba-hzy@users....
Expression.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc
 278 34 2023-08-01 2023-08-01 1 1 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
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
ScalarOperatorGens.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 264 5 2023-05-25 2023-05-25 1 1 69444450+liming30@users.nor... 69444450+liming30@users.nor...
TagAutoCreation.java
in paimon-core/src/main/java/org/apache/paimon/tag
 263 19 2023-07-19 2023-07-19 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
CanalRecordParser.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal
 251 14 2023-07-11 2023-07-24 3 1 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
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...
MergeSorter.java
in paimon-core/src/main/java/org/apache/paimon/mergetree
 243 14 2023-06-26 2023-07-17 2 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
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
BinaryStringUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 228 13 2023-06-19 2023-06-19 1 1 37063904+zhuangchong@users.... 37063904+zhuangchong@users....
FileDeletionBase.java
in paimon-core/src/main/java/org/apache/paimon/operation
 215 13 2023-07-06 2023-07-06 1 1 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
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
BinaryRowSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 208 25 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
GlobalIndexAssigner.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index
 206 14 2023-08-07 2023-08-07 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
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
JavaLexer.g4
in paimon-common/src/main/antlr4
 188 - 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
AllTableOptionsTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 180 19 2023-07-31 2023-07-31 1 1 41894543+leaves12138@users.... 41894543+leaves12138@users....
SchemaMergingUtils.java
in paimon-core/src/main/java/org/apache/paimon/schema
 176 5 2023-08-01 2023-08-01 1 1 biyan900116@gmail.com biyan900116@gmail.com
FileIOUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 176 14 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
MonitorFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator
 172 7 2023-05-04 2023-06-14 2 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
MergeIntoActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 169 4 2023-07-11 2023-07-11 1 1 37063904+zhuangchong@users.... 37063904+zhuangchong@users....
FieldWriterFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/avro
 167 22 2023-07-05 2023-07-05 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
ColumnarRow.java
in paimon-common/src/main/java/org/apache/paimon/data/columnar
 162 34 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
TimeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 161 9 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
BinaryExternalSortBuffer.java
in paimon-core/src/main/java/org/apache/paimon/sort
 158 10 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
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
DescriptiveStatisticsHistogramStatistics.java
in paimon-core/src/main/java/org/apache/paimon/metrics
 150 23 2023-07-05 2023-07-05 1 1 liguojun@bytedance.com liguojun@bytedance.com
Projection.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 149 14 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
ContainsLevels.java
in paimon-core/src/main/java/org/apache/paimon/mergetree
 149 12 2023-07-26 2023-07-26 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
SortMergeReaderWithMinHeap.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 146 8 2023-04-27 2023-04-27 1 1 69444450+liming30@users.nor... 69444450+liming30@users.nor...
InternalArraySerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 142 11 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
ProjectedRowData.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 135 26 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
ScanBucketFilter.java
in paimon-core/src/main/java/org/apache/paimon/operation
 135 9 2023-06-08 2023-06-08 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
InstantiationUtil.java
in paimon-common/src/main/java/org/apache/paimon/utils
 135 10 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
IndexManifestEntry.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 131 15 2023-06-12 2023-06-12 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
FieldSumAgg.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate
 129 5 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
StructuredOptionsSplitter.java
in paimon-common/src/main/java/org/apache/paimon/options
 129 11 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
FlinkCatalogPropertiesUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils
 121 7 2023-04-26 2023-05-04 2 1 33053040+yuzelin@users.nore... 33053040+yuzelin@users.nore...
KafkaSyncTableActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 116 3 2023-07-11 2023-07-11 1 1 37063904+zhuangchong@users.... 37063904+zhuangchong@users....
DefaultValueAssigner.java
in paimon-core/src/main/java/org/apache/paimon/operation
 114 7 2023-07-17 2023-07-17 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
JavaSerializer.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils
 113 18 2023-05-04 2023-05-04 1 1 jingsonglee0@gmail.com jingsonglee0@gmail.com
MurmurHashUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 112 18 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
KeyProjectedRow.java
in paimon-common/src/main/java/org/apache/paimon/utils
 110 22 2023-03-17 2023-03-17 1 1 lzljs3620320@aliyun.com lzljs3620320@aliyun.com
Correlations

File Size vs. Number of Changes: 1188 points

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 389 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 330 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 52 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 271 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 115 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 123 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 129 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 302 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 192 lines of code y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 257 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 127 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 178 lines of code y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 170 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 57 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 178 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 190 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 229 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 183 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 32 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 212 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 12 lines of code y: 3 # changes paimon-filesystems/paimon-oss/src/main/java/org/apache/paimon/oss/OSSLoader.java x: 53 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 1423 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 234 lines of code y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 170 lines of code y: 8 # changes paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 29 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 40 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntIntSerializer.java x: 24 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 48 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 5 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 170 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 39 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 298 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 54 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java x: 57 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 201 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 309 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 188 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 369 lines of code y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 7 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 160 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 136 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 40 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 309 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 341 lines of code y: 17 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/NoPrimaryKeyLookupTable.java x: 55 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBListState.java x: 52 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 84 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 85 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBStateFactory.java x: 79 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 67 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 69 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/ChannelComputer.java x: 28 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 79 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 46 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordPartitionKeyExtractor.java x: 21 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 94 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 140 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java x: 81 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicCdcBucketSink.java x: 88 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 206 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 99 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/IndexBootstrap.java x: 41 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyPartPartitionKeyExtractor.java x: 34 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java x: 62 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/InternalTypeInfo.java x: 64 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 193 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 116 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/PreAssignSplitAssigner.java x: 64 lines of code y: 2 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 130 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 354 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 190 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 188 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 238 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcMultiplexRecordChannelComputer.java x: 59 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 109 lines of code y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 331 lines of code y: 21 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 155 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 70 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java x: 111 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/lineage/LineageMeta.java x: 17 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 163 lines of code y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 120 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 55 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 95 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 217 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumn.java x: 29 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 278 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/types/DataField.java x: 100 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 183 lines of code y: 15 # changes paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 39 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 470 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 176 lines of code y: 1 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 100 lines of code y: 11 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala x: 15 lines of code y: 3 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWriteBuilder.scala x: 20 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 218 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 192 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 80 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 98 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 166 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 181 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 180 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 55 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 707 lines of code y: 20 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 617 lines of code y: 17 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 33 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 340 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 245 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 163 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 146 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 161 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 263 lines of code y: 14 # changes paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 215 lines of code y: 9 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 259 lines of code y: 15 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonObjectInspectorFactory.java x: 68 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 196 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/SnapshotNotExistPlan.java x: 12 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileStoreSource.java x: 62 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 229 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/memory/MemoryPoolFactory.java x: 83 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 26 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 77 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 43 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 92 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 159 lines of code y: 7 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 122 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRow.java x: 180 lines of code y: 6 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 370 lines of code y: 8 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 232 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionFactory.java x: 120 lines of code y: 2 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 227 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 174 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java x: 149 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 117 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeTreeCompactRewriter.java x: 102 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeFunctionWrapper.java x: 91 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 72 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeTreeCompactRewriter.java x: 63 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 104 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalogFactory.java x: 53 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 33 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 131 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 97 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 251 lines of code y: 13 # changes paimon-common/src/main/java/org/apache/paimon/types/ReassignFieldId.java x: 38 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 822 lines of code y: 12 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 183 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/consumer/ConsumerManager.java x: 92 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 251 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 73 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/LogicalTypeConversion.java x: 24 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 224 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 195 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 200 lines of code y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 414 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDataColumnReader.java x: 29 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 308 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 9 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 169 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 263 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/OrcWriterFactory.java x: 72 lines of code y: 5 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonDateObjectInspector.java x: 45 lines of code y: 6 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonDecimalObjectInspector.java x: 46 lines of code y: 6 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonMapObjectInspector.java x: 86 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java x: 109 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 312 lines of code y: 9 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/EventParser.java x: 22 lines of code y: 7 # changes paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 75 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 19 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java x: 139 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 243 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/operation/DefaultValueAssigner.java x: 114 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java x: 222 lines of code y: 8 # changes paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScanImpl.java x: 41 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/source/TableRead.java x: 25 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 133 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java x: 150 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 155 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java x: 165 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java x: 162 lines of code y: 2 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonStorageHandler.java x: 89 lines of code y: 7 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 288 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/utils/IOUtils.java x: 90 lines of code y: 2 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/SearchArgumentToPredicateConverter.java x: 139 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 281 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcSinkBuilder.java x: 46 lines of code y: 3 # changes paimon-codegen/src/main/scala/org/apache/paimon/codegen/EqualiserCodeGenerator.scala x: 125 lines of code y: 2 # changes paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGeneratorContext.scala x: 92 lines of code y: 3 # changes paimon-flink/paimon-flink-action/src/main/java/org/apache/paimon/flink/action/FlinkActions.java x: 17 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 4 lines of code y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 85 lines of code y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactActionFactory.java x: 58 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DeleteAction.java x: 58 lines of code y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoActionFactory.java x: 169 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreWrite.java x: 150 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalStartingScanner.java x: 61 lines of code y: 3 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputSplit.java x: 75 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/utils/IntHashSet.java x: 35 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/index/HashIndexMaintainer.java x: 78 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/factories/Factory.java x: 4 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/CompactedStartingScanner.java x: 32 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullCompactedStartingScanner.java x: 25 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 248 lines of code y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 60 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/SystemTableSource.java x: 86 lines of code y: 9 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 151 lines of code y: 12 # changes paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 267 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 215 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 87 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/RollbackHelper.java x: 94 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 32 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java x: 119 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 51 lines of code y: 6 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 95 lines of code y: 7 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 385 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/FieldWriterFactory.java x: 167 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/statistics/FieldStatsCollector.java x: 44 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 143 lines of code y: 10 # changes paimon-core/src/main/java/org/apache/paimon/metrics/DescriptiveStatisticsHistogramStatistics.java x: 150 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 59 lines of code y: 7 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcTableStatsExtractor.java x: 204 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetTableStatsExtractor.java x: 200 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 116 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/predicate/OnlyPartitionKeyEqualVisitor.java x: 72 lines of code y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSink.java x: 191 lines of code y: 7 # changes paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableRead.java x: 26 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/source/AppendOnlySplitGenerator.java x: 35 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/source/MergeTreeSplitGenerator.java x: 58 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSplitEnumerator.java x: 58 lines of code y: 9 # changes paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java x: 130 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeReaders.java x: 67 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/ReadOperator.java x: 46 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/utils/HadoopUtils.java x: 127 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java x: 5 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 26 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FileStoreSink.java x: 22 lines of code y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSink.java x: 18 lines of code y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 12 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/DynamicBucketSink.java x: 45 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcPredicateFunctionVisitor.java x: 169 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactManager.java x: 232 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/BinaryStringUtils.java x: 228 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 526 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 311 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 105 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java x: 112 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/io/RollingFileWriter.java x: 105 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/DataTable.java x: 13 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/source/StreamTableScan.java x: 15 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousCompactorStartingScanner.java x: 29 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromSnapshotStartingScanner.java x: 17 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScanner.java x: 22 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 19 lines of code y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorFunction.java x: 172 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/io/FileWriter.java x: 30 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordKeyAndBucketExtractor.java x: 82 lines of code y: 5 # changes paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java x: 131 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFile.java x: 73 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 158 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java x: 189 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 258 lines of code y: 3 # changes paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java x: 172 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java x: 169 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 105 lines of code y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/FixedBucketRowKeyExtractor.java x: 49 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 107 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/operation/ScanBucketFilter.java x: 135 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 255 lines of code y: 6 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntry.java x: 160 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 305 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/memory/HeapMemorySegmentPool.java x: 10 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 436 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/types/RowKind.java x: 42 lines of code y: 3 # changes paimon-core/src/main/java/org/apache/paimon/KeyValue.java x: 146 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/AvroToRowDataConverters.java x: 234 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalFieldParser.java x: 85 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/options/ConfigOption.java x: 124 lines of code y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 122 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCommittableSerializer.java x: 106 lines of code y: 1 # changes paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 686 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/AddBoolBeforeReturnRewriter.java x: 88 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/BlockStatementGrouper.java x: 230 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/CodeRewriter.java x: 4 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/ReturnValueRewriter.java x: 106 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/AbstractBinaryWriter.java x: 204 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryArrayWriter.java x: 190 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 325 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryWriter.java x: 153 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/DataGetters.java x: 20 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/data/NestedRow.java x: 248 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/BytesColumnVector.java x: 22 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/fs/Path.java x: 199 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/io/DataOutputSerializer.java x: 273 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreReader.java x: 236 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java x: 325 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/plugin/ComponentClassLoader.java x: 171 lines of code y: 6 # changes paimon-common/src/main/java/org/apache/paimon/utils/CloseableIterator.java x: 133 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 264 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/utils/VarLengthIntUtils.java x: 90 lines of code y: 4 # changes paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2506 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetFileFormatFactory.java x: 33 lines of code y: 5 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/AbstractColumnReader.java x: 193 lines of code y: 4 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/BaseVectorizedColumnReader.java x: 218 lines of code y: 4 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/RunLengthDecoder.java x: 223 lines of code y: 5 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/SerializableHiveConf.java x: 39 lines of code y: 4 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveDeserializer.java x: 221 lines of code y: 3 # changes paimon-spark/paimon-spark-2/src/main/java/org/apache/paimon/spark/SparkDataSourceReader.java x: 103 lines of code y: 4 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 381 lines of code y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/JavaSerializer.java x: 113 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/JoinedRow.java x: 178 lines of code y: 3 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcSplitReaderUtil.java x: 75 lines of code y: 4 # 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-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java x: 85 lines of code y: 4 # changes paimon-common/src/main/java/org/apache/paimon/types/ArrayType.java x: 66 lines of code y: 5 # changes paimon-common/src/main/java/org/apache/paimon/plugin/PluginLoader.java x: 120 lines of code y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteState.java x: 102 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 169 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/mergetree/Levels.java x: 141 lines of code y: 2 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java x: 143 lines of code y: 3 # changes paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 527 lines of code y: 2 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 346 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java x: 239 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/stats/FieldStatsArraySerializer.java x: 98 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryArray.java x: 429 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/BinaryString.java x: 734 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/GenericMap.java x: 73 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/data/GenericRow.java x: 149 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/options/MemorySize.java x: 267 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/options/Options.java x: 189 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 294 lines of code y: 3 # 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-codegen/src/main/scala/org/apache/paimon/codegen/SortCodeGenerator.scala x: 290 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/io/DataInputDeserializer.java x: 316 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/options/OptionsUtils.java x: 219 lines of code y: 2 # changes paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java x: 133 lines of code y: 2 # 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/casting/CastExecutor.java x: 4 lines of code y: 2 # changes paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 112 lines of code y: 2 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java x: 184 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/sort/AbstractBinaryExternalMerger.java x: 131 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 345 lines of code y: 2 # changes paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 488 lines of code y: 2 # changes paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 158 lines of code y: 1 # changes paimon-core/src/main/java/org/apache/paimon/sort/QuickSort.java x: 240 lines of code y: 1 # changes paimon-common/src/main/antlr4/JavaLexer.g4 x: 188 lines of code y: 1 # changes paimon-common/src/main/antlr4/JavaParser.g4 x: 520 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRow.java x: 162 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java x: 142 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 529 lines of code y: 1 # changes paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 770 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/data/AbstractPagedInputView.java x: 370 lines of code y: 1 # changes paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcFilters.java x: 200 lines of code y: 1 # changes paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 504 lines of code y: 1 # changes
26.0
# changes
  min: 1.0
  average: 2.94
  25th percentile: 1.0
  median: 2.0
  75th percentile: 4.0
  max: 26.0
0 2506.0
lines of code
min: 2.0 | average: 83.1 | 25th percentile: 21.0 | median: 45.0 | 75th percentile: 101.75 | max: 2506.0

Number of Contributors vs. Number of Changes: 1188 points

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 9 # contributors y: 26 # changes paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 5 # contributors y: 10 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 # contributors y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 3 # contributors y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 4 # contributors y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 4 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 4 # contributors y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 8 # contributors y: 14 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 8 # contributors y: 22 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 3 # contributors y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 3 # contributors y: 3 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 10 # contributors y: 18 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 5 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 4 # contributors y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 5 # contributors y: 4 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 5 # contributors y: 5 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 5 # contributors y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 # contributors y: 2 # changes paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 2 # contributors y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 7 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 6 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 5 # contributors y: 9 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 12 # contributors y: 15 # changes paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 1 # contributors y: 2 # changes paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 5 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 2 # contributors y: 5 # changes paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 4 # contributors y: 6 # changes paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 5 # contributors y: 17 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 3 # contributors y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 6 # contributors y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 5 # contributors y: 8 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 3 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 7 # contributors y: 10 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 7 # contributors y: 11 # changes paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 7 # contributors y: 12 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 8 # contributors y: 11 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 5 # contributors y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 12 # contributors y: 21 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java x: 2 # contributors y: 4 # changes paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 10 # contributors y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 8 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 6 # contributors y: 15 # changes paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 6 # contributors y: 9 # changes paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala x: 1 # contributors y: 3 # changes paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 6 # contributors y: 6 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 10 # contributors y: 20 # changes paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 12 # contributors y: 17 # changes paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 # contributors y: 2 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 9 # contributors y: 14 # changes paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 7 # contributors y: 9 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 8 # contributors y: 15 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 8 # contributors y: 12 # changes paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 7 # contributors y: 8 # changes paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputFormat.java x: 7 # contributors y: 13 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 8 # contributors y: 13 # changes paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 4 # contributors y: 10 # changes paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java x: 3 # contributors y: 8 # changes paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 6 # contributors y: 14 # changes paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 5 # contributors y: 12 # changes paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java x: 2 # contributors y: 7 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 6 # contributors y: 7 # changes paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 6 # contributors y: 10 # changes paimon-common/src/main/java/org/apache/paimon/statistics/TruncateFieldStatsCollector.java x: 2 # contributors y: 1 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSink.java x: 7 # contributors y: 7 # changes paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSource.java x: 8 # contributors y: 10 # changes paimon-format/src/main/java/org/apache/paimon/format/avro/AvroSchemaConverter.java x: 4 # contributors y: 3 # changes
26.0
# changes
  min: 1.0
  average: 2.94
  25th percentile: 1.0
  median: 2.0
  75th percentile: 4.0
  max: 26.0
0 12.0
# contributors
min: 1.0 | average: 2.28 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 12.0

Number of Contributors vs. File Size: 1188 points

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 9 # contributors y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 5 # contributors y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 # contributors y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 3 # contributors y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 4 # contributors y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 4 # contributors y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 4 # contributors y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 8 # contributors y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 8 # contributors y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 3 # contributors y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 3 # contributors y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 10 # contributors y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 5 # contributors y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 4 # contributors y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 5 # contributors y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 5 # contributors y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 5 # contributors y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 # contributors y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 # contributors y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 4 # contributors y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 2 # contributors y: 12 lines of code paimon-filesystems/paimon-oss/src/main/java/org/apache/paimon/oss/OSSLoader.java x: 2 # contributors y: 53 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 5 # contributors y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 7 # contributors y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 6 # contributors y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 # contributors y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 # contributors y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 4 # contributors y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 # contributors y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 3 # contributors y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 5 # contributors y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 3 # contributors y: 54 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 4 # contributors y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 12 # contributors y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 4 # contributors y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 9 # contributors y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 5 # contributors y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 5 # contributors y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 2 # contributors y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 4 # contributors y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 5 # contributors y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 3 # contributors y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBStateFactory.java x: 4 # contributors y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 3 # contributors y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 2 # contributors y: 69 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/ChannelComputer.java x: 2 # contributors y: 28 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 6 # contributors y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 5 # contributors y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordUtils.java x: 1 # contributors y: 68 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 3 # contributors y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 5 # contributors y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java x: 1 # contributors y: 81 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 # contributors y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 # contributors y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/IndexBootstrapOperator.java x: 1 # contributors y: 37 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 7 # contributors y: 193 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 2 # contributors y: 116 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/SplitAssigner.java x: 3 # contributors y: 11 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 7 # contributors y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 7 # contributors y: 354 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 8 # contributors y: 138 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 4 # contributors y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 5 # contributors y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 12 # contributors y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 2 # contributors y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 2 # contributors y: 70 lines of code paimon-common/src/main/java/org/apache/paimon/lineage/LineageMeta.java x: 1 # contributors y: 17 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 10 # contributors y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 7 # contributors y: 120 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 5 # contributors y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 4 # contributors y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 8 # contributors y: 217 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 # contributors y: 278 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataField.java x: 4 # contributors y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 6 # contributors y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 4 # contributors y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 6 # contributors y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 # contributors y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 6 # contributors y: 100 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 3 # contributors y: 218 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 5 # contributors y: 80 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 7 # contributors y: 98 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 7 # contributors y: 166 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 4 # contributors y: 181 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 # contributors y: 180 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 6 # contributors y: 55 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 10 # contributors y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 12 # contributors y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 5 # contributors y: 33 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 # contributors y: 245 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 2 # contributors y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 3 # contributors y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyTableCompactionCoordinator.java x: 2 # contributors y: 193 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 9 # contributors y: 263 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 7 # contributors y: 215 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 8 # contributors y: 259 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonObjectInspectorFactory.java x: 4 # contributors y: 68 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 6 # contributors y: 196 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 9 # contributors y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileStoreSource.java x: 7 # contributors y: 62 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 8 # contributors y: 229 lines of code paimon-core/src/main/java/org/apache/paimon/memory/MemoryPoolFactory.java x: 2 # contributors y: 83 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 5 # contributors y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 5 # contributors y: 77 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 7 # contributors y: 43 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 5 # contributors y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 7 # contributors y: 370 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 6 # contributors y: 232 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 3 # contributors y: 227 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 3 # contributors y: 174 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java x: 1 # contributors y: 149 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 3 # contributors y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 # contributors y: 104 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/LocationKeyExtractor.java x: 5 # contributors y: 93 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputFormat.java x: 7 # contributors y: 113 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 6 # contributors y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 8 # contributors y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 7 # contributors y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 7 # contributors y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 1 # contributors y: 251 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/LogicalTypeConversion.java x: 4 # contributors y: 24 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 4 # contributors y: 414 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDataColumnReaderFactory.java x: 4 # contributors y: 174 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 6 # contributors y: 308 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 4 # contributors y: 255 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 5 # contributors y: 60 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaSinkFunction.java x: 3 # contributors y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 2 # contributors y: 9 lines of code paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 1 # contributors y: 263 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcWriterFactory.java x: 4 # contributors y: 72 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonDateObjectInspector.java x: 6 # contributors y: 45 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java x: 1 # contributors y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 5 # contributors y: 312 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java x: 1 # contributors y: 72 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 6 # contributors y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 4 # contributors y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java x: 2 # contributors y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 1 # contributors y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 3 # contributors y: 133 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 3 # contributors y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java x: 3 # contributors y: 165 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 6 # contributors y: 288 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IOUtils.java x: 2 # contributors y: 90 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java x: 1 # contributors y: 89 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/SearchArgumentToPredicateConverter.java x: 4 # contributors y: 139 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 4 # contributors y: 281 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java x: 2 # contributors y: 119 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 8 # contributors y: 4 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreWrite.java x: 6 # contributors y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java x: 3 # contributors y: 113 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 6 # contributors y: 248 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/SystemTableSource.java x: 7 # contributors y: 86 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 5 # contributors y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 1 # contributors y: 215 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 6 # contributors y: 95 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 1 # contributors y: 385 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldWriterFactory.java x: 1 # contributors y: 167 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 6 # contributors y: 143 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 6 # contributors y: 161 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcTableStatsExtractor.java x: 2 # contributors y: 204 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSource.java x: 8 # contributors y: 59 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSplitEnumerator.java x: 7 # contributors y: 58 lines of code paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java x: 2 # contributors y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java x: 3 # contributors y: 5 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 6 # contributors y: 26 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FileStoreSink.java x: 7 # contributors y: 22 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSink.java x: 5 # contributors y: 18 lines of code paimon-common/src/main/java/org/apache/paimon/utils/BinaryStringUtils.java x: 1 # contributors y: 228 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 4 # contributors y: 526 lines of code paimon-core/src/main/java/org/apache/paimon/io/RollingFileWriter.java x: 5 # contributors y: 105 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetBulkWriter.java x: 3 # contributors y: 27 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java x: 1 # contributors y: 131 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 4 # contributors y: 158 lines of code paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java x: 3 # contributors y: 189 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 7 # contributors y: 105 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 3 # contributors y: 305 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 3 # contributors y: 436 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 2 # contributors y: 686 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/MemberFieldRewriter.java x: 3 # contributors y: 255 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/ReturnValueRewriter.java x: 2 # contributors y: 106 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 3 # contributors y: 325 lines of code paimon-common/src/main/java/org/apache/paimon/data/NestedRow.java x: 2 # contributors y: 248 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataOutputSerializer.java x: 2 # contributors y: 273 lines of code paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreReader.java x: 4 # contributors y: 236 lines of code paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java x: 4 # contributors y: 325 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 2 # contributors y: 264 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2 # contributors y: 2506 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/RunLengthDecoder.java x: 4 # contributors y: 223 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 5 # contributors y: 381 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/FlinkCatalogPropertiesUtil.java x: 1 # contributors y: 121 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReaderWithMinHeap.java x: 1 # contributors y: 146 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 2 # contributors y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 2 # contributors y: 527 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 # contributors y: 346 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java x: 2 # contributors y: 239 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryArray.java x: 2 # contributors y: 429 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryString.java x: 2 # contributors y: 734 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 4 # contributors y: 294 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 paimon-codegen/src/main/scala/org/apache/paimon/codegen/SortCodeGenerator.scala x: 2 # contributors y: 290 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataInputDeserializer.java x: 2 # contributors y: 316 lines of code paimon-common/src/main/java/org/apache/paimon/options/OptionsUtils.java x: 2 # contributors y: 219 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java x: 2 # contributors y: 184 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/RowDataVectorizer.java x: 2 # contributors y: 236 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 2 # contributors y: 345 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 2 # contributors y: 488 lines of code paimon-common/src/main/antlr4/JavaLexer.g4 x: 1 # contributors y: 188 lines of code paimon-common/src/main/antlr4/JavaParser.g4 x: 1 # contributors y: 520 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 1 # contributors y: 529 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 1 # contributors y: 770 lines of code paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedInputView.java x: 1 # contributors y: 370 lines of code paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedOutputView.java x: 1 # contributors y: 276 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 1 # contributors y: 504 lines of code
2506.0
lines of code
  min: 2.0
  average: 83.1
  25th percentile: 21.0
  median: 45.0
  75th percentile: 101.75
  max: 2506.0
0 12.0
# contributors
min: 1.0 | average: 2.28 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 12.0