apache / incubator-celeborn
File Size

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

Intro
Learn more...
File Size Overall
9% | 15% | 36% | 19% | 18%
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
scala14% | 32% | 26% | 12% | 13%
java6% | 2% | 44% | 24% | 22%
proto0% | 0% | 73% | 26% | 0%
py0% | 0% | 67% | 22% | 10%
yaml0% | 0% | 0% | 81% | 18%
bash0% | 0% | 0% | 100% | 0%
yml0% | 0% | 0% | 0% | 100%
tpl0% | 0% | 0% | 0% | 100%
sbt0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
common18% | 10% | 27% | 21% | 23%
client25% | 14% | 31% | 17% | 10%
worker0% | 46% | 32% | 12% | 8%
master0% | 22% | 55% | 4% | 17%
project0% | 99% | 0% | 0% | <1%
client-spark0% | 0% | 73% | 13% | 13%
client-flink0% | 0% | 37% | 38% | 24%
dev0% | 0% | 100% | 0% | 0%
charts0% | 0% | 0% | 72% | 27%
build0% | 0% | 0% | 84% | 15%
toolkit0% | 0% | 0% | 63% | 36%
service0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 3090 81
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1513 45
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 953 23
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 884 33
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 882 78
ControlMessages.scala
in common/src/main/scala/org/apache/celeborn/common/protocol/message
 842 14
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 783 23
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 713 28
PartitionFilesSorter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 608 27
Worker.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 595 12
588 4
Controller.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 587 6
CelebornInputStream.java
in client/src/main/java/org/apache/celeborn/client/read
 497 20
CelebornColumnType.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 485 94
FlinkShuffleClientImpl.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 485 17
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 475 37
RemoteShuffleInputGateDelegation.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 445 25
HashBasedShuffleWriter.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 416 14
SlotsAllocator.java
in master/src/main/java/org/apache/celeborn/service/deploy/master
 411 6
proto
TransportMessages.proto
in common/src/main/proto
 407 -
406 14
HARaftServer.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 394 23
CommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 386 13
MapDataPartitionReader.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 380 27
FileWriter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 364 29
SortBasedShuffleWriter.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 359 13
CelebornCompressionSchemes.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 355 24
PbSerDeUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 350 17
SortBasedShuffleWriter.java
in client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn
 342 12
SortBasedPusher.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn
 341 16
MemoryManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory
 340 29
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 339 36
StateMachine.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 334 23
JavaUtils.java
in common/src/main/java/org/apache/celeborn/common/util
 322 28
FetchHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 319 13
HashBasedShuffleWriter.java
in client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn
 316 11
TransportResponseHandler.java
in common/src/main/java/org/apache/celeborn/common/network/client
 307 17
CelebornColumnBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 299 17
SparkShuffleManager.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 287 14
PartitionSortedBuffer.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer
 272 20
CelebornColumnarBatchCodeGenBuild.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 271 3
PartitionLocation.java
in common/src/main/java/org/apache/celeborn/common/protocol
 271 38
AbstractMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 267 12
ChangePartitionManager.scala
in client/src/main/scala/org/apache/celeborn/client
 267 8
SerializationDebugger.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 266 28
CommitManager.scala
in client/src/main/scala/org/apache/celeborn/client
 265 18
DynMethods.java
in common/src/main/java/org/apache/celeborn/reflect
 262 40
RemoteShuffleResultPartitionDelegation.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 261 19
CreditStreamManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 260 24
HAMasterMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 257 13
Files With Most Units (Top 50)
File# lines# units
CelebornColumnType.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 485 94
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 3090 81
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 882 78
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1513 45
DynMethods.java
in common/src/main/java/org/apache/celeborn/reflect
 262 40
PartitionLocation.java
in common/src/main/java/org/apache/celeborn/common/protocol
 271 38
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 475 37
DynFields.java
in common/src/main/java/org/apache/celeborn/reflect
 225 36
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 339 36
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 884 33
RemoteShuffleInputGate.java
in client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink
 219 33
RemoteShuffleInputGate.java
in client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink
 197 33
BufferPacker.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer
 254 32
RemoteShuffleInputGate.java
in client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink
 212 32
FileInfo.java
in common/src/main/java/org/apache/celeborn/common/meta
 177 31
MemoryManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory
 340 29
FileWriter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 364 29
JavaUtils.java
in common/src/main/java/org/apache/celeborn/common/util
 322 28
