apache / celeborn
File Size

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

Intro
Learn more...
File Size Overall
15% | 13% | 31% | 18% | 21%
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
scala33% | 13% | 27% | 11% | 13%
java3% | 11% | 37% | 22% | 25%
yaml41% | 25% | 0% | 17% | 16%
proto0% | 87% | 12% | 0% | 0%
h0% | 0% | 32% | 25% | 41%
py0% | 0% | 69% | 20% | 9%
cpp0% | 0% | 20% | 62% | 17%
cmake0% | 0% | 100% | 0% | 0%
tpl0% | 0% | 0% | 72% | 27%
bash0% | 0% | 0% | 100% | 0%
vue0% | 0% | 0% | 0% | 100%
ts0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
mustache0% | 0% | 0% | 0% | 100%
scss0% | 0% | 0% | 0% | 100%
sbt0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
common25% | 13% | 21% | 17% | 21%
client41% | 9% | 33% | 8% | 6%
worker20% | 34% | 19% | 14% | 10%
project82% | 0% | 13% | 0% | 4%
master21% | 26% | 30% | 8% | 12%
openapi9% | 16% | 23% | 20% | 30%
cpp0% | 15% | 25% | 35% | 22%
client-flink0% | 5% | 43% | 26% | 24%
client-spark0% | 4% | 69% | 10% | 15%
client-tez0% | 0% | 56% | 25% | 18%
service0% | 0% | 23% | 27% | 49%
dev0% | 0% | 100% | 0% | 0%
client-mr0% | 0% | 30% | 66% | 2%
cli0% | 0% | 30% | 0% | 69%
charts0% | 0% | 0% | 53% | 46%
multipart-uploader0% | 0% | 0% | 100% | 0%
build0% | 0% | 0% | 77% | 22%
toolkit0% | 0% | 0% | 63% | 36%
web0% | 0% | 0% | 0% | 100%
spi0% | 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
 5367 115
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1889 51
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 1622 57
1459 6
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 1404 34
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 1315 43
ControlMessages.scala
in common/src/main/scala/org/apache/celeborn/common/protocol/message
 1212 25
master_rest_v1.yaml
in openapi/openapi-client/src/main/openapi3
 1110 -
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 1094 42
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 990 93
Worker.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 947 21
PartitionFilesSorter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 866 36
proto
TransportMessages.proto
in common/src/main/proto
 784 -
proto
TransportMessagesCpp.proto
in cpp/celeborn/proto
 784 -
CelebornInputStream.java
in client/src/main/java/org/apache/celeborn/client/read
 780 22
Controller.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 740 9
worker_rest_v1.yaml
in openapi/openapi-client/src/main/openapi3
 687 -
PbSerDeUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 643 38
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 619 54
FlinkShuffleClientImpl.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client
 618 22
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker
 610 54
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker
 610 54
TierWriter.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 586 47
SlotsAllocator.java
in master/src/main/java/org/apache/celeborn/service/deploy/master
 579 7
FetchHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 576 22
MemoryManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory
 554 47
AbstractMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 532 28
SparkUtils.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 523 20
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 509 39
HARaftServer.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 504 30
CelebornColumnType.scala
in client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 466 88
CelebornTierConsumerAgent.java
in client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered
 464 20
CelebornTierConsumerAgent.java
in client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered
 464 20
CelebornColumnType.scala
in client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 463 88
CommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 462 14
CelebornColumnType.scala
in client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 461 88
461 16
RatisApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master
 459 23
RemoteShuffleInputGateDelegation.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 455 25
MapPartitionDataReader.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 448 33
CelebornShuffleManager.java
in client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl
 427 18
SparkUtils.java
in client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn
 402 15
WorkerInfoResponse.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 401 58
CelebornShuffleReader.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn
 400 5
SortBasedPusher.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn
 399 18
TransportResponseHandler.java
in common/src/main/java/org/apache/celeborn/common/network/client
 397 21
HAMasterMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 397 20
CelebornDagAppMaster.java
in client-tez/tez/src/main/java/org/apache/tez/dag/app
 394 8
SparkShuffleManager.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 393 16
CelebornTierProducerAgent.java
in client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered
 386 14
Files With Most Units (Top 50)
File# lines# units
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 5367 115
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 990 93
CelebornColumnType.scala
in client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 461 88
CelebornColumnType.scala
in client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 466 88
CelebornColumnType.scala
in client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 463 88
WorkerInfoResponse.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 401 58
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 1622 57
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 619 54
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker
 610 54
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker
 610 54
WorkerData.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 361 52
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1889 51
ThreadStack.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 335 48
TierWriter.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 586 47
MemoryManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory
 554 47
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 1315 43
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 1094 42
DynMethods.java
in common/src/main/java/org/apache/celeborn/reflect
 262 40
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 509 39
PbSerDeUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 643 38
PartitionLocation.java
in common/src/main/java/org/apache/celeborn/common/protocol
 271 38
StorageInfo.java
in common/src/main/java/org/apache/celeborn/common/protocol
 243 37
TransportConf.java
in common/src/main/java/org/apache/celeborn/common/network/util
 148 37
DynFields.java
in common/src/main/java/org/apache/celeborn/reflect
 225 36
PartitionFilesSorter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 866 36
BufferPacker.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer
 291 34
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 1404 34
MapPartitionDataReader.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 448 33
PartitionMetaHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 340 32
PartitionDataWriter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 221 31
JavaUtils.java
in common/src/main/java/org/apache/celeborn/common/util
 351 30
