Path	Lines of Code
fluss-client/src/main/java/com/alibaba/fluss/client/FlussConnection.java	148
fluss-client/src/main/java/com/alibaba/fluss/client/lookup/Lookup.java	12
fluss-client/src/main/java/com/alibaba/fluss/client/lookup/LookupSender.java	303
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/ScanRecord.java	60
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/batch/LimitBatchScanner.java	141
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/BucketScanStatus.java	25
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/CompletedFetch.java	182
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchBuffer.java	179
fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetcher.java	412
fluss-client/src/main/java/com/alibaba/fluss/client/table/writer/Append.java	6
fluss-client/src/main/java/com/alibaba/fluss/client/utils/MetadataUtils.java	259
fluss-client/src/main/java/com/alibaba/fluss/client/write/IdempotenceManager.java	200
fluss-client/src/main/java/com/alibaba/fluss/client/write/RecordAccumulator.java	552
fluss-client/src/main/java/com/alibaba/fluss/client/write/Sender.java	409
fluss-client/src/main/java/com/alibaba/fluss/client/write/WriterClient.java	235
fluss-common/src/main/java/com/alibaba/fluss/cluster/BucketLocation.java	88
fluss-common/src/main/java/com/alibaba/fluss/cluster/Cluster.java	231
fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockInputStream.java	214
fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockOutputStream.java	272
fluss-common/src/main/java/com/alibaba/fluss/memory/AbstractPagedOutputView.java	210
fluss-common/src/main/java/com/alibaba/fluss/plugin/DirectoryBasedPluginFinder.java	57
fluss-common/src/main/java/com/alibaba/fluss/record/ChangeTypeVectorWriter.java	25
fluss-common/src/main/java/com/alibaba/fluss/record/DefaultKvRecord.java	126
fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java	307
fluss-common/src/main/java/com/alibaba/fluss/record/IndexedLogRecord.java	122
fluss-common/src/main/java/com/alibaba/fluss/record/LogRecordReadContext.java	158
fluss-common/src/main/java/com/alibaba/fluss/row/MemoryAwareGetters.java	9
fluss-common/src/main/java/com/alibaba/fluss/row/columnar/ColumnarRow.java	92
fluss-common/src/main/java/com/alibaba/fluss/utils/PartitionUtils.java	92
fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/FlussScheduler.java	141
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/catalog/FlinkCatalog.java	562
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/sink/FlinkTableSink.java	307
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup/LookupNormalizer.java	226
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/FlinkSourceSplitReader.java	451
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlinkConversions.java	263
fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java	103
fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaCommandDecoder.java	157
fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaRequestHandler.java	184
fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/operator/PaimonMultiWriterOperator.java	240
fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader/FlinkSourceSplitReader.java	413
fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java	115
fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/NameUtilities.java	37
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/RpcGatewayService.java	39
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/client/ServerConnection.java	388
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java	272
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/ServerChannelInitializer.java	58
fluss-rpc/src/main/proto/FlussApi.proto	683
fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java	617
fluss-server/src/main/java/com/alibaba/fluss/server/TabletManagerBase.java	177
fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/AutoPartitionManager.java	342
fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorContext.java	463
fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java	864
fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java	375
fluss-server/src/main/java/com/alibaba/fluss/server/entity/FetchData.java	71
fluss-server/src/main/java/com/alibaba/fluss/server/kv/KvManager.java	237
fluss-server/src/main/java/com/alibaba/fluss/server/kv/KvRecoverHelper.java	180
fluss-server/src/main/java/com/alibaba/fluss/server/kv/KvTablet.java	429
fluss-server/src/main/java/com/alibaba/fluss/server/kv/partialupdate/PartialUpdaterCache.java	23
fluss-server/src/main/java/com/alibaba/fluss/server/kv/rowmerger/DefaultRowMerger.java	66
fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/ZooKeeperCompletedSnapshotHandleStore.java	70
fluss-server/src/main/java/com/alibaba/fluss/server/kv/wal/ArrowWalBuilder.java	41
fluss-server/src/main/java/com/alibaba/fluss/server/kv/wal/IndexWalBuilder.java	44
fluss-server/src/main/java/com/alibaba/fluss/server/log/FetchParams.java	135
fluss-server/src/main/java/com/alibaba/fluss/server/log/LogLoader.java	95
fluss-server/src/main/java/com/alibaba/fluss/server/log/LogManager.java	372
fluss-server/src/main/java/com/alibaba/fluss/server/log/LogSegment.java	438
fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java	925
fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/FsRemoteLogOutputStream.java	153
fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogSegmentFiles.java	67
fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/LogTieringTask.java	388
fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogManager.java	276
fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/RemoteLogTablet.java	252
fluss-server/src/main/java/com/alibaba/fluss/server/metadata/ClusterMetadataInfo.java	160
fluss-server/src/main/java/com/alibaba/fluss/server/replica/AdjustIsrManager.java	136
fluss-server/src/main/java/com/alibaba/fluss/server/replica/Replica.java	1411
fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java	1262
fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java	492
fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java	333
fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletService.java	373
fluss-server/src/main/java/com/alibaba/fluss/server/utils/ServerRpcMessageUtils.java	1245
tools/ci/fluss-ci-tools/src/main/java/com/alibaba/fluss/tools/ci/licensecheck/NoticeFileChecker.java	314