Platform.java
in common/src/main/java/org/apache/celeborn/common/unsafe
 235 28
SerializationDebugger.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 266 28
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 713 28
PartitionFilesSorter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 608 27
MapDataPartitionReader.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 380 27
DynConstructors.java
in common/src/main/java/org/apache/celeborn/reflect
 233 26
RemoteShuffleInputGateDelegation.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 445 25
CelebornCompressionSchemes.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 355 24
TransportClient.java
in common/src/main/java/org/apache/celeborn/common/network/client
 253 24
CreditStreamManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 260 24
TransportConf.java
in common/src/main/java/org/apache/celeborn/common/network/util
 76 23
ConfigBuilder.scala
in common/src/main/scala/org/apache/celeborn/common/internal/config
 240 23
StateMachine.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 334 23
HARaftServer.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 394 23
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 783 23
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 953 23
RemoteShuffleResultPartition.java
in client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink
 169 23
CelebornColumnStats.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 233 21
CelebornInputStream.java
in client/src/main/java/org/apache/celeborn/client/read
 497 20
ReducePartitionCommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 236 20
PartitionSortedBuffer.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer
 272 20
RemoteShuffleResultPartition.java
in client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink
 157 20
ShutdownHookManager.java
in common/src/main/java/org/apache/celeborn/common/util
 194 19
WorkerInfo.scala
in common/src/main/scala/org/apache/celeborn/common/meta
 219 19
DeviceMonitor.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 248 19
RemoteShuffleResultPartitionDelegation.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 261 19
RemoteShuffleResultPartition.java
in client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink
 156 19
StorageInfo.java
in common/src/main/java/org/apache/celeborn/common/protocol
 110 18
CommitManager.scala
in client/src/main/scala/org/apache/celeborn/client
 265 18
CelebornColumnBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 299 17
TransportResponseHandler.java
in common/src/main/java/org/apache/celeborn/common/network/client
 307 17
PbSerDeUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 350 17
Files With Long Lines (Top 24)

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

File# lines# units# long lines
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 3090 81 20
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1513 45 19
588 4 8
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 953 23 4
mkdocs.yml
in root
 75 - 2
master-statefulset.yaml
in charts/celeborn/templates
 123 - 2
worker-statefulset.yaml
in charts/celeborn/templates
 129 - 2
configmap.yaml
in charts/celeborn/templates
 102 - 2
values.yaml
in charts/celeborn
 110 - 2
151 - 2
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 713 28 2
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 884 33 2
CelebornShuffleFallbackPolicyRunner.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn
 38 4 1
CelebornBatchBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 28 2 1
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 339 36 1
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 882 78 1
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 475 37 1
CelebornRackResolver.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master/network
 64 4 1
FetchHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 319 13 1
Worker.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 595 12 1
CommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 386 13 1
ApplicationHeartbeater.scala
in client/src/main/scala/org/apache/celeborn/client
 77 3 1