HARaftServer.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 504 30
ContainerInfo.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 214 30
PartitionLocationData.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 218 29
WorkersResponse.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 211 29
SerializationDebugger.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 266 28
Platform.java
in common/src/main/java/org/apache/celeborn/common/unsafe
 238 28
TransportClient.java
in common/src/main/java/org/apache/celeborn/common/network/client
 320 28
AbstractMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 532 28
CreditStreamManager.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 324 27
MapFileMeta.java
in common/src/main/java/org/apache/celeborn/common/meta
 123 26
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
 455 25
ControlMessages.scala
in common/src/main/scala/org/apache/celeborn/common/protocol/message
 1212 25
CelebornCompressionSchemes.scala
in client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 353 25
CelebornCompressionSchemes.scala
in client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 356 25
CelebornCompressionSchemes.scala
in client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar
 356 25
ThreadUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 298 24
ReducePartitionCommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 340 24
HttpService.scala
in service/src/main/scala/org/apache/celeborn/server/common
 289 24
Files With Long Lines (Top 50)

There are 141 files with lines longer than 120 characters. In total, there are 346 long lines.

File# lines# units# long lines
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 5367 115 30
1459 6 26
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1889 51 20
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 1622 57 15
RatisApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master
 459 23 9
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 1094 42 7
WorkerApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master
 301 15 6
ShufflePartitionsResponse.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 101 11 5
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker
 610 54 5
ApiClient.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker
 610 54 5
ApplicationApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master
 220 11 5
FetchHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 576 22 4
StoragePolicy.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 170 3 4
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 1404 34 4
RatisResource.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1
 328 15 4
configmap.yaml
in charts/celeborn/templates
 46 - 3
CelebornBufferStream.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client
 288 16 3
CommitHandler.scala
in client/src/main/scala/org/apache/celeborn/client/commit
 462 14 3
ApiBaseResource.scala
in service/src/main/scala/org/apache/celeborn/server/common/http/api
 90 5 3
HttpServer.scala
in service/src/main/scala/org/apache/celeborn/server/common/http
 152 7 3
Worker.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 947 21 3
PartitionMetaHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 340 32 3
WorkerInfoResponse.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 401 58 3
WorkerResourceConsumption.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 153 21 3
BaseApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker
 39 10 3
ApiException.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker
 58 12 3
HttpBasicAuth.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth
 31 5 3
ConfApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker
 139 7 3
WorkerApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker
 179 9 3
BaseApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker
 39 10 3
ApiException.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker
 58 12 3
HttpBasicAuth.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth
 31 5 3
ConfApi.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master
 139 7 3
master_rest_v1.yaml
in openapi/openapi-client/src/main/openapi3
 1110 - 3
values.yaml
in charts/celeborn/ci
 99 - 2
statefulset.yaml
in charts/celeborn/templates/worker
 154 - 2
statefulset.yaml
in charts/celeborn/templates/master
 151 - 2
values.yaml
in charts/celeborn
 158 - 2
CelebornScheduler.java
in client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped
 308 14 2
RemoteShuffleOutputGate.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 226 14 2
ChangePartitionManager.scala
in client/src/main/scala/org/apache/celeborn/client
 350 10 2
HttpService.scala
in service/src/main/scala/org/apache/celeborn/server/common
 289 24 2
Controller.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 740 9 2
JVMQuake.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/monitor
 143 6 2
SparkUtils.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 523 20 2
151 - 2
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 1315 43 2
ApiMasterResource.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api
 117 2 2
WorkerResource.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1
 156 6 2
ThreadStack.java
in openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model
 335 48 2
