apache / paimon
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
6% | 9% | 29% | 23% | 30%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java5% | 9% | 30% | 23% | 30%
yaml86% | 0% | 12% | 0% | <1%
scala0% | 5% | 19% | 32% | 41%
g40% | 55% | 24% | 19% | 0%
xml0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
paimon-common6% | 8% | 32% | 20% | 32%
paimon-format13% | 30% | 27% | 13% | 14%
paimon-filesystems46% | 0% | 22% | 22% | 7%
paimon-open-api62% | 25% | 9% | 0% | 2%
paimon-hive23% | 0% | 19% | 28% | 28%
paimon-flink2% | 1% | 28% | 28% | 39%
paimon-core2% | 10% | 32% | 24% | 29%
paimon-benchmark0% | 23% | 22% | 32% | 21%
paimon-codegen0% | 37% | 31% | 11% | 20%
paimon-arrow0% | 30% | 32% | 13% | 23%
paimon-spark0% | 0% | 28% | 29% | 41%
paimon-service0% | 0% | 42% | 19% | 37%
tools0% | 0% | 39% | 24% | 35%
paimon-bundle0% | 0% | 0% | 0% | 100%
paimon-codegen-loader0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 2825 236
XmlResponsesSaxParser.java
in paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform
 2506 151
rest-catalog-open-api.yaml
in paimon-open-api
 2136 -
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 1523 74
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 1426 74
RecordReaderImpl.java
in paimon-format/src/main/java/org/apache/orc/impl
 1426 40
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 1384 49
ParquetFileReader.java
in paimon-format/src/main/java/org/apache/parquet/hadoop
 1271 67
RESTCatalog.java
in paimon-core/src/main/java/org/apache/paimon/rest
 966 55
RESTCatalogController.java
in paimon-open-api/src/main/java/org/apache/paimon/open/api
 871 30
OrcFile.java
in paimon-format/src/main/java/org/apache/orc
 854 112
WriterImpl.java
in paimon-format/src/main/java/org/apache/orc/impl
 821 50
VectorizedRleValuesReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 803 47
MemorySegmentUtils.java
in paimon-common/src/main/java/org/apache/paimon/memory
 781 65
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 773 44
ProcfsBasedProcessTree.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 748 66
BinaryString.java
in paimon-common/src/main/java/org/apache/paimon/data
 734 49
GenerateUtils.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 690 28
ParquetVectorUpdaterFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 679 79
IcebergCommitCallback.java
in paimon-core/src/main/java/org/apache/paimon/iceberg
 671 21
ArrowFieldWriters.java
in paimon-arrow/src/main/java/org/apache/paimon/arrow/writer
 656 53
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 599 61
ParquetRowDataWriter.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/writer
 597 72
SchemaChange.java
in paimon-core/src/main/java/org/apache/paimon/schema
 595 72
PhysicalFsWriter.java
in paimon-format/src/main/java/org/apache/orc/impl
 595 42
RecordReaderUtils.java
in paimon-format/src/main/java/org/apache/orc/impl
 593 38
SnapshotManager.java
in paimon-core/src/main/java/org/apache/paimon/utils
 591 29
RowCompactedSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 590 59
PartialUpdateMergeFunction.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 582 18
NestedPrimitiveColumnReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/reader
 575 24
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 566 16
DataTypeJsonParser.java
in paimon-common/src/main/java/org/apache/paimon/types
 545 40
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 543 95
ParquetSplitReaderUtil.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/reader
 529 8
DateTimeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 528 47
JavaParser.g4
in paimon-common/src/main/antlr4
 520 -
DataFileMeta.java
in paimon-core/src/main/java/org/apache/paimon/io
 518 36
Expression.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc
 505 40
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 505 53
CompactProcedure.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure
 499 13
GenericVariantBuilder.java
in paimon-common/src/main/java/org/apache/paimon/data/variant
 499 31
SnapshotReaderImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 493 38
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 488 7
SysInfoLinux.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 483 30
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 479 26
SparkCatalog.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 476 19
Arrow2PaimonVectorConverter.java
in paimon-arrow/src/main/java/org/apache/paimon/arrow/converter
 470 22
BinaryArray.java
in paimon-common/src/main/java/org/apache/paimon/data
 468 55
ParquetReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet
 468 22
OrcConf.java
in paimon-format/src/main/java/org/apache/orc
 466 22
Files With Most Units (Top 50)
File# lines# units
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 2825 236
XmlResponsesSaxParser.java
in paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform
 2506 151
OrcFile.java
in paimon-format/src/main/java/org/apache/orc
 854 112
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 543 95
ParquetVectorUpdaterFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 679 79
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 1426 74
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 1523 74
SchemaChange.java
in paimon-core/src/main/java/org/apache/paimon/schema
 595 72
ParquetRowDataWriter.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/writer
 597 72
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 420 69
ParquetFileReader.java
in paimon-format/src/main/java/org/apache/parquet/hadoop
 1271 67
ProcfsBasedProcessTree.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 748 66
MemorySegmentUtils.java
in paimon-common/src/main/java/org/apache/paimon/memory
 781 65
MemorySegment.java
in paimon-common/src/main/java/org/apache/paimon/memory
 436 64
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 599 61
RowCompactedSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 590 59
FieldReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/avro
 436 58
BinaryArray.java
in paimon-common/src/main/java/org/apache/paimon/data
 468 55
RESTCatalog.java
in paimon-core/src/main/java/org/apache/paimon/rest
 966 55
ArrowFieldWriters.java
in paimon-arrow/src/main/java/org/apache/paimon/arrow/writer
 656 53
DelegatedFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 253 53
AbstractCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 505 53
WriterImpl.java
in paimon-format/src/main/java/org/apache/orc/impl
 821 50
BinaryRow.java
in paimon-common/src/main/java/org/apache/paimon/data
 358 49
BinaryString.java
in paimon-common/src/main/java/org/apache/paimon/data
 734 49
FlinkCalciteClasses.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils
 262 49
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 1384 49
DateTimeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 528 47
FlinkGenericCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 423 47
DelegateCatalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 241 47
VectorizedRleValuesReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader
 803 47
RowType.java
in paimon-common/src/main/java/org/apache/paimon/types
 344 46
FlinkRowWrapper.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 255 45
FlinkRowData.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 252 45
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 773 44
SparkInternalRowWrapper.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 279 43
DataTypes.java
in paimon-common/src/main/java/org/apache/paimon/types
 152 43
PhysicalFsWriter.java
in paimon-format/src/main/java/org/apache/orc/impl
 595 42
SparkRow.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 323 41
DataTypeJsonParser.java
in paimon-common/src/main/java/org/apache/paimon/types
 545 40
Expression.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc
 505 40
DataSplit.java
in paimon-core/src/main/java/org/apache/paimon/table/source
 421 40
RecordReaderImpl.java
in paimon-format/src/main/java/org/apache/orc/impl
 1426 40
HadoopFileIO.java
in paimon-common/src/main/java/org/apache/paimon/fs/hadoop
 315 39
PrivilegedFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/privilege
 238 39
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 436 39
AppendOnlyWriter.java
in paimon-core/src/main/java/org/apache/paimon/append
 430 39
FileMonitorTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 265 38
SnapshotReaderImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 493 38
FormatTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 273 38
Files With Long Lines (Top 50)

There are 132 files with lines longer than 120 characters. In total, there are 391 long lines.

File# lines# units# long lines
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 2825 236 93
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 488 7 38
RocksDBOptions.java
in paimon-core/src/main/java/org/apache/paimon/lookup
 260 2 19
MergeIntoActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 156 3 9
HiveCatalogOptions.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 67 1 9
PulsarActionUtils.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar
 347 8 8
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 1384 49 8
MySqlSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 137 5 7
CompactDatabaseActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 82 3 5
MongoDBSyncTableActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb
 98 5 5