CelebornBufferStream.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 154 10 1
FlinkShuffleClientImpl.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 485 17 1
Correlations

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 22 commits (all time) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 20 commits (all time) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 100 commits (all time) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 4 commits (all time) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 2 commits (all time) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 5 commits (all time) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 4 commits (all time) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 27 commits (all time) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 72 commits (all time) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 148 commits (all time) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 52 commits (all time) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 72 commits (all time) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 11 commits (all time) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 14 commits (all time) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 15 commits (all time) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 2 commits (all time) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 2 commits (all time) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/StreamHandle.java x: 2 commits (all time) y: 47 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 3 commits (all time) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 13 commits (all time) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 14 commits (all time) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 14 commits (all time) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 28 commits (all time) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 56 commits (all time) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 48 commits (all time) y: 882 lines of code mkdocs.yml x: 18 commits (all time) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 8 commits (all time) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 60 commits (all time) y: 953 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala x: 20 commits (all time) y: 83 lines of code project/CelebornBuild.scala x: 3 commits (all time) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 29 commits (all time) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 16 commits (all time) y: 193 lines of code build/sbt-launch-lib.bash x: 1 commits (all time) y: 151 lines of code project/plugins.sbt x: 1 commits (all time) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 28 commits (all time) y: 267 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java x: 6 commits (all time) y: 44 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 11 commits (all time) y: 98 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java x: 14 commits (all time) y: 257 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 23 commits (all time) y: 73 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala x: 12 commits (all time) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 81 commits (all time) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 24 commits (all time) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 95 commits (all time) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 3 commits (all time) y: 92 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 6 commits (all time) y: 118 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 6 commits (all time) y: 20 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 12 commits (all time) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 12 commits (all time) y: 287 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java x: 4 commits (all time) y: 80 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 9 commits (all time) y: 191 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 4 commits (all time) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 22 commits (all time) y: 416 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 20 commits (all time) y: 359 lines of code common/src/main/java/org/apache/celeborn/common/client/MasterClient.java x: 3 commits (all time) y: 170 lines of code common/src/main/java/org/apache/celeborn/common/network/TransportContext.java x: 7 commits (all time) y: 115 lines of code common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java x: 2 commits (all time) y: 12 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java x: 2 commits (all time) y: 121 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 3 commits (all time) y: 141 lines of code common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java x: 6 commits (all time) y: 194 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 14 commits (all time) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 7 commits (all time) y: 334 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 3 commits (all time) y: 111 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 17 commits (all time) y: 341 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 16 commits (all time) y: 316 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 16 commits (all time) y: 342 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java x: 12 commits (all time) y: 108 lines of code common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java x: 11 commits (all time) y: 140 lines of code common/src/main/java/org/apache/celeborn/common/write/SimplePushStrategy.java x: 3 commits (all time) y: 26 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 18 commits (all time) y: 219 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 11 commits (all time) y: 213 lines of code master/src/main/proto/Resource.proto x: 5 commits (all time) y: 146 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 15 commits (all time) y: 163 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 6 commits (all time) y: 340 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java x: 4 commits (all time) y: 53 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 10 commits (all time) y: 225 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 5 commits (all time) y: 164 lines of code common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java x: 13 commits (all time) y: 177 lines of code common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 3 commits (all time) y: 49 lines of code charts/celeborn/values.yaml x: 11 commits (all time) y: 110 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 5 commits (all time) y: 445 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 4 commits (all time) y: 176 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java x: 3 commits (all time) y: 41 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 6 commits (all time) y: 49 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 6 commits (all time) y: 100 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 commits (all time) y: 32 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 1 commits (all time) y: 13 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 7 commits (all time) y: 132 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 commits (all time) y: 38 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala x: 1 commits (all time) y: 105 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 1 commits (all time) y: 299 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala x: 1 commits (all time) y: 233 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 commits (all time) y: 485 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala x: 1 commits (all time) y: 271 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala x: 1 commits (all time) y: 138 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala x: 1 commits (all time) y: 67 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 1 commits (all time) y: 355 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala x: 1 commits (all time) y: 49 lines of code client/src/main/java/org/apache/celeborn/client/compress/Compressor.java x: 9 commits (all time) y: 28 lines of code client/src/main/java/org/apache/celeborn/client/compress/Decompressor.java x: 6 commits (all time) y: 35 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 commits (all time) y: 497 lines of code client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala x: 6 commits (all time) y: 124 lines of code common/src/main/java/org/apache/celeborn/common/protocol/RpcNameConstants.java x: 3 commits (all time) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala x: 9 commits (all time) y: 240 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala x: 12 commits (all time) y: 185 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigProvider.scala x: 5 commits (all time) y: 24 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/MetricsConfig.scala x: 5 commits (all time) y: 71 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 16 commits (all time) y: 339 lines of code toolkit/scripts/genConfs.py x: 8 commits (all time) y: 135 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 33 commits (all time) y: 587 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 5 commits (all time) y: 322 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala x: 4 commits (all time) y: 10 lines of code common/src/main/scala/org/apache/celeborn/common/util/FunctionConverter.scala x: 3 commits (all time) y: 16 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java x: 8 commits (all time) y: 190 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 21 commits (all time) y: 248 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala x: 5 commits (all time) y: 139 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java x: 2 commits (all time) y: 159 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 20 commits (all time) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 15 commits (all time) y: 236 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/PushData.java x: 3 commits (all time) y: 82 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/PushDataHandShake.java x: 2 commits (all time) y: 87 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/RegionFinish.java x: 2 commits (all time) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 9 commits (all time) y: 271 lines of code common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java x: 17 commits (all time) y: 59 lines of code common/src/main/java/org/apache/celeborn/common/write/PushState.java x: 8 commits (all time) y: 55 lines of code common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala x: 9 commits (all time) y: 84 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 19 commits (all time) y: 350 lines of code client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala x: 6 commits (all time) y: 77 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java x: 6 commits (all time) y: 91 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala x: 2 commits (all time) y: 266 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java x: 3 commits (all time) y: 261 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 4 commits (all time) y: 156 lines of code client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 3 commits (all time) y: 157 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala x: 9 commits (all time) y: 51 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala x: 10 commits (all time) y: 57 lines of code charts/celeborn/templates/configmap.yaml x: 9 commits (all time) y: 102 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 8 commits (all time) y: 475 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/MetricsSystem.scala x: 4 commits (all time) y: 134 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala x: 4 commits (all time) y: 69 lines of code charts/celeborn/templates/master-statefulset.yaml x: 11 commits (all time) y: 123 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Heartbeat.java x: 2 commits (all time) y: 20 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java x: 3 commits (all time) y: 126 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorter.java x: 2 commits (all time) y: 103 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java x: 5 commits (all time) y: 123 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java x: 5 commits (all time) y: 54 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java x: 7 commits (all time) y: 34 lines of code client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java x: 2 commits (all time) y: 29 lines of code dev/merge_pr.py x: 1 commits (all time) y: 406 lines of code common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala x: 5 commits (all time) y: 27 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 1 commits (all time) y: 219 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleEnvironment.java x: 1 commits (all time) y: 132 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java x: 6 commits (all time) y: 254 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 8 commits (all time) y: 197 lines of code client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 1 commits (all time) y: 212 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartition.java x: 2 commits (all time) y: 217 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionFileWriter.java x: 9 commits (all time) y: 246 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java x: 1 commits (all time) y: 119 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java x: 1 commits (all time) y: 260 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java x: 8 commits (all time) y: 182 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java x: 10 commits (all time) y: 101 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java x: 7 commits (all time) y: 59 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/PartitionSortedBuffer.java x: 2 commits (all time) y: 272 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java x: 4 commits (all time) y: 93 lines of code common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java x: 2 commits (all time) y: 235 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Outbox.scala x: 2 commits (all time) y: 186 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportRequestHandler.java x: 1 commits (all time) y: 73 lines of code
3090.0
lines of code
  min: 1.0
  average: 127.64
  25th percentile: 25.5
  median: 55.5
  75th percentile: 154.5
  max: 3090.0
