alibaba / fluss
File Size

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

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


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java7% | 8% | 32% | 19% | 30%
proto0% | 100% | 0% | 0% | 0%
css0% | 0% | 0% | 69% | 30%
ts0% | 0% | 0% | 96% | 3%
xml0% | 0% | 0% | 0% | 100%
tsx0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
fluss-server12% | 13% | 38% | 15% | 20%
fluss-filesystems70% | 0% | 0% | 9% | 19%
fluss-common4% | 6% | 32% | 16% | 40%
fluss-flink0% | 11% | 34% | 26% | 26%
fluss-rpc0% | 14% | 24% | 17% | 43%
fluss-lakehouse0% | 13% | 21% | 27% | 37%
fluss-client0% | 6% | 35% | 27% | 30%
fluss-metrics0% | 0% | 74% | 13% | 12%
tools0% | 0% | 49% | 13% | 36%
fluss-protogen0% | 0% | 24% | 45% | 30%
fluss-kafka0% | 0% | 0% | 87% | 12%
website0% | 0% | 0% | 48% | 51%
fluss-lake0% | 0% | 0% | 88% | 11%
fluss-dist0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
XmlResponsesSaxParser.java
in fluss-filesystems/fluss-fs-s3/src/main/java/com/amazonaws/services/s3/model/transform
2506 151
Replica.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica
1411 84
ConfigOptions.java
in fluss-common/src/main/java/com/alibaba/fluss/config
1308 -
ReplicaManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica
1262 56
ServerRpcMessageUtils.java
in fluss-server/src/main/java/com/alibaba/fluss/server/utils
1245 58
LogTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
925 76
CoordinatorEventProcessor.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
864 33
BinaryString.java
in fluss-common/src/main/java/com/alibaba/fluss/row
729 48
proto
FlussApi.proto
in fluss-rpc/src/main/proto
683 -
FlinkSourceEnumerator.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator
680 46
RpcServiceBase.java
in fluss-server/src/main/java/com/alibaba/fluss/server
617 26
MemorySegment.java
in fluss-common/src/main/java/com/alibaba/fluss/memory
615 69
DefaultAuthorizer.java
in fluss-server/src/main/java/com/alibaba/fluss/server/authorizer
582 31
PureJavaCrc32C.java
in fluss-common/src/main/java/com/alibaba/fluss/utils/crc
571 5
FlinkSourceEnumerator.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/enumerator
570 35
ZooKeeperClient.java
in fluss-server/src/main/java/com/alibaba/fluss/server/zk
565 62
FlinkCatalog.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/catalog
562 45
RecordAccumulator.java
in fluss-client/src/main/java/com/alibaba/fluss/client/write
552 26
RemoteLogIndexCache.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
532 29
ReplicaFetcherThread.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher
492 26
WriterStateManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
482 45
CoordinatorContext.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
463 63
FlinkSourceSplitReader.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader
451 16
LocalLog.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
448 39
ArrowUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
440 29
LogSegment.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
438 35
KvTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv
429 25
FlussAdmin.java
in fluss-client/src/main/java/com/alibaba/fluss/client/admin
429 25
FlinkSourceSplitReader.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader
413 20
CoordinatorRequestBatch.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
412 15
LogFetcher.java
in fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log
412 17
FutureUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent
409 41
Sender.java
in fluss-client/src/main/java/com/alibaba/fluss/client/write
409 25
PushdownUtils.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils
400 10
FlinkTableSource.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source
398 15
TableDescriptor.java
in fluss-common/src/main/java/com/alibaba/fluss/metadata
390 46
MetadataManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
390 25
LogTieringTask.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
388 19
ServerConnection.java
in fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/client
388 21
PaimonStoreMultiCommitter.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer
379 15
CoordinatorService.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
375 17
TabletService.java
in fluss-server/src/main/java/com/alibaba/fluss/server/tablet
373 20
LogManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
372 15
IndexedRow.java
in fluss-common/src/main/java/com/alibaba/fluss/row/indexed
365 36
CoordinatorServer.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
358 14
LakeTableTieringManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
354 29
Configuration.java
in fluss-common/src/main/java/com/alibaba/fluss/config
350 50
FileLogProjection.java
in fluss-common/src/main/java/com/alibaba/fluss/record
350 12
ReplicaStateMachine.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine
350 15
TableBucketStateMachine.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine
347 18
Files With Most Units (Top 50)
File# lines# units
XmlResponsesSaxParser.java
in fluss-filesystems/fluss-fs-s3/src/main/java/com/amazonaws/services/s3/model/transform
2506 151
Replica.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica
1411 84
LogTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
925 76
MemorySegment.java
in fluss-common/src/main/java/com/alibaba/fluss/memory
615 69
CoordinatorContext.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
463 63
ZooKeeperClient.java
in fluss-server/src/main/java/com/alibaba/fluss/server/zk
565 62
ServerRpcMessageUtils.java
in fluss-server/src/main/java/com/alibaba/fluss/server/utils
1245 58
ReplicaManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica
1262 56
ZkData.java
in fluss-server/src/main/java/com/alibaba/fluss/server/zk/data
322 52
Configuration.java
in fluss-common/src/main/java/com/alibaba/fluss/config
350 50
BinaryString.java
in fluss-common/src/main/java/com/alibaba/fluss/row
729 48
TableDescriptor.java
in fluss-common/src/main/java/com/alibaba/fluss/metadata
390 46
FlinkSourceEnumerator.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator
680 46
WriterStateManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
482 45
FlinkCatalog.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/catalog
562 45
FutureUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent
409 41
Schema.java
in fluss-common/src/main/java/com/alibaba/fluss/metadata
345 40
LocalLog.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
448 39
IndexedRow.java
in fluss-common/src/main/java/com/alibaba/fluss/row/indexed
365 36
AbstractIndex.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
339 36
PhysicalTableMetricGroup.java
in fluss-server/src/main/java/com/alibaba/fluss/server/metrics/group
300 35
LogSegment.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
438 35
FlinkSourceEnumerator.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/enumerator
570 35
KafkaRequestHandler.java
in fluss-kafka/src/main/java/com/alibaba/fluss/kafka
184 35
FlussPaths.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
279 34
FileLogRecords.java
in fluss-common/src/main/java/com/alibaba/fluss/record
328 34
ProtoCodecUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
229 33
DefaultLogRecordBatch.java
in fluss-common/src/main/java/com/alibaba/fluss/record
307 33
KvPreWriteBuffer.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv/prewrite
279 33
CoordinatorEventProcessor.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
864 33
PaimonBinaryRowWriter.java
in fluss-common/src/main/java/com/alibaba/fluss/row/encode/paimon
334 31
DefaultAuthorizer.java
in fluss-server/src/main/java/com/alibaba/fluss/server/authorizer
582 31
FlussLZ4BlockOutputStream.java
in fluss-common/src/main/java/com/alibaba/fluss/compression
272 30
IndexedRowWriter.java
in fluss-common/src/main/java/com/alibaba/fluss/row/indexed
278 30
RowType.java
in fluss-common/src/main/java/com/alibaba/fluss/types
189 30
ArrowUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
440 29
RemoteLogIndexCache.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
532 29
LakeTableTieringManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
354 29
TableInfo.java
in fluss-common/src/main/java/com/alibaba/fluss/metadata
240 28
Cluster.java
in fluss-common/src/main/java/com/alibaba/fluss/cluster
231 27
CompactedRowWriter.java
in fluss-common/src/main/java/com/alibaba/fluss/row/compacted
286 27
MemorySize.java
in fluss-common/src/main/java/com/alibaba/fluss/config
264 26
CompactedRow.java
in fluss-common/src/main/java/com/alibaba/fluss/row/compacted
162 26
RpcServiceBase.java
in fluss-server/src/main/java/com/alibaba/fluss/server
617 26
ReplicaFetcherThread.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher
492 26
RecordAccumulator.java
in fluss-client/src/main/java/com/alibaba/fluss/client/write
552 26
DataTypes.java
in fluss-common/src/main/java/com/alibaba/fluss/types
81 25
FileLogInputStream.java
in fluss-common/src/main/java/com/alibaba/fluss/record
201 25
KvTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv
429 25
MetadataManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
390 25
Files With Long Lines (Top 50)