SparkConnectorOptions.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 62 - 4
CatalogOptions.java
in paimon-common/src/main/java/org/apache/paimon/options
 132 - 4
FlinkFactoryUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories
 344 18 4
CompactActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 116 4 4
CdcActionCommonUtils.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc
 264 12 4
PostgresSyncTableActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres
 94 4 4
MarkPartitionDoneActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 50 3 3
DeleteActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 46 3 3
MergeIntoAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 390 22 3
RemoveUnexistingFilesActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 49 3 3
FlinkCatalogOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 34 - 3
MongoDBSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb
 89 4 3
MySqlActionUtils.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 237 6 3
MySqlSyncTableActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 91 4 3
PulsarSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar
 91 4 3
PulsarSyncTableActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar
 87 4 3
JarFileChecker.java
in tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck
 249 17 3
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 773 44 3
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 566 16 3
RewritePaimonViewCommands.scala
in paimon-spark/paimon-spark-3.3/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions
 52 2 2
PaimonAnalysis.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis
 302 17 2
MergePaimonScalarSubqueriesBase.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/optimizer
 304 15 2
OptionUtils.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util
 81 6 2
CompactProcedure.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure
 499 13 2
ExceptionUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 278 32 2
FileStoreLookupFunction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup
 346 18 2
CompactDatabaseAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 230 15 2
RemoveOrphanFilesActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 53 3 2
DropPartitionActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 50 3 2
CopyFilesActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 69 3 2
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 325 22 2
MongoDBActionUtils.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb
 100 2 2
KafkaSyncTableActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 87 4 2
KafkaSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 90 4 2
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 187 12 2
Expression.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc
 505 40 2
SyncTableActionBase.java
in paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc
 168 13 2
NoticeFileChecker.java
in tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck
 299 9 2
rest-management-api.yaml
in paimon-open-api
 320 - 2
PartialUpdateMergeFunction.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 582 18 2
Correlations