0 148.0
commits (all time)
min: 1.0 | average: 6.58 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 6.0 | max: 148.0

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 11 contributors (all time) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 6 contributors (all time) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 14 contributors (all time) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 4 contributors (all time) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 2 contributors (all time) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 2 contributors (all time) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 3 contributors (all time) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 9 contributors (all time) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 11 contributors (all time) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 20 contributors (all time) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 12 contributors (all time) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 11 contributors (all time) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 6 contributors (all time) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 8 contributors (all time) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 5 contributors (all time) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 2 contributors (all time) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 2 contributors (all time) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 3 contributors (all time) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 8 contributors (all time) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 8 contributors (all time) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 6 contributors (all time) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 10 contributors (all time) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 19 contributors (all time) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 16 contributors (all time) y: 882 lines of code mkdocs.yml x: 5 contributors (all time) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 5 contributors (all time) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 15 contributors (all time) y: 953 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala x: 10 contributors (all time) y: 83 lines of code project/CelebornBuild.scala x: 1 contributors (all time) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 13 contributors (all time) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 6 contributors (all time) y: 193 lines of code build/sbt-launch-lib.bash x: 1 contributors (all time) y: 151 lines of code project/plugins.sbt x: 1 contributors (all time) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 9 contributors (all time) y: 267 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java x: 4 contributors (all time) y: 44 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 4 contributors (all time) y: 98 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 6 contributors (all time) y: 73 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala x: 3 contributors (all time) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 18 contributors (all time) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 7 contributors (all time) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 20 contributors (all time) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 2 contributors (all time) y: 92 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 5 contributors (all time) y: 118 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 3 contributors (all time) y: 20 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 5 contributors (all time) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 4 contributors (all time) y: 287 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 4 contributors (all time) y: 191 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 4 contributors (all time) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 9 contributors (all time) y: 416 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 7 contributors (all time) y: 359 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 10 contributors (all time) y: 265 lines of code common/src/main/java/org/apache/celeborn/common/client/MasterClient.java x: 2 contributors (all time) y: 170 lines of code common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java x: 2 contributors (all time) y: 12 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java x: 2 contributors (all time) y: 121 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 3 contributors (all time) y: 141 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 6 contributors (all time) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 6 contributors (all time) y: 334 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 3 contributors (all time) y: 94 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 3 contributors (all time) y: 111 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 6 contributors (all time) y: 341 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 7 contributors (all time) y: 316 lines of code common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java x: 5 contributors (all time) y: 140 lines of code common/src/main/java/org/apache/celeborn/common/write/SimplePushStrategy.java x: 3 contributors (all time) y: 26 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 10 contributors (all time) y: 219 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 6 contributors (all time) y: 213 lines of code master/src/main/proto/Resource.proto x: 5 contributors (all time) y: 146 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 5 contributors (all time) y: 340 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 7 contributors (all time) y: 225 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 5 contributors (all time) y: 164 lines of code common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java x: 7 contributors (all time) y: 177 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 4 contributors (all time) y: 445 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 4 contributors (all time) y: 176 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java x: 3 contributors (all time) y: 41 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 3 contributors (all time) y: 49 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 2 contributors (all time) y: 100 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 contributors (all time) y: 32 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 1 contributors (all time) y: 13 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 2 contributors (all time) y: 132 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 contributors (all time) y: 38 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala x: 1 contributors (all time) y: 105 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 1 contributors (all time) y: 299 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala x: 1 contributors (all time) y: 233 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 contributors (all time) y: 485 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala x: 1 contributors (all time) y: 271 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala x: 1 contributors (all time) y: 138 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala x: 1 contributors (all time) y: 67 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 1 contributors (all time) y: 355 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala x: 1 contributors (all time) y: 49 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 contributors (all time) y: 497 lines of code client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala x: 6 contributors (all time) y: 124 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala x: 5 contributors (all time) y: 240 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala x: 7 contributors (all time) y: 185 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 9 contributors (all time) y: 339 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 12 contributors (all time) y: 587 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 4 contributors (all time) y: 322 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala x: 4 contributors (all time) y: 10 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/Source.scala x: 3 contributors (all time) y: 12 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala x: 2 contributors (all time) y: 21 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 6 contributors (all time) y: 248 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 8 contributors (all time) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala x: 5 contributors (all time) y: 172 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 6 contributors (all time) y: 236 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/RegionFinish.java x: 2 contributors (all time) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 7 contributors (all time) y: 271 lines of code common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java x: 6 contributors (all time) y: 59 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 9 contributors (all time) y: 350 lines of code client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala x: 4 contributors (all time) y: 77 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java x: 4 contributors (all time) y: 91 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala x: 2 contributors (all time) y: 266 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 4 contributors (all time) y: 156 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala x: 4 contributors (all time) y: 51 lines of code charts/celeborn/templates/configmap.yaml x: 5 contributors (all time) y: 102 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 5 contributors (all time) y: 475 lines of code common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala x: 3 contributors (all time) y: 168 lines of code charts/celeborn/templates/master-statefulset.yaml x: 5 contributors (all time) y: 123 lines of code charts/celeborn/templates/worker-statefulset.yaml x: 4 contributors (all time) y: 129 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java x: 3 contributors (all time) y: 126 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java x: 1 contributors (all time) y: 78 lines of code dev/merge_pr.py x: 1 contributors (all time) y: 406 lines of code common/src/main/java/org/apache/celeborn/common/write/PushStrategy.java x: 2 contributors (all time) y: 26 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java x: 1 contributors (all time) y: 87 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 1 contributors (all time) y: 219 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleEnvironment.java x: 1 contributors (all time) y: 132 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java x: 5 contributors (all time) y: 254 lines of code client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 3 contributors (all time) y: 197 lines of code client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 1 contributors (all time) y: 212 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartition.java x: 2 contributors (all time) y: 217 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/BufferQueue.java x: 1 contributors (all time) y: 115 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java x: 1 contributors (all time) y: 260 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java x: 3 contributors (all time) y: 182 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java x: 3 contributors (all time) y: 101 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/PartitionSortedBuffer.java x: 2 contributors (all time) y: 272 lines of code common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala x: 2 contributors (all time) y: 142 lines of code common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java x: 2 contributors (all time) y: 235 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Outbox.scala x: 2 contributors (all time) y: 186 lines of code
3090.0
lines of code
  min: 1.0
  average: 127.64
  25th percentile: 25.5
  median: 55.5
  75th percentile: 154.5
  max: 3090.0