Correlations

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 11 commits (all time) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 334 commits (all time) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 166 commits (all time) y: 947 lines of code charts/celeborn/ci/values.yaml x: 6 commits (all time) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 16 commits (all time) y: 46 lines of code charts/celeborn/templates/master/service.yaml x: 6 commits (all time) y: 63 lines of code charts/celeborn/templates/master/statefulset.yaml x: 16 commits (all time) y: 151 lines of code charts/celeborn/templates/worker/statefulset.yaml x: 15 commits (all time) y: 154 lines of code charts/celeborn/values.yaml x: 32 commits (all time) y: 158 lines of code charts/celeborn/templates/master/_helpers.tpl x: 2 commits (all time) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 4 commits (all time) y: 23 lines of code charts/celeborn/templates/worker/_helpers.tpl x: 2 commits (all time) y: 103 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 35 commits (all time) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 150 commits (all time) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 160 commits (all time) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 37 commits (all time) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 22 commits (all time) y: 579 lines of code project/CelebornBuild.scala x: 125 commits (all time) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 12 commits (all time) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 20 commits (all time) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 40 commits (all time) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 6 commits (all time) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala x: 2 commits (all time) y: 10 lines of code common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala x: 8 commits (all time) y: 16 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 85 commits (all time) y: 990 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfigServiceFactory.java x: 8 commits (all time) y: 35 lines of code master/src/main/proto/Resource.proto x: 22 commits (all time) y: 227 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApplicationResource.scala x: 7 commits (all time) y: 72 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ApplicationApi.java x: 6 commits (all time) y: 220 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 19 commits (all time) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 11 commits (all time) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala x: 10 commits (all time) y: 76 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala x: 6 commits (all time) y: 586 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java x: 3 commits (all time) y: 618 lines of code common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java x: 24 commits (all time) y: 84 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 93 commits (all time) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 47 commits (all time) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 36 commits (all time) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 33 commits (all time) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 26 commits (all time) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 6 commits (all time) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 57 commits (all time) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 176 commits (all time) y: 1315 lines of code multipart-uploader/multipart-uploader-oss/src/main/java/org/apache/celeborn/OssMultipartUploadHandler.java x: 1 commits (all time) y: 111 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java x: 19 commits (all time) y: 221 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 50 commits (all time) y: 866 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/TierWriterHelper.java x: 2 commits (all time) y: 39 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 57 commits (all time) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 56 commits (all time) y: 576 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 103 commits (all time) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 27 commits (all time) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 103 commits (all time) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 2 commits (all time) y: 132 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java x: 4 commits (all time) y: 82 lines of code client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 3 commits (all time) y: 134 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 4 commits (all time) y: 134 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java x: 5 commits (all time) y: 39 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 1 commits (all time) y: 135 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java x: 1 commits (all time) y: 33 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 1 commits (all time) y: 47 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java x: 1 commits (all time) y: 64 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 commits (all time) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 1 commits (all time) y: 464 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java x: 1 commits (all time) y: 90 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java x: 1 commits (all time) y: 172 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 commits (all time) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 33 commits (all time) y: 278 lines of code client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala x: 20 commits (all time) y: 192 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 25 commits (all time) y: 340 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/SerdeVersion.java x: 1 commits (all time) y: 12 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 18 commits (all time) y: 128 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 26 commits (all time) y: 509 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 30 commits (all time) y: 554 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriterContext.java x: 3 commits (all time) y: 126 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandler.scala x: 2 commits (all time) y: 340 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StoragePolicy.scala x: 3 commits (all time) y: 170 lines of code charts/celeborn/templates/_helpers.tpl x: 7 commits (all time) y: 106 lines of code charts/celeborn/templates/master/podmonitor.yaml x: 3 commits (all time) y: 37 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 35 commits (all time) y: 243 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 47 commits (all time) y: 393 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 35 commits (all time) y: 400 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 46 commits (all time) y: 211 lines of code common/src/main/proto/TransportMessages.proto x: 121 commits (all time) y: 784 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala x: 20 commits (all time) y: 31 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 34 commits (all time) y: 344 lines of code cpp/celeborn/utils/CelebornUtils.cpp x: 3 commits (all time) y: 55 lines of code cpp/celeborn/utils/CelebornUtils.h x: 6 commits (all time) y: 71 lines of code common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala x: 3 commits (all time) y: 73 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 32 commits (all time) y: 136 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java x: 31 commits (all time) y: 397 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 31 commits (all time) y: 278 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala x: 4 commits (all time) y: 353 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfig.java x: 8 commits (all time) y: 254 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 19 commits (all time) y: 265 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 31 commits (all time) y: 349 lines of code client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java x: 9 commits (all time) y: 249 lines of code client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java x: 4 commits (all time) y: 13 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 22 commits (all time) y: 254 lines of code multipart-uploader/multipart-uploader-s3/src/main/java/org/apache/celeborn/S3MultipartUploadHandler.java x: 1 commits (all time) y: 160 lines of code common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala x: 12 commits (all time) y: 98 lines of code common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala x: 14 commits (all time) y: 298 lines of code cpp/celeborn/network/TransportClient.h x: 3 commits (all time) y: 92 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java x: 9 commits (all time) y: 136 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala x: 10 commits (all time) y: 36 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 6 commits (all time) y: 34 lines of code common/src/main/java/org/apache/celeborn/common/network/TransportContext.java x: 22 commits (all time) y: 201 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 30 commits (all time) y: 297 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java x: 19 commits (all time) y: 148 lines of code cli/src/main/scala/org/apache/celeborn/cli/master/MasterOptions.scala x: 8 commits (all time) y: 80 lines of code cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommandImpl.scala x: 9 commits (all time) y: 208 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/WorkerResource.scala x: 12 commits (all time) y: 156 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/WorkerApi.java x: 5 commits (all time) y: 301 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java x: 4 commits (all time) y: 361 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ApiUtils.scala x: 6 commits (all time) y: 133 lines of code common/src/main/java/org/apache/celeborn/common/client/MasterClient.java x: 17 commits (all time) y: 188 lines of code client/src/main/java/org/apache/celeborn/client/DummyShuffleClient.java x: 2 commits (all time) y: 175 lines of code common/src/main/java/org/apache/celeborn/common/protocol/StorageInfo.java x: 8 commits (all time) y: 243 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java x: 2 commits (all time) y: 123 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 4 commits (all time) y: 269 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala x: 5 commits (all time) y: 55 lines of code cpp/celeborn/network/MessageDispatcher.h x: 2 commits (all time) y: 62 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java x: 12 commits (all time) y: 174 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/ApiMasterResource.scala x: 8 commits (all time) y: 117 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/RatisResource.scala x: 6 commits (all time) y: 328 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiBaseResource.scala x: 5 commits (all time) y: 90 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/WorkerResource.scala x: 4 commits (all time) y: 63 lines of code cpp/celeborn/network/MessageDispatcher.cpp x: 1 commits (all time) y: 223 lines of code client-mr/mr/src/main/java/org/apache/hadoop/mapreduce/task/reduce/CelebornShuffleConsumer.java x: 5 commits (all time) y: 149 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionData.java x: 5 commits (all time) y: 217 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 9 commits (all time) y: 53 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala x: 50 commits (all time) y: 168 lines of code cpp/celeborn/conf/CelebornConf.cpp x: 2 commits (all time) y: 155 lines of code cpp/celeborn/utils/CelebornException.cpp x: 2 commits (all time) y: 211 lines of code cpp/celeborn/utils/CelebornException.h x: 2 commits (all time) y: 272 lines of code cpp/celeborn/utils/Exceptions.h x: 2 commits (all time) y: 330 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 10 commits (all time) y: 131 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 10 commits (all time) y: 455 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 7 commits (all time) y: 226 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/CelebornBufferStream.java x: 1 commits (all time) y: 288 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 4 commits (all time) y: 464 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 4 commits (all time) y: 386 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java x: 8 commits (all time) y: 134 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java x: 14 commits (all time) y: 40 lines of code common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java x: 12 commits (all time) y: 136 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyMemoryMetrics.java x: 6 commits (all time) y: 158 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java x: 1 commits (all time) y: 197 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 18 commits (all time) y: 280 lines of code client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 7 commits (all time) y: 47 lines of code client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 commits (all time) y: 466 lines of code client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 1 commits (all time) y: 356 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/RpcSource.scala x: 3 commits (all time) y: 12 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java x: 4 commits (all time) y: 159 lines of code client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala x: 10 commits (all time) y: 121 lines of code client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala x: 24 commits (all time) y: 209 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala x: 8 commits (all time) y: 93 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java x: 16 commits (all time) y: 275 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 23 commits (all time) y: 211 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 10 commits (all time) y: 177 lines of code service/src/main/scala/org/apache/celeborn/common/metrics/sink/JsonServlet.scala x: 2 commits (all time) y: 313 lines of code client-tez/tez/src/main/java/org/apache/tez/dag/app/CelebornDagAppMaster.java x: 2 commits (all time) y: 394 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 27 commits (all time) y: 320 lines of code common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java x: 8 commits (all time) y: 50 lines of code cpp/celeborn/proto/TransportMessagesCpp.proto x: 1 commits (all time) y: 784 lines of code client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornShuffleManager.java x: 1 commits (all time) y: 427 lines of code client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornScheduler.java x: 1 commits (all time) y: 308 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerInfoResponse.java x: 3 commits (all time) y: 401 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java x: 20 commits (all time) y: 62 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 47 commits (all time) y: 289 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionDataReader.java x: 2 commits (all time) y: 252 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DbConfigServiceImpl.java x: 7 commits (all time) y: 40 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Inbox.scala x: 5 commits (all time) y: 285 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/authentication/AuthenticationFilter.scala x: 4 commits (all time) y: 176 lines of code client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala x: 17 commits (all time) y: 142 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 25 commits (all time) y: 399 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 21 commits (all time) y: 333 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ThreadStack.java x: 4 commits (all time) y: 335 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java x: 13 commits (all time) y: 324 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java x: 10 commits (all time) y: 291 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java x: 10 commits (all time) y: 228 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionDataReader.java x: 3 commits (all time) y: 448 lines of code common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java x: 21 commits (all time) y: 76 lines of code project/plugins.sbt x: 7 commits (all time) y: 5 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ContainerInfo.java x: 2 commits (all time) y: 214 lines of code common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java x: 12 commits (all time) y: 194 lines of code client-mr/mr/src/main/java/org/apache/celeborn/mapreduce/v2/app/MRAppMasterWithCeleborn.java x: 8 commits (all time) y: 177 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 28 commits (all time) y: 504 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java x: 16 commits (all time) y: 136 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterCommitData.java x: 3 commits (all time) y: 164 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/FsConfigServiceImpl.java x: 11 commits (all time) y: 95 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 11 commits (all time) y: 351 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala x: 11 commits (all time) y: 152 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiClient.java x: 2 commits (all time) y: 610 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/PartitionLocationData.java x: 3 commits (all time) y: 218 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/SendWorkerEventRequest.java x: 4 commits (all time) y: 124 lines of code common/src/main/java/org/apache/celeborn/common/protocol/TransportModuleConstants.java x: 5 commits (all time) y: 13 lines of code common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java x: 17 commits (all time) y: 159 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 18 commits (all time) y: 195 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 24 commits (all time) y: 298 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala x: 7 commits (all time) y: 139 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 24 commits (all time) y: 397 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 12 commits (all time) y: 256 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala x: 3 commits (all time) y: 353 lines of code common/src/main/java/org/apache/celeborn/common/util/ShuffleBlockInfoUtils.java x: 5 commits (all time) y: 128 lines of code common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java x: 5 commits (all time) y: 238 lines of code common/src/main/java/org/apache/celeborn/common/network/ssl/SSLFactory.java x: 3 commits (all time) y: 334 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java x: 14 commits (all time) y: 106 lines of code client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornSortBasedPusher.java x: 3 commits (all time) y: 281 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala x: 14 commits (all time) y: 196 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala x: 10 commits (all time) y: 58 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala x: 14 commits (all time) y: 67 lines of code common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala x: 10 commits (all time) y: 250 lines of code client/src/main/java/org/apache/celeborn/client/ReviveManager.java x: 7 commits (all time) y: 95 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/PushData.java x: 5 commits (all time) y: 84 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/PushMergedData.java x: 4 commits (all time) y: 98 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 2 commits (all time) y: 294 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 2 commits (all time) y: 461 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 10 commits (all time) y: 271 lines of code client/src/main/java/org/apache/celeborn/client/compress/Compressor.java x: 9 commits (all time) y: 28 lines of code
5367.0
lines of code
  min: 1.0
  average: 120.67
  25th percentile: 23.0
  median: 54.0
  75th percentile: 135.0
  max: 5367.0