File Size vs. Commits (all time): 2422 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 5 commits (all time) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 6 commits (all time) y: 88 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 3 commits (all time) y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 3 commits (all time) y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 10 commits (all time) y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 15 commits (all time) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 32 commits (all time) y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 commits (all time) y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 commits (all time) y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 commits (all time) y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 7 commits (all time) y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 37 commits (all time) y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 commits (all time) y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 35 commits (all time) y: 97 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/CreateOrReplaceTagExec.scala x: 2 commits (all time) y: 51 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 18 commits (all time) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 66 commits (all time) y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 14 commits (all time) y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 8 commits (all time) y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 9 commits (all time) y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 3 commits (all time) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java x: 2 commits (all time) y: 21 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/BearTokenAuthProvider.java x: 3 commits (all time) y: 18 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java x: 7 commits (all time) y: 49 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFECSTokenLoader.java x: 2 commits (all time) y: 90 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java x: 2 commits (all time) y: 38 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 2 commits (all time) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFTokenLoader.java x: 2 commits (all time) y: 5 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalog/functions/PaimonFunctions.scala x: 2 commits (all time) y: 104 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 127 commits (all time) y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 14 commits (all time) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 8 commits (all time) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromWatermarkStartingScanner.java x: 3 commits (all time) y: 43 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 9 commits (all time) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 17 commits (all time) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/TableIndexesTable.java x: 4 commits (all time) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 9 commits (all time) y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 201 commits (all time) y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 76 commits (all time) y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 3 commits (all time) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 9 commits (all time) y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 9 commits (all time) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 14 commits (all time) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/UpdatePaimonTableCommand.scala x: 19 commits (all time) y: 114 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 19 commits (all time) y: 337 lines of code paimon-common/src/main/java/org/apache/paimon/utils/OptimizedRoaringBitmap64.java x: 2 commits (all time) y: 185 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 106 commits (all time) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 57 commits (all time) y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 25 commits (all time) y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java x: 28 commits (all time) y: 241 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTUtil.java x: 6 commits (all time) y: 97 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 135 commits (all time) y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 41 commits (all time) y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 36 commits (all time) y: 871 lines of code paimon-format/src/main/java/org/apache/paimon/format/OrcOptions.java x: 7 commits (all time) y: 26 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/AbstractOrcColumnVector.java x: 9 commits (all time) y: 74 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcArrayColumnVector.java x: 9 commits (all time) y: 34 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcMapColumnVector.java x: 10 commits (all time) y: 38 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 8 commits (all time) y: 102 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReaderFactory.scala x: 6 commits (all time) y: 29 lines of code paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 3 commits (all time) y: 71 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 31 commits (all time) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 15 commits (all time) y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 9 commits (all time) y: 343 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 10 commits (all time) y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/utils/CompressUtils.java x: 1 commits (all time) y: 23 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ListCloneFilesFunction.java x: 2 commits (all time) y: 129 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RollbackProcedure.java x: 4 commits (all time) y: 101 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowUtils.java x: 8 commits (all time) y: 213 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriter.java x: 4 commits (all time) y: 51 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactoryVisitor.java x: 4 commits (all time) y: 149 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 4 commits (all time) y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 34 commits (all time) y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 7 commits (all time) y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneFilesFunction.java x: 1 commits (all time) y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneProcessFunction.java x: 1 commits (all time) y: 61 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneUtils.java x: 1 commits (all time) y: 119 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CloneProcedure.java x: 3 commits (all time) y: 65 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyDataFileOperator.java x: 1 commits (all time) y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyFilesUtil.java x: 1 commits (all time) y: 215 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 commits (all time) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 commits (all time) y: 205 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CopyFilesProcedure.java x: 1 commits (all time) y: 79 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 16 commits (all time) y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 6 commits (all time) y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 20 commits (all time) y: 217 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 39 commits (all time) y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 60 commits (all time) y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 22 commits (all time) y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java x: 1 commits (all time) y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactTask.java x: 1 commits (all time) y: 111 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java x: 1 commits (all time) y: 144 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 4 commits (all time) y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 commits (all time) y: 198 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 42 commits (all time) y: 118 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 13 commits (all time) y: 108 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 22 commits (all time) y: 187 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 20 commits (all time) y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/AppendTableCompactor.java x: 1 commits (all time) y: 156 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/MultiTableScanBase.java x: 7 commits (all time) y: 91 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendBypassCompactWorkerOperator.java x: 5 commits (all time) y: 47 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendCompactWorkerOperator.java x: 5 commits (all time) y: 81 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 8 commits (all time) y: 162 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlySingleTableCompactionWorkerOperator.java x: 5 commits (all time) y: 39 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CombinedTableCompactorSink.java x: 15 commits (all time) y: 159 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactionTaskTypeInfo.java x: 5 commits (all time) y: 56 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 39 commits (all time) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTableCompactionTaskTypeInfo.java x: 4 commits (all time) y: 70 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataHashPartitionChannelComputer.java x: 2 commits (all time) y: 29 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperator.java x: 9 commits (all time) y: 81 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/AppendBypassCoordinateOperatorFactory.java x: 4 commits (all time) y: 27 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 29 commits (all time) y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 11 commits (all time) y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 3 commits (all time) y: 249 lines of code paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java x: 4 commits (all time) y: 199 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonRecordReaderIterator.scala x: 5 commits (all time) y: 124 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 17 commits (all time) y: 205 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 2 commits (all time) y: 279 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/BucketExpression.scala x: 2 commits (all time) y: 58 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 48 commits (all time) y: 346 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/partitioner/ShuffleStrategy.java x: 1 commits (all time) y: 7 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 12 commits (all time) y: 187 lines of code paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/HadoopCompliantFileIO.java x: 2 commits (all time) y: 219 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 61 commits (all time) y: 773 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RoaringBitmap32.java x: 12 commits (all time) y: 129 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 5 commits (all time) y: 671 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java x: 11 commits (all time) y: 148 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/KeyAndBucketExtractor.java x: 5 commits (all time) y: 21 lines of code paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 12 commits (all time) y: 225 lines of code paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java x: 6 commits (all time) y: 286 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala x: 30 commits (all time) y: 114 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 18 commits (all time) y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 26 commits (all time) y: 147 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 28 commits (all time) y: 364 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 24 commits (all time) y: 88 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataRollingFileWriter.java x: 18 commits (all time) y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 18 commits (all time) y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 23 commits (all time) y: 239 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 18 commits (all time) y: 164 lines of code paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs/HadoopCompliantFileIO.java x: 1 commits (all time) y: 182 lines of code paimon-filesystems/paimon-obs-impl/src/main/java/org/apache/paimon/obs/OBSFileIO.java x: 1 commits (all time) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/table/DataTable.java x: 15 commits (all time) y: 25 lines of code paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java x: 14 commits (all time) y: 253 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 30 commits (all time) y: 99 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 62 commits (all time) y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/CompactBucketsTable.java x: 5 commits (all time) y: 210 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 14 commits (all time) y: 265 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 20 commits (all time) y: 157 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/PurgeFilesProcedure.java x: 4 commits (all time) y: 56 lines of code paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java x: 17 commits (all time) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/KeyValueTableRead.java x: 12 commits (all time) y: 111 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceReader.java x: 15 commits (all time) y: 78 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FormatCatalogTable.java x: 4 commits (all time) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 2 commits (all time) y: 344 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 14 commits (all time) y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 44 commits (all time) y: 213 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 42 commits (all time) y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 65 commits (all time) y: 392 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 23 commits (all time) y: 122 lines of code paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketFileStoreWrite.java x: 4 commits (all time) y: 83 lines of code paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyFileStoreTable.java x: 31 commits (all time) y: 151 lines of code paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 27 commits (all time) y: 132 lines of code paimon-core/src/main/java/org/apache/paimon/utils/StatsCollectorFactories.java x: 8 commits (all time) y: 58 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 64 commits (all time) y: 591 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 15 commits (all time) y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 16 commits (all time) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 28 commits (all time) y: 57 lines of code paimon-core/src/main/java/org/apache/paimon/utils/CatalogBranchManager.java x: 5 commits (all time) y: 70 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileSystemBranchManager.java x: 4 commits (all time) y: 175 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 52 commits (all time) y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 27 commits (all time) y: 85 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 27 commits (all time) y: 71 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 52 commits (all time) y: 493 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 17 commits (all time) y: 246 lines of code paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java x: 23 commits (all time) y: 136 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ExpirePartitionsProcedure.java x: 11 commits (all time) y: 82 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/ExpireSnapshotsProcedure.java x: 6 commits (all time) y: 60 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/ExpirePartitionsProcedure.java x: 11 commits (all time) y: 101 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 7 commits (all time) y: 8 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java x: 13 commits (all time) y: 282 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndex.java x: 7 commits (all time) y: 318 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ThreadPoolUtils.java x: 7 commits (all time) y: 158 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 59 commits (all time) y: 488 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTask.java x: 5 commits (all time) y: 308 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 67 commits (all time) y: 322 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScanner.java x: 15 commits (all time) y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java x: 26 commits (all time) y: 157 lines of code paimon-open-api/rest-management-api.yaml x: 5 commits (all time) y: 320 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValue.java x: 8 commits (all time) y: 133 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 33 commits (all time) y: 396 lines of code paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 13 commits (all time) y: 295 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergDataFileMeta.java x: 7 commits (all time) y: 218 lines of code paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java x: 17 commits (all time) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 21 commits (all time) y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 29 commits (all time) y: 370 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 23 commits (all time) y: 331 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java x: 10 commits (all time) y: 221 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 11 commits (all time) y: 269 lines of code paimon-core/src/main/java/org/apache/paimon/rest/responses/ErrorResponse.java x: 9 commits (all time) y: 59 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDeltaStartingScanner.java x: 4 commits (all time) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldAggregatorFactory.java x: 4 commits (all time) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 66 commits (all time) y: 1384 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java x: 7 commits (all time) y: 131 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageLegacyV2Serializer.java x: 5 commits (all time) y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java x: 15 commits (all time) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 33 commits (all time) y: 299 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 26 commits (all time) y: 421 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveUnexistingFilesAction.java x: 2 commits (all time) y: 164 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/postpone/RewritePostponeBucketCommittableOperator.java x: 2 commits (all time) y: 121 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RewriteFileIndexSink.java x: 6 commits (all time) y: 321 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcSimpleStatsExtractor.java x: 6 commits (all time) y: 220 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala x: 11 commits (all time) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 30 commits (all time) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 18 commits (all time) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMetaSerializer.java x: 6 commits (all time) y: 53 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestList.java x: 18 commits (all time) y: 96 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 23 commits (all time) y: 284 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScan.java x: 11 commits (all time) y: 37 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java x: 12 commits (all time) y: 34 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java x: 10 commits (all time) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTObjectMapper.java x: 5 commits (all time) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java x: 24 commits (all time) y: 197 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ParallelExecution.java x: 3 commits (all time) y: 156 lines of code paimon-core/src/main/java/org/apache/paimon/view/ViewChange.java x: 1 commits (all time) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 80 commits (all time) y: 1426 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkProcedures.java x: 32 commits (all time) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/partition/PartitionMarkDone.java x: 14 commits (all time) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 27 commits (all time) y: 108 lines of code paimon-core/src/main/java/org/apache/paimon/table/CatalogEnvironment.java x: 12 commits (all time) y: 88 lines of code paimon-core/src/main/java/org/apache/paimon/rest/responses/GetTableResponse.java x: 6 commits (all time) y: 73 lines of code paimon-core/src/main/java/org/apache/paimon/rest/responses/GetViewResponse.java x: 3 commits (all time) y: 46 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/extensions/PaimonSparkSessionExtensions.scala x: 20 commits (all time) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolution.java x: 4 commits (all time) y: 233 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/aggregate/LocalAggregator.scala x: 5 commits (all time) y: 98 lines of code paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java x: 11 commits (all time) y: 191 lines of code paimon-core/src/main/java/org/apache/paimon/utils/HintFileUtils.java x: 3 commits (all time) y: 94 lines of code paimon-core/src/main/java/org/apache/paimon/table/RollbackHelper.java x: 14 commits (all time) y: 160 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexWriter.java x: 4 commits (all time) y: 13 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndexMeta.java x: 7 commits (all time) y: 247 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndexMetaV2.java x: 3 commits (all time) y: 280 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/AbstractRecordParser.java x: 2 commits (all time) y: 86 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/canal/CanalRecordParser.java x: 11 commits (all time) y: 162 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumBsonRecordParser.java x: 3 commits (all time) y: 147 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/strategy/MongoVersionStrategy.java x: 7 commits (all time) y: 107 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlRecordParser.java x: 15 commits (all time) y: 215 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresRecordParser.java x: 9 commits (all time) y: 292 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 8 commits (all time) y: 82 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java x: 18 commits (all time) y: 306 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareBatchSource.java x: 3 commits (all time) y: 110 lines of code paimon-core/src/main/java/org/apache/paimon/table/FormatTable.java x: 8 commits (all time) y: 273 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveTableUtils.java x: 7 commits (all time) y: 86 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkSource.scala x: 11 commits (all time) y: 89 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java x: 20 commits (all time) y: 303 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java x: 12 commits (all time) y: 175 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/PartitionEntry.java x: 5 commits (all time) y: 138 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionManagement.scala x: 22 commits (all time) y: 120 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java x: 25 commits (all time) y: 264 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 14 commits (all time) y: 348 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 5 commits (all time) y: 262 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 7 commits (all time) y: 505 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 13 commits (all time) y: 345 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/splitread/IncrementalDiffSplitRead.java x: 6 commits (all time) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/io/RecordLevelExpire.java x: 9 commits (all time) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 19 commits (all time) y: 224 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/Migrator.java x: 4 commits (all time) y: 6 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MigrateTableProcedure.java x: 7 commits (all time) y: 71 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 7 commits (all time) y: 268 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 20 commits (all time) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/operation/TagDeletion.java x: 14 commits (all time) y: 89 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexFormat.java x: 8 commits (all time) y: 241 lines of code paimon-core/src/main/java/org/apache/paimon/Changelog.java x: 5 commits (all time) y: 102 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestFile.java x: 11 commits (all time) y: 220 lines of code paimon-core/src/main/java/org/apache/paimon/tag/Tag.java x: 5 commits (all time) y: 179 lines of code paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java x: 20 commits (all time) y: 179 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetInputFile.java x: 6 commits (all time) y: 34 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 35 commits (all time) y: 468 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetUtil.java x: 12 commits (all time) y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 28 commits (all time) y: 69 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStore.java x: 11 commits (all time) y: 182 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 13 commits (all time) y: 28 lines of code paimon-core/src/main/java/org/apache/paimon/crosspartition/IndexBootstrap.java x: 6 commits (all time) y: 118 lines of code paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 18 commits (all time) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java x: 20 commits (all time) y: 238 lines of code paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 29 commits (all time) y: 215 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupFileStoreTable.java x: 3 commits (all time) y: 112 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 48 commits (all time) y: 430 lines of code paimon-core/src/main/java/org/apache/paimon/compact/CompactFutureManager.java x: 7 commits (all time) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/compact/CompactManager.java x: 6 commits (all time) y: 17 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 30 commits (all time) y: 326 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/UniversalCompaction.java x: 7 commits (all time) y: 192 lines of code paimon-core/src/main/java/org/apache/paimon/utils/RecordWriter.java x: 9 commits (all time) y: 16 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 26 commits (all time) y: 181 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/BatchWriteGeneratorTagOperator.java x: 9 commits (all time) y: 117 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 16 commits (all time) y: 75 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreMultiCommitter.java x: 19 commits (all time) y: 207 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 22 commits (all time) y: 124 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 40 commits (all time) y: 152 lines of code paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java x: 24 commits (all time) y: 394 lines of code paimon-core/src/main/java/org/apache/paimon/operation/metrics/CompactionMetrics.java x: 8 commits (all time) y: 192 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/BranchesTable.java x: 11 commits (all time) y: 177 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 9 commits (all time) y: 597 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncTableActionBase.java x: 18 commits (all time) y: 168 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 16 commits (all time) y: 297 lines of code paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 11 commits (all time) y: 393 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileStoreSource.java x: 10 commits (all time) y: 62 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java x: 26 commits (all time) y: 213 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java x: 9 commits (all time) y: 273 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 55 commits (all time) y: 566 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactActionFactory.java x: 12 commits (all time) y: 116 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java x: 16 commits (all time) y: 106 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/SortBufferWriteBuffer.java x: 11 commits (all time) y: 223 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupChangelogMergeFunctionWrapper.java x: 15 commits (all time) y: 153 lines of code paimon-core/src/main/java/org/apache/paimon/index/PartitionIndex.java x: 8 commits (all time) y: 115 lines of code paimon-core/src/main/java/org/apache/paimon/index/SimpleHashBucketAssigner.java x: 4 commits (all time) y: 99 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AggregationFieldsTable.java x: 9 commits (all time) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 7 commits (all time) y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 27 commits (all time) y: 169 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 32 commits (all time) y: 415 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 17 commits (all time) y: 158 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 14 commits (all time) y: 167 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java x: 24 commits (all time) y: 272 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java x: 22 commits (all time) y: 234 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcFileFormat.java x: 34 commits (all time) y: 158 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java x: 28 commits (all time) y: 255 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/FieldWriterFactory.java x: 3 commits (all time) y: 270 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableAction.java x: 23 commits (all time) y: 35 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java x: 12 commits (all time) y: 421 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/DynamicBucketCompactSink.java x: 5 commits (all time) y: 32 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/DynamicBucketSink.java x: 12 commits (all time) y: 71 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 29 commits (all time) y: 325 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 4 commits (all time) y: 132 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/PaimonUtils.scala x: 8 commits (all time) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 28 commits (all time) y: 518 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcWriterFactory.java x: 13 commits (all time) y: 78 lines of code paimon-common/src/main/java/org/apache/paimon/sort/zorder/ZIndexer.java x: 1 commits (all time) y: 328 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 8 commits (all time) y: 90 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java x: 10 commits (all time) y: 89 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 9 commits (all time) y: 137 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionFactory.java x: 11 commits (all time) y: 53 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/ParquetVectorUpdaterFactory.java x: 2 commits (all time) y: 679 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedColumnReader.java x: 2 commits (all time) y: 267 lines of code paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneAction.java x: 2 commits (all time) y: 174 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScan.scala x: 24 commits (all time) y: 102 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonBaseScanBuilder.scala x: 10 commits (all time) y: 23 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonScan.scala x: 15 commits (all time) y: 126 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonSplitScan.scala x: 8 commits (all time) y: 41 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkV2FilterConverter.scala x: 2 commits (all time) y: 210 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonMergeIntoBase.scala x: 6 commits (all time) y: 103 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java x: 14 commits (all time) y: 85 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 13 commits (all time) y: 259 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/converter/Arrow2PaimonVectorConverter.java x: 6 commits (all time) y: 470 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/MapColumnVector.java x: 6 commits (all time) y: 5 lines of code paimon-common/src/main/java/org/apache/paimon/utils/VectorMappingUtils.java x: 5 commits (all time) y: 342 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedPlainValuesReader.java x: 1 commits (all time) y: 250 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/VectorizedRleValuesReader.java x: 1 commits (all time) y: 803 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/BytesColumnReader.java x: 9 commits (all time) y: 104 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/NestedPrimitiveColumnReader.java x: 9 commits (all time) y: 575 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 14 commits (all time) y: 529 lines of code paimon-format/src/main/java/org/apache/orc/OrcConf.java x: 6 commits (all time) y: 466 lines of code paimon-core/src/main/java/org/apache/paimon/operation/LocalOrphanFilesClean.java x: 13 commits (all time) y: 240 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java x: 16 commits (all time) y: 120 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/procedure/SparkOrphanFilesClean.scala x: 2 commits (all time) y: 197 lines of code paimon-common/src/main/java/org/apache/paimon/fs/hadoop/HadoopFileIO.java x: 9 commits (all time) y: 315 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 20 commits (all time) y: 249 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 32 commits (all time) y: 146 lines of code paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 22 commits (all time) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommit.java x: 17 commits (all time) y: 34 lines of code paimon-common/src/main/java/org/apache/paimon/options/Options.java x: 9 commits (all time) y: 193 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetFileFormat.java x: 22 commits (all time) y: 63 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java x: 14 commits (all time) y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 20 commits (all time) y: 286 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 6 commits (all time) y: 545 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMetadata.java x: 3 commits (all time) y: 263 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupStreamingReader.java x: 10 commits (all time) y: 120 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java x: 22 commits (all time) y: 329 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/NoPrimaryKeyLookupTable.java x: 14 commits (all time) y: 105 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyLookupTable.java x: 17 commits (all time) y: 108 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 16 commits (all time) y: 82 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 18 commits (all time) y: 390 lines of code paimon-common/src/main/java/org/apache/paimon/format/FormatReaderFactory.java x: 13 commits (all time) y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/operation/RawFileSplitRead.java x: 16 commits (all time) y: 206 lines of code paimon-format/src/main/java/org/apache/orc/impl/RecordReaderImpl.java x: 4 commits (all time) y: 1426 lines of code paimon-format/src/main/java/org/apache/parquet/internal/filter2/columnindex/RowRanges.java x: 3 commits (all time) y: 218 lines of code paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 20 commits (all time) y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java x: 42 commits (all time) y: 325 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AutoTagForSavepointCommitterOperator.java x: 7 commits (all time) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 24 commits (all time) y: 60 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala x: 14 commits (all time) y: 302 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 23 commits (all time) y: 59 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 16 commits (all time) y: 595 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 19 commits (all time) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 29 commits (all time) y: 231 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java x: 13 commits (all time) y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntry.java x: 18 commits (all time) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java x: 21 commits (all time) y: 189 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 18 commits (all time) y: 323 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 19 commits (all time) y: 319 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowFieldTypeConversion.java x: 2 commits (all time) y: 143 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 4 commits (all time) y: 690 lines of code paimon-common/src/main/java/org/apache/paimon/casting/CastedArray.java x: 2 commits (all time) y: 146 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryArray.java x: 7 commits (all time) y: 468 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 11 commits (all time) y: 358 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 6 commits (all time) y: 229 lines of code paimon-common/src/main/java/org/apache/paimon/data/NestedRow.java x: 8 commits (all time) y: 256 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 4 commits (all time) y: 205 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRow.java x: 6 commits (all time) y: 167 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariant.java x: 2 commits (all time) y: 384 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 5 commits (all time) y: 781 lines of code paimon-common/src/main/java/org/apache/paimon/sort/hilbert/HilbertIndexer.java x: 4 commits (all time) y: 244 lines of code paimon-common/src/main/java/org/apache/paimon/types/InternalRowToSizeVisitor.java x: 2 commits (all time) y: 257 lines of code paimon-format/src/main/java/org/apache/parquet/filter2/predicate/ParquetFilters.java x: 5 commits (all time) y: 234 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 17 commits (all time) y: 233 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/Projection.java x: 2 commits (all time) y: 312 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileStoreSource.java x: 20 commits (all time) y: 84 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java x: 11 commits (all time) y: 206 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 30 commits (all time) y: 304 lines of code paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java x: 8 commits (all time) y: 139 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 16 commits (all time) y: 20 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 15 commits (all time) y: 13 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseAction.java x: 18 commits (all time) y: 34 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 33 commits (all time) y: 187 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 23 commits (all time) y: 86 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/MergeIntoProcedure.java x: 10 commits (all time) y: 148 lines of code paimon-core/src/main/java/org/apache/paimon/utils/ObjectsCache.java x: 11 commits (all time) y: 115 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantBuilder.java x: 1 commits (all time) y: 499 lines of code paimon-common/src/main/java/org/apache/paimon/data/variant/GenericVariantUtil.java x: 1 commits (all time) y: 412 lines of code paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcUtils.java x: 3 commits (all time) y: 457 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MultiTablesReadOperator.java x: 8 commits (all time) y: 145 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataField.java x: 10 commits (all time) y: 140 lines of code paimon-common/src/main/java/org/apache/paimon/utils/BitSliceIndexRoaringBitmap.java x: 2 commits (all time) y: 246 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 26 commits (all time) y: 115 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactory.java x: 17 commits (all time) y: 15 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/RunLengthDecoder.java x: 9 commits (all time) y: 265 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/DataCatalogTable.java x: 6 commits (all time) y: 141 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalog.java x: 7 commits (all time) y: 423 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonStatistics.scala x: 15 commits (all time) y: 106 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/optimizer/MergePaimonScalarSubqueriesBase.scala x: 4 commits (all time) y: 304 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sorter/SortUtils.java x: 13 commits (all time) y: 153 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 29 commits (all time) y: 275 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 17 commits (all time) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileRecordReader.java x: 13 commits (all time) y: 38 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 3 commits (all time) y: 483 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/BinaryRowSerializer.java x: 5 commits (all time) y: 212 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java x: 21 commits (all time) y: 25 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java x: 7 commits (all time) y: 22 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupTable.java x: 12 commits (all time) y: 14 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 24 commits (all time) y: 220 lines of code paimon-common/src/main/java/org/apache/paimon/utils/BinaryStringUtils.java x: 4 commits (all time) y: 265 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java x: 6 commits (all time) y: 414 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/pool/CachedClientPool.java x: 3 commits (all time) y: 239 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 11 commits (all time) y: 21 lines of code paimon-common/src/main/java/org/apache/paimon/utils/HadoopUtils.java x: 10 commits (all time) y: 188 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/NumberSequenceRowSource.java x: 1 commits (all time) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 14 commits (all time) y: 50 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeFunctionWrapper.java x: 10 commits (all time) y: 82 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeTreeCompactRewriter.java x: 15 commits (all time) y: 65 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeTreeCompactRewriter.java x: 20 commits (all time) y: 155 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 16 commits (all time) y: 237 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresActionUtils.java x: 5 commits (all time) y: 158 lines of code paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreWriter.java x: 15 commits (all time) y: 347 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexOptions.java x: 3 commits (all time) y: 180 lines of code paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java x: 9 commits (all time) y: 249 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 9 commits (all time) y: 209 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 11 commits (all time) y: 265 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 3 commits (all time) y: 436 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldWriterFactory.java x: 3 commits (all time) y: 210 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 18 commits (all time) y: 284 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarActionUtils.java x: 10 commits (all time) y: 347 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableWrite.java x: 10 commits (all time) y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 30 commits (all time) y: 218 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncJobHandler.java x: 9 commits (all time) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 21 commits (all time) y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSinkBase.java x: 12 commits (all time) y: 139 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 8 commits (all time) y: 590 lines of code paimon-common/src/main/java/org/apache/paimon/data/Timestamp.java x: 6 commits (all time) y: 124 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeReaders.java x: 11 commits (all time) y: 74 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/TableRead.java x: 9 commits (all time) y: 27 lines of code paimon-common/src/main/java/org/apache/paimon/options/MemorySize.java x: 5 commits (all time) y: 272 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/BatchWriteBuilderImpl.java x: 8 commits (all time) y: 47 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDataColumnReaderFactory.java x: 9 commits (all time) y: 154 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 22 commits (all time) y: 173 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 10 commits (all time) y: 528 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/RewriteFileIndexSource.java x: 1 commits (all time) y: 224 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactRewriter.java x: 12 commits (all time) y: 92 lines of code paimon-format/src/main/java/org/apache/orc/impl/RecordReaderUtils.java x: 1 commits (all time) y: 593 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/sort/SparkHilbertUDF.java x: 3 commits (all time) y: 194 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/format/DebeziumEvent.java x: 5 commits (all time) y: 177 lines of code paimon-core/src/main/java/org/apache/paimon/privilege/FileBasedPrivilegeManager.java x: 1 commits (all time) y: 376 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSink.java x: 14 commits (all time) y: 26 lines of code paimon-common/src/main/antlr4/JavaParser.g4 x: 3 commits (all time) y: 520 lines of code paimon-format/src/main/java/org/apache/orc/OrcFile.java x: 2 commits (all time) y: 854 lines of code paimon-format/src/main/java/org/apache/orc/impl/PhysicalFsWriter.java x: 2 commits (all time) y: 595 lines of code paimon-format/src/main/java/org/apache/orc/impl/WriterImpl.java x: 2 commits (all time) y: 821 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputFormat.java x: 17 commits (all time) y: 25 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FollowUpScanner.java x: 8 commits (all time) y: 11 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/SortCodeGenerator.scala x: 4 commits (all time) y: 290 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/BlockStatementGrouper.java x: 7 commits (all time) y: 230 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/DeclarationRewriter.java x: 7 commits (all time) y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/fs/Path.java x: 10 commits (all time) y: 200 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 5 commits (all time) y: 436 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 4 commits (all time) y: 2506 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveDeserializer.java x: 4 commits (all time) y: 221 lines of code paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network/ServerConnection.java x: 3 commits (all time) y: 316 lines of code paimon-service/paimon-service-client/src/main/java/org/apache/paimon/service/network/AbstractServerHandler.java x: 2 commits (all time) y: 239 lines of code tools/ci/paimon-ci-tools/src/main/java/org/apache/paimon/tools/ci/licensecheck/NoticeFileChecker.java x: 1 commits (all time) y: 299 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 15 commits (all time) y: 5 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java x: 5 commits (all time) y: 197 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java x: 5 commits (all time) y: 250 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryString.java x: 5 commits (all time) y: 734 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java x: 3 commits (all time) y: 748 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/org/apache/paimon/s3/S3FileIO.java x: 7 commits (all time) y: 115 lines of code paimon-core/src/main/java/org/apache/paimon/sort/QuickSort.java x: 1 commits (all time) y: 240 lines of code paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedInputView.java x: 2 commits (all time) y: 370 lines of code
2825.0
lines of code
  min: 2.0
  average: 91.83
  25th percentile: 22.0
  median: 49.0
  75th percentile: 105.25
  max: 2825.0