0 20.0
contributors (all time)
min: 1.0 | average: 3.01 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 20.0

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 3 commits (30d) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 1 commits (30d) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 7 commits (30d) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 1 commits (30d) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 1 commits (30d) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 1 commits (30d) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 2 commits (30d) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 5 commits (30d) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 7 commits (30d) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 20 commits (30d) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 6 commits (30d) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 6 commits (30d) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 1 commits (30d) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 1 commits (30d) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 1 commits (30d) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 1 commits (30d) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 1 commits (30d) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 1 commits (30d) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 1 commits (30d) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 2 commits (30d) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 1 commits (30d) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 3 commits (30d) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 5 commits (30d) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 1 commits (30d) y: 882 lines of code mkdocs.yml x: 13 commits (30d) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 2 commits (30d) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 4 commits (30d) y: 953 lines of code project/CelebornBuild.scala x: 3 commits (30d) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 6 commits (30d) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 2 commits (30d) y: 193 lines of code project/plugins.sbt x: 1 commits (30d) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 2 commits (30d) y: 267 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 1 commits (30d) y: 98 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 4 commits (30d) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 5 commits (30d) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 3 commits (30d) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 10 commits (30d) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 2 commits (30d) y: 92 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 2 commits (30d) y: 118 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 3 commits (30d) y: 20 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala x: 2 commits (30d) y: 64 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 9 commits (30d) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 9 commits (30d) y: 287 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java x: 2 commits (30d) y: 80 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 1 commits (30d) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 3 commits (30d) y: 416 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 4 commits (30d) y: 359 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 1 commits (30d) y: 141 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 1 commits (30d) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 1 commits (30d) y: 334 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 3 commits (30d) y: 341 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 2 commits (30d) y: 316 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 1 commits (30d) y: 213 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 4 commits (30d) y: 163 lines of code
3090.0
lines of code
  min: 1.0
  average: 290.18
  25th percentile: 83.0
  median: 181.0
  75th percentile: 341.0
  max: 3090.0