0 334.0
commits (all time)
min: 1.0 | average: 6.4 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 334.0

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 7 contributors (all time) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 53 contributors (all time) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 36 contributors (all time) y: 947 lines of code charts/celeborn/ci/values.yaml x: 2 contributors (all time) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 7 contributors (all time) y: 46 lines of code charts/celeborn/templates/master/service.yaml x: 3 contributors (all time) y: 63 lines of code charts/celeborn/templates/master/statefulset.yaml x: 4 contributors (all time) y: 151 lines of code charts/celeborn/values.yaml x: 13 contributors (all time) y: 158 lines of code charts/celeborn/templates/master/_helpers.tpl x: 1 contributors (all time) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 1 contributors (all time) y: 23 lines of code charts/celeborn/templates/worker/_helpers.tpl x: 1 contributors (all time) y: 103 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 17 contributors (all time) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 36 contributors (all time) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 30 contributors (all time) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 18 contributors (all time) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 16 contributors (all time) y: 579 lines of code project/CelebornBuild.scala x: 24 contributors (all time) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 7 contributors (all time) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 11 contributors (all time) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 15 contributors (all time) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 6 contributors (all time) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala x: 2 contributors (all time) y: 10 lines of code common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala x: 7 contributors (all time) y: 16 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 32 contributors (all time) y: 990 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfigServiceFactory.java x: 5 contributors (all time) y: 35 lines of code master/src/main/proto/Resource.proto x: 15 contributors (all time) y: 227 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApplicationResource.scala x: 2 contributors (all time) y: 72 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ApplicationApi.java x: 2 contributors (all time) y: 220 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 4 contributors (all time) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 4 contributors (all time) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala x: 7 contributors (all time) y: 76 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala x: 3 contributors (all time) y: 586 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java x: 3 contributors (all time) y: 618 lines of code common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java x: 9 contributors (all time) y: 84 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 28 contributors (all time) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 21 contributors (all time) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 13 contributors (all time) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 17 contributors (all time) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 15 contributors (all time) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 4 contributors (all time) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 24 contributors (all time) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 30 contributors (all time) y: 1315 lines of code multipart-uploader/multipart-uploader-oss/src/main/java/org/apache/celeborn/OssMultipartUploadHandler.java x: 1 contributors (all time) y: 111 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java x: 11 contributors (all time) y: 221 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 15 contributors (all time) y: 866 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/TierWriterHelper.java x: 2 contributors (all time) y: 39 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 23 contributors (all time) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 21 contributors (all time) y: 576 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 29 contributors (all time) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 13 contributors (all time) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 34 contributors (all time) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 1 contributors (all time) y: 132 lines of code client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java x: 2 contributors (all time) y: 134 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 1 contributors (all time) y: 47 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 contributors (all time) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 1 contributors (all time) y: 464 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java x: 1 contributors (all time) y: 172 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 contributors (all time) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 14 contributors (all time) y: 278 lines of code client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala x: 9 contributors (all time) y: 192 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 10 contributors (all time) y: 340 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/SerdeVersion.java x: 1 contributors (all time) y: 12 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java x: 11 contributors (all time) y: 128 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 15 contributors (all time) y: 509 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/JavaSerializer.scala x: 4 contributors (all time) y: 132 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 16 contributors (all time) y: 554 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandler.scala x: 1 contributors (all time) y: 340 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StoragePolicy.scala x: 2 contributors (all time) y: 170 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 16 contributors (all time) y: 243 lines of code client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 12 contributors (all time) y: 219 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 21 contributors (all time) y: 393 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 18 contributors (all time) y: 400 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClient.java x: 21 contributors (all time) y: 211 lines of code common/src/main/proto/TransportMessages.proto x: 25 contributors (all time) y: 784 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala x: 9 contributors (all time) y: 31 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 15 contributors (all time) y: 344 lines of code common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala x: 3 contributors (all time) y: 73 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java x: 16 contributors (all time) y: 136 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java x: 15 contributors (all time) y: 397 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala x: 3 contributors (all time) y: 353 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfig.java x: 4 contributors (all time) y: 254 lines of code common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala x: 14 contributors (all time) y: 265 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 12 contributors (all time) y: 349 lines of code client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java x: 9 contributors (all time) y: 249 lines of code client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java x: 4 contributors (all time) y: 13 lines of code multipart-uploader/multipart-uploader-s3/src/main/java/org/apache/celeborn/S3MultipartUploadHandler.java x: 1 contributors (all time) y: 160 lines of code common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala x: 8 contributors (all time) y: 98 lines of code common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala x: 8 contributors (all time) y: 298 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java x: 6 contributors (all time) y: 136 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/CelebornShuffleDataIO.java x: 3 contributors (all time) y: 38 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala x: 4 contributors (all time) y: 34 lines of code common/src/main/java/org/apache/celeborn/common/network/TransportContext.java x: 13 contributors (all time) y: 201 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 18 contributors (all time) y: 297 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java x: 11 contributors (all time) y: 148 lines of code cli/src/main/scala/org/apache/celeborn/cli/master/MasterOptions.scala x: 5 contributors (all time) y: 80 lines of code cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommandImpl.scala x: 5 contributors (all time) y: 208 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/WorkerApi.java x: 1 contributors (all time) y: 301 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java x: 1 contributors (all time) y: 361 lines of code common/src/main/java/org/apache/celeborn/common/client/MasterClient.java x: 12 contributors (all time) y: 188 lines of code common/src/main/java/org/apache/celeborn/common/protocol/StorageInfo.java x: 4 contributors (all time) y: 243 lines of code common/src/main/java/org/apache/celeborn/common/write/PushState.java x: 8 contributors (all time) y: 68 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java x: 2 contributors (all time) y: 123 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 3 contributors (all time) y: 269 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala x: 5 contributors (all time) y: 55 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java x: 10 contributors (all time) y: 174 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/RatisResource.scala x: 2 contributors (all time) y: 328 lines of code cpp/celeborn/network/MessageDispatcher.cpp x: 1 contributors (all time) y: 223 lines of code client-tez/tez/src/main/java/org/apache/celeborn/client/CelebornTezReader.java x: 2 contributors (all time) y: 62 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionData.java x: 4 contributors (all time) y: 217 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java x: 4 contributors (all time) y: 53 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala x: 24 contributors (all time) y: 168 lines of code cpp/celeborn/utils/CelebornException.cpp x: 1 contributors (all time) y: 211 lines of code cpp/celeborn/utils/Exceptions.h x: 1 contributors (all time) y: 330 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java x: 8 contributors (all time) y: 131 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java x: 7 contributors (all time) y: 455 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java x: 7 contributors (all time) y: 226 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/CelebornBufferStream.java x: 1 contributors (all time) y: 288 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 3 contributors (all time) y: 464 lines of code client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 3 contributors (all time) y: 386 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java x: 7 contributors (all time) y: 134 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java x: 10 contributors (all time) y: 40 lines of code common/src/main/java/org/apache/celeborn/common/network/util/NettyMemoryMetrics.java x: 5 contributors (all time) y: 158 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java x: 4 contributors (all time) y: 71 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java x: 3 contributors (all time) y: 133 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java x: 7 contributors (all time) y: 280 lines of code client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 1 contributors (all time) y: 466 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/RpcSource.scala x: 3 contributors (all time) y: 12 lines of code client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala x: 14 contributors (all time) y: 350 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala x: 3 contributors (all time) y: 93 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java x: 8 contributors (all time) y: 275 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPusher.java x: 10 contributors (all time) y: 211 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfo.scala x: 7 contributors (all time) y: 161 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala x: 9 contributors (all time) y: 177 lines of code service/src/main/scala/org/apache/celeborn/common/metrics/sink/JsonServlet.scala x: 2 contributors (all time) y: 313 lines of code client-tez/tez/src/main/java/org/apache/tez/dag/app/CelebornDagAppMaster.java x: 2 contributors (all time) y: 394 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java x: 16 contributors (all time) y: 320 lines of code cpp/celeborn/proto/TransportMessagesCpp.proto x: 1 contributors (all time) y: 784 lines of code client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornShuffleManager.java x: 1 contributors (all time) y: 427 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java x: 14 contributors (all time) y: 62 lines of code service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala x: 15 contributors (all time) y: 289 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerStatusManager.scala x: 5 contributors (all time) y: 126 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionDataReader.java x: 2 contributors (all time) y: 252 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/Inbox.scala x: 5 contributors (all time) y: 285 lines of code client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala x: 10 contributors (all time) y: 142 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java x: 9 contributors (all time) y: 399 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java x: 10 contributors (all time) y: 333 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java x: 8 contributors (all time) y: 324 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java x: 5 contributors (all time) y: 228 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java x: 5 contributors (all time) y: 105 lines of code common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java x: 7 contributors (all time) y: 194 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/BaseConfigServiceImpl.java x: 4 contributors (all time) y: 85 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigService.java x: 6 contributors (all time) y: 31 lines of code client-mr/mr/src/main/java/org/apache/celeborn/mapreduce/v2/app/MRAppMasterWithCeleborn.java x: 4 contributors (all time) y: 177 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java x: 14 contributors (all time) y: 504 lines of code common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java x: 7 contributors (all time) y: 351 lines of code service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala x: 6 contributors (all time) y: 152 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiClient.java x: 1 contributors (all time) y: 610 lines of code common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java x: 8 contributors (all time) y: 159 lines of code common/src/main/java/org/apache/celeborn/common/meta/MapFileMeta.java x: 3 contributors (all time) y: 123 lines of code common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java x: 8 contributors (all time) y: 195 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 10 contributors (all time) y: 298 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala x: 6 contributors (all time) y: 82 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java x: 3 contributors (all time) y: 156 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java x: 10 contributors (all time) y: 397 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java x: 9 contributors (all time) y: 98 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java x: 9 contributors (all time) y: 256 lines of code common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java x: 5 contributors (all time) y: 238 lines of code client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java x: 6 contributors (all time) y: 106 lines of code client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornSortBasedPusher.java x: 3 contributors (all time) y: 281 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/ThreadPoolSource.scala x: 2 contributors (all time) y: 151 lines of code common/src/main/java/org/apache/celeborn/reflect/DynConstructors.java x: 1 contributors (all time) y: 233 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala x: 2 contributors (all time) y: 294 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala x: 2 contributors (all time) y: 205 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala x: 2 contributors (all time) y: 461 lines of code client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala x: 2 contributors (all time) y: 256 lines of code common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java x: 8 contributors (all time) y: 271 lines of code
5367.0
lines of code
  min: 1.0
  average: 120.67
  25th percentile: 23.0
  median: 54.0
  75th percentile: 135.0
  max: 5367.0