0 201.0
commits (all time)
min: 1.0 | average: 5.56 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 6.0 | max: 201.0

File Size vs. Contributors (all time): 2422 points

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

File Size vs. Commits (30 days): 278 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 1 commits (30d) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 2 commits (30d) y: 88 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 1 commits (30d) y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 commits (30d) y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 2 commits (30d) y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 commits (30d) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 7 commits (30d) y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 commits (30d) y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 commits (30d) y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 commits (30d) y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 1 commits (30d) y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 4 commits (30d) y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 commits (30d) y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 1 commits (30d) y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 2 commits (30d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 3 commits (30d) y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 2 commits (30d) y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 1 commits (30d) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 1 commits (30d) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 3 commits (30d) y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 2 commits (30d) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 1 commits (30d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 1 commits (30d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 1 commits (30d) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 4 commits (30d) y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 11 commits (30d) y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 3 commits (30d) y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 3 commits (30d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 2 commits (30d) y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 2 commits (30d) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 3 commits (30d) y: 122 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java x: 2 commits (30d) y: 116 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 4 commits (30d) y: 184 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 3 commits (30d) y: 337 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 2 commits (30d) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 2 commits (30d) y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 1 commits (30d) y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java x: 2 commits (30d) y: 241 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 5 commits (30d) y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 1 commits (30d) y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 1 commits (30d) y: 871 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 1 commits (30d) y: 102 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 2 commits (30d) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 1 commits (30d) y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 2 commits (30d) y: 343 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 2 commits (30d) y: 75 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 1 commits (30d) y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 1 commits (30d) y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 1 commits (30d) y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 commits (30d) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 commits (30d) y: 205 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 1 commits (30d) y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 1 commits (30d) y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 3 commits (30d) y: 217 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 2 commits (30d) y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 1 commits (30d) y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 1 commits (30d) y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 1 commits (30d) y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 commits (30d) y: 198 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 1 commits (30d) y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 2 commits (30d) y: 302 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 2 commits (30d) y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 2 commits (30d) y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 1 commits (30d) y: 249 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 1 commits (30d) y: 279 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 1 commits (30d) y: 346 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 1 commits (30d) y: 773 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 1 commits (30d) y: 671 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 1 commits (30d) y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 2 commits (30d) y: 147 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriterImpl.java x: 2 commits (30d) y: 50 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 2 commits (30d) y: 364 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 3 commits (30d) y: 239 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 2 commits (30d) y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 1 commits (30d) y: 265 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 2 commits (30d) y: 157 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 commits (30d) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 2 commits (30d) y: 213 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 1 commits (30d) y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 3 commits (30d) y: 392 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 1 commits (30d) y: 591 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 1 commits (30d) y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 1 commits (30d) y: 493 lines of code
2825.0
lines of code
  min: 3.0
  average: 166.08
  25th percentile: 45.75
  median: 89.5
  75th percentile: 187.25
  max: 2825.0
0 11.0
commits (30d)
min: 1.0 | average: 1.31 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 11.0

File Size vs. Contributors (30 days): 278 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 1 contributors (30d) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 1 contributors (30d) y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 contributors (30d) y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 2 contributors (30d) y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 contributors (30d) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 3 contributors (30d) y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 contributors (30d) y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 contributors (30d) y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 contributors (30d) y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 1 contributors (30d) y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 3 contributors (30d) y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 contributors (30d) y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 1 contributors (30d) y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 2 contributors (30d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 3 contributors (30d) y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 2 contributors (30d) y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 1 contributors (30d) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 1 contributors (30d) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 1 contributors (30d) y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java x: 2 contributors (30d) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 1 contributors (30d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 1 contributors (30d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 1 contributors (30d) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 2 contributors (30d) y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 5 contributors (30d) y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 3 contributors (30d) y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 2 contributors (30d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java x: 2 contributors (30d) y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 2 contributors (30d) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 2 contributors (30d) y: 122 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 4 contributors (30d) y: 184 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 3 contributors (30d) y: 337 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 2 contributors (30d) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 2 contributors (30d) y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 1 contributors (30d) y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java x: 2 contributors (30d) y: 241 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 4 contributors (30d) y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 1 contributors (30d) y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 1 contributors (30d) y: 871 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 1 contributors (30d) y: 102 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 1 contributors (30d) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 1 contributors (30d) y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 2 contributors (30d) y: 343 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 2 contributors (30d) y: 75 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 1 contributors (30d) y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 1 contributors (30d) y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 1 contributors (30d) y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 contributors (30d) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 contributors (30d) y: 205 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 1 contributors (30d) y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 1 contributors (30d) y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 2 contributors (30d) y: 217 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 2 contributors (30d) y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 1 contributors (30d) y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 1 contributors (30d) y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 1 contributors (30d) y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 contributors (30d) y: 198 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 1 contributors (30d) y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 2 contributors (30d) y: 302 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 2 contributors (30d) y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 2 contributors (30d) y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 1 contributors (30d) y: 249 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 1 contributors (30d) y: 279 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 1 contributors (30d) y: 346 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 1 contributors (30d) y: 773 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 1 contributors (30d) y: 671 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 1 contributors (30d) y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 2 contributors (30d) y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 2 contributors (30d) y: 157 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 contributors (30d) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 1 contributors (30d) y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 2 contributors (30d) y: 392 lines of code paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketFileStoreWrite.java x: 2 contributors (30d) y: 83 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 1 contributors (30d) y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 1 contributors (30d) y: 493 lines of code
2825.0
lines of code
  min: 3.0
  average: 166.08
  25th percentile: 45.75
  median: 89.5
  75th percentile: 187.25
  max: 2825.0
0 5.0
contributors (30d)
min: 1.0 | average: 1.19 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 5.0

File Size vs. Commits (90 days): 706 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 1 commits (90d) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 2 commits (90d) y: 88 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RefreshBlacklist.java x: 1 commits (90d) y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 3 commits (90d) y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 2 commits (90d) y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 3 commits (90d) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 14 commits (90d) y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 commits (90d) y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 commits (90d) y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 commits (90d) y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 2 commits (90d) y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 7 commits (90d) y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util/OptionUtils.scala x: 3 commits (90d) y: 81 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 commits (90d) y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 3 commits (90d) y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 8 commits (90d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 38 commits (90d) y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 8 commits (90d) y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 3 commits (90d) y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 8 commits (90d) y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 2 commits (90d) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java x: 2 commits (90d) y: 21 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProvider.java x: 5 commits (90d) y: 115 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java x: 7 commits (90d) y: 49 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFECSTokenLoader.java x: 2 commits (90d) y: 90 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java x: 2 commits (90d) y: 38 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 2 commits (90d) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 13 commits (90d) y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 1 commits (90d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 4 commits (90d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 2 commits (90d) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 4 commits (90d) y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 27 commits (90d) y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 8 commits (90d) y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 3 commits (90d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 3 commits (90d) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 4 commits (90d) y: 122 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java x: 3 commits (90d) y: 116 lines of code paimon-core/src/main/java/org/apache/paimon/index/DeletionVectorMeta.java x: 1 commits (90d) y: 69 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/UpdatePaimonTableCommand.scala x: 2 commits (90d) y: 114 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 4 commits (90d) y: 184 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 5 commits (90d) y: 337 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 12 commits (90d) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 11 commits (90d) y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 8 commits (90d) y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTUtil.java x: 4 commits (90d) y: 97 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 13 commits (90d) y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 26 commits (90d) y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 21 commits (90d) y: 871 lines of code paimon-format/src/main/java/org/apache/paimon/format/OrcOptions.java x: 2 commits (90d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/disk/IOManagerImpl.java x: 1 commits (90d) y: 90 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 1 commits (90d) y: 102 lines of code paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 3 commits (90d) y: 71 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 5 commits (90d) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 1 commits (90d) y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 4 commits (90d) y: 343 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 4 commits (90d) y: 75 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ListCloneFilesFunction.java x: 2 commits (90d) y: 129 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowUtils.java x: 1 commits (90d) y: 213 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriter.java x: 2 commits (90d) y: 51 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactory.java x: 1 commits (90d) y: 6 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 1 commits (90d) y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 6 commits (90d) y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 2 commits (90d) y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneProcessFunction.java x: 1 commits (90d) y: 61 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 commits (90d) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 commits (90d) y: 205 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 1 commits (90d) y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 4 commits (90d) y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java x: 8 commits (90d) y: 217 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 5 commits (90d) y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 4 commits (90d) y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 4 commits (90d) y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java x: 1 commits (90d) y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java x: 1 commits (90d) y: 144 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 1 commits (90d) y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 commits (90d) y: 198 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 4 commits (90d) y: 108 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 5 commits (90d) y: 187 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 2 commits (90d) y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 2 commits (90d) y: 162 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 8 commits (90d) y: 302 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 3 commits (90d) y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 2 commits (90d) y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 2 commits (90d) y: 249 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 3 commits (90d) y: 205 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 2 commits (90d) y: 279 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 3 commits (90d) y: 346 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 1 commits (90d) y: 187 lines of code paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/HadoopCompliantFileIO.java x: 2 commits (90d) y: 219 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 5 commits (90d) y: 773 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 3 commits (90d) y: 671 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java x: 2 commits (90d) y: 148 lines of code paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 1 commits (90d) y: 225 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 4 commits (90d) y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 4 commits (90d) y: 147 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java x: 2 commits (90d) y: 364 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 4 commits (90d) y: 88 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 3 commits (90d) y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 5 commits (90d) y: 239 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 3 commits (90d) y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/CompactBucketsTable.java x: 2 commits (90d) y: 210 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 2 commits (90d) y: 265 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java x: 3 commits (90d) y: 157 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 commits (90d) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 5 commits (90d) y: 213 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 6 commits (90d) y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 7 commits (90d) y: 392 lines of code paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 4 commits (90d) y: 132 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 8 commits (90d) y: 591 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 2 commits (90d) y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 5 commits (90d) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 4 commits (90d) y: 57 lines of code paimon-core/src/main/java/org/apache/paimon/utils/CatalogBranchManager.java x: 5 commits (90d) y: 70 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileSystemBranchManager.java x: 4 commits (90d) y: 175 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 3 commits (90d) y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 4 commits (90d) y: 493 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 5 commits (90d) y: 246 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java x: 3 commits (90d) y: 282 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTask.java x: 2 commits (90d) y: 308 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 7 commits (90d) y: 322 lines of code paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java x: 11 commits (90d) y: 157 lines of code paimon-open-api/rest-management-api.yaml x: 5 commits (90d) y: 320 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 6 commits (90d) y: 396 lines of code paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 2 commits (90d) y: 295 lines of code paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java x: 3 commits (90d) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 3 commits (90d) y: 370 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 3 commits (90d) y: 331 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 2 commits (90d) y: 269 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 6 commits (90d) y: 1384 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 2 commits (90d) y: 421 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RewriteFileIndexSink.java x: 1 commits (90d) y: 321 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 6 commits (90d) y: 284 lines of code paimon-core/src/main/java/org/apache/paimon/view/ViewChange.java x: 1 commits (90d) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 5 commits (90d) y: 1426 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonViewExec.scala x: 2 commits (90d) y: 177 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 3 commits (90d) y: 108 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogSnapshotCommit.java x: 3 commits (90d) y: 35 lines of code paimon-core/src/main/java/org/apache/paimon/tag/SnapshotLoaderImpl.java x: 4 commits (90d) y: 44 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/bitmap/BitmapFileIndexMeta.java x: 4 commits (90d) y: 247 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileIndexWriter.java x: 1 commits (90d) y: 289 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/aliyun/AliyunRecordParser.java x: 3 commits (90d) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java x: 1 commits (90d) y: 306 lines of code paimon-core/src/main/java/org/apache/paimon/table/FormatTable.java x: 3 commits (90d) y: 273 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/PartitionEntry.java x: 2 commits (90d) y: 138 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 1 commits (90d) y: 348 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 commits (90d) y: 505 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionBase.java x: 3 commits (90d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 4 commits (90d) y: 224 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthSignature.java x: 3 commits (90d) y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/RESTAuthParameter.java x: 4 commits (90d) y: 32 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/RescaleProcedure.java x: 3 commits (90d) y: 60 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 1 commits (90d) y: 268 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexFormat.java x: 1 commits (90d) y: 241 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 2 commits (90d) y: 468 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 1 commits (90d) y: 430 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 2 commits (90d) y: 326 lines of code paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java x: 1 commits (90d) y: 394 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 1 commits (90d) y: 597 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 1 commits (90d) y: 566 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 1 commits (90d) y: 415 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java x: 1 commits (90d) y: 255 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 1 commits (90d) y: 325 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 1 commits (90d) y: 518 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/ParquetVectorUpdaterFactory.java x: 1 commits (90d) y: 679 lines of code
2825.0
lines of code
  min: 3.0
  average: 140.75
  25th percentile: 43.0
  median: 88.0
  75th percentile: 171.0
  max: 2825.0
0 38.0
commits (90d)
min: 1.0 | average: 1.96 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 38.0

File Size vs. Contributors (90 days): 706 points

paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java x: 1 contributors (90d) y: 114 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/SystemCatalogTable.java x: 1 contributors (90d) y: 88 lines of code paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 contributors (90d) y: 32 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala x: 2 contributors (90d) y: 111 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala x: 2 contributors (90d) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala x: 6 contributors (90d) y: 400 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2Write.scala x: 1 contributors (90d) y: 151 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonV2WriteBuilder.scala x: 1 contributors (90d) y: 39 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/PaimonWrite.scala x: 1 contributors (90d) y: 19 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkConnectorOptions.java x: 2 contributors (90d) y: 62 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonCommand.scala x: 6 contributors (90d) y: 213 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/util/OptionUtils.scala x: 3 contributors (90d) y: 81 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/BaseWriteBuilder.scala x: 1 contributors (90d) y: 45 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 2 contributors (90d) y: 97 lines of code paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java x: 5 contributors (90d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java x: 5 contributors (90d) y: 966 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java x: 4 contributors (90d) y: 61 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java x: 3 contributors (90d) y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java x: 3 contributors (90d) y: 171 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java x: 2 contributors (90d) y: 6 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java x: 2 contributors (90d) y: 21 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProvider.java x: 4 contributors (90d) y: 115 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java x: 3 contributors (90d) y: 49 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java x: 2 contributors (90d) y: 38 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java x: 2 contributors (90d) y: 76 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 4 contributors (90d) y: 599 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java x: 1 contributors (90d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java x: 3 contributors (90d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 1 contributors (90d) y: 189 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java x: 2 contributors (90d) y: 54 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 14 contributors (90d) y: 2825 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 3 contributors (90d) y: 417 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java x: 2 contributors (90d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java x: 3 contributors (90d) y: 125 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java x: 3 contributors (90d) y: 122 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java x: 2 contributors (90d) y: 116 lines of code paimon-core/src/main/java/org/apache/paimon/index/DeletionVectorMeta.java x: 1 contributors (90d) y: 69 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveCloneUtils.java x: 4 contributors (90d) y: 184 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java x: 5 contributors (90d) y: 337 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 5 contributors (90d) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 4 contributors (90d) y: 420 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java x: 2 contributors (90d) y: 235 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java x: 4 contributors (90d) y: 241 lines of code paimon-core/src/main/java/org/apache/paimon/rest/RESTUtil.java x: 3 contributors (90d) y: 97 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 7 contributors (90d) y: 1523 lines of code paimon-open-api/rest-catalog-open-api.yaml x: 4 contributors (90d) y: 2136 lines of code paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java x: 4 contributors (90d) y: 871 lines of code paimon-core/src/main/java/org/apache/paimon/disk/IOManagerImpl.java x: 1 contributors (90d) y: 90 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonPartitionReader.scala x: 1 contributors (90d) y: 102 lines of code paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java x: 3 contributors (90d) y: 71 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 2 contributors (90d) y: 266 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/PrimaryKeyPartialLookupTable.java x: 1 contributors (90d) y: 292 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java x: 4 contributors (90d) y: 343 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/vector/ArrowFormatWriter.java x: 4 contributors (90d) y: 75 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/ListCloneFilesFunction.java x: 2 contributors (90d) y: 129 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/ArrowUtils.java x: 1 contributors (90d) y: 213 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriterFactory.java x: 1 contributors (90d) y: 6 lines of code paimon-arrow/src/main/java/org/apache/paimon/arrow/writer/ArrowFieldWriters.java x: 1 contributors (90d) y: 656 lines of code paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java x: 2 contributors (90d) y: 382 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java x: 2 contributors (90d) y: 375 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneProcessFunction.java x: 1 contributors (90d) y: 61 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyManifestFileOperator.java x: 1 contributors (90d) y: 171 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/copy/CopyMetaFilesFunction.java x: 1 contributors (90d) y: 205 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java x: 1 contributors (90d) y: 128 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java x: 3 contributors (90d) y: 366 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 4 contributors (90d) y: 582 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 2 contributors (90d) y: 476 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 3 contributors (90d) y: 135 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java x: 1 contributors (90d) y: 360 lines of code paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java x: 1 contributors (90d) y: 144 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java x: 1 contributors (90d) y: 162 lines of code paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java x: 1 contributors (90d) y: 198 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 4 contributors (90d) y: 108 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java x: 2 contributors (90d) y: 230 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyMultiTableCompactionWorkerOperator.java x: 2 contributors (90d) y: 162 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 5 contributors (90d) y: 302 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java x: 3 contributors (90d) y: 499 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetFileReader.java x: 2 contributors (90d) y: 1271 lines of code paimon-format/src/main/java/org/apache/parquet/hadoop/ParquetWriter.java x: 1 contributors (90d) y: 249 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkTableSource.java x: 2 contributors (90d) y: 205 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRowWrapper.java x: 2 contributors (90d) y: 279 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 3 contributors (90d) y: 346 lines of code paimon-filesystems/paimon-jindo/src/main/java/org/apache/paimon/jindo/HadoopCompliantFileIO.java x: 2 contributors (90d) y: 219 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 4 contributors (90d) y: 773 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java x: 3 contributors (90d) y: 671 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java x: 2 contributors (90d) y: 148 lines of code paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java x: 1 contributors (90d) y: 225 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonTable.scala x: 2 contributors (90d) y: 314 lines of code paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java x: 3 contributors (90d) y: 239 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 2 contributors (90d) y: 543 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java x: 1 contributors (90d) y: 265 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 contributors (90d) y: 344 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 3 contributors (90d) y: 479 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 5 contributors (90d) y: 392 lines of code paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketFileStoreWrite.java x: 2 contributors (90d) y: 83 lines of code paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyFileStoreTable.java x: 3 contributors (90d) y: 151 lines of code paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 4 contributors (90d) y: 132 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/SupportsRowLevelOperationFlinkTableSink.java x: 2 contributors (90d) y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java x: 4 contributors (90d) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java x: 3 contributors (90d) y: 57 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 1 contributors (90d) y: 436 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java x: 3 contributors (90d) y: 246 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTask.java x: 1 contributors (90d) y: 308 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 5 contributors (90d) y: 322 lines of code paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java x: 3 contributors (90d) y: 157 lines of code paimon-open-api/rest-management-api.yaml x: 3 contributors (90d) y: 320 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 2 contributors (90d) y: 396 lines of code paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java x: 3 contributors (90d) y: 340 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 3 contributors (90d) y: 331 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 2 contributors (90d) y: 269 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 2 contributors (90d) y: 1384 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 2 contributors (90d) y: 299 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 2 contributors (90d) y: 421 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RewriteFileIndexSink.java x: 1 contributors (90d) y: 321 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 3 contributors (90d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java x: 3 contributors (90d) y: 284 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 2 contributors (90d) y: 1426 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonViewExec.scala x: 2 contributors (90d) y: 177 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 3 contributors (90d) y: 108 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileIndexWriter.java x: 1 contributors (90d) y: 289 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 1 contributors (90d) y: 348 lines of code paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 contributors (90d) y: 505 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 4 contributors (90d) y: 224 lines of code paimon-core/src/main/java/org/apache/paimon/rest/auth/RESTAuthParameter.java x: 3 contributors (90d) y: 32 lines of code paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java x: 1 contributors (90d) y: 268 lines of code paimon-common/src/main/java/org/apache/paimon/fileindex/FileIndexFormat.java x: 1 contributors (90d) y: 241 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 1 contributors (90d) y: 430 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 2 contributors (90d) y: 326 lines of code paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java x: 1 contributors (90d) y: 394 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 1 contributors (90d) y: 597 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 1 contributors (90d) y: 566 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 1 contributors (90d) y: 415 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 1 contributors (90d) y: 325 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 1 contributors (90d) y: 518 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/newreader/ParquetVectorUpdaterFactory.java x: 1 contributors (90d) y: 679 lines of code
2825.0
lines of code
  min: 3.0
  average: 140.75
  25th percentile: 43.0
  median: 88.0
  75th percentile: 171.0
  max: 2825.0
0 14.0
contributors (90d)
min: 1.0 | average: 1.49 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 14.0