0 20.0
commits (30d)
min: 1.0 | average: 2.65 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 3.0 | max: 20.0

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 3 contributors (30d) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 1 contributors (30d) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 4 contributors (30d) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 1 contributors (30d) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 1 contributors (30d) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 1 contributors (30d) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 2 contributors (30d) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 5 contributors (30d) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 4 contributors (30d) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 6 contributors (30d) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 3 contributors (30d) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 3 contributors (30d) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 1 contributors (30d) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 1 contributors (30d) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 1 contributors (30d) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 1 contributors (30d) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 1 contributors (30d) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 1 contributors (30d) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 1 contributors (30d) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 2 contributors (30d) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 1 contributors (30d) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 3 contributors (30d) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 4 contributors (30d) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 1 contributors (30d) y: 882 lines of code mkdocs.yml x: 4 contributors (30d) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 1 contributors (30d) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 3 contributors (30d) y: 953 lines of code project/CelebornBuild.scala x: 1 contributors (30d) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 3 contributors (30d) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 2 contributors (30d) y: 193 lines of code project/plugins.sbt x: 1 contributors (30d) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 2 contributors (30d) y: 267 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 1 contributors (30d) y: 98 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 2 contributors (30d) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 2 contributors (30d) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 2 contributors (30d) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 7 contributors (30d) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 1 contributors (30d) y: 92 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 2 contributors (30d) y: 118 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 2 contributors (30d) y: 20 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala x: 2 contributors (30d) y: 64 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 5 contributors (30d) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 4 contributors (30d) y: 287 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 1 contributors (30d) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 2 contributors (30d) y: 416 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 1 contributors (30d) y: 141 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 1 contributors (30d) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 1 contributors (30d) y: 334 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 2 contributors (30d) y: 94 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 2 contributors (30d) y: 341 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 1 contributors (30d) y: 213 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 2 contributors (30d) y: 163 lines of code
3090.0
lines of code
  min: 1.0
  average: 290.18
  25th percentile: 83.0
  median: 181.0
  75th percentile: 341.0
  max: 3090.0