There are 79 files with lines longer than 120 characters. In total, there are 245 long lines.

File# lines# units# long lines
ConfigOptions.java
in fluss-common/src/main/java/com/alibaba/fluss/config
1308 - 119
index.tsx
in website/src/components/HomepageFeatures
76 8 6
FlinkTableSink.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/sink
307 14 5
FileSystem.java
in fluss-common/src/main/java/com/alibaba/fluss/fs
264 11 4
CoordinatorRequestBatch.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
412 15 4
AbstractMetricGroup.java
in fluss-common/src/main/java/com/alibaba/fluss/metrics/groups
201 19 3
ReporterSetup.java
in fluss-common/src/main/java/com/alibaba/fluss/metrics/reporter
109 4 3
TableDescriptorValidation.java
in fluss-server/src/main/java/com/alibaba/fluss/server/utils
211 9 3
Replica.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica
1411 84 3
PrometheusReporter.java
in fluss-metrics/fluss-metrics-prometheus/src/main/java/com/alibaba/fluss/metrics/prometheus
332 19 3
JarFileChecker.java
in tools/ci/fluss-ci-tools/src/main/java/com/alibaba/fluss/tools/ci/licensecheck
246 17 3
FlinkConnectorOptions.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink
112 2 3
HadoopFsPlugin.java
in fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs
114 3 3
plugins.xml
in fluss-dist/src/main/assemblies
62 - 3
ExceptionUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
210 24 2
ServerMetricUtils.java
in fluss-server/src/main/java/com/alibaba/fluss/server/metrics
223 16 2
KvManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv
237 10 2
PeriodicSnapshotManager.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot
285 19 2
RemoteLogManifest.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
103 11 2
CoordinatorEventProcessor.java
in fluss-server/src/main/java/com/alibaba/fluss/server/coordinator
864 33 2
NoticeFileChecker.java
in tools/ci/fluss-ci-tools/src/main/java/com/alibaba/fluss/tools/ci/licensecheck
314 9 2
LookupNormalizer.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/lookup
226 13 2
FlinkSourceSplitReader.java
in fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader
451 16 2
NettyServerHandler.java
in fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server
272 17 2
ProtobufRepeatedBytesField.java
in fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator
122 10 2
ProtobufRepeatedNumberField.java
in fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator
167 11 2
LogFetchCollector.java
in fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log
213 3 2
custom.css
in website/src/css
175 - 2
opt.xml
in fluss-dist/src/main/assemblies
25 - 2
InstantiationUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
209 17 1
DataTypeJsonSerde.java
in fluss-common/src/main/java/com/alibaba/fluss/utils/json
244 15 1
ArrowUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/utils
440 29 1
MemorySegmentOutputView.java
in fluss-common/src/main/java/com/alibaba/fluss/memory
146 17 1
TableDescriptor.java
in fluss-common/src/main/java/com/alibaba/fluss/metadata
390 46 1
CorruptMessageException.java
in fluss-common/src/main/java/com/alibaba/fluss/exception
19 4 1
RocksDBOperationUtils.java
in fluss-common/src/main/java/com/alibaba/fluss/rocksdb
75 3 1
PaimonStoreMultiCommitter.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer
379 15 1
PaimonMultiWriterOperator.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/operator
240 11 1
FlinkSourceEnumerator.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/enumerator
680 46 1
SnapshotReader.java
in fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/reader
123 12 1
ZkNodeChangeNotificationWatcher.java
in fluss-server/src/main/java/com/alibaba/fluss/server/authorizer
134 8 1
TabletManagerBase.java
in fluss-server/src/main/java/com/alibaba/fluss/server
177 10 1
KvRecoverHelper.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv
180 7 1
PartialUpdater.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv/partialupdate
95 4 1
KvTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/kv
429 25 1
OffsetIndex.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
208 17 1
LogTablet.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log
925 76 1
LogTieringTask.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
388 19 1
RemoteLogIndexCache.java
in fluss-server/src/main/java/com/alibaba/fluss/server/log/remote
532 29 1
DelayedFetchLog.java
in fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay
168 7 1