0 53.0
contributors (all time)
min: 1.0 | average: 3.13 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 3.0 | max: 53.0

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 2 commits (30d) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 4 commits (30d) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 1 commits (30d) y: 947 lines of code charts/celeborn/ci/values.yaml x: 3 commits (30d) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 1 commits (30d) y: 46 lines of code charts/celeborn/templates/master/statefulset.yaml x: 9 commits (30d) y: 151 lines of code charts/celeborn/templates/master/_helpers.tpl x: 1 commits (30d) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 1 commits (30d) y: 23 lines of code charts/celeborn/templates/worker/_helpers.tpl x: 1 commits (30d) y: 103 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 1 commits (30d) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 2 commits (30d) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 3 commits (30d) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 3 commits (30d) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 2 commits (30d) y: 579 lines of code project/CelebornBuild.scala x: 3 commits (30d) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 1 commits (30d) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 1 commits (30d) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 1 commits (30d) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 1 commits (30d) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 3 commits (30d) y: 990 lines of code master/src/main/proto/Resource.proto x: 1 commits (30d) y: 227 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 1 commits (30d) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 1 commits (30d) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala x: 2 commits (30d) y: 76 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 1 commits (30d) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 1 commits (30d) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 1 commits (30d) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 commits (30d) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 1 commits (30d) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 1 commits (30d) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 1 commits (30d) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 1 commits (30d) y: 1315 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 1 commits (30d) y: 866 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 1 commits (30d) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 1 commits (30d) y: 576 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 1 commits (30d) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 1 commits (30d) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 1 commits (30d) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 1 commits (30d) y: 132 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 commits (30d) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 commits (30d) y: 386 lines of code
5367.0
lines of code
  min: 9.0
  average: 432.14
  25th percentile: 68.0
  median: 151.0
  75th percentile: 582.5
  max: 5367.0