0 7.0
contributors (30d)
min: 1.0 | average: 1.78 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 11 commits (90d) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 10 commits (90d) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 25 commits (90d) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 3 commits (90d) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 2 commits (90d) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 1 commits (90d) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 2 commits (90d) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 7 commits (90d) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 23 commits (90d) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 64 commits (90d) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 24 commits (90d) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 27 commits (90d) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 4 commits (90d) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 4 commits (90d) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 2 commits (90d) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 1 commits (90d) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 1 commits (90d) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 2 commits (90d) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 3 commits (90d) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 5 commits (90d) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 4 commits (90d) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 8 commits (90d) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 18 commits (90d) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 16 commits (90d) y: 882 lines of code mkdocs.yml x: 13 commits (90d) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 5 commits (90d) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 17 commits (90d) y: 953 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala x: 4 commits (90d) y: 83 lines of code project/CelebornBuild.scala x: 3 commits (90d) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 10 commits (90d) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 5 commits (90d) y: 193 lines of code build/sbt-launch-lib.bash x: 1 commits (90d) y: 151 lines of code project/plugins.sbt x: 1 commits (90d) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 11 commits (90d) y: 267 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 2 commits (90d) y: 98 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java x: 6 commits (90d) y: 257 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 6 commits (90d) y: 73 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala x: 2 commits (90d) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 25 commits (90d) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 7 commits (90d) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 32 commits (90d) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 3 commits (90d) y: 92 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 4 commits (90d) y: 118 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 3 commits (90d) y: 20 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 12 commits (90d) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 12 commits (90d) y: 287 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java x: 3 commits (90d) y: 80 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 7 commits (90d) y: 191 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 2 commits (90d) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 13 commits (90d) y: 416 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 14 commits (90d) y: 359 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 9 commits (90d) y: 265 lines of code common/src/main/java/org/apache/celeborn/common/client/MasterClient.java x: 3 commits (90d) y: 170 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java x: 1 commits (90d) y: 121 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 2 commits (90d) y: 141 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 5 commits (90d) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 2 commits (90d) y: 334 lines of code client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala x: 11 commits (90d) y: 188 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 9 commits (90d) y: 341 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 10 commits (90d) y: 316 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 11 commits (90d) y: 342 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java x: 6 commits (90d) y: 108 lines of code common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java x: 3 commits (90d) y: 140 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 8 commits (90d) y: 219 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 2 commits (90d) y: 213 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 5 commits (90d) y: 163 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 4 commits (90d) y: 340 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java x: 2 commits (90d) y: 53 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java x: 1 commits (90d) y: 87 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 5 commits (90d) y: 225 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 1 commits (90d) y: 164 lines of code common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java x: 2 commits (90d) y: 177 lines of code charts/celeborn/values.yaml x: 7 commits (90d) y: 110 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 4 commits (90d) y: 445 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 3 commits (90d) y: 176 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java x: 2 commits (90d) y: 41 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 5 commits (90d) y: 49 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 3 commits (90d) y: 100 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 commits (90d) y: 32 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 1 commits (90d) y: 13 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 3 commits (90d) y: 132 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala x: 1 commits (90d) y: 105 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 1 commits (90d) y: 299 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala x: 1 commits (90d) y: 233 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 commits (90d) y: 485 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala x: 1 commits (90d) y: 271 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala x: 1 commits (90d) y: 138 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala x: 1 commits (90d) y: 67 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 1 commits (90d) y: 355 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 commits (90d) y: 497 lines of code client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala x: 4 commits (90d) y: 124 lines of code common/src/main/java/org/apache/celeborn/common/protocol/RpcNameConstants.java x: 2 commits (90d) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala x: 3 commits (90d) y: 240 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigProvider.scala x: 2 commits (90d) y: 24 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 7 commits (90d) y: 587 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 1 commits (90d) y: 322 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 6 commits (90d) y: 248 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 8 commits (90d) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 4 commits (90d) y: 236 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 3 commits (90d) y: 271 lines of code common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java x: 4 commits (90d) y: 59 lines of code common/src/main/java/org/apache/celeborn/common/write/PushState.java x: 3 commits (90d) y: 55 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/network/CelebornRackResolver.scala x: 3 commits (90d) y: 64 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala x: 1 commits (90d) y: 266 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java x: 2 commits (90d) y: 261 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 2 commits (90d) y: 169 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java x: 2 commits (90d) y: 126 lines of code dev/merge_pr.py x: 1 commits (90d) y: 406 lines of code
3090.0
lines of code
  min: 1.0
  average: 179.5
  25th percentile: 42.5
  median: 102.0
  75th percentile: 222.0
  max: 3090.0
0 64.0
commits (90d)
min: 1.0 | average: 4.0 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 64.0

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

