apache / incubator-paimon
File Size

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

Intro
Learn more...
File Size Overall
3% | 7% | 26% | 27% | 33%
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
java4% | 6% | 27% | 28% | 33%
scala0% | 31% | 34% | 5% | 28%
g40% | 73% | 0% | 26% | 0%
xml0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
paimon-filesystems78% | 0% | 0% | 17% | 3%
paimon-common5% | 13% | 27% | 23% | 30%
paimon-benchmark0% | 38% | 7% | 31% | 21%
paimon-core0% | 2% | 26% | 33% | 36%
paimon-flink0% | 3% | 25% | 30% | 40%
paimon-codegen0% | 37% | 30% | 12% | 20%
paimon-hive0% | 16% | 18% | 24% | 40%
paimon-format0% | 0% | 45% | 24% | 29%
paimon-spark0% | 0% | 49% | 19% | 30%
tools0% | 0% | 0% | 0% | 100%
paimon-codegen-loader0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
XmlResponsesSaxParser.java
in paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform
 2506 151
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 1423 113
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 822 22
MemorySegmentUtils.java
in paimon-common/src/main/java/org/apache/paimon/memory
 770 64
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
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 707 54
GenerateUtils.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 686 28
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 617 35
RowCompactedSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 529 55
DataTypeJsonParser.java
in paimon-common/src/main/java/org/apache/paimon/types
 527 38
DateTimeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 526 46
JavaParser.g4
in paimon-common/src/main/antlr4
 520 -
SysInfoLinux.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 504 29
ParquetRowDataWriter.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/writer
 488 55
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 470 21
MemorySegment.java
in paimon-common/src/main/java/org/apache/paimon/memory
 436 64
BinaryArray.java
in paimon-common/src/main/java/org/apache/paimon/data
 429 52
ArrayColumnReader.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/reader
 414 9
MySqlDebeziumJsonEventParser.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 389 13
FieldReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/avro
 385 55
SchemaChange.java
in paimon-core/src/main/java/org/apache/paimon/schema
 381 63
AbstractPagedInputView.java
in paimon-common/src/main/java/org/apache/paimon/data
 370 27
SparkCatalog.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 370 20
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 369 27
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 354 21
FlinkFactoryUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories
 346 18
ParquetSplitReaderUtil.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/reader
 345 3
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 341 54
MergeIntoAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 340 19
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 331 14
FilesTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 330 25
HashLookupStoreWriter.java
in paimon-common/src/main/java/org/apache/paimon/lookup/hash
 325 10
BinaryRow.java
in paimon-common/src/main/java/org/apache/paimon/data
 325 46
DataInputDeserializer.java
in paimon-common/src/main/java/org/apache/paimon/io
 316 29
MySqlTypeUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 312 10
PredicateBuilder.java
in paimon-common/src/main/java/org/apache/paimon/predicate
 311 30
SchemaValidation.java
in paimon-core/src/main/java/org/apache/paimon/schema
 309 9
SnapshotReaderImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source/snapshot
 309 18
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 308 29
ManifestFileMeta.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 305 16
PhysicalWriterImpl.java
in paimon-format/src/main/java/org/apache/paimon/format/orc/writer
 304 26
MySqlActionUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 302 7
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 298 22
ParquetReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet
 294 18
SortCodeGenerator.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 290 12
SparkRow.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 288 38
StringUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 281 16
Expression.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc
 278 34
AbstractPagedOutputView.java
in paimon-common/src/main/java/org/apache/paimon/data
 276 24
Files With Most Units (Top 50)
File# lines# units
XmlResponsesSaxParser.java
in paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform
 2506 151
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 1423 113
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
 770 64
MemorySegment.java
in paimon-common/src/main/java/org/apache/paimon/memory
 436 64
SchemaChange.java
in paimon-core/src/main/java/org/apache/paimon/schema
 381 63
RowCompactedSerializer.java
in paimon-common/src/main/java/org/apache/paimon/data/serializer
 529 55
FieldReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/avro
 385 55
ParquetRowDataWriter.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/writer
 488 55
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 707 54
AuditLogTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 341 54
BinaryArray.java
in paimon-common/src/main/java/org/apache/paimon/data
 429 52
BinaryString.java
in paimon-common/src/main/java/org/apache/paimon/data
 734 49
DateTimeUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 526 46
BinaryRow.java
in paimon-common/src/main/java/org/apache/paimon/data
 325 46
FlinkRowData.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 252 45
FlinkRowWrapper.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 246 43
DataTypes.java
in paimon-common/src/main/java/org/apache/paimon/types
 146 41
DataTypeJsonParser.java
in paimon-common/src/main/java/org/apache/paimon/types
 527 38
SparkRow.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 288 38
NestedRow.java
in paimon-common/src/main/java/org/apache/paimon/data
 248 36
HiveCatalog.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 617 35
Expression.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc
 278 34
ColumnarRow.java
in paimon-common/src/main/java/org/apache/paimon/data/columnar
 162 34
ParquetDataColumnReaderFactory.java
in paimon-format/src/main/java/org/apache/paimon/format/parquet/reader
 174 33
HadoopFileIO.java
in paimon-common/src/main/java/org/apache/paimon/fs/hadoop
 189 32
ExceptionUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 264 31
LocalFileIO.java
in paimon-common/src/main/java/org/apache/paimon/fs/local
 258 31
PredicateBuilder.java
in paimon-common/src/main/java/org/apache/paimon/predicate
 311 30
GenericArray.java
in paimon-common/src/main/java/org/apache/paimon/data
 224 30
FlinkFileIO.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 169 29
SysInfoLinux.java
in paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu
 504 29
Snapshot.java
in paimon-core/src/main/java/org/apache/paimon
 308 29
Options.java
in paimon-common/src/main/java/org/apache/paimon/options
 189 29
DataTypeChecks.java
in paimon-common/src/main/java/org/apache/paimon/types
 163 29
DataInputDeserializer.java
in paimon-common/src/main/java/org/apache/paimon/io
 316 29
GenerateUtils.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 686 28
Catalog.java
in paimon-core/src/main/java/org/apache/paimon/catalog
 166 28
MemorySize.java
in paimon-common/src/main/java/org/apache/paimon/options
 267 28
RowType.java
in paimon-common/src/main/java/org/apache/paimon/types
 200 28
SequenceGenerator.java
in paimon-core/src/main/java/org/apache/paimon/table/sink
 170 27
AbstractFileStoreTable.java
in paimon-core/src/main/java/org/apache/paimon/table
 369 27
ColumnarArray.java
in paimon-common/src/main/java/org/apache/paimon/data/columnar
 195 27
GenericRow.java
in paimon-common/src/main/java/org/apache/paimon/data
 149 27