0 9.0
commits (30d)
min: 1.0 | average: 1.55 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 9.0

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 2 contributors (30d) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 4 contributors (30d) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 1 contributors (30d) y: 947 lines of code charts/celeborn/ci/values.yaml x: 1 contributors (30d) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 1 contributors (30d) y: 46 lines of code charts/celeborn/templates/master/statefulset.yaml x: 1 contributors (30d) y: 151 lines of code charts/celeborn/templates/master/_helpers.tpl x: 1 contributors (30d) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 1 contributors (30d) y: 23 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 1 contributors (30d) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 2 contributors (30d) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 3 contributors (30d) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 3 contributors (30d) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 2 contributors (30d) y: 579 lines of code project/CelebornBuild.scala x: 3 contributors (30d) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 1 contributors (30d) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 1 contributors (30d) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 1 contributors (30d) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 1 contributors (30d) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 3 contributors (30d) y: 990 lines of code master/src/main/proto/Resource.proto x: 1 contributors (30d) y: 227 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 1 contributors (30d) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 1 contributors (30d) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala x: 2 contributors (30d) y: 76 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 1 contributors (30d) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 1 contributors (30d) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 1 contributors (30d) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 1 contributors (30d) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 1 contributors (30d) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 1 contributors (30d) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 1 contributors (30d) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 1 contributors (30d) y: 1315 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 1 contributors (30d) y: 866 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 1 contributors (30d) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala x: 1 contributors (30d) y: 576 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 1 contributors (30d) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 1 contributors (30d) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 1 contributors (30d) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 1 contributors (30d) y: 132 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 contributors (30d) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 contributors (30d) y: 386 lines of code
5367.0
lines of code
  min: 9.0
  average: 432.14
  25th percentile: 68.0
  median: 151.0
  75th percentile: 582.5
  max: 5367.0