client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java x: 8 contributors (90d) y: 485 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 4 contributors (90d) y: 267 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 8 contributors (90d) y: 884 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 3 contributors (90d) y: 118 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java x: 2 contributors (90d) y: 154 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 1 contributors (90d) y: 38 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java x: 2 contributors (90d) y: 380 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 6 contributors (90d) y: 319 lines of code common/src/main/proto/TransportMessages.proto x: 6 contributors (90d) y: 407 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 11 contributors (90d) y: 3090 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 8 contributors (90d) y: 842 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 7 contributors (90d) y: 783 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 2 contributors (90d) y: 228 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 2 contributors (90d) y: 166 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 2 contributors (90d) y: 185 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java x: 1 contributors (90d) y: 75 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java x: 1 contributors (90d) y: 60 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 2 contributors (90d) y: 65 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 3 contributors (90d) y: 253 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 5 contributors (90d) y: 181 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 3 contributors (90d) y: 307 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java x: 5 contributors (90d) y: 364 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 7 contributors (90d) y: 713 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 6 contributors (90d) y: 882 lines of code mkdocs.yml x: 4 contributors (90d) y: 75 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 3 contributors (90d) y: 411 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 8 contributors (90d) y: 953 lines of code project/CelebornBuild.scala x: 1 contributors (90d) y: 588 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 4 contributors (90d) y: 103 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 3 contributors (90d) y: 193 lines of code build/sbt-launch-lib.bash x: 1 contributors (90d) y: 151 lines of code project/plugins.sbt x: 1 contributors (90d) y: 2 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 1 contributors (90d) y: 98 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 3 contributors (90d) y: 73 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 7 contributors (90d) y: 595 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 3 contributors (90d) y: 608 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 10 contributors (90d) y: 1513 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 2 contributors (90d) y: 92 lines of code service/src/main/scala/org/apache/celeborn/server/common/Service.scala x: 2 contributors (90d) y: 20 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 5 contributors (90d) y: 202 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 4 contributors (90d) y: 287 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java x: 2 contributors (90d) y: 80 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 4 contributors (90d) y: 191 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java x: 2 contributors (90d) y: 32 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 6 contributors (90d) y: 416 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 6 contributors (90d) y: 359 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 6 contributors (90d) y: 265 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java x: 1 contributors (90d) y: 121 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java x: 2 contributors (90d) y: 141 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 4 contributors (90d) y: 394 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 2 contributors (90d) y: 334 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 3 contributors (90d) y: 94 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 4 contributors (90d) y: 341 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 5 contributors (90d) y: 316 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 5 contributors (90d) y: 342 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java x: 2 contributors (90d) y: 108 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 5 contributors (90d) y: 219 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 2 contributors (90d) y: 213 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 4 contributors (90d) y: 340 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java x: 1 contributors (90d) y: 87 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 3 contributors (90d) y: 225 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 1 contributors (90d) y: 164 lines of code common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java x: 2 contributors (90d) y: 177 lines of code common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 2 contributors (90d) y: 49 lines of code charts/celeborn/values.yaml x: 4 contributors (90d) y: 110 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 3 contributors (90d) y: 445 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 3 contributors (90d) y: 176 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java x: 2 contributors (90d) y: 41 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 3 contributors (90d) y: 49 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 1 contributors (90d) y: 32 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 1 contributors (90d) y: 13 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 2 contributors (90d) y: 132 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 1 contributors (90d) y: 299 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala x: 1 contributors (90d) y: 233 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 contributors (90d) y: 485 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala x: 1 contributors (90d) y: 271 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala x: 1 contributors (90d) y: 138 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala x: 1 contributors (90d) y: 67 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 1 contributors (90d) y: 355 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 contributors (90d) y: 497 lines of code client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala x: 4 contributors (90d) y: 124 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala x: 2 contributors (90d) y: 240 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 5 contributors (90d) y: 587 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 1 contributors (90d) y: 322 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala x: 2 contributors (90d) y: 10 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala x: 3 contributors (90d) y: 139 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 4 contributors (90d) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 3 contributors (90d) y: 236 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 2 contributors (90d) y: 271 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala x: 1 contributors (90d) y: 266 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java x: 3 contributors (90d) y: 123 lines of code dev/merge_pr.py x: 1 contributors (90d) y: 406 lines of code
3090.0
lines of code
  min: 1.0
  average: 179.5
  25th percentile: 42.5
  median: 102.0
  75th percentile: 222.0
  max: 3090.0
0 11.0
contributors (90d)
min: 1.0 | average: 2.25 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 3.0 | max: 11.0