AbstractPagedInputView.java
in paimon-common/src/main/java/org/apache/paimon/data
 370 27
SparkInternalRow.java
in paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark
 180 27
ProjectedRowData.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 135 26
HiveTypeUtils.java
in paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive
 215 26
TableSchema.java
in paimon-core/src/main/java/org/apache/paimon/schema
 188 26
PartitionsTable.java
in paimon-core/src/main/java/org/apache/paimon/table/system
 245 26
Files With Long Lines (Top 45)

There are 45 files with lines longer than 120 characters. In total, there are 144 long lines.

File# lines# units# long lines
CoreOptions.java
in paimon-common/src/main/java/org/apache/paimon
 1423 113 42
RocksDBOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 271 4 18
FlinkConnectorOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 234 4 10
MergeIntoActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 169 4 10
MySqlSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 155 3 5
FlinkFactoryUtil.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories
 346 18 4
SchemaManager.java
in paimon-core/src/main/java/org/apache/paimon/schema
 470 21 4
DeleteActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 43 3 3
FlinkCatalogOptions.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 18 - 3
HiveCatalogOptions.java
in paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive
 27 1 3
MySqlActionUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 302 7 2
MySqlSyncDatabaseAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 331 14 2
DropPartitionActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 44 3 2
MergeIntoAction.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 340 19 2
FileStoreCommitImpl.java
in paimon-core/src/main/java/org/apache/paimon/operation
 822 22 2
CatalogOptions.java
in paimon-common/src/main/java/org/apache/paimon/options
 68 - 2
ExceptionUtils.java
in paimon-common/src/main/java/org/apache/paimon/utils
 264 31 2
GenerateUtils.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 686 28 1
ExprCodeGenerator.scala
in paimon-codegen/src/main/scala/org/apache/paimon/codegen
 96 2 1
FlinkSourceBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source
 229 17 1
FlinkTableSink.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink
 191 11 1
FlinkCatalog.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink
 707 54 1
Expression.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc
 278 34 1
ComputedColumnUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc
 52 1 1
KafkaSyncTableActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 116 3 1
KafkaActionUtils.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 271 9 1
KafkaSyncDatabaseActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka
 104 3 1
MySqlSyncTableActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 117 3 1
MySqlTableSchemaBuilder.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql
 68 2 1
CompactActionFactory.java
in paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action
 58 3 1
bin.xml
in paimon-benchmark/paimon-cluster-benchmark/src/main/assemblies
 48 - 1
AbstractFileStoreScan.java
in paimon-core/src/main/java/org/apache/paimon/operation
 298 22 1
AbstractFileStoreWrite.java
in paimon-core/src/main/java/org/apache/paimon/operation
 354 21 1
ManifestFileMetaSerializer.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 45 4 1
ManifestEntrySerializer.java
in paimon-core/src/main/java/org/apache/paimon/manifest
 58 7 1
AppendOnlyCompactManager.java
in paimon-core/src/main/java/org/apache/paimon/append
 232 18 1
InnerStreamTableScanImpl.java
in paimon-core/src/main/java/org/apache/paimon/table/source
 196 11 1
BufferFileChannelReader.java
in paimon-core/src/main/java/org/apache/paimon/disk
 32 1 1
IOManagerImpl.java
in paimon-core/src/main/java/org/apache/paimon/disk
 71 7 1
PartialUpdateMergeFunction.java
in paimon-core/src/main/java/org/apache/paimon/mergetree/compact
 238 11 1
SecurityContext.java
in paimon-common/src/main/java/org/apache/paimon/security
 57 4 1
DataOutputSerializer.java
in paimon-common/src/main/java/org/apache/paimon/io
 273 26 1
PluginLoader.java
in paimon-common/src/main/java/org/apache/paimon/plugin
 120 6 1
FileFormat.java
in paimon-common/src/main/java/org/apache/paimon/format
 75 9 1
WriteIntoPaimonTable.scala
in paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands
 218 7 1