0 4.0
contributors (30d)
min: 1.0 | average: 1.21 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 4.0

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 3 commits (90d) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 17 commits (90d) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 3 commits (90d) y: 947 lines of code charts/celeborn/ci/values.yaml x: 3 commits (90d) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 2 commits (90d) y: 46 lines of code charts/celeborn/templates/master/statefulset.yaml x: 11 commits (90d) y: 151 lines of code charts/celeborn/templates/worker/statefulset.yaml x: 10 commits (90d) y: 154 lines of code charts/celeborn/templates/master/_helpers.tpl x: 2 commits (90d) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 2 commits (90d) y: 23 lines of code charts/celeborn/templates/worker/_helpers.tpl x: 2 commits (90d) y: 103 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 2 commits (90d) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 8 commits (90d) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 10 commits (90d) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 4 commits (90d) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 4 commits (90d) y: 579 lines of code project/CelebornBuild.scala x: 13 commits (90d) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 2 commits (90d) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 4 commits (90d) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 4 commits (90d) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 1 commits (90d) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 4 commits (90d) y: 990 lines of code service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfigServiceFactory.java x: 1 commits (90d) y: 35 lines of code master/src/main/proto/Resource.proto x: 1 commits (90d) y: 227 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApplicationResource.scala x: 1 commits (90d) y: 72 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 2 commits (90d) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 2 commits (90d) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala x: 5 commits (90d) y: 586 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java x: 1 commits (90d) y: 618 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 4 commits (90d) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 3 commits (90d) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 2 commits (90d) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 7 commits (90d) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 4 commits (90d) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 1 commits (90d) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 3 commits (90d) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 3 commits (90d) y: 1315 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java x: 2 commits (90d) y: 221 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 1 commits (90d) y: 866 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 3 commits (90d) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 4 commits (90d) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 1 commits (90d) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 3 commits (90d) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 1 commits (90d) y: 132 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java x: 1 commits (90d) y: 47 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 commits (90d) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 1 commits (90d) y: 464 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java x: 1 commits (90d) y: 90 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 commits (90d) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 3 commits (90d) y: 278 lines of code client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala x: 2 commits (90d) y: 192 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 3 commits (90d) y: 340 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 2 commits (90d) y: 509 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/JavaSerializer.scala x: 2 commits (90d) y: 132 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 3 commits (90d) y: 554 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandler.scala x: 1 commits (90d) y: 340 lines of code charts/celeborn/templates/_helpers.tpl x: 2 commits (90d) y: 106 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 1 commits (90d) y: 243 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 3 commits (90d) y: 393 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 4 commits (90d) y: 400 lines of code common/src/main/proto/TransportMessages.proto x: 2 commits (90d) y: 784 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 1 commits (90d) y: 278 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 2 commits (90d) y: 349 lines of code client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java x: 3 commits (90d) y: 249 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 2 commits (90d) y: 254 lines of code multipart-uploader/multipart-uploader-s3/src/main/java/org/apache/celeborn/S3MultipartUploadHandler.java x: 1 commits (90d) y: 160 lines of code common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala x: 1 commits (90d) y: 298 lines of code common/src/main/java/org/apache/celeborn/common/network/TransportContext.java x: 1 commits (90d) y: 201 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 2 commits (90d) y: 297 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java x: 3 commits (90d) y: 148 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java x: 1 commits (90d) y: 361 lines of code
5367.0
lines of code
  min: 6.0
  average: 279.89
  25th percentile: 53.0
  median: 135.0
  75th percentile: 297.0
  max: 5367.0
