Path	Lines of Code
paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java	417
paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java	135
paimon-core/src/main/java/org/apache/paimon/Changelog.java	102
paimon-core/src/main/java/org/apache/paimon/FileStore.java	69
paimon-core/src/main/java/org/apache/paimon/KeyValue.java	133
paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java	213
paimon-core/src/main/java/org/apache/paimon/KeyValueSerializer.java	61
paimon-core/src/main/java/org/apache/paimon/KeyValueThinSerializer.java	30
paimon-core/src/main/java/org/apache/paimon/Snapshot.java	370
paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java	360
paimon-core/src/main/java/org/apache/paimon/append/AppendCompactTask.java	111
paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java	430
paimon-core/src/main/java/org/apache/paimon/append/AppendPreCommitCompactCoordinator.java	46
paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java	286
paimon-core/src/main/java/org/apache/paimon/append/MultiTableAppendCompactTask.java	34
paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java	505
paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java	303
paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalogLoader.java	15
paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java	420
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogFactory.java	60
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLoader.java	8
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLock.java	8
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLockContext.java	9
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogLockFactory.java	6
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogSnapshotCommit.java	35
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogUtils.java	235
paimon-core/src/main/java/org/apache/paimon/catalog/Database.java	40
paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java	241
paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java	152
paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalogFactory.java	20
paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalogLoader.java	19
paimon-core/src/main/java/org/apache/paimon/catalog/Identifier.java	175
paimon-core/src/main/java/org/apache/paimon/catalog/PropertyChange.java	54
paimon-core/src/main/java/org/apache/paimon/catalog/RenamingSnapshotCommit.java	76
paimon-core/src/main/java/org/apache/paimon/catalog/SnapshotCommit.java	13
paimon-core/src/main/java/org/apache/paimon/catalog/TableMetadata.java	26
paimon-core/src/main/java/org/apache/paimon/codegen/CodeGenUtils.java	133
paimon-core/src/main/java/org/apache/paimon/compact/CompactDeletionFile.java	85
paimon-core/src/main/java/org/apache/paimon/compact/CompactFutureManager.java	40
paimon-core/src/main/java/org/apache/paimon/compact/CompactManager.java	17
paimon-core/src/main/java/org/apache/paimon/compact/CompactResult.java	52
paimon-core/src/main/java/org/apache/paimon/compact/CompactTask.java	80
paimon-core/src/main/java/org/apache/paimon/compact/CompactUnit.java	28
paimon-core/src/main/java/org/apache/paimon/compact/NoopCompactManager.java	48
paimon-core/src/main/java/org/apache/paimon/consumer/Consumer.java	51
paimon-core/src/main/java/org/apache/paimon/consumer/ConsumerManager.java	128
paimon-core/src/main/java/org/apache/paimon/crosspartition/BucketAssigner.java	45
paimon-core/src/main/java/org/apache/paimon/crosspartition/DeleteExistingProcessor.java	42
paimon-core/src/main/java/org/apache/paimon/crosspartition/ExistingProcessor.java	53
paimon-core/src/main/java/org/apache/paimon/crosspartition/GlobalIndexAssigner.java	357
paimon-core/src/main/java/org/apache/paimon/crosspartition/IndexBootstrap.java	118
paimon-core/src/main/java/org/apache/paimon/crosspartition/KeyPartOrRow.java	26
paimon-core/src/main/java/org/apache/paimon/crosspartition/KeyPartPartitionKeyExtractor.java	33
paimon-core/src/main/java/org/apache/paimon/crosspartition/SkipNewExistingProcessor.java	29
paimon-core/src/main/java/org/apache/paimon/crosspartition/UseOldExistingProcessor.java	48
paimon-core/src/main/java/org/apache/paimon/deletionvectors/ApplyDeletionFileRecordIterator.java	46
paimon-core/src/main/java/org/apache/paimon/deletionvectors/ApplyDeletionVectorReader.java	35
paimon-core/src/main/java/org/apache/paimon/deletionvectors/Bitmap64DeletionVector.java	136
paimon-core/src/main/java/org/apache/paimon/deletionvectors/BitmapDeletionVector.java	100
paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionFileWriter.java	39
paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVector.java	125
paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java	54
paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsIndexFile.java	122
paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorsMaintainer.java	116
paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/AppendDeleteFileMaintainer.java	144
paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/BaseAppendDeleteFileMaintainer.java	34
paimon-core/src/main/java/org/apache/paimon/deletionvectors/append/BucketedAppendDeleteFileMaintainer.java	37
paimon-core/src/main/java/org/apache/paimon/disk/AbstractFileIOChannel.java	69
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileChannelReader.java	32
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileReader.java	9
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileReaderImpl.java	19
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileWriter.java	9
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileWriterImpl.java	19
paimon-core/src/main/java/org/apache/paimon/disk/ChannelReaderInputView.java	93
paimon-core/src/main/java/org/apache/paimon/disk/ChannelReaderInputViewIterator.java	45
paimon-core/src/main/java/org/apache/paimon/disk/ChannelWithMeta.java	20
paimon-core/src/main/java/org/apache/paimon/disk/ChannelWriterOutputView.java	74
paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java	249
paimon-core/src/main/java/org/apache/paimon/disk/FileChannelManager.java	8
paimon-core/src/main/java/org/apache/paimon/disk/FileChannelManagerImpl.java	96
paimon-core/src/main/java/org/apache/paimon/disk/FileChannelUtil.java	33
paimon-core/src/main/java/org/apache/paimon/disk/FileIOChannel.java	79
paimon-core/src/main/java/org/apache/paimon/disk/IOManager.java	20
paimon-core/src/main/java/org/apache/paimon/disk/IOManagerImpl.java	90
paimon-core/src/main/java/org/apache/paimon/disk/InMemoryBuffer.java	177
paimon-core/src/main/java/org/apache/paimon/disk/RowBuffer.java	36
paimon-core/src/main/java/org/apache/paimon/format/FileFormatDiscover.java	21
paimon-core/src/main/java/org/apache/paimon/format/FormatKey.java	25
paimon-core/src/main/java/org/apache/paimon/hash/BytesHashMap.java	222
paimon-core/src/main/java/org/apache/paimon/hash/BytesMap.java	265
paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java	671
paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergMetadataCommitter.java	6
paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergMetadataCommitterFactory.java	6
paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergOptions.java	148
paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergPathFactory.java	80
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergConversions.java	123
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergDataFileMeta.java	218
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergDataFileMetaSerializer.java	50
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestEntry.java	92
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestEntrySerializer.java	56
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestFile.java	220
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestFileMeta.java	203
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestFileMetaSerializer.java	67
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergManifestList.java	50
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergPartitionSummary.java	62
paimon-core/src/main/java/org/apache/paimon/iceberg/manifest/IcebergPartitionSummarySerializer.java	22
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataField.java	268
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergDataTypeDeserializer.java	38
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergListType.java	71
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMapType.java	92
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergMetadata.java	263
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergPartitionField.java	74
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergPartitionSpec.java	50
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergSchema.java	74
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergSnapshot.java	87
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergSnapshotSummary.java	37
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergSortOrder.java	51
paimon-core/src/main/java/org/apache/paimon/iceberg/metadata/IcebergStructType.java	49
paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrateHadoopMetadata.java	82
paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrateHadoopMetadataFactory.java	15
paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrateMetadata.java	7
paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrateMetadataFactory.java	7
paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java	366
paimon-core/src/main/java/org/apache/paimon/index/BucketAssigner.java	17
paimon-core/src/main/java/org/apache/paimon/index/DeletionVectorMeta.java	69
paimon-core/src/main/java/org/apache/paimon/index/HashBucketAssigner.java	129
paimon-core/src/main/java/org/apache/paimon/index/HashIndexFile.java	25
paimon-core/src/main/java/org/apache/paimon/index/HashIndexMaintainer.java	88
paimon-core/src/main/java/org/apache/paimon/index/IndexFile.java	30
paimon-core/src/main/java/org/apache/paimon/index/IndexFileHandler.java	234
paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta.java	97
paimon-core/src/main/java/org/apache/paimon/index/IndexFileMeta09Serializer.java	73
paimon-core/src/main/java/org/apache/paimon/index/IndexFileMetaSerializer.java	62
paimon-core/src/main/java/org/apache/paimon/index/IndexMaintainer.java	13
paimon-core/src/main/java/org/apache/paimon/index/PartitionIndex.java	115
paimon-core/src/main/java/org/apache/paimon/index/SimpleHashBucketAssigner.java	99
paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java	59
paimon-core/src/main/java/org/apache/paimon/io/DataFileIndexWriter.java	289
paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta.java	518
paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta08Serializer.java	108
paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta09Serializer.java	114
paimon-core/src/main/java/org/apache/paimon/io/DataFileMeta10LegacySerializer.java	119
paimon-core/src/main/java/org/apache/paimon/io/DataFileMetaSerializer.java	61
paimon-core/src/main/java/org/apache/paimon/io/DataFilePathFactory.java	128
paimon-core/src/main/java/org/apache/paimon/io/DataFileRecordReader.java	67
paimon-core/src/main/java/org/apache/paimon/io/DataIncrement.java	58
paimon-core/src/main/java/org/apache/paimon/io/FileIndexEvaluator.java	50
paimon-core/src/main/java/org/apache/paimon/io/FileReaderFactory.java	6
paimon-core/src/main/java/org/apache/paimon/io/FileWriter.java	30
paimon-core/src/main/java/org/apache/paimon/io/FileWriterContext.java	22
paimon-core/src/main/java/org/apache/paimon/io/IdentifierSerializer.java	23
paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java	56
paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileRecordReader.java	38
paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java	147
paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriterImpl.java	50
paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java	231
paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java	364
paimon-core/src/main/java/org/apache/paimon/io/KeyValueThinDataFileWriterImpl.java	67
paimon-core/src/main/java/org/apache/paimon/io/RecordLevelExpire.java	160
paimon-core/src/main/java/org/apache/paimon/io/RollingFileWriter.java	124
paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java	88
paimon-core/src/main/java/org/apache/paimon/io/RowDataRollingFileWriter.java	75
paimon-core/src/main/java/org/apache/paimon/io/SimpleStatsProducer.java	82
paimon-core/src/main/java/org/apache/paimon/io/SingleFileWriter.java	158
paimon-core/src/main/java/org/apache/paimon/io/SplitsParallelReadUtil.java	97
paimon-core/src/main/java/org/apache/paimon/io/StatsCollectingSingleFileWriter.java	55
paimon-core/src/main/java/org/apache/paimon/jdbc/AbstractDistributedLockDialect.java	69
paimon-core/src/main/java/org/apache/paimon/jdbc/DistributedLockDialectFactory.java	23
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java	394
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogFactory.java	20
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLoader.java	22
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLock.java	74
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLockContext.java	30
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogLockFactory.java	25
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalogOptions.java	21
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcClientPool.java	45
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcDistributedLockDialect.java	13
paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcUtils.java	457
paimon-core/src/main/java/org/apache/paimon/jdbc/MysqlDistributedLockDialect.java	49
paimon-core/src/main/java/org/apache/paimon/jdbc/PostgresqlDistributedLockDialect.java	49
paimon-core/src/main/java/org/apache/paimon/jdbc/SqlLiteDistributedLockDialect.java	49
paimon-core/src/main/java/org/apache/paimon/lookup/BulkLoader.java	90
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBListState.java	55
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBOptions.java	260
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBSetState.java	83
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBState.java	108
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBStateFactory.java	98
paimon-core/src/main/java/org/apache/paimon/lookup/RocksDBValueState.java	65
paimon-core/src/main/java/org/apache/paimon/manifest/BucketEntry.java	107
paimon-core/src/main/java/org/apache/paimon/manifest/ExpireFileEntry.java	69
paimon-core/src/main/java/org/apache/paimon/manifest/FileEntry.java	215
paimon-core/src/main/java/org/apache/paimon/manifest/FileKind.java	25
paimon-core/src/main/java/org/apache/paimon/manifest/FileSource.java	23
paimon-core/src/main/java/org/apache/paimon/manifest/FilteredManifestEntry.java	11
paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntry.java	92
paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestEntrySerializer.java	52
paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFile.java	76
paimon-core/src/main/java/org/apache/paimon/manifest/IndexManifestFileHandler.java	162
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCacheFilter.java	9
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittable.java	86
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestCommittableSerializer.java	94
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntry.java	139
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestEntrySerializer.java	68
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFile.java	188
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMeta.java	146
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestFileMetaSerializer.java	53
paimon-core/src/main/java/org/apache/paimon/manifest/ManifestList.java	96
paimon-core/src/main/java/org/apache/paimon/manifest/PartitionEntry.java	138
paimon-core/src/main/java/org/apache/paimon/manifest/SimpleFileEntry.java	145
paimon-core/src/main/java/org/apache/paimon/manifest/WrappedManifestCommittable.java	65
paimon-core/src/main/java/org/apache/paimon/memory/Buffer.java	33
paimon-core/src/main/java/org/apache/paimon/memory/MemoryOwner.java	6
paimon-core/src/main/java/org/apache/paimon/memory/MemoryPoolFactory.java	102
paimon-core/src/main/java/org/apache/paimon/mergetree/DataFileReader.java	39
paimon-core/src/main/java/org/apache/paimon/mergetree/DropDeleteReader.java	42
paimon-core/src/main/java/org/apache/paimon/mergetree/LevelSortedRun.java	35
paimon-core/src/main/java/org/apache/paimon/mergetree/Levels.java	151
paimon-core/src/main/java/org/apache/paimon/mergetree/LookupFile.java	97
paimon-core/src/main/java/org/apache/paimon/mergetree/LookupLevels.java	287
paimon-core/src/main/java/org/apache/paimon/mergetree/LookupUtils.java	86
paimon-core/src/main/java/org/apache/paimon/mergetree/MergeSorter.java	209
paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeReaders.java	74
paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java	326
paimon-core/src/main/java/org/apache/paimon/mergetree/SortBufferWriteBuffer.java	223
paimon-core/src/main/java/org/apache/paimon/mergetree/SortedRun.java	76
paimon-core/src/main/java/org/apache/paimon/mergetree/WriteBuffer.java	26
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/AbstractCompactRewriter.java	23
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogMergeTreeRewriter.java	173
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ChangelogResult.java	37
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/CompactRewriter.java	11
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/CompactStrategy.java	34
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ConcatRecordReader.java	52
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/DeduplicateMergeFunction.java	48
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeFunction.java	58
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FirstRowMergeFunctionWrapper.java	41
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ForceUpLevel0Compaction.java	19
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeFunctionWrapper.java	82
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FullChangelogMergeTreeCompactRewriter.java	65
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/IntervalPartition.java	69
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupChangelogMergeFunctionWrapper.java	153
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeFunction.java	63
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LookupMergeTreeCompactRewriter.java	155
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/LoserTree.java	244
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunction.java	8
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunctionFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeFunctionWrapper.java	9
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java	224
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactRewriter.java	92
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactTask.java	130
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java	582
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/ReducerMergeFunctionWrapper.java	35
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReader.java	28
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReaderWithLoserTree.java	81
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/SortMergeReaderWithMinHeap.java	156
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/UniversalCompaction.java	192
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java	163
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java	25
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolAndAgg.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldBoolOrAgg.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java	158
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldFirstNonNullValueAgg.java	22
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldFirstValueAgg.java	22
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldHllSketchAgg.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldIgnoreRetractAgg.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastNonNullValueAgg.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldLastValueAgg.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldListaggAgg.java	22
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMaxAgg.java	20
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMergeMapAgg.java	68
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldMinAgg.java	20
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldNestedUpdateAgg.java	100
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldPrimaryKeyAgg.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldProductAgg.java	104
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldRoaringBitmap32Agg.java	32
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldRoaringBitmap64Agg.java	31
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldSumAgg.java	135
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldThetaSketchAgg.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldAggregatorFactory.java	39
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldBoolAndAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldBoolOrAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldCollectAggFactory.java	22
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldFirstNonNullValueAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldFirstNonNullValueAggLegacyFactory.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldFirstValueAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldHllSketchAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldLastNonNullValueAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldLastValueAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldListaggAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldMaxAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldMergeMapAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldMinAggFactory.java	15
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldNestedUpdateAggFactory.java	32
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldPrimaryKeyAggFactory.java	16
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldProductAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldRoaringBitmap32AggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldRoaringBitmap64AggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldSumAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/factory/FieldThetaSketchAggFactory.java	21
paimon-core/src/main/java/org/apache/paimon/mergetree/localmerge/HashMapLocalMerger.java	98
paimon-core/src/main/java/org/apache/paimon/mergetree/localmerge/LocalMerger.java	12
paimon-core/src/main/java/org/apache/paimon/mergetree/localmerge/SortBufferLocalMerger.java	49
paimon-core/src/main/java/org/apache/paimon/metastore/AddPartitionCommitCallback.java	72
paimon-core/src/main/java/org/apache/paimon/metastore/AddPartitionTagCallback.java	37
paimon-core/src/main/java/org/apache/paimon/metastore/TagPreviewCommitCallback.java	33
paimon-core/src/main/java/org/apache/paimon/metrics/Counter.java	14
paimon-core/src/main/java/org/apache/paimon/metrics/DescriptiveStatisticsHistogram.java	53
paimon-core/src/main/java/org/apache/paimon/metrics/DescriptiveStatisticsHistogramStatistics.java	150
paimon-core/src/main/java/org/apache/paimon/metrics/Gauge.java	10
paimon-core/src/main/java/org/apache/paimon/metrics/Histogram.java	12
paimon-core/src/main/java/org/apache/paimon/metrics/HistogramStatistics.java	12
paimon-core/src/main/java/org/apache/paimon/metrics/Metric.java	8
paimon-core/src/main/java/org/apache/paimon/metrics/MetricGroup.java	13
paimon-core/src/main/java/org/apache/paimon/metrics/MetricGroupImpl.java	74
paimon-core/src/main/java/org/apache/paimon/metrics/MetricRegistry.java	13
paimon-core/src/main/java/org/apache/paimon/metrics/MetricType.java	8
paimon-core/src/main/java/org/apache/paimon/metrics/SimpleCounter.java	24
paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java	217
paimon-core/src/main/java/org/apache/paimon/migrate/Migrator.java	6
paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreScan.java	436
paimon-core/src/main/java/org/apache/paimon/operation/AbstractFileStoreWrite.java	479
paimon-core/src/main/java/org/apache/paimon/operation/AppendFileStoreWrite.java	61
paimon-core/src/main/java/org/apache/paimon/operation/AppendOnlyFileStoreScan.java	85
paimon-core/src/main/java/org/apache/paimon/operation/BaseAppendFileStoreWrite.java	198
paimon-core/src/main/java/org/apache/paimon/operation/BucketSelectConverter.java	125
paimon-core/src/main/java/org/apache/paimon/operation/BucketedAppendFileStoreWrite.java	78
paimon-core/src/main/java/org/apache/paimon/operation/BundleFileStoreWriter.java	7
paimon-core/src/main/java/org/apache/paimon/operation/ChangelogDeletion.java	88
paimon-core/src/main/java/org/apache/paimon/operation/CleanOrphanFilesResult.java	30
paimon-core/src/main/java/org/apache/paimon/operation/DefaultValueAssigner.java	112
paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java	344
paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommit.java	34
paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java	1384
paimon-core/src/main/java/org/apache/paimon/operation/FileStoreScan.java	85
paimon-core/src/main/java/org/apache/paimon/operation/FileStoreWrite.java	88
paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java	213
paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreWrite.java	392
paimon-core/src/main/java/org/apache/paimon/operation/ListUnexistingFiles.java	74
paimon-core/src/main/java/org/apache/paimon/operation/LocalOrphanFilesClean.java	240
paimon-core/src/main/java/org/apache/paimon/operation/Lock.java	43
paimon-core/src/main/java/org/apache/paimon/operation/ManifestFileMerger.java	215
paimon-core/src/main/java/org/apache/paimon/operation/ManifestsReader.java	150
paimon-core/src/main/java/org/apache/paimon/operation/MemoryFileStoreWrite.java	122
paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java	273
paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java	382
paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java	136
paimon-core/src/main/java/org/apache/paimon/operation/RawFileSplitRead.java	206
paimon-core/src/main/java/org/apache/paimon/operation/ReverseReader.java	42
paimon-core/src/main/java/org/apache/paimon/operation/SnapshotDeletion.java	69
paimon-core/src/main/java/org/apache/paimon/operation/SplitRead.java	45
paimon-core/src/main/java/org/apache/paimon/operation/TagDeletion.java	89
paimon-core/src/main/java/org/apache/paimon/operation/metrics/CacheMetrics.java	22
paimon-core/src/main/java/org/apache/paimon/operation/metrics/CommitMetrics.java	101
paimon-core/src/main/java/org/apache/paimon/operation/metrics/CommitStats.java	183
paimon-core/src/main/java/org/apache/paimon/operation/metrics/CompactTimer.java	108
paimon-core/src/main/java/org/apache/paimon/operation/metrics/CompactionMetrics.java	192
paimon-core/src/main/java/org/apache/paimon/operation/metrics/MetricUtils.java	11
paimon-core/src/main/java/org/apache/paimon/operation/metrics/ScanMetrics.java	49
paimon-core/src/main/java/org/apache/paimon/operation/metrics/ScanStats.java	31
paimon-core/src/main/java/org/apache/paimon/operation/metrics/WriterBufferMetric.java	52
paimon-core/src/main/java/org/apache/paimon/partition/Partition.java	63
paimon-core/src/main/java/org/apache/paimon/partition/PartitionExpireStrategy.java	49
paimon-core/src/main/java/org/apache/paimon/partition/PartitionPredicate.java	190
paimon-core/src/main/java/org/apache/paimon/partition/PartitionStatistics.java	96
paimon-core/src/main/java/org/apache/paimon/partition/PartitionTimeExtractor.java	99
paimon-core/src/main/java/org/apache/paimon/partition/PartitionUpdateTimeExpireStrategy.java	22
paimon-core/src/main/java/org/apache/paimon/partition/PartitionUtils.java	42
paimon-core/src/main/java/org/apache/paimon/partition/PartitionValuesTimeExpireStrategy.java	82
paimon-core/src/main/java/org/apache/paimon/partition/actions/AddDonePartitionAction.java	33
paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneAction.java	174
paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneException.java	10
paimon-core/src/main/java/org/apache/paimon/partition/actions/MarkPartitionDoneEventAction.java	27
paimon-core/src/main/java/org/apache/paimon/partition/actions/PartitionMarkDoneAction.java	87
paimon-core/src/main/java/org/apache/paimon/partition/actions/SuccessFileMarkDoneAction.java	39
paimon-core/src/main/java/org/apache/paimon/partition/file/SuccessFile.java	73
paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketFileStoreWrite.java	83
paimon-core/src/main/java/org/apache/paimon/postpone/PostponeBucketWriter.java	68
paimon-core/src/main/java/org/apache/paimon/privilege/AllGrantedPrivilegeChecker.java	35
paimon-core/src/main/java/org/apache/paimon/privilege/EntityType.java	7
paimon-core/src/main/java/org/apache/paimon/privilege/FileBasedPrivilegeManager.java	376
paimon-core/src/main/java/org/apache/paimon/privilege/FileBasedPrivilegeManagerLoader.java	20
paimon-core/src/main/java/org/apache/paimon/privilege/NoPrivilegeException.java	32
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegeChecker.java	33
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegeCheckerImpl.java	122
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegeManager.java	16
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegeManagerLoader.java	6
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegeType.java	32
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java	172
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalogLoader.java	18
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStore.java	182
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java	238
paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedObjectTable.java	57
paimon-core/src/main/java/org/apache/paimon/query/QueryLocation.java	6
paimon-core/src/main/java/org/apache/paimon/query/QueryLocationImpl.java	26
paimon-core/src/main/java/org/apache/paimon/query/QueryServer.java	7
paimon-core/src/main/java/org/apache/paimon/rest/DefaultErrorHandler.java	54
paimon-core/src/main/java/org/apache/paimon/rest/ErrorHandler.java	4
paimon-core/src/main/java/org/apache/paimon/rest/ExponentialHttpRetryInterceptor.java	106
paimon-core/src/main/java/org/apache/paimon/rest/HttpClient.java	201
paimon-core/src/main/java/org/apache/paimon/rest/LoggingInterceptor.java	27
paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java	966
paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogFactory.java	15
paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogInternalOptions.java	10
paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogLoader.java	17
paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalogOptions.java	61
paimon-core/src/main/java/org/apache/paimon/rest/RESTClient.java	22
paimon-core/src/main/java/org/apache/paimon/rest/RESTMessage.java	4
paimon-core/src/main/java/org/apache/paimon/rest/RESTObjectMapper.java	6
paimon-core/src/main/java/org/apache/paimon/rest/RESTRequest.java	2
paimon-core/src/main/java/org/apache/paimon/rest/RESTResponse.java	2
paimon-core/src/main/java/org/apache/paimon/rest/RESTToken.java	36
paimon-core/src/main/java/org/apache/paimon/rest/RESTTokenFileIO.java	171
paimon-core/src/main/java/org/apache/paimon/rest/RESTUtil.java	97
paimon-core/src/main/java/org/apache/paimon/rest/ResourcePaths.java	157
paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProvider.java	6
paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderEnum.java	20
paimon-core/src/main/java/org/apache/paimon/rest/auth/AuthProviderFactory.java	21
paimon-core/src/main/java/org/apache/paimon/rest/auth/BearTokenAuthProvider.java	18
paimon-core/src/main/java/org/apache/paimon/rest/auth/BearTokenAuthProviderFactory.java	13
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProvider.java	115
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthProviderFactory.java	49
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFAuthSignature.java	150
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFECSTokenLoader.java	90
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFECSTokenLoaderFactory.java	16
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoader.java	38
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFLocalFileTokenLoaderFactory.java	14
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFToken.java	76
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFTokenLoader.java	5
paimon-core/src/main/java/org/apache/paimon/rest/auth/DLFTokenLoaderFactory.java	15
paimon-core/src/main/java/org/apache/paimon/rest/auth/RESTAuthFunction.java	15
paimon-core/src/main/java/org/apache/paimon/rest/auth/RESTAuthParameter.java	32
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/AlreadyExistsException.java	17
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/BadRequestException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/ForbiddenException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/NoSuchResourceException.java	17
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/NotAuthorizedException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/NotImplementedException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/RESTException.java	9
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/ServiceFailureException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/exceptions/ServiceUnavailableException.java	6
paimon-core/src/main/java/org/apache/paimon/rest/requests/AlterDatabaseRequest.java	32
paimon-core/src/main/java/org/apache/paimon/rest/requests/AlterTableRequest.java	22
paimon-core/src/main/java/org/apache/paimon/rest/requests/AlterViewRequest.java	22
paimon-core/src/main/java/org/apache/paimon/rest/requests/BasePartitionsRequest.java	23
paimon-core/src/main/java/org/apache/paimon/rest/requests/CommitTableRequest.java	33
paimon-core/src/main/java/org/apache/paimon/rest/requests/CreateBranchRequest.java	33
paimon-core/src/main/java/org/apache/paimon/rest/requests/CreateDatabaseRequest.java	31
paimon-core/src/main/java/org/apache/paimon/rest/requests/CreateTableRequest.java	32
paimon-core/src/main/java/org/apache/paimon/rest/requests/CreateViewRequest.java	32
paimon-core/src/main/java/org/apache/paimon/rest/requests/ForwardBranchRequest.java	5
paimon-core/src/main/java/org/apache/paimon/rest/requests/MarkDonePartitionsRequest.java	14
paimon-core/src/main/java/org/apache/paimon/rest/requests/RenameTableRequest.java	31
paimon-core/src/main/java/org/apache/paimon/rest/requests/RollbackTableRequest.java	21
paimon-core/src/main/java/org/apache/paimon/rest/responses/AlterDatabaseResponse.java	40
paimon-core/src/main/java/org/apache/paimon/rest/responses/AuditRESTResponse.java	63
paimon-core/src/main/java/org/apache/paimon/rest/responses/CommitTableResponse.java	20
paimon-core/src/main/java/org/apache/paimon/rest/responses/ConfigResponse.java	47
paimon-core/src/main/java/org/apache/paimon/rest/responses/ErrorResponse.java	59
paimon-core/src/main/java/org/apache/paimon/rest/responses/GetDatabaseResponse.java	55
paimon-core/src/main/java/org/apache/paimon/rest/responses/GetTableResponse.java	73
paimon-core/src/main/java/org/apache/paimon/rest/responses/GetTableSnapshotResponse.java	21
paimon-core/src/main/java/org/apache/paimon/rest/responses/GetTableTokenResponse.java	31
paimon-core/src/main/java/org/apache/paimon/rest/responses/GetViewResponse.java	46
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListBranchesResponse.java	21
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListDatabasesResponse.java	37
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListPartitionsResponse.java	38
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListTableDetailsResponse.java	38
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListTablesResponse.java	37
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListViewDetailsResponse.java	38
paimon-core/src/main/java/org/apache/paimon/rest/responses/ListViewsResponse.java	37
paimon-core/src/main/java/org/apache/paimon/rest/responses/PagedResponse.java	7
paimon-core/src/main/java/org/apache/paimon/schema/IndexCastMapping.java	9
paimon-core/src/main/java/org/apache/paimon/schema/KeyValueFieldsExtractor.java	10
paimon-core/src/main/java/org/apache/paimon/schema/Schema.java	261
paimon-core/src/main/java/org/apache/paimon/schema/SchemaChange.java	595
paimon-core/src/main/java/org/apache/paimon/schema/SchemaEvolutionUtil.java	206
paimon-core/src/main/java/org/apache/paimon/schema/SchemaManager.java	773
paimon-core/src/main/java/org/apache/paimon/schema/SchemaMergingUtils.java	183
paimon-core/src/main/java/org/apache/paimon/schema/SchemaSerializer.java	104
paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java	566
paimon-core/src/main/java/org/apache/paimon/schema/TableSchema.java	286
paimon-core/src/main/java/org/apache/paimon/service/ServiceManager.java	44
paimon-core/src/main/java/org/apache/paimon/sort/AbstractBinaryExternalMerger.java	131
paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalMerger.java	63
paimon-core/src/main/java/org/apache/paimon/sort/BinaryExternalSortBuffer.java	225
paimon-core/src/main/java/org/apache/paimon/sort/BinaryInMemorySortBuffer.java	162
paimon-core/src/main/java/org/apache/paimon/sort/BinaryIndexedSortable.java	171
paimon-core/src/main/java/org/apache/paimon/sort/BinaryMergeIterator.java	61
paimon-core/src/main/java/org/apache/paimon/sort/HeapSort.java	37
paimon-core/src/main/java/org/apache/paimon/sort/IndexedSortable.java	10
paimon-core/src/main/java/org/apache/paimon/sort/IndexedSorter.java	5
paimon-core/src/main/java/org/apache/paimon/sort/PartialOrderPriorityQueue.java	107
paimon-core/src/main/java/org/apache/paimon/sort/QuickSort.java	240
paimon-core/src/main/java/org/apache/paimon/sort/SortBuffer.java	13
paimon-core/src/main/java/org/apache/paimon/sort/SpillChannelManager.java	48
paimon-core/src/main/java/org/apache/paimon/stats/ColStats.java	161
paimon-core/src/main/java/org/apache/paimon/stats/SimpleStats.java	72
paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsConverter.java	74
paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolution.java	233
paimon-core/src/main/java/org/apache/paimon/stats/SimpleStatsEvolutions.java	65
paimon-core/src/main/java/org/apache/paimon/stats/Statistics.java	150
paimon-core/src/main/java/org/apache/paimon/stats/StatsFile.java	36
paimon-core/src/main/java/org/apache/paimon/stats/StatsFileHandler.java	45
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java	599
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java	118
paimon-core/src/main/java/org/apache/paimon/table/BucketSpec.java	32
paimon-core/src/main/java/org/apache/paimon/table/CatalogEnvironment.java	88
paimon-core/src/main/java/org/apache/paimon/table/DataTable.java	25
paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java	253
paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java	191
paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshots.java	6
paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java	222
paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java	340
paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java	99
paimon-core/src/main/java/org/apache/paimon/table/FileStoreTableFactory.java	97
paimon-core/src/main/java/org/apache/paimon/table/FormatTable.java	273
paimon-core/src/main/java/org/apache/paimon/table/FormatTableOptions.java	11
paimon-core/src/main/java/org/apache/paimon/table/InnerTable.java	34
paimon-core/src/main/java/org/apache/paimon/table/Instant.java	59
paimon-core/src/main/java/org/apache/paimon/table/KnownSplitsTable.java	58
paimon-core/src/main/java/org/apache/paimon/table/PartitionHandler.java	43
paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyFileStoreTable.java	151
paimon-core/src/main/java/org/apache/paimon/table/PrimaryKeyTableUtils.java	63
paimon-core/src/main/java/org/apache/paimon/table/ReadonlyTable.java	215
paimon-core/src/main/java/org/apache/paimon/table/RollbackHelper.java	160
paimon-core/src/main/java/org/apache/paimon/table/Table.java	97
paimon-core/src/main/java/org/apache/paimon/table/TableSnapshot.java	97
paimon-core/src/main/java/org/apache/paimon/table/object/ObjectRefresh.java	64
paimon-core/src/main/java/org/apache/paimon/table/object/ObjectTable.java	152
paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java	189
paimon-core/src/main/java/org/apache/paimon/table/query/TableQuery.java	13
paimon-core/src/main/java/org/apache/paimon/table/sink/AppendCompactTaskSerializer.java	74
paimon-core/src/main/java/org/apache/paimon/table/sink/AppendTableRowKeyExtractor.java	19
paimon-core/src/main/java/org/apache/paimon/table/sink/BatchTableCommit.java	14
paimon-core/src/main/java/org/apache/paimon/table/sink/BatchTableWrite.java	7
paimon-core/src/main/java/org/apache/paimon/table/sink/BatchWriteBuilder.java	19
paimon-core/src/main/java/org/apache/paimon/table/sink/BatchWriteBuilderImpl.java	47
paimon-core/src/main/java/org/apache/paimon/table/sink/CallbackUtils.java	46
paimon-core/src/main/java/org/apache/paimon/table/sink/ChannelComputer.java	28
paimon-core/src/main/java/org/apache/paimon/table/sink/CommitCallback.java	9
paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessage.java	12
paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageImpl.java	131
paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageLegacyV2Serializer.java	151
paimon-core/src/main/java/org/apache/paimon/table/sink/CommitMessageSerializer.java	136
paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRowKeyExtractor.java	21
paimon-core/src/main/java/org/apache/paimon/table/sink/FixedBucketRowKeyExtractor.java	47
paimon-core/src/main/java/org/apache/paimon/table/sink/FixedBucketWriteSelector.java	20
paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableCommit.java	9
paimon-core/src/main/java/org/apache/paimon/table/sink/InnerTableWrite.java	5
paimon-core/src/main/java/org/apache/paimon/table/sink/KeyAndBucketExtractor.java	21
paimon-core/src/main/java/org/apache/paimon/table/sink/MultiTableCompactionTaskSerializer.java	83
paimon-core/src/main/java/org/apache/paimon/table/sink/PartitionKeyExtractor.java	6
paimon-core/src/main/java/org/apache/paimon/table/sink/PostponeBucketRowKeyExtractor.java	12
paimon-core/src/main/java/org/apache/paimon/table/sink/RowKeyExtractor.java	48
paimon-core/src/main/java/org/apache/paimon/table/sink/RowKindGenerator.java	41
paimon-core/src/main/java/org/apache/paimon/table/sink/RowPartitionKeyExtractor.java	26
paimon-core/src/main/java/org/apache/paimon/table/sink/SinkRecord.java	31
paimon-core/src/main/java/org/apache/paimon/table/sink/StreamTableCommit.java	9
paimon-core/src/main/java/org/apache/paimon/table/sink/StreamTableWrite.java	8
paimon-core/src/main/java/org/apache/paimon/table/sink/StreamWriteBuilder.java	12
paimon-core/src/main/java/org/apache/paimon/table/sink/StreamWriteBuilderImpl.java	44
paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommit.java	8
paimon-core/src/main/java/org/apache/paimon/table/sink/TableCommitImpl.java	299
paimon-core/src/main/java/org/apache/paimon/table/sink/TableWrite.java	22
paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java	218
paimon-core/src/main/java/org/apache/paimon/table/sink/TagCallback.java	5
paimon-core/src/main/java/org/apache/paimon/table/sink/WriteBuilder.java	16
paimon-core/src/main/java/org/apache/paimon/table/sink/WriteSelector.java	6
paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableRead.java	84
paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataTableScan.java	284
paimon-core/src/main/java/org/apache/paimon/table/source/AppendOnlySplitGenerator.java	42
paimon-core/src/main/java/org/apache/paimon/table/source/DataFilePlan.java	20
paimon-core/src/main/java/org/apache/paimon/table/source/DataSplit.java	421
paimon-core/src/main/java/org/apache/paimon/table/source/DataTableBatchScan.java	89
paimon-core/src/main/java/org/apache/paimon/table/source/DataTableScan.java	4
paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java	282
paimon-core/src/main/java/org/apache/paimon/table/source/DeletionFile.java	153
paimon-core/src/main/java/org/apache/paimon/table/source/EndOfScanException.java	9
paimon-core/src/main/java/org/apache/paimon/table/source/IndexFile.java	29
paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableRead.java	31
paimon-core/src/main/java/org/apache/paimon/table/source/InnerTableScan.java	37
paimon-core/src/main/java/org/apache/paimon/table/source/KeyValueTableRead.java	111
paimon-core/src/main/java/org/apache/paimon/table/source/MergeTreeSplitGenerator.java	92
paimon-core/src/main/java/org/apache/paimon/table/source/OutOfRangeException.java	7
paimon-core/src/main/java/org/apache/paimon/table/source/PlanImpl.java	28
paimon-core/src/main/java/org/apache/paimon/table/source/RawFile.java	96
paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilder.java	34
paimon-core/src/main/java/org/apache/paimon/table/source/ReadBuilderImpl.java	161
paimon-core/src/main/java/org/apache/paimon/table/source/ReadOnceTableScan.java	20
paimon-core/src/main/java/org/apache/paimon/table/source/ResetRowKindRecordIterator.java	26
paimon-core/src/main/java/org/apache/paimon/table/source/ScanMode.java	6
paimon-core/src/main/java/org/apache/paimon/table/source/SingletonSplit.java	7
paimon-core/src/main/java/org/apache/paimon/table/source/SnapshotNotExistPlan.java	12
paimon-core/src/main/java/org/apache/paimon/table/source/Split.java	18
paimon-core/src/main/java/org/apache/paimon/table/source/SplitGenerator.java	22
paimon-core/src/main/java/org/apache/paimon/table/source/StreamDataTableScan.java	7
paimon-core/src/main/java/org/apache/paimon/table/source/StreamTableScan.java	15
paimon-core/src/main/java/org/apache/paimon/table/source/TableRead.java	27
paimon-core/src/main/java/org/apache/paimon/table/source/TableScan.java	21
paimon-core/src/main/java/org/apache/paimon/table/source/ValueContentRowDataRecordIterator.java	20
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/AbstractStartingScanner.java	33
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/AllDeltaFollowUpScanner.java	13
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/BoundedChecker.java	14
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ChangelogFollowUpScanner.java	20
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/CompactedStartingScanner.java	39
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousCompactorStartingScanner.java	33
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromSnapshotFullStartingScanner.java	24
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromSnapshotStartingScanner.java	39
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousFromTimestampStartingScanner.java	55
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ContinuousLatestStartingScanner.java	25
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/DeltaFollowUpScanner.java	24
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/EmptyResultStartingScanner.java	11
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FileCreationTimeStartingScanner.java	32
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FollowUpScanner.java	11
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullCompactedStartingScanner.java	50
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullStartingScanner.java	33
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDeltaStartingScanner.java	136
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/IncrementalDiffStartingScanner.java	116
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/ReadPlanStartingScanner.java	29
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReader.java	71
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java	493
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StartingContext.java	16
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StartingScanner.java	44
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromSnapshotStartingScanner.java	40
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTagStartingScanner.java	26
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromTimestampStartingScanner.java	35
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/StaticFromWatermarkStartingScanner.java	43
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/TimeTravelUtil.java	222
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/IncrementalChangelogReadProvider.java	67
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/IncrementalDiffReadProvider.java	37
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/IncrementalDiffSplitRead.java	183
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/MergeFileSplitReadProvider.java	40
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/RawFileSplitReadProvider.java	42
paimon-core/src/main/java/org/apache/paimon/table/source/splitread/SplitReadProvider.java	9
paimon-core/src/main/java/org/apache/paimon/table/system/AggregationFieldsTable.java	189
paimon-core/src/main/java/org/apache/paimon/table/system/AllTableOptionsTable.java	151
paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java	543
paimon-core/src/main/java/org/apache/paimon/table/system/BinlogTable.java	114
paimon-core/src/main/java/org/apache/paimon/table/system/BranchesTable.java	177
paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java	169
paimon-core/src/main/java/org/apache/paimon/table/system/CatalogOptionsTable.java	144
paimon-core/src/main/java/org/apache/paimon/table/system/CompactBucketsTable.java	210
paimon-core/src/main/java/org/apache/paimon/table/system/ConsumersTable.java	157
paimon-core/src/main/java/org/apache/paimon/table/system/FileMonitorTable.java	265
paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java	415
paimon-core/src/main/java/org/apache/paimon/table/system/ManifestsTable.java	189
paimon-core/src/main/java/org/apache/paimon/table/system/OptionsTable.java	158
paimon-core/src/main/java/org/apache/paimon/table/system/PartitionsTable.java	167
paimon-core/src/main/java/org/apache/paimon/table/system/ReadOptimizedTable.java	157
paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java	235
paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java	272
paimon-core/src/main/java/org/apache/paimon/table/system/StatisticTable.java	166
paimon-core/src/main/java/org/apache/paimon/table/system/SystemTableLoader.java	60
paimon-core/src/main/java/org/apache/paimon/table/system/TableIndexesTable.java	189
paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java	234
paimon-core/src/main/java/org/apache/paimon/tag/SnapshotLoaderImpl.java	44
paimon-core/src/main/java/org/apache/paimon/tag/SuccessFileTagCallback.java	49
paimon-core/src/main/java/org/apache/paimon/tag/Tag.java	179
paimon-core/src/main/java/org/apache/paimon/tag/TagAutoCreation.java	190
paimon-core/src/main/java/org/apache/paimon/tag/TagAutoManager.java	43
paimon-core/src/main/java/org/apache/paimon/tag/TagBatchCreation.java	96
paimon-core/src/main/java/org/apache/paimon/tag/TagPeriodHandler.java	213
paimon-core/src/main/java/org/apache/paimon/tag/TagPreview.java	75
paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExpire.java	87
paimon-core/src/main/java/org/apache/paimon/tag/TagTimeExtractor.java	56
paimon-core/src/main/java/org/apache/paimon/utils/AsyncRecordReader.java	80
paimon-core/src/main/java/org/apache/paimon/utils/BatchRecordWriter.java	6
paimon-core/src/main/java/org/apache/paimon/utils/BranchManager.java	57
paimon-core/src/main/java/org/apache/paimon/utils/CatalogBranchManager.java	70
paimon-core/src/main/java/org/apache/paimon/utils/ChangelogManager.java	143
paimon-core/src/main/java/org/apache/paimon/utils/CommitIncrement.java	32
paimon-core/src/main/java/org/apache/paimon/utils/CompressUtils.java	23
paimon-core/src/main/java/org/apache/paimon/utils/DataFilePathFactories.java	17
paimon-core/src/main/java/org/apache/paimon/utils/FileStorePathFactory.java	239
paimon-core/src/main/java/org/apache/paimon/utils/FileSystemBranchManager.java	175
paimon-core/src/main/java/org/apache/paimon/utils/FileUtils.java	81
paimon-core/src/main/java/org/apache/paimon/utils/FormatReaderMapping.java	229
paimon-core/src/main/java/org/apache/paimon/utils/HintFileUtils.java	94
paimon-core/src/main/java/org/apache/paimon/utils/IOExceptionSupplier.java	7
paimon-core/src/main/java/org/apache/paimon/utils/IntObjectSerializer.java	19
paimon-core/src/main/java/org/apache/paimon/utils/IteratorRecordReader.java	38
paimon-core/src/main/java/org/apache/paimon/utils/JsonDeserializer.java	5
paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java	197
paimon-core/src/main/java/org/apache/paimon/utils/JsonSerializer.java	6
paimon-core/src/main/java/org/apache/paimon/utils/KeyComparatorSupplier.java	23
paimon-core/src/main/java/org/apache/paimon/utils/KeyValueWithLevelNoReusingSerializer.java	32
paimon-core/src/main/java/org/apache/paimon/utils/ManifestReadThreadPool.java	29
paimon-core/src/main/java/org/apache/paimon/utils/MutableObjectIterator.java	6
paimon-core/src/main/java/org/apache/paimon/utils/NextSnapshotFetcher.java	51
paimon-core/src/main/java/org/apache/paimon/utils/ObjectSerializer.java	73
paimon-core/src/main/java/org/apache/paimon/utils/ObjectsCache.java	115
paimon-core/src/main/java/org/apache/paimon/utils/ObjectsFile.java	179
paimon-core/src/main/java/org/apache/paimon/utils/OffsetRow.java	101
paimon-core/src/main/java/org/apache/paimon/utils/PartialRow.java	100
paimon-core/src/main/java/org/apache/paimon/utils/PartitionPathUtils.java	162
paimon-core/src/main/java/org/apache/paimon/utils/PartitionStatisticsReporter.java	71
paimon-core/src/main/java/org/apache/paimon/utils/PathFactory.java	6
paimon-core/src/main/java/org/apache/paimon/utils/RecordWriter.java	16
paimon-core/src/main/java/org/apache/paimon/utils/Restorable.java	7
paimon-core/src/main/java/org/apache/paimon/utils/RowIterator.java	7
paimon-core/src/main/java/org/apache/paimon/utils/SegmentsCache.java	65
paimon-core/src/main/java/org/apache/paimon/utils/SerializableRunnable.java	4
paimon-core/src/main/java/org/apache/paimon/utils/SerializableSupplier.java	5
paimon-core/src/main/java/org/apache/paimon/utils/SerializationUtils.java	59
paimon-core/src/main/java/org/apache/paimon/utils/SimpleFileReader.java	7
paimon-core/src/main/java/org/apache/paimon/utils/SnapshotLoader.java	11
paimon-core/src/main/java/org/apache/paimon/utils/SnapshotManager.java	591
paimon-core/src/main/java/org/apache/paimon/utils/SnapshotNotExistException.java	16
paimon-core/src/main/java/org/apache/paimon/utils/StatsCollectorFactories.java	58
paimon-core/src/main/java/org/apache/paimon/utils/TagManager.java	325
paimon-core/src/main/java/org/apache/paimon/utils/UserDefinedSeqComparator.java	50
paimon-core/src/main/java/org/apache/paimon/utils/ValueEqualiserSupplier.java	40
paimon-core/src/main/java/org/apache/paimon/utils/VersionedObjectSerializer.java	32
paimon-core/src/main/java/org/apache/paimon/view/View.java	17
paimon-core/src/main/java/org/apache/paimon/view/ViewChange.java	266
paimon-core/src/main/java/org/apache/paimon/view/ViewImpl.java	82
paimon-core/src/main/java/org/apache/paimon/view/ViewSchema.java	81