Correlations

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

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 31 commits (all time) y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 13 commits (all time) y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 commits (all time) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 5 commits (all time) y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 6 commits (all time) y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 9 commits (all time) y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 10 commits (all time) y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 16 commits (all time) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 25 commits (all time) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 4 commits (all time) y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 3 commits (all time) y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 19 commits (all time) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 7 commits (all time) y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 4 commits (all time) y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 5 commits (all time) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 7 commits (all time) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 6 commits (all time) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 commits (all time) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 commits (all time) y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 9 commits (all time) y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 3 commits (all time) y: 12 lines of code paimon-filesystems/paimon-oss/src/main/java/org/apache/paimon/oss/OSSLoader.java x: 7 commits (all time) y: 53 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 8 commits (all time) y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 18 commits (all time) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 9 commits (all time) y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 commits (all time) y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 commits (all time) y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 5 commits (all time) y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 commits (all time) y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 3 commits (all time) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 11 commits (all time) y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 6 commits (all time) y: 54 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 5 commits (all time) y: 50 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 5 commits (all time) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 16 commits (all time) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 5 commits (all time) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 34 commits (all time) y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 2 commits (all time) y: 7 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 14 commits (all time) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 12 commits (all time) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 9 commits (all time) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 20 commits (all time) y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/NoPrimaryKeyLookupTable.java x: 2 commits (all time) y: 55 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBListState.java x: 3 commits (all time) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 3 commits (all time) y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 6 commits (all time) y: 85 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBStateFactory.java x: 4 commits (all time) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 3 commits (all time) y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 2 commits (all time) y: 69 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/ChannelComputer.java x: 3 commits (all time) y: 28 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 13 commits (all time) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 9 commits (all time) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 8 commits (all time) y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 12 commits (all time) y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicBucketSink.java x: 1 commits (all time) y: 81 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 commits (all time) y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 commits (all time) y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/IndexBootstrapOperator.java x: 1 commits (all time) y: 37 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/KeyWithRowSerializer.java x: 1 commits (all time) y: 62 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 13 commits (all time) y: 193 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 2 commits (all time) y: 116 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 13 commits (all time) y: 354 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 14 commits (all time) y: 138 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 14 commits (all time) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 10 commits (all time) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 10 commits (all time) y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 15 commits (all time) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 28 commits (all time) y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 3 commits (all time) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 4 commits (all time) y: 70 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java x: 5 commits (all time) y: 111 lines of code paimon-common/src/main/java/org/apache/paimon/lineage/LineageMeta.java x: 1 commits (all time) y: 17 lines of code paimon-common/src/main/java/org/apache/paimon/options/CatalogOptions.java x: 4 commits (all time) y: 68 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 17 commits (all time) y: 120 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 11 commits (all time) y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 9 commits (all time) y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumn.java x: 2 commits (all time) y: 29 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 commits (all time) y: 278 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataField.java x: 6 commits (all time) y: 100 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 17 commits (all time) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 8 commits (all time) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 11 commits (all time) y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 commits (all time) y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 18 commits (all time) y: 100 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 6 commits (all time) y: 218 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 8 commits (all time) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 5 commits (all time) y: 80 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 10 commits (all time) y: 98 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 13 commits (all time) y: 166 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 commits (all time) y: 180 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 23 commits (all time) y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 30 commits (all time) y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 9 commits (all time) y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 10 commits (all time) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 commits (all time) y: 245 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 2 commits (all time) y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 5 commits (all time) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 7 commits (all time) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 17 commits (all time) y: 263 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 12 commits (all time) y: 215 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 24 commits (all time) y: 259 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonInternalRowObjectInspector.java x: 4 commits (all time) y: 109 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonObjectInspectorFactory.java x: 6 commits (all time) y: 68 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 12 commits (all time) y: 196 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 14 commits (all time) y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileStoreSource.java x: 10 commits (all time) y: 62 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 12 commits (all time) y: 229 lines of code paimon-core/src/main/java/org/apache/paimon/memory/MemoryPoolFactory.java x: 2 commits (all time) y: 83 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 7 commits (all time) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 8 commits (all time) y: 77 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 3 commits (all time) y: 92 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 9 commits (all time) y: 159 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 10 commits (all time) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkInternalRow.java x: 10 commits (all time) y: 180 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 19 commits (all time) y: 370 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 9 commits (all time) y: 232 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java x: 4 commits (all time) y: 188 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkGenericCatalog.java x: 3 commits (all time) y: 227 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 6 commits (all time) y: 174 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java x: 1 commits (all time) y: 149 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 8 commits (all time) y: 117 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeFunctionWrapper.java x: 6 commits (all time) y: 91 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 5 commits (all time) y: 72 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeTreeCompactRewriter.java x: 7 commits (all time) y: 63 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 commits (all time) y: 104 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/LocationKeyExtractor.java x: 7 commits (all time) y: 93 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputFormat.java x: 13 commits (all time) y: 113 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java x: 12 commits (all time) y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 6 commits (all time) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 4 commits (all time) y: 97 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 13 commits (all time) y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 14 commits (all time) y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java x: 13 commits (all time) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 3 commits (all time) y: 251 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 3 commits (all time) y: 73 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/LogicalTypeConversion.java x: 5 commits (all time) y: 24 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/BinaryStringSerializer.java x: 4 commits (all time) y: 33 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 5 commits (all time) y: 224 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 2 commits (all time) y: 195 lines of code paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 7 commits (all time) y: 200 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ArrayUtils.java x: 4 commits (all time) y: 187 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 8 commits (all time) y: 414 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 12 commits (all time) y: 308 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/OrcBulkWriter.java x: 7 commits (all time) y: 81 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 5 commits (all time) y: 255 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala x: 2 commits (all time) y: 19 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaSinkFunction.java x: 3 commits (all time) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 4 commits (all time) y: 9 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java x: 11 commits (all time) y: 169 lines of code paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 1 commits (all time) y: 263 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcFileFormat.java x: 19 commits (all time) y: 138 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonDateObjectInspector.java x: 7 commits (all time) y: 45 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonDecimalObjectInspector.java x: 6 commits (all time) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java x: 3 commits (all time) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java x: 2 commits (all time) y: 72 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 15 commits (all time) y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 8 commits (all time) y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java x: 2 commits (all time) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 2 commits (all time) y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/operation/DefaultValueAssigner.java x: 1 commits (all time) y: 114 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java x: 10 commits (all time) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScanImpl.java x: 4 commits (all time) y: 41 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/TableRead.java x: 6 commits (all time) y: 25 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java x: 2 commits (all time) y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 9 commits (all time) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java x: 9 commits (all time) y: 180 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 10 commits (all time) y: 288 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IOUtils.java x: 2 commits (all time) y: 90 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveMetastoreClient.java x: 1 commits (all time) y: 89 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/SearchArgumentToPredicateConverter.java x: 9 commits (all time) y: 139 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 5 commits (all time) y: 281 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java x: 4 commits (all time) y: 119 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/EqualiserCodeGenerator.scala x: 2 commits (all time) y: 125 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 13 commits (all time) y: 4 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 11 commits (all time) y: 85 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RollbackToAction.java x: 6 commits (all time) y: 30 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreWrite.java x: 15 commits (all time) y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java x: 5 commits (all time) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java x: 10 commits (all time) y: 117 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/CompactedStartingScanner.java x: 10 commits (all time) y: 32 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 15 commits (all time) y: 248 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/SystemTableSource.java x: 9 commits (all time) y: 86 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 13 commits (all time) y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 1 commits (all time) y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 7 commits (all time) y: 32 lines of code paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java x: 7 commits (all time) y: 119 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 8 commits (all time) y: 51 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/AvroFileFormat.java x: 15 commits (all time) y: 95 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 1 commits (all time) y: 385 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldWriterFactory.java x: 1 commits (all time) y: 167 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 13 commits (all time) y: 143 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 11 commits (all time) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java x: 10 commits (all time) y: 59 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcTableStatsExtractor.java x: 4 commits (all time) y: 204 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetFileFormat.java x: 15 commits (all time) y: 55 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkFilterConverter.java x: 9 commits (all time) y: 117 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/OnlyPartitionKeyEqualVisitor.java x: 1 commits (all time) y: 72 lines of code paimon-core/src/main/java/org/apache/paimon/table/TableUtils.java x: 5 commits (all time) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/SplitGenerator.java x: 3 commits (all time) y: 7 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/StaticFileStoreSplitEnumerator.java x: 9 commits (all time) y: 58 lines of code paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java x: 5 commits (all time) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeReaders.java x: 5 commits (all time) y: 67 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/SortBufferWriteBuffer.java x: 3 commits (all time) y: 198 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/ReadOperator.java x: 2 commits (all time) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 8 commits (all time) y: 26 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FileStoreSink.java x: 10 commits (all time) y: 22 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 5 commits (all time) y: 12 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcPredicateFunctionVisitor.java x: 10 commits (all time) y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/utils/BinaryStringUtils.java x: 1 commits (all time) y: 228 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 6 commits (all time) y: 526 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 4 commits (all time) y: 311 lines of code paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 2 commits (all time) y: 105 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/StreamTableScan.java x: 7 commits (all time) y: 15 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FollowUpScanner.java x: 6 commits (all time) y: 11 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorFunction.java x: 2 commits (all time) y: 172 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java x: 1 commits (all time) y: 131 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java x: 5 commits (all time) y: 119 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java x: 5 commits (all time) y: 93 lines of code paimon-common/src/main/java/org/apache/paimon/fs/local/LocalFileIO.java x: 6 commits (all time) y: 258 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/HadoopCompliantFileIO.java x: 4 commits (all time) y: 172 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIO.java x: 3 commits (all time) y: 169 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java x: 11 commits (all time) y: 105 lines of code paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java x: 4 commits (all time) y: 107 lines of code paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 6 commits (all time) y: 255 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 4 commits (all time) y: 305 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 4 commits (all time) y: 436 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValue.java x: 3 commits (all time) y: 146 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataType.java x: 8 commits (all time) y: 82 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 6 commits (all time) y: 122 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 2 commits (all time) y: 686 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/CodeGenerator.java x: 4 commits (all time) y: 13 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/CodeSplitUtil.java x: 4 commits (all time) y: 24 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/FunctionSplitter.java x: 4 commits (all time) y: 149 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 7 commits (all time) y: 325 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryWriter.java x: 5 commits (all time) y: 153 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataOutputSerializer.java x: 4 commits (all time) y: 273 lines of code paimon-common/src/main/java/org/apache/paimon/lookup/hash/HashLookupStoreReader.java x: 7 commits (all time) y: 236 lines of code paimon-common/src/main/java/org/apache/paimon/plugin/ComponentClassLoader.java x: 8 commits (all time) y: 171 lines of code paimon-common/src/main/java/org/apache/paimon/utils/CloseableIterator.java x: 4 commits (all time) y: 133 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 3 commits (all time) y: 264 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 3 commits (all time) y: 2506 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/BaseVectorizedColumnReader.java x: 7 commits (all time) y: 218 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/FixedLenBytesColumnReader.java x: 5 commits (all time) y: 107 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveDeserializer.java x: 3 commits (all time) y: 221 lines of code paimon-spark/paimon-spark-2/src/main/java/org/apache/paimon/spark/SparkDataSourceReader.java x: 10 commits (all time) y: 103 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkScan.java x: 10 commits (all time) y: 82 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java x: 6 commits (all time) y: 381 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReaderWithMinHeap.java x: 1 commits (all time) y: 146 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalogFactory.java x: 12 commits (all time) y: 51 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java x: 8 commits (all time) y: 233 lines of code paimon-common/src/main/java/org/apache/paimon/format/FormatWriterFactory.java x: 5 commits (all time) y: 7 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/reader/OrcSplitReaderUtil.java x: 7 commits (all time) y: 75 lines of code paimon-common/src/main/java/org/apache/paimon/types/MapType.java x: 6 commits (all time) y: 73 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalRowSerializer.java x: 5 commits (all time) y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeJsonParser.java x: 3 commits (all time) y: 527 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/factories/FlinkFactoryUtil.java x: 1 commits (all time) y: 346 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryArray.java x: 5 commits (all time) y: 429 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-common/src/main/java/org/apache/paimon/options/MemorySize.java x: 3 commits (all time) y: 267 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java x: 9 commits (all time) y: 294 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-codegen/src/main/scala/org/apache/paimon/codegen/SortCodeGenerator.scala x: 3 commits (all time) y: 290 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataInputDeserializer.java x: 2 commits (all time) y: 316 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ProjectedRow.java x: 3 commits (all time) y: 133 lines of code paimon-core/src/main/java/org/apache/paimon/sort/BinaryInMemorySortBuffer.java x: 3 commits (all time) y: 159 lines of code paimon-filesystems/paimon-oss-impl/src/main/java/org/apache/paimon/oss/OSSFileIO.java x: 7 commits (all time) y: 112 lines of code paimon-format/src/main/java/org/apache/paimon/format/fs/HadoopReadOnlyFileSystem.java x: 6 commits (all time) y: 141 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java x: 2 commits (all time) y: 184 lines of code paimon-core/src/main/java/org/apache/paimon/sort/AbstractBinaryExternalMerger.java x: 2 commits (all time) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/RocksDBOptions.java x: 2 commits (all time) y: 271 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/RowDataVectorizer.java x: 5 commits (all time) y: 236 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetSplitReaderUtil.java x: 5 commits (all time) y: 345 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/writer/ParquetRowDataWriter.java x: 5 commits (all time) y: 488 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/antlr4/JavaParser.g4 x: 2 commits (all time) y: 520 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/BinaryRowSerializer.java x: 4 commits (all time) y: 208 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/InternalArraySerializer.java x: 4 commits (all time) y: 142 lines of code paimon-common/src/main/java/org/apache/paimon/data/serializer/RowCompactedSerializer.java x: 4 commits (all time) y: 529 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegmentUtils.java x: 3 commits (all time) y: 770 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SortUtil.java x: 2 commits (all time) y: 211 lines of code paimon-common/src/main/java/org/apache/paimon/data/AbstractPagedInputView.java x: 2 commits (all time) y: 370 lines of code paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java x: 1 commits (all time) y: 504 lines of code
2506.0
lines of code
  min: 2.0
  average: 83.1
  25th percentile: 21.0
  median: 45.0
  75th percentile: 101.75
  max: 2506.0