0 17.0
commits (90d)
min: 1.0 | average: 1.99 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 17.0

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

common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala x: 2 contributors (90d) y: 113 lines of code common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala x: 13 contributors (90d) y: 5367 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala x: 3 contributors (90d) y: 947 lines of code charts/celeborn/ci/values.yaml x: 1 contributors (90d) y: 99 lines of code charts/celeborn/templates/configmap.yaml x: 1 contributors (90d) y: 46 lines of code charts/celeborn/templates/master/statefulset.yaml x: 1 contributors (90d) y: 151 lines of code charts/celeborn/templates/master/_helpers.tpl x: 1 contributors (90d) y: 81 lines of code charts/celeborn/templates/master/priorityclass.yaml x: 1 contributors (90d) y: 23 lines of code common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala x: 2 contributors (90d) y: 619 lines of code client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java x: 8 contributors (90d) y: 1889 lines of code client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala x: 8 contributors (90d) y: 1622 lines of code common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala x: 4 contributors (90d) y: 279 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java x: 4 contributors (90d) y: 579 lines of code project/CelebornBuild.scala x: 6 contributors (90d) y: 1459 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 2 contributors (90d) y: 402 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java x: 4 contributors (90d) y: 523 lines of code client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala x: 4 contributors (90d) y: 462 lines of code common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala x: 1 contributors (90d) y: 9 lines of code common/src/main/scala/org/apache/celeborn/common/util/Utils.scala x: 3 contributors (90d) y: 990 lines of code master/src/main/proto/Resource.proto x: 1 contributors (90d) y: 227 lines of code openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml x: 1 contributors (90d) y: 1110 lines of code openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml x: 1 contributors (90d) y: 687 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala x: 2 contributors (90d) y: 76 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala x: 3 contributors (90d) y: 586 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java x: 1 contributors (90d) y: 618 lines of code common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala x: 4 contributors (90d) y: 1212 lines of code common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala x: 3 contributors (90d) y: 643 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala x: 2 contributors (90d) y: 278 lines of code client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java x: 5 contributors (90d) y: 780 lines of code client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java x: 3 contributors (90d) y: 313 lines of code common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java x: 1 contributors (90d) y: 121 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java x: 3 contributors (90d) y: 532 lines of code master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala x: 3 contributors (90d) y: 1315 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java x: 2 contributors (90d) y: 221 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java x: 1 contributors (90d) y: 866 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/TierWriterHelper.java x: 2 contributors (90d) y: 39 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala x: 3 contributors (90d) y: 740 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala x: 4 contributors (90d) y: 1404 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala x: 1 contributors (90d) y: 185 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala x: 3 contributors (90d) y: 1094 lines of code client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java x: 1 contributors (90d) y: 132 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java x: 1 contributors (90d) y: 269 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java x: 1 contributors (90d) y: 464 lines of code client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java x: 1 contributors (90d) y: 386 lines of code client/src/main/scala/org/apache/celeborn/client/CommitManager.scala x: 3 contributors (90d) y: 278 lines of code client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala x: 2 contributors (90d) y: 192 lines of code client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala x: 3 contributors (90d) y: 340 lines of code common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala x: 2 contributors (90d) y: 509 lines of code common/src/main/scala/org/apache/celeborn/common/serializer/JavaSerializer.scala x: 2 contributors (90d) y: 132 lines of code worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java x: 2 contributors (90d) y: 554 lines of code worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandler.scala x: 1 contributors (90d) y: 340 lines of code client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 1 contributors (90d) y: 243 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java x: 3 contributors (90d) y: 393 lines of code client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala x: 4 contributors (90d) y: 400 lines of code common/src/main/proto/TransportMessages.proto x: 2 contributors (90d) y: 784 lines of code master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java x: 1 contributors (90d) y: 278 lines of code client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java x: 2 contributors (90d) y: 349 lines of code client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java x: 3 contributors (90d) y: 249 lines of code client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java x: 2 contributors (90d) y: 254 lines of code common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala x: 1 contributors (90d) y: 298 lines of code common/src/main/java/org/apache/celeborn/common/network/TransportContext.java x: 1 contributors (90d) y: 201 lines of code common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java x: 2 contributors (90d) y: 297 lines of code common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java x: 3 contributors (90d) y: 148 lines of code openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java x: 1 contributors (90d) y: 361 lines of code
5367.0
lines of code
  min: 6.0
  average: 279.89
  25th percentile: 53.0
  median: 135.0
  75th percentile: 297.0
  max: 5367.0
0 13.0
contributors (90d)
min: 1.0 | average: 1.62 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 13.0