0 34.0
commits (all time)
min: 1.0 | average: 3.63 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 34.0

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

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

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

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 9 commits (30d) y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 3 commits (30d) y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 commits (30d) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 3 commits (30d) y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 3 commits (30d) y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 7 commits (30d) y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 6 commits (30d) y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 5 commits (30d) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 7 commits (30d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 1 commits (30d) y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 1 commits (30d) y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 2 commits (30d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 2 commits (30d) y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 1 commits (30d) y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 4 commits (30d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 3 commits (30d) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 1 commits (30d) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 commits (30d) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 commits (30d) y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 1 commits (30d) y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 1 commits (30d) y: 12 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 7 commits (30d) y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 7 commits (30d) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 1 commits (30d) y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 commits (30d) y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 commits (30d) y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntIntSerializer.java x: 1 commits (30d) y: 24 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 1 commits (30d) y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 commits (30d) y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 1 commits (30d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 1 commits (30d) y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 2 commits (30d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 5 commits (30d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 1 commits (30d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 8 commits (30d) y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 1 commits (30d) y: 7 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 5 commits (30d) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 2 commits (30d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 2 commits (30d) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 3 commits (30d) y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBListState.java x: 2 commits (30d) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 1 commits (30d) y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 2 commits (30d) y: 85 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 1 commits (30d) y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 1 commits (30d) y: 69 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 2 commits (30d) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordPartitionKeyExtractor.java x: 1 commits (30d) y: 21 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 2 commits (30d) y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 3 commits (30d) y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicCdcBucketSink.java x: 1 commits (30d) y: 88 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 commits (30d) y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 commits (30d) y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 4 commits (30d) y: 193 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 2 commits (30d) y: 116 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 3 commits (30d) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 2 commits (30d) y: 354 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 2 commits (30d) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 4 commits (30d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 2 commits (30d) y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 4 commits (30d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 8 commits (30d) y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 3 commits (30d) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 2 commits (30d) y: 70 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java x: 3 commits (30d) y: 111 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 4 commits (30d) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 5 commits (30d) y: 120 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 1 commits (30d) y: 217 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 commits (30d) y: 278 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 2 commits (30d) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 2 commits (30d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 3 commits (30d) y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 commits (30d) y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 3 commits (30d) y: 100 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkSource.scala x: 2 commits (30d) y: 57 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 2 commits (30d) y: 218 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 1 commits (30d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/TableWriteOperator.java x: 1 commits (30d) y: 77 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 commits (30d) y: 180 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 5 commits (30d) y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 6 commits (30d) y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 2 commits (30d) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 commits (30d) y: 245 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 1 commits (30d) y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 1 commits (30d) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyTableCompactionCoordinator.java x: 2 commits (30d) y: 193 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 1 commits (30d) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 3 commits (30d) y: 263 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 4 commits (30d) y: 259 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonInternalRowObjectInspector.java x: 1 commits (30d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 1 commits (30d) y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 1 commits (30d) y: 92 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 1 commits (30d) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 3 commits (30d) y: 370 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionFactory.java x: 3 commits (30d) y: 120 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 1 commits (30d) y: 117 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeTreeCompactRewriter.java x: 1 commits (30d) y: 102 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 3 commits (30d) y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 commits (30d) y: 104 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 2 commits (30d) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 2 commits (30d) y: 97 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 1 commits (30d) y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 1 commits (30d) y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 3 commits (30d) y: 251 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 2 commits (30d) y: 73 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTableSchemaBuilder.java x: 4 commits (30d) y: 68 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 1 commits (30d) y: 224 lines of code paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 1 commits (30d) y: 200 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 1 commits (30d) y: 414 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 1 commits (30d) y: 308 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/OrcBulkWriter.java x: 2 commits (30d) y: 81 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 3 commits (30d) y: 60 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java x: 2 commits (30d) y: 9 lines of code paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 1 commits (30d) y: 263 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/OrcFileFormat.java x: 1 commits (30d) y: 138 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 1 commits (30d) y: 312 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/EventParser.java x: 2 commits (30d) y: 22 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 1 commits (30d) y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java x: 3 commits (30d) y: 222 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 1 commits (30d) y: 155 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 1 commits (30d) y: 288 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 1 commits (30d) y: 281 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java x: 2 commits (30d) y: 119 lines of code
1423.0
lines of code
  min: 4.0
  average: 120.66
  25th percentile: 40.0
  median: 83.0
  75th percentile: 170.0
  max: 1423.0
0 9.0
commits (30d)
min: 1.0 | average: 1.69 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 9.0

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

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 3 contributors (30d) y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 2 contributors (30d) y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 contributors (30d) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 2 contributors (30d) y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 2 contributors (30d) y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 3 contributors (30d) y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 3 contributors (30d) y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 3 contributors (30d) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 5 contributors (30d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 1 contributors (30d) y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 1 contributors (30d) y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 2 contributors (30d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 2 contributors (30d) y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 1 contributors (30d) y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 4 contributors (30d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 3 contributors (30d) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 1 contributors (30d) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 contributors (30d) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 contributors (30d) y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 1 contributors (30d) y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 1 contributors (30d) y: 12 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 4 contributors (30d) y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 5 contributors (30d) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 1 contributors (30d) y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 contributors (30d) y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 contributors (30d) y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntIntSerializer.java x: 1 contributors (30d) y: 24 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 1 contributors (30d) y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 contributors (30d) y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java x: 1 contributors (30d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 1 contributors (30d) y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 2 contributors (30d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 3 contributors (30d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 1 contributors (30d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 5 contributors (30d) y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 1 contributors (30d) y: 7 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 4 contributors (30d) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 1 contributors (30d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 2 contributors (30d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 1 contributors (30d) y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 1 contributors (30d) y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 1 contributors (30d) y: 85 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 1 contributors (30d) y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java x: 1 contributors (30d) y: 69 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 2 contributors (30d) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordPartitionKeyExtractor.java x: 1 contributors (30d) y: 21 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 2 contributors (30d) y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 2 contributors (30d) y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 contributors (30d) y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 contributors (30d) y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 3 contributors (30d) y: 193 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 2 contributors (30d) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 1 contributors (30d) y: 354 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 2 contributors (30d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 1 contributors (30d) y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 2 contributors (30d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 3 contributors (30d) y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 2 contributors (30d) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 2 contributors (30d) y: 70 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 4 contributors (30d) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 4 contributors (30d) y: 120 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/AbstractFlinkTableFactory.java x: 1 contributors (30d) y: 217 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 contributors (30d) y: 278 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 2 contributors (30d) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 2 contributors (30d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 3 contributors (30d) y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 contributors (30d) y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 2 contributors (30d) y: 100 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 1 contributors (30d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/TableWriteOperator.java x: 1 contributors (30d) y: 77 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 contributors (30d) y: 180 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 2 contributors (30d) y: 55 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 4 contributors (30d) y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 6 contributors (30d) y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 2 contributors (30d) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 contributors (30d) y: 245 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 1 contributors (30d) y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 1 contributors (30d) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyTableCompactionCoordinator.java x: 2 contributors (30d) y: 193 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 1 contributors (30d) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 2 contributors (30d) y: 263 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 2 contributors (30d) y: 215 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonInternalRowObjectInspector.java x: 1 contributors (30d) y: 109 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 4 contributors (30d) y: 196 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 1 contributors (30d) y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java x: 1 contributors (30d) y: 92 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 1 contributors (30d) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 3 contributors (30d) y: 370 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java x: 1 contributors (30d) y: 117 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeTreeCompactRewriter.java x: 1 contributors (30d) y: 102 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 contributors (30d) y: 104 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 1 contributors (30d) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 1 contributors (30d) y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 1 contributors (30d) y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 2 contributors (30d) y: 73 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTableSchemaBuilder.java x: 3 contributors (30d) y: 68 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 1 contributors (30d) y: 224 lines of code paimon-common/src/main/java/org/apache/paimon/types/RowType.java x: 1 contributors (30d) y: 200 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 1 contributors (30d) y: 414 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 1 contributors (30d) y: 308 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/writer/OrcBulkWriter.java x: 2 contributors (30d) y: 81 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 2 contributors (30d) y: 60 lines of code paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java x: 1 contributors (30d) y: 263 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 1 contributors (30d) y: 312 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 2 contributors (30d) y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 1 contributors (30d) y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScanImpl.java x: 2 contributors (30d) y: 41 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java x: 1 contributors (30d) y: 155 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 1 contributors (30d) y: 288 lines of code paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java x: 1 contributors (30d) y: 281 lines of code paimon-common/src/main/java/org/apache/paimon/factories/FactoryUtil.java x: 2 contributors (30d) y: 89 lines of code
1423.0
lines of code
  min: 4.0
  average: 120.66
  25th percentile: 40.0
  median: 83.0
  75th percentile: 170.0
  max: 1423.0
0 6.0
contributors (30d)
min: 1.0 | average: 1.39 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 6.0

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

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 17 commits (90d) y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 3 commits (90d) y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 commits (90d) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 5 commits (90d) y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 6 commits (90d) y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 9 commits (90d) y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 10 commits (90d) y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 12 commits (90d) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 18 commits (90d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 1 commits (90d) y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 1 commits (90d) y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 12 commits (90d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 5 commits (90d) y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 3 commits (90d) y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 5 commits (90d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 4 commits (90d) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 3 commits (90d) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 commits (90d) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 commits (90d) y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 2 commits (90d) y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 1 commits (90d) y: 12 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 8 commits (90d) y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 12 commits (90d) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 6 commits (90d) y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 commits (90d) y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 commits (90d) y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 2 commits (90d) y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 commits (90d) y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 6 commits (90d) y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java x: 2 commits (90d) y: 54 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 2 commits (90d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 9 commits (90d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 2 commits (90d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 22 commits (90d) y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/BucketMode.java x: 2 commits (90d) y: 7 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 8 commits (90d) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java x: 5 commits (90d) y: 40 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 8 commits (90d) y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 1 commits (90d) y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBState.java x: 2 commits (90d) y: 85 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 1 commits (90d) y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 7 commits (90d) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordUtils.java x: 2 commits (90d) y: 68 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 8 commits (90d) y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 10 commits (90d) y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 commits (90d) y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 commits (90d) y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/IndexBootstrapOperator.java x: 1 commits (90d) y: 37 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 7 commits (90d) y: 193 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 2 commits (90d) y: 116 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/SplitAssigner.java x: 3 commits (90d) y: 11 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 7 commits (90d) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 7 commits (90d) y: 354 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java x: 8 commits (90d) y: 138 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java x: 10 commits (90d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 7 commits (90d) y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 7 commits (90d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 22 commits (90d) y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 3 commits (90d) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 4 commits (90d) y: 70 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java x: 5 commits (90d) y: 111 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 11 commits (90d) y: 120 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java x: 4 commits (90d) y: 55 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 3 commits (90d) y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumn.java x: 2 commits (90d) y: 29 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 commits (90d) y: 278 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 13 commits (90d) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 6 commits (90d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 5 commits (90d) y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 commits (90d) y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 8 commits (90d) y: 100 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 6 commits (90d) y: 218 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/GlobalFullCompactionSinkWrite.java x: 6 commits (90d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/PrepareCommitOperator.java x: 3 commits (90d) y: 80 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 4 commits (90d) y: 98 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java x: 6 commits (90d) y: 166 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 2 commits (90d) y: 181 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 commits (90d) y: 180 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 5 commits (90d) y: 55 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 11 commits (90d) y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 9 commits (90d) y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 5 commits (90d) y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 5 commits (90d) y: 340 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java x: 3 commits (90d) y: 245 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 1 commits (90d) y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 1 commits (90d) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyTableCompactionCoordinator.java x: 5 commits (90d) y: 193 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java x: 4 commits (90d) y: 161 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 9 commits (90d) y: 263 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 5 commits (90d) y: 215 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 8 commits (90d) y: 259 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonInternalRowObjectInspector.java x: 3 commits (90d) y: 109 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonObjectInspectorFactory.java x: 3 commits (90d) y: 68 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 8 commits (90d) y: 196 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 7 commits (90d) y: 234 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java x: 5 commits (90d) y: 229 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 4 commits (90d) y: 26 lines of code paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java x: 2 commits (90d) y: 77 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWrite.java x: 3 commits (90d) y: 43 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 3 commits (90d) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 6 commits (90d) y: 370 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTypeUtils.java x: 4 commits (90d) y: 232 lines of code paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java x: 4 commits (90d) y: 174 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java x: 1 commits (90d) y: 149 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java x: 3 commits (90d) y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 commits (90d) y: 104 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/LocationKeyExtractor.java x: 6 commits (90d) y: 93 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 2 commits (90d) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 2 commits (90d) y: 97 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 4 commits (90d) y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 5 commits (90d) y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 3 commits (90d) y: 251 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/LogicalTypeConversion.java x: 3 commits (90d) y: 24 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTableSchemaBuilder.java x: 4 commits (90d) y: 68 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 1 commits (90d) y: 224 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 1 commits (90d) y: 195 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 3 commits (90d) y: 414 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetDataColumnReaderFactory.java x: 3 commits (90d) y: 174 lines of code paimon-core/src/main/java/org/apache/paimon/Snapshot.java x: 7 commits (90d) y: 308 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 2 commits (90d) y: 255 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 5 commits (90d) y: 60 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala x: 2 commits (90d) y: 19 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 3 commits (90d) y: 312 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 8 commits (90d) y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 5 commits (90d) y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java x: 2 commits (90d) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 2 commits (90d) y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/operation/DefaultValueAssigner.java x: 1 commits (90d) y: 114 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java x: 3 commits (90d) y: 133 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java x: 2 commits (90d) y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java x: 2 commits (90d) y: 162 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 4 commits (90d) y: 288 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IOUtils.java x: 1 commits (90d) y: 90 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/SearchArgumentToPredicateConverter.java x: 3 commits (90d) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreRead.java x: 2 commits (90d) y: 119 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 7 commits (90d) y: 4 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreWrite.java x: 8 commits (90d) y: 150 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IntHashSet.java x: 3 commits (90d) y: 35 lines of code paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java x: 7 commits (90d) y: 248 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 6 commits (90d) y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 1 commits (90d) y: 267 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 1 commits (90d) y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java x: 4 commits (90d) y: 87 lines of code paimon-core/src/main/java/org/apache/paimon/table/Table.java x: 4 commits (90d) y: 32 lines of code paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java x: 7 commits (90d) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java x: 5 commits (90d) y: 119 lines of code paimon-common/src/main/java/org/apache/paimon/format/TableStatsCollector.java x: 6 commits (90d) y: 54 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 7 commits (90d) y: 51 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 1 commits (90d) y: 385 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 7 commits (90d) y: 143 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java x: 5 commits (90d) y: 161 lines of code paimon-format/src/main/java/org/apache/paimon/format/orc/filter/OrcTableStatsExtractor.java x: 4 commits (90d) y: 204 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/OnlyPartitionKeyEqualVisitor.java x: 1 commits (90d) y: 72 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkTableSink.java x: 3 commits (90d) y: 191 lines of code paimon-common/src/main/java/org/apache/paimon/reader/RecordReader.java x: 1 commits (90d) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java x: 3 commits (90d) y: 5 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FileStoreSink.java x: 5 commits (90d) y: 22 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/Committer.java x: 4 commits (90d) y: 12 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactManager.java x: 1 commits (90d) y: 232 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 3 commits (90d) y: 526 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 1 commits (90d) y: 311 lines of code paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java x: 2 commits (90d) y: 105 lines of code paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java x: 4 commits (90d) y: 112 lines of code paimon-core/src/main/java/org/apache/paimon/io/RollingFileWriter.java x: 4 commits (90d) y: 105 lines of code paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 5 commits (90d) y: 255 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 2 commits (90d) y: 305 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 2 commits (90d) y: 436 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java x: 4 commits (90d) y: 122 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 1 commits (90d) y: 686 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/BlockStatementGrouper.java x: 2 commits (90d) y: 230 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/DeclarationRewriter.java x: 2 commits (90d) y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 2 commits (90d) y: 325 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataOutputSerializer.java x: 2 commits (90d) y: 273 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 2 commits (90d) y: 264 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2 commits (90d) y: 2506 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/BaseVectorizedColumnReader.java x: 2 commits (90d) y: 218 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LoserTree.java x: 1 commits (90d) y: 244 lines of code
2506.0
lines of code
  min: 4.0
  average: 94.21
  25th percentile: 26.0
  median: 56.0
  75th percentile: 120.0
  max: 2506.0
0 22.0
commits (90d)
min: 1.0 | average: 2.49 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 22.0

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

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java x: 7 contributors (90d) y: 389 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java x: 2 contributors (90d) y: 330 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumnUtils.java x: 1 contributors (90d) y: 52 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaActionUtils.java x: 3 contributors (90d) y: 271 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSchema.java x: 4 contributors (90d) y: 115 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java x: 4 contributors (90d) y: 123 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java x: 4 contributors (90d) y: 129 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java x: 5 contributors (90d) y: 302 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java x: 7 contributors (90d) y: 192 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/PredicateConverter.java x: 1 contributors (90d) y: 257 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogDeserializationSchema.java x: 1 contributors (90d) y: 127 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java x: 8 contributors (90d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/RowDataStoreWriteOperator.java x: 4 contributors (90d) y: 170 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCommitter.java x: 3 contributors (90d) y: 57 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java x: 5 contributors (90d) y: 178 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java x: 4 contributors (90d) y: 190 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FileStoreSourceSplitReader.java x: 3 contributors (90d) y: 229 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java x: 3 contributors (90d) y: 183 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java x: 2 contributors (90d) y: 32 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIO.java x: 2 contributors (90d) y: 212 lines of code paimon-common/src/main/java/org/apache/paimon/fs/FileIOLoader.java x: 1 contributors (90d) y: 12 lines of code paimon-common/src/main/java/org/apache/paimon/CoreOptions.java x: 5 contributors (90d) y: 1423 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java x: 6 contributors (90d) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/SequenceGenerator.java x: 5 contributors (90d) y: 170 lines of code paimon-common/src/main/java/org/apache/paimon/utils/IDMapping.java x: 1 contributors (90d) y: 29 lines of code paimon-common/src/main/java/org/apache/paimon/utils/PositiveIntInt.java x: 1 contributors (90d) y: 40 lines of code paimon-common/src/main/java/org/apache/paimon/utils/RowDataToObjectArrayConverter.java x: 2 contributors (90d) y: 48 lines of code paimon-common/src/main/java/org/apache/paimon/utils/SerBiFunction.java x: 1 contributors (90d) y: 5 lines of code paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java x: 3 contributors (90d) y: 170 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java x: 4 contributors (90d) y: 298 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java x: 2 contributors (90d) y: 50 lines of code paimon-core/src/main/java/org/apache/paimon/schema/Schema.java x: 2 contributors (90d) y: 201 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java x: 6 contributors (90d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java x: 2 contributors (90d) y: 188 lines of code paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java x: 7 contributors (90d) y: 369 lines of code paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java x: 4 contributors (90d) y: 160 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/AbstractInnerTableScan.java x: 5 contributors (90d) y: 136 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java x: 4 contributors (90d) y: 309 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java x: 3 contributors (90d) y: 341 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBSetState.java x: 1 contributors (90d) y: 84 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBStateFactory.java x: 2 contributors (90d) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/RocksDBValueState.java x: 1 contributors (90d) y: 67 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java x: 3 contributors (90d) y: 79 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecord.java x: 3 contributors (90d) y: 46 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcSinkBuilder.java x: 3 contributors (90d) y: 94 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java x: 5 contributors (90d) y: 140 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java x: 1 contributors (90d) y: 206 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssignerOperator.java x: 1 contributors (90d) y: 99 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/IndexBootstrapOperator.java x: 1 contributors (90d) y: 37 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/ContinuousFileSplitEnumerator.java x: 3 contributors (90d) y: 193 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/AlignedSplitAssigner.java x: 2 contributors (90d) y: 116 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/PreAssignSplitAssigner.java x: 2 contributors (90d) y: 64 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/assigners/SplitAssigner.java x: 3 contributors (90d) y: 11 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/PaimonMetaHook.java x: 6 contributors (90d) y: 130 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java x: 5 contributors (90d) y: 354 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java x: 5 contributors (90d) y: 190 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java x: 3 contributors (90d) y: 238 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java x: 3 contributors (90d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java x: 10 contributors (90d) y: 331 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java x: 2 contributors (90d) y: 155 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java x: 2 contributors (90d) y: 70 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java x: 6 contributors (90d) y: 163 lines of code paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java x: 6 contributors (90d) y: 120 lines of code paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java x: 2 contributors (90d) y: 95 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/ComputedColumn.java x: 2 contributors (90d) y: 29 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java x: 1 contributors (90d) y: 278 lines of code paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java x: 6 contributors (90d) y: 183 lines of code paimon-core/src/main/java/org/apache/paimon/FileStore.java x: 3 contributors (90d) y: 39 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java x: 3 contributors (90d) y: 470 lines of code paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java x: 1 contributors (90d) y: 176 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkTable.java x: 5 contributors (90d) y: 100 lines of code paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/WriteIntoPaimonTable.scala x: 3 contributors (90d) y: 218 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreCompactOperator.java x: 4 contributors (90d) y: 98 lines of code paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java x: 2 contributors (90d) y: 181 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java x: 1 contributors (90d) y: 180 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java x: 5 contributors (90d) y: 55 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java x: 7 contributors (90d) y: 707 lines of code paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java x: 7 contributors (90d) y: 617 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java x: 4 contributors (90d) y: 33 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MergeIntoAction.java x: 4 contributors (90d) y: 340 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypeChecks.java x: 1 contributors (90d) y: 163 lines of code paimon-common/src/main/java/org/apache/paimon/types/DataTypes.java x: 1 contributors (90d) y: 146 lines of code paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java x: 5 contributors (90d) y: 263 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java x: 5 contributors (90d) y: 215 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java x: 6 contributors (90d) y: 259 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/objectinspector/PaimonObjectInspectorFactory.java x: 3 contributors (90d) y: 68 lines of code paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java x: 6 contributors (90d) y: 196 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java x: 4 contributors (90d) y: 234 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java x: 3 contributors (90d) y: 26 lines of code paimon-common/src/main/java/org/apache/paimon/utils/TypeUtils.java x: 3 contributors (90d) y: 159 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkArrayData.java x: 3 contributors (90d) y: 122 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java x: 5 contributors (90d) y: 370 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/ContainsLevels.java x: 1 contributors (90d) y: 149 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java x: 3 contributors (90d) y: 104 lines of code paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/LocationKeyExtractor.java x: 5 contributors (90d) y: 93 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/kafka/KafkaLogStoreFactory.java x: 1 contributors (90d) y: 131 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/log/LogStoreTableFactory.java x: 1 contributors (90d) y: 97 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/DataTableSource.java x: 3 contributors (90d) y: 251 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java x: 4 contributors (90d) y: 822 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java x: 1 contributors (90d) y: 251 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcDynamicTableParsingProcessFunction.java x: 3 contributors (90d) y: 73 lines of code paimon-common/src/main/java/org/apache/paimon/data/GenericArray.java x: 1 contributors (90d) y: 224 lines of code paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarArray.java x: 1 contributors (90d) y: 195 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ArrayColumnReader.java x: 3 contributors (90d) y: 414 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java x: 2 contributors (90d) y: 255 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java x: 4 contributors (90d) y: 60 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java x: 1 contributors (90d) y: 109 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTypeUtils.java x: 3 contributors (90d) y: 312 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecord.java x: 1 contributors (90d) y: 72 lines of code paimon-common/src/main/java/org/apache/paimon/format/FileFormat.java x: 5 contributors (90d) y: 75 lines of code paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java x: 4 contributors (90d) y: 19 lines of code paimon-core/src/main/java/org/apache/paimon/casting/DefaultValueRow.java x: 2 contributors (90d) y: 139 lines of code paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java x: 1 contributors (90d) y: 243 lines of code paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java x: 2 contributors (90d) y: 162 lines of code paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkRow.java x: 4 contributors (90d) y: 288 lines of code paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/SearchArgumentToPredicateConverter.java x: 3 contributors (90d) y: 139 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/EqualiserCodeGenerator.scala x: 2 contributors (90d) y: 125 lines of code paimon-flink/paimon-flink-action/src/main/java/org/apache/paimon/flink/action/FlinkActions.java x: 2 contributors (90d) y: 17 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/Action.java x: 4 contributors (90d) y: 4 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java x: 4 contributors (90d) y: 85 lines of code paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreWrite.java x: 4 contributors (90d) y: 150 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileStoreExpireImpl.java x: 3 contributors (90d) y: 151 lines of code paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java x: 1 contributors (90d) y: 267 lines of code paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java x: 1 contributors (90d) y: 215 lines of code paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java x: 4 contributors (90d) y: 51 lines of code paimon-format/src/main/java/org/apache/paimon/format/avro/FieldReaderFactory.java x: 1 contributors (90d) y: 385 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java x: 4 contributors (90d) y: 143 lines of code paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java x: 2 contributors (90d) y: 5 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CompactorSink.java x: 4 contributors (90d) y: 26 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FileStoreSink.java x: 5 contributors (90d) y: 22 lines of code paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcSink.java x: 5 contributors (90d) y: 18 lines of code paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactManager.java x: 1 contributors (90d) y: 232 lines of code paimon-common/src/main/java/org/apache/paimon/utils/DateTimeUtils.java x: 2 contributors (90d) y: 526 lines of code paimon-common/src/main/java/org/apache/paimon/predicate/PredicateBuilder.java x: 1 contributors (90d) y: 311 lines of code paimon-core/src/main/java/org/apache/paimon/io/RollingFileWriter.java x: 4 contributors (90d) y: 105 lines of code paimon-common/src/main/java/org/apache/paimon/utils/InternalRowUtils.java x: 5 contributors (90d) y: 255 lines of code paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java x: 2 contributors (90d) y: 305 lines of code paimon-common/src/main/java/org/apache/paimon/memory/MemorySegment.java x: 2 contributors (90d) y: 436 lines of code paimon-codegen/src/main/scala/org/apache/paimon/codegen/GenerateUtils.scala x: 1 contributors (90d) y: 686 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/BlockStatementGrouper.java x: 2 contributors (90d) y: 230 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/BlockStatementSplitter.java x: 2 contributors (90d) y: 131 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/DeclarationRewriter.java x: 2 contributors (90d) y: 169 lines of code paimon-common/src/main/java/org/apache/paimon/codegen/codesplit/ReturnValueRewriter.java x: 2 contributors (90d) y: 106 lines of code paimon-common/src/main/java/org/apache/paimon/data/BinaryRow.java x: 2 contributors (90d) y: 325 lines of code paimon-common/src/main/java/org/apache/paimon/io/DataOutputSerializer.java x: 2 contributors (90d) y: 273 lines of code paimon-common/src/main/java/org/apache/paimon/utils/ExceptionUtils.java x: 2 contributors (90d) y: 264 lines of code paimon-filesystems/paimon-s3-impl/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2 contributors (90d) y: 2506 lines of code paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/BaseVectorizedColumnReader.java x: 2 contributors (90d) y: 218 lines of code
2506.0
lines of code
  min: 4.0
  average: 94.21
  25th percentile: 26.0
  median: 56.0
  75th percentile: 120.0
  max: 2506.0
0 10.0
contributors (90d)
min: 1.0 | average: 1.96 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 10.0