apache / uniffle
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 717 files with 75,896 lines of code.
    • 1 file changed more than 100 times (589 lines of code)
    • 10 files changed 51-100 times (8,957 lines of code)
    • 32 files changed 21-50 times (11,675 lines of code)
    • 137 files changed 6-20 times (24,886 lines of code)
    • 537 files changed 1-5 times (29,789 lines of code)
<1% | 11% | 15% | 32% | 39%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 717 files with 75,896 lines of code.
    • 4 files changed by more than 25 contributors (2,610 lines of code)
    • 42 files changed by 11-25 contributors (18,008 lines of code)
    • 74 files changed by 6-10 contributors (16,097 lines of code)
    • 311 files changed by 2-5 contributors (25,935 lines of code)
    • 286 files changed by 1 contributor (13,246 lines of code)
3% | 23% | 21% | 34% | 17%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, go, xml, yaml, sh, md, txt, js, vue, patch, scala, json, properties, mod, py, html, gitignore, toml, proto, cmd, eslintignore
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java<1% | 12% | 17% | 32% | 37%
proto0% | 100% | 0% | 0% | 0%
go0% | 0% | 0% | 32% | 67%
vue0% | 0% | 0% | 89% | 10%
js0% | 0% | 0% | 21% | 78%
xml0% | 0% | 0% | 47% | 52%
scala0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
toml0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
client-spark6% | 13% | 45% | 14% | 19%
server0% | 37% | 22% | 14% | 25%
internal-client0% | 25% | 18% | 18% | 37%
client0% | 32% | 14% | 32% | 19%
proto0% | 100% | 0% | 0% | 0%
coordinator0% | 0% | 36% | 29% | 33%
common0% | 0% | 8% | 32% | 59%
storage0% | 0% | 9% | 42% | 48%
client-tez0% | 0% | 0% | 68% | 31%
client-mr0% | 0% | 0% | 58% | 41%
dashboard0% | 0% | 0% | 55% | 44%
deploy0% | 0% | 0% | 30% | 69%
conf0% | 0% | 0% | 100% | 0%
ROOT0% | 0% | 0% | 100% | 0%
cli0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
dev0% | 0% | 0% | 0% | 100%
release0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RssShuffleManager.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle
 589 22 2021-12-24 2025-04-25 108 31 frankzfli@tencent.com zuston@apache.org
RssShuffleManager.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle
 354 13 2021-12-24 2025-04-16 89 31 frankzfli@tencent.com xianjingfeng666@gmail.com
ShuffleTaskManager.java
in server/src/main/java/org/apache/uniffle/server
 957 51 2022-07-04 2025-04-30 77 24 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
ShuffleServerConf.java
in server/src/main/java/org/apache/uniffle/server
 686 4 2022-07-04 2025-04-09 65 20 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
proto
Rss.proto
in proto/src/main/proto
 652 - 2021-11-16 2025-04-30 64 21 duanmeng@outlook.com zuston@apache.org
ShuffleWriteClientImpl.java
in client/src/main/java/org/apache/uniffle/client/impl
 1108 31 2022-07-04 2025-04-23 64 28 jerqi1242949407@gmail.com zuston@apache.org
ShuffleServerGrpcService.java
in server/src/main/java/org/apache/uniffle/server
 1719 24 2022-07-04 2025-02-24 62 19 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
RssShuffleWriter.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer
 914 30 2021-11-10 2025-04-25 61 21 colinma@tencent.com zuston@apache.org
ShuffleBufferManager.java
in server/src/main/java/org/apache/uniffle/server/buffer
 765 38 2022-07-04 2025-04-09 60 18 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
ShuffleServer.java
in server/src/main/java/org/apache/uniffle/server
 559 44 2022-07-04 2025-04-01 57 26 jerqi1242949407@gmail.com zhengchenyu16@163.com
ShuffleServerGrpcClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 1243 30 2022-07-04 2025-04-29 53 17 jerqi1242949407@gmail.com zuston@apache.org
RssShuffleWriter.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer
 510 16 2021-11-10 2025-02-07 46 16 colinma@tencent.com zuston@apache.org
WriteBufferManager.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/writer
 592 35 2021-11-10 2025-04-23 45 19 colinma@tencent.com zuston@apache.org
ShuffleFlushManager.java
in server/src/main/java/org/apache/uniffle/server
 264 15 2022-07-04 2024-10-29 43 22 colinma@tencent.com baoloongmao@tencent.com
ShuffleServerMetrics.java
in server/src/main/java/org/apache/uniffle/server
 480 14 2022-07-04 2025-02-24 42 17 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
LocalStorageManager.java
in server/src/main/java/org/apache/uniffle/server/storage
 416 15 2022-07-04 2025-02-24 38 18 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
RssSparkConfig.java
in client-spark/common/src/main/java/org/apache/spark/shuffle
 427 7 2022-05-09 2024-11-26 38 19 colinma@tencent.com baoloongmao@tencent.com
SimpleClusterManager.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 429 32 2022-07-04 2025-01-26 35 17 jerqi1242949407@gmail.com zuston@apache.org
RssShuffleManagerBase.java
in client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager
 1314 60 2023-04-10 2025-04-27 34 10 xianjin@apache.org zuston@apache.org
RssClientConf.java
in common/src/main/java/org/apache/uniffle/common/config
 289 - 2022-10-26 2025-03-26 33 13 zuston@apache.org zuston@apache.org
ShuffleServerNettyHandler.java
in server/src/main/java/org/apache/uniffle/server/netty
 963 14 2023-05-17 2024-11-26 33 14 31424839+leixm@users.norepl... baoloongmao@tencent.com
RssBaseConf.java
in common/src/main/java/org/apache/uniffle/common/config
 301 1 2022-07-04 2025-03-24 32 18 jerqi1242949407@gmail.com rickyma@tencent.com
RssShuffleReader.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader
 332 8 2021-11-16 2025-04-30 32 18 duanmeng@outlook.com zuston@apache.org
ShuffleServerGrpcNettyClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 488 11 2023-05-08 2025-04-29 31 12 31424839+leixm@users.norepl... zuston@apache.org
CoordinatorServer.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 235 17 2022-07-04 2025-03-14 30 16 jerqi1242949407@gmail.com summaryzb@gmail.com
DelegationRssShuffleManager.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle
 269 13 2022-01-26 2025-01-07 28 15 duanmeng@outlook.com baoloongmao@tencent.com
RssUtils.java
in common/src/main/java/org/apache/uniffle/common/util
 373 21 2022-07-04 2024-10-16 28 17 jerqi1242949407@gmail.com zuston@apache.org
CoordinatorGrpcService.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 497 17 2022-07-04 2024-11-19 28 14 jerqi1242949407@gmail.com baoloongmao@tencent.com
CoordinatorConf.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 241 3 2022-07-04 2024-08-09 27 13 junfan.zhang@outlook.com baoloongmao@tencent.com
RssSparkShuffleUtils.java
in client-spark/common/src/main/java/org/apache/spark/shuffle
 325 18 2022-04-28 2025-04-27 27 20 frankzfli@tencent.com zuston@apache.org
ApplicationManager.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 421 29 2022-07-04 2025-04-16 27 15 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
ShuffleReadClientImpl.java
in client/src/main/java/org/apache/uniffle/client/impl
 287 8 2022-07-04 2025-04-29 25 10 jerqi1242949407@gmail.com zuston@apache.org
ShuffleHandlerFactory.java
in storage/src/main/java/org/apache/uniffle/storage/factory
 173 8 2022-07-04 2025-04-29 23 13 jerqi1242949407@gmail.com zuston@apache.org
LocalStorage.java
in storage/src/main/java/org/apache/uniffle/storage/common
 275 39 2022-07-04 2024-11-26 23 13 jerqi1242949407@gmail.com baoloongmao@tencent.com
LocalStorageChecker.java
in server/src/main/java/org/apache/uniffle/server
 284 11 2022-07-04 2025-03-04 23 13 jerqi1242949407@gmail.com summaryzb@gmail.com
CoordinatorGrpcClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 379 14 2022-07-04 2024-11-19 23 14 jerqi1242949407@gmail.com baoloongmao@tencent.com
ShuffleBuffer.java
in server/src/main/java/org/apache/uniffle/server/buffer
 36 - 2022-07-04 2024-10-17 22 10 jerqi1242949407@gmail.com baoloongmao@tencent.com
Constants.java
in common/src/main/java/org/apache/uniffle/common/util
 59 1 2022-07-04 2024-11-26 22 11 jerqi1242949407@gmail.com baoloongmao@tencent.com
ShuffleWriteClient.java
in client/src/main/java/org/apache/uniffle/client/api
 208 8 2022-07-04 2024-12-09 22 12 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
RssShuffleReader.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader
 252 10 2021-12-24 2024-07-26 22 16 frankzfli@tencent.com jam.xu@vipshop.com
RegisterHeartBeat.java
in server/src/main/java/org/apache/uniffle/server
 82 5 2022-07-04 2025-03-04 21 15 jerqi1242949407@gmail.com summaryzb@gmail.com
DelegationRssShuffleManager.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle
 191 11 2022-01-26 2025-01-07 21 12 duanmeng@outlook.com baoloongmao@tencent.com
ShuffleTaskInfo.java
in server/src/main/java/org/apache/uniffle/server
 283 36 2022-08-18 2024-12-09 21 10 84573424+smallzhongfeng@use... 33595968+yl09099@users.nore...
ShuffleManagerGrpcService.java
in client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager
 677 30 2023-03-30 2025-04-30 20 7 xianjin@apache.org zuston@apache.org
GrpcServer.java
in common/src/main/java/org/apache/uniffle/common/rpc
 211 18 2022-07-04 2024-10-18 19 11 jerqi1242949407@gmail.com baoloongmao@tencent.com
RssShuffleDataIterator.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/reader
 174 8 2021-12-24 2024-08-20 18 12 frankzfli@tencent.com 643348094@qq.com
DefaultFlushEventHandler.java
in server/src/main/java/org/apache/uniffle/server
 239 12 2023-07-11 2024-11-19 18 12 31424839+leixm@users.norepl... zuston@apache.org
ShuffleClientFactory.java
in client/src/main/java/org/apache/uniffle/client/factory
 339 81 2022-07-04 2025-04-29 18 10 jerqi1242949407@gmail.com zuston@apache.org
ServerNode.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 341 35 2022-07-04 2025-04-28 18 9 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
RssDAGAppMaster.java
in client-tez/src/main/java/org/apache/tez/dag/app
 567 23 2023-06-06 2025-04-20 18 8 694360875@qq.com 21970289+qijiale76@users.no...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RssShuffleManager.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle
 589 22 2021-12-24 2025-04-25 108 31 frankzfli@tencent.com zuston@apache.org
RssShuffleManager.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle
 354 13 2021-12-24 2025-04-16 89 31 frankzfli@tencent.com xianjingfeng666@gmail.com
ShuffleWriteClientImpl.java
in client/src/main/java/org/apache/uniffle/client/impl
 1108 31 2022-07-04 2025-04-23 64 28 jerqi1242949407@gmail.com zuston@apache.org
ShuffleServer.java
in server/src/main/java/org/apache/uniffle/server
 559 44 2022-07-04 2025-04-01 57 26 jerqi1242949407@gmail.com zhengchenyu16@163.com
ShuffleTaskManager.java
in server/src/main/java/org/apache/uniffle/server
 957 51 2022-07-04 2025-04-30 77 24 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
ShuffleFlushManager.java
in server/src/main/java/org/apache/uniffle/server
 264 15 2022-07-04 2024-10-29 43 22 colinma@tencent.com baoloongmao@tencent.com
proto
Rss.proto
in proto/src/main/proto
 652 - 2021-11-16 2025-04-30 64 21 duanmeng@outlook.com zuston@apache.org
RssShuffleWriter.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer
 914 30 2021-11-10 2025-04-25 61 21 colinma@tencent.com zuston@apache.org
ShuffleServerConf.java
in server/src/main/java/org/apache/uniffle/server
 686 4 2022-07-04 2025-04-09 65 20 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
RssSparkShuffleUtils.java
in client-spark/common/src/main/java/org/apache/spark/shuffle
 325 18 2022-04-28 2025-04-27 27 20 frankzfli@tencent.com zuston@apache.org
ShuffleServerGrpcService.java
in server/src/main/java/org/apache/uniffle/server
 1719 24 2022-07-04 2025-02-24 62 19 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
WriteBufferManager.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/writer
 592 35 2021-11-10 2025-04-23 45 19 colinma@tencent.com zuston@apache.org
RssSparkConfig.java
in client-spark/common/src/main/java/org/apache/spark/shuffle
 427 7 2022-05-09 2024-11-26 38 19 colinma@tencent.com baoloongmao@tencent.com
ShuffleBufferManager.java
in server/src/main/java/org/apache/uniffle/server/buffer
 765 38 2022-07-04 2025-04-09 60 18 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
LocalStorageManager.java
in server/src/main/java/org/apache/uniffle/server/storage
 416 15 2022-07-04 2025-02-24 38 18 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
RssBaseConf.java
in common/src/main/java/org/apache/uniffle/common/config
 301 1 2022-07-04 2025-03-24 32 18 jerqi1242949407@gmail.com rickyma@tencent.com
RssShuffleReader.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader
 332 8 2021-11-16 2025-04-30 32 18 duanmeng@outlook.com zuston@apache.org
ShuffleServerGrpcClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 1243 30 2022-07-04 2025-04-29 53 17 jerqi1242949407@gmail.com zuston@apache.org
ShuffleServerMetrics.java
in server/src/main/java/org/apache/uniffle/server
 480 14 2022-07-04 2025-02-24 42 17 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
SimpleClusterManager.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 429 32 2022-07-04 2025-01-26 35 17 jerqi1242949407@gmail.com zuston@apache.org
RssUtils.java
in common/src/main/java/org/apache/uniffle/common/util
 373 21 2022-07-04 2024-10-16 28 17 jerqi1242949407@gmail.com zuston@apache.org
RssShuffleWriter.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer
 510 16 2021-11-10 2025-02-07 46 16 colinma@tencent.com zuston@apache.org
CoordinatorServer.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 235 17 2022-07-04 2025-03-14 30 16 jerqi1242949407@gmail.com summaryzb@gmail.com
RssShuffleReader.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader
 252 10 2021-12-24 2024-07-26 22 16 frankzfli@tencent.com jam.xu@vipshop.com
DelegationRssShuffleManager.java
in client-spark/spark3/src/main/java/org/apache/spark/shuffle
 269 13 2022-01-26 2025-01-07 28 15 duanmeng@outlook.com baoloongmao@tencent.com
ApplicationManager.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 421 29 2022-07-04 2025-04-16 27 15 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
RegisterHeartBeat.java
in server/src/main/java/org/apache/uniffle/server
 82 5 2022-07-04 2025-03-04 21 15 jerqi1242949407@gmail.com summaryzb@gmail.com
ShuffleServerNettyHandler.java
in server/src/main/java/org/apache/uniffle/server/netty
 963 14 2023-05-17 2024-11-26 33 14 31424839+leixm@users.norepl... baoloongmao@tencent.com
CoordinatorGrpcService.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 497 17 2022-07-04 2024-11-19 28 14 jerqi1242949407@gmail.com baoloongmao@tencent.com
CoordinatorGrpcClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 379 14 2022-07-04 2024-11-19 23 14 jerqi1242949407@gmail.com baoloongmao@tencent.com
RssClientConf.java
in common/src/main/java/org/apache/uniffle/common/config
 289 - 2022-10-26 2025-03-26 33 13 zuston@apache.org zuston@apache.org
CoordinatorConf.java
in coordinator/src/main/java/org/apache/uniffle/coordinator
 241 3 2022-07-04 2024-08-09 27 13 junfan.zhang@outlook.com baoloongmao@tencent.com
LocalStorageChecker.java
in server/src/main/java/org/apache/uniffle/server
 284 11 2022-07-04 2025-03-04 23 13 jerqi1242949407@gmail.com summaryzb@gmail.com
LocalStorage.java
in storage/src/main/java/org/apache/uniffle/storage/common
 275 39 2022-07-04 2024-11-26 23 13 jerqi1242949407@gmail.com baoloongmao@tencent.com
ShuffleHandlerFactory.java
in storage/src/main/java/org/apache/uniffle/storage/factory
 173 8 2022-07-04 2025-04-29 23 13 jerqi1242949407@gmail.com zuston@apache.org
ShuffleServerGrpcNettyClient.java
in internal-client/src/main/java/org/apache/uniffle/client/impl/grpc
 488 11 2023-05-08 2025-04-29 31 12 31424839+leixm@users.norepl... zuston@apache.org
ShuffleWriteClient.java
in client/src/main/java/org/apache/uniffle/client/api
 208 8 2022-07-04 2024-12-09 22 12 jerqi1242949407@gmail.com 33595968+yl09099@users.nore...
DelegationRssShuffleManager.java
in client-spark/spark2/src/main/java/org/apache/spark/shuffle
 191 11 2022-01-26 2025-01-07 21 12 duanmeng@outlook.com baoloongmao@tencent.com
RssShuffleDataIterator.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/reader
 174 8 2021-12-24 2024-08-20 18 12 frankzfli@tencent.com 643348094@qq.com
DefaultFlushEventHandler.java
in server/src/main/java/org/apache/uniffle/server
 239 12 2023-07-11 2024-11-19 18 12 31424839+leixm@users.norepl... zuston@apache.org
Constants.java
in common/src/main/java/org/apache/uniffle/common/util
 59 1 2022-07-04 2024-11-26 22 11 jerqi1242949407@gmail.com baoloongmao@tencent.com
GrpcServer.java
in common/src/main/java/org/apache/uniffle/common/rpc
 211 18 2022-07-04 2024-10-18 19 11 jerqi1242949407@gmail.com baoloongmao@tencent.com
RssClientConfig.java
in client/src/main/java/org/apache/uniffle/client/util
 71 - 2022-07-04 2025-04-10 17 11 jerqi1242949407@gmail.com andras.salamon@melda.info
WriteBufferManager.java
in client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer
 433 12 2023-06-10 2024-10-10 16 11 74609438+bin41215@users.nor... zhengchenyu16@163.com
ClientUtils.java
in client/src/main/java/org/apache/uniffle/client/util
 94 6 2022-07-04 2024-07-05 14 11 jerqi1242949407@gmail.com qijiale76@foxmail.com
LocalStorageMeta.java
in storage/src/main/java/org/apache/uniffle/storage/common
 95 15 2022-07-04 2025-04-16 13 11 jerqi1242949407@gmail.com xianjingfeng666@gmail.com
RssShuffleManagerBase.java
in client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager
 1314 60 2023-04-10 2025-04-27 34 10 xianjin@apache.org zuston@apache.org
ShuffleReadClientImpl.java
in client/src/main/java/org/apache/uniffle/client/impl
 287 8 2022-07-04 2025-04-29 25 10 jerqi1242949407@gmail.com zuston@apache.org
ShuffleBuffer.java
in server/src/main/java/org/apache/uniffle/server/buffer
 36 - 2022-07-04 2024-10-17 22 10 jerqi1242949407@gmail.com baoloongmao@tencent.com
ShuffleTaskInfo.java
in server/src/main/java/org/apache/uniffle/server
 283 36 2022-08-18 2024-12-09 21 10 84573424+smallzhongfeng@use... 33595968+yl09099@users.nore...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
Partition.java
in server/src/main/java/org/apache/uniffle/server/merge
 434 30 2024-08-12 2024-10-22 3 1 zhengchenyu16@163.com zhengchenyu16@163.com
BlockFlushFileReader.java
in server/src/main/java/org/apache/uniffle/server/merge
 402 33 2024-08-12 2024-10-22 2 1 zhengchenyu16@163.com zhengchenyu16@163.com
ShufflePage.scala
in client-spark/extension/src/main/scala/org/apache/spark/ui
 299 7 2025-04-25 2025-04-30 4 1 zuston@apache.org zuston@apache.org
RecordCollector.java
in client-mr/core/src/main/java/org/apache/uniffle/client/shuffle
 288 36 2024-09-29 2024-09-29 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
ThreadPoolManager.java
in common/src/main/java/org/apache/uniffle/common/executor
 265 13 2024-10-09 2024-10-16 2 1 baoloongmao@tencent.com baoloongmao@tencent.com
UniffleClientSimOnYarnAppMaster.java
in tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator
 249 13 2025-01-03 2025-01-03 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
RMRssOrderedGroupedKVInput.java
in client-tez/src/main/java/org/apache/tez/runtime/library/input
 248 10 2024-10-10 2024-10-10 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
RMRssShuffle.java
in client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped
 225 11 2024-10-10 2024-10-22 2 1 zhengchenyu16@163.com zhengchenyu16@163.com
RMRssShuffle.java
in client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce
 207 13 2024-09-29 2025-03-12 3 1 zhengchenyu16@163.com zhengchenyu16@163.com
syncer.go
in deploy/kubernetes/operator/pkg/webhook/syncer
 204 10 2022-09-01 2022-09-01 1 1 jasonawang@tencent.com jasonawang@tencent.com
Merger.java
in common/src/main/java/org/apache/uniffle/common/merger
 188 12 2024-07-22 2024-10-22 2 1 zhengchenyu16@163.com zhengchenyu16@163.com
certs.go
in deploy/kubernetes/operator/pkg/utils
 185 9 2022-09-01 2022-09-01 1 1 jasonawang@tencent.com jasonawang@tencent.com
manager.go
in deploy/kubernetes/operator/pkg/webhook
 180 6 2022-09-01 2024-09-04 2 1 jasonawang@tencent.com jasonawang@tencent.com
RssInMemoryMerger.java
in client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped
 173 4 2023-10-19 2023-10-19 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
UniffleClientSimOnYarnClient.java
in tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator
 173 3 2025-01-03 2025-01-03 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
UniffleTask.java
in tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator
 159 3 2025-01-03 2025-01-03 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
JvmPauseMonitor.java
in common/src/main/java/org/apache/uniffle/common/util
 154 15 2024-01-19 2024-01-19 1 1 zuston@apache.org zuston@apache.org
BlockIdLayout.java
in common/src/main/java/org/apache/uniffle/common/util
 147 12 2024-03-07 2024-03-12 2 1 github@enrico.minack.dev github@enrico.minack.dev
DynamicClientConfService.java
in coordinator/src/main/java/org/apache/uniffle/coordinator/conf
 131 7 2023-11-30 2023-11-30 1 1 zuston@apache.org zuston@apache.org
DashboardPage.vue
in dashboard/src/main/webapp/src/pages
 129 - 2024-08-22 2024-08-22 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
PrefetchableClientReadHandler.java
in storage/src/main/java/org/apache/uniffle/storage/handler/impl
 122 5 2025-02-08 2025-02-11 2 1 zuston@apache.org zuston@apache.org
MergedResult.java
in server/src/main/java/org/apache/uniffle/server/merge
 116 11 2024-08-12 2024-10-22 2 1 zhengchenyu16@163.com zhengchenyu16@163.com
rss-controller.yaml
in deploy/kubernetes/operator/config/manager
 114 - 2022-09-23 2023-04-26 2 1 jasonawang@tencent.com jasonawang@tencent.com
TopNShuffleDataSizeOfAppCalcTask.java
in server/src/main/java/org/apache/uniffle/server
 111 4 2024-01-12 2024-01-12 1 1 1169158401@qq.com 1169158401@qq.com
RemoteFetchedInput.java
in client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle
 108 10 2023-10-31 2023-10-31 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
SendShuffleDataRequestV1.java
in common/src/main/java/org/apache/uniffle/common/netty/protocol
 108 16 2024-10-31 2024-10-31 1 1 mr.liwenlong@outlook.com mr.liwenlong@outlook.com
HadoopConfigApp.java
in tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator
 106 6 2025-01-03 2025-01-03 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
CompositeFileRegion.java
in common/src/main/java/io/netty/util
 106 12 2024-11-26 2024-11-26 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
UniffleListener.scala
in client-spark/extension/src/main/scala/org/apache/spark
 102 10 2025-04-25 2025-04-30 4 1 zuston@apache.org zuston@apache.org
AbstractSegmentSplitter.java
in common/src/main/java/org/apache/uniffle/common/segment
 101 2 2024-11-26 2024-11-26 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
UniffleStatusStore.scala
in client-spark/extension/src/main/scala/org/apache/spark
 99 11 2025-04-25 2025-04-30 4 1 zuston@apache.org zuston@apache.org
RssReportShuffleReadMetricRequest.java
in internal-client/src/main/java/org/apache/uniffle/client/request
 96 10 2025-04-25 2025-04-30 3 1 zuston@apache.org zuston@apache.org
FileSerInputStream.java
in common/src/main/java/org/apache/uniffle/common/serializer
 95 9 2024-10-22 2024-10-22 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
KryoSerializerInstance.java
in common/src/main/java/org/apache/uniffle/common/serializer/kryo
 88 7 2025-03-14 2025-03-14 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
GetLocalShuffleIndexV2Response.java
in common/src/main/java/org/apache/uniffle/common/netty/protocol
 87 7 2024-11-26 2024-11-26 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
config.go
in deploy/kubernetes/operator/pkg/webhook/config
 85 8 2022-09-01 2024-09-04 2 1 jasonawang@tencent.com jasonawang@tencent.com
statefulset.go
in deploy/kubernetes/operator/pkg/controller/util/kubernetes
 83 3 2022-09-20 2022-09-20 1 1 jasonawang@tencent.com jasonawang@tencent.com
PartitionDataReplicaRequirementTracking.java
in client/src/main/java/org/apache/uniffle/client
 83 6 2024-04-17 2024-05-09 2 1 zuston@apache.org zuston@apache.org
DefaultMergeEventHandler.java
in server/src/main/java/org/apache/uniffle/server/merge
 82 8 2024-08-12 2024-10-22 2 1 zhengchenyu16@163.com zhengchenyu16@163.com
MultiPartLocalStorageManager.java
in server/src/main/java/org/apache/uniffle/server/storage
 82 4 2024-11-26 2024-11-26 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
RpcAuditContext.java
in common/src/main/java/org/apache/uniffle/common/audit
 80 11 2024-08-28 2024-08-28 1 1 baoloongmao@tencent.com baoloongmao@tencent.com
GetSortedShuffleDataRequest.java
in common/src/main/java/org/apache/uniffle/common/netty/protocol
 79 12 2024-10-22 2024-10-22 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
KryoDeserializationStream.java
in common/src/main/java/org/apache/uniffle/common/serializer/kryo
 78 7 2025-03-14 2025-03-14 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
service.go
in deploy/kubernetes/operator/pkg/controller/util/kubernetes
 78 4 2022-09-20 2022-09-20 1 1 jasonawang@tencent.com jasonawang@tencent.com
rss.go
in deploy/kubernetes/operator/pkg/utils
 76 4 2023-02-02 2023-02-02 1 1 jasonawang@tencent.com jasonawang@tencent.com
AsynDeletionEventManager.java
in storage/src/main/java/org/apache/uniffle/storage/handler/impl
 76 3 2025-02-24 2025-02-24 1 1 33595968+yl09099@users.nore... 33595968+yl09099@users.nore...
BufferedRawWritableDeserializationStream.java
in common/src/main/java/org/apache/uniffle/common/serializer/writable
 74 6 2024-10-22 2024-10-22 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
ExpiringCloseableSupplier.java
in common/src/main/java/org/apache/uniffle/common/util
 74 8 2024-07-26 2024-07-26 1 1 jam.xu@vipshop.com jam.xu@vipshop.com
RecordBuffer.java
in client/src/main/java/org/apache/uniffle/client/record
 72 13 2024-09-11 2024-09-11 1 1 zhengchenyu16@163.com zhengchenyu16@163.com
ShuffleServerPushCostTracker.java
in client/src/main/java/org/apache/uniffle/client/impl
 72 6 2025-04-23 2025-04-25 2 1 zuston@apache.org zuston@apache.org
Correlations

File Size vs. Number of Changes: 719 points

client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleReadMetric.java x: 44 lines of code y: 2 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java x: 677 lines of code y: 20 # changes client-spark/extension/src/main/scala/org/apache/spark/UniffleListener.scala x: 102 lines of code y: 4 # changes client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala x: 99 lines of code y: 4 # changes client-spark/extension/src/main/scala/org/apache/spark/ui/ShufflePage.scala x: 299 lines of code y: 4 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 332 lines of code y: 32 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleReadMetricRequest.java x: 96 lines of code y: 3 # changes proto/src/main/proto/Rss.proto x: 652 lines of code y: 64 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/ShuffleServerReadCost.java x: 69 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java x: 957 lines of code y: 77 # changes client/src/main/java/org/apache/uniffle/client/factory/ShuffleClientFactory.java x: 339 lines of code y: 18 # changes client/src/main/java/org/apache/uniffle/client/impl/ShuffleReadClientImpl.java x: 287 lines of code y: 25 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ClientInfo.java x: 26 lines of code y: 1 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerClient.java x: 52 lines of code y: 8 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java x: 1243 lines of code y: 53 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java x: 488 lines of code y: 31 # changes storage/src/main/java/org/apache/uniffle/storage/factory/ShuffleHandlerFactory.java x: 173 lines of code y: 23 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandler.java x: 219 lines of code y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileClientReadHandler.java x: 175 lines of code y: 12 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java x: 105 lines of code y: 12 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/ShuffleServerReadCostTracker.java x: 24 lines of code y: 1 # changes storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleReadHandlerRequest.java x: 195 lines of code y: 13 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkShuffleUtils.java x: 325 lines of code y: 27 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java x: 1314 lines of code y: 34 # changes client-spark/extension/src/main/scala/org/apache/spark/UniffleHistoryServerPlugin.scala x: 16 lines of code y: 1 # changes client-spark/extension/src/main/scala/org/apache/spark/UnifflePlugin.scala x: 38 lines of code y: 2 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleMetric.java x: 15 lines of code y: 1 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleWriteMetric.java x: 6 lines of code y: 1 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/events/UniffleEvent.java x: 7 lines of code y: 1 # changes client-spark/extension/src/main/scala/org/apache/spark/ui/ShuffleTab.scala x: 12 lines of code y: 1 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 589 lines of code y: 108 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 914 lines of code y: 61 # changes client/src/main/java/org/apache/uniffle/client/impl/ShuffleServerPushCostTracker.java x: 72 lines of code y: 2 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleManagerClient.java x: 39 lines of code y: 14 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleManagerGrpcClient.java x: 144 lines of code y: 15 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleWriteMetricRequest.java x: 51 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/web/JettyServer.java x: 146 lines of code y: 11 # changes common/src/main/java/org/apache/uniffle/common/web/resource/MetricResource.java x: 50 lines of code y: 4 # changes dashboard/src/main/java/org/apache/uniffle/dashboard/web/Dashboard.java x: 135 lines of code y: 4 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/AddBlockEvent.java x: 47 lines of code y: 8 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java x: 144 lines of code y: 10 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java x: 592 lines of code y: 45 # changes client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java x: 1108 lines of code y: 64 # changes client/src/main/java/org/apache/uniffle/client/response/SendShuffleDataResult.java x: 33 lines of code y: 5 # changes client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java x: 567 lines of code y: 18 # changes internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleServerClientFactory.java x: 52 lines of code y: 10 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 354 lines of code y: 89 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssShuffleManager.java x: 1211 lines of code y: 10 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleScheduler.java x: 1647 lines of code y: 16 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/ApplicationManager.java x: 421 lines of code y: 27 # changes server/src/main/java/org/apache/uniffle/server/merge/Shuffle.java x: 82 lines of code y: 4 # changes server/src/main/java/org/apache/uniffle/server/merge/ShuffleMergeManager.java x: 268 lines of code y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java x: 95 lines of code y: 13 # changes storage/src/main/java/org/apache/uniffle/storage/common/DefaultStorageMediaProvider.java x: 92 lines of code y: 9 # changes client/src/main/java/org/apache/uniffle/client/util/RssClientConfig.java x: 71 lines of code y: 17 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerConf.java x: 686 lines of code y: 65 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java x: 765 lines of code y: 60 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssMergeManager.java x: 497 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServer.java x: 559 lines of code y: 57 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/MutableShuffleHandleInfo.java x: 315 lines of code y: 5 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/ShuffleHandleInfo.java x: 17 lines of code y: 3 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/SimpleShuffleHandleInfo.java x: 49 lines of code y: 3 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/StageAttemptShuffleHandleInfo.java x: 103 lines of code y: 3 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/split/PartitionSplitInfo.java x: 32 lines of code y: 1 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/TaskAttemptAssignment.java x: 35 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java x: 289 lines of code y: 33 # changes common/src/main/java/org/apache/uniffle/common/config/RssBaseConf.java x: 301 lines of code y: 32 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorServer.java x: 235 lines of code y: 30 # changes common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java x: 95 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoDeserializationStream.java x: 78 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializationStream.java x: 57 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializerInstance.java x: 88 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/kryo/PoolWrapper.java x: 40 lines of code y: 1 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RMRssShuffle.java x: 207 lines of code y: 3 # changes client/src/main/java/org/apache/uniffle/client/record/reader/KeyValueReader.java x: 7 lines of code y: 2 # changes client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java x: 594 lines of code y: 6 # changes common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java x: 58 lines of code y: 6 # changes server/src/main/java/org/apache/uniffle/server/LocalStorageChecker.java x: 284 lines of code y: 23 # changes server/src/main/java/org/apache/uniffle/server/RegisterHeartBeat.java x: 82 lines of code y: 21 # changes server/src/main/java/org/apache/uniffle/server/storage/SingleStorageManager.java x: 132 lines of code y: 9 # changes common/src/main/java/org/apache/uniffle/common/ReconfigurableRegistry.java x: 90 lines of code y: 3 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java x: 1719 lines of code y: 62 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerMetrics.java x: 480 lines of code y: 42 # changes server/src/main/java/org/apache/uniffle/server/event/PurgeEvent.java x: 46 lines of code y: 3 # changes server/src/main/java/org/apache/uniffle/server/event/ShufflePurgeEvent.java x: 11 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManager.java x: 189 lines of code y: 12 # changes server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManager.java x: 416 lines of code y: 38 # changes storage/src/main/java/org/apache/uniffle/storage/handler/AsynDeletionEvent.java x: 54 lines of code y: 1 # changes storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleDeleteHandler.java x: 4 lines of code y: 3 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/AsynDeletionEventManager.java x: 76 lines of code y: 1 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleDeleteHandler.java x: 96 lines of code y: 5 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileAsyncDeleteHandler.java x: 69 lines of code y: 1 # changes storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleDeleteHandlerRequest.java x: 38 lines of code y: 3 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataSkippableReadHandler.java x: 77 lines of code y: 9 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/PrefetchableClientReadHandler.java x: 122 lines of code y: 2 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleReadHandler.java x: 198 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/compression/Codec.java x: 35 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/compression/ZstdCodec.java x: 91 lines of code y: 7 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 510 lines of code y: 46 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/GrpcClient.java x: 60 lines of code y: 6 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java x: 429 lines of code y: 35 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorMetrics.java x: 97 lines of code y: 7 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 191 lines of code y: 21 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 269 lines of code y: 28 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManagerUtils.java x: 19 lines of code y: 1 # changes internal-client/src/main/java/org/apache/uniffle/client/api/CoordinatorClient.java x: 26 lines of code y: 4 # changes internal-client/src/main/java/org/apache/uniffle/client/factory/CoordinatorClientFactory.java x: 78 lines of code y: 11 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcRetryableClient.java x: 261 lines of code y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileBlackHoleWriter.java x: 28 lines of code y: 1 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileNioWriter.java x: 58 lines of code y: 2 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/HadoopConfigApp.java x: 106 lines of code y: 1 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/NMCallBackHandler.java x: 48 lines of code y: 1 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnAppMaster.java x: 249 lines of code y: 1 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnClient.java x: 173 lines of code y: 1 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleTask.java x: 159 lines of code y: 1 # changes tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/Utils.java x: 67 lines of code y: 1 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ServerResource.java x: 217 lines of code y: 15 # changes dashboard/src/main/webapp/src/pages/ShuffleServerPage.vue x: 209 lines of code y: 6 # changes dashboard/src/main/webapp/src/pages/serverstatus/NodeListPage.vue x: 473 lines of code y: 10 # changes dashboard/src/main/webapp/src/router/index.js x: 74 lines of code y: 6 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/PooledHadoopShuffleWriteHandler.java x: 99 lines of code y: 6 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssStageResubmitManager.java x: 21 lines of code y: 2 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/BlockIdSelfManagedShuffleWriteClient.java x: 99 lines of code y: 3 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerInterface.java x: 27 lines of code y: 13 # changes client/src/main/java/org/apache/uniffle/client/api/ShuffleWriteClient.java x: 208 lines of code y: 22 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssPartitionToShuffleServerRequest.java x: 30 lines of code y: 2 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleWriteFailureRequest.java x: 51 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/ShuffleTaskInfo.java x: 283 lines of code y: 21 # changes server/src/main/java/org/apache/uniffle/server/block/DefaultShuffleBlockIdManager.java x: 177 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/block/PartitionedShuffleBlockIdManager.java x: 130 lines of code y: 2 # changes dashboard/src/main/webapp/src/pages/ApplicationPage.vue x: 182 lines of code y: 14 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java x: 427 lines of code y: 38 # changes common/src/main/java/org/apache/uniffle/common/ShuffleDataSegment.java x: 27 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java x: 85 lines of code y: 9 # changes common/src/main/java/org/apache/uniffle/common/netty/MessageEncoder.java x: 58 lines of code y: 8 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataRequest.java x: 133 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexResponse.java x: 70 lines of code y: 5 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java x: 154 lines of code y: 8 # changes common/src/main/java/org/apache/uniffle/common/segment/AbstractSegmentSplitter.java x: 101 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/segment/FixedSizeSegmentSplitter.java x: 13 lines of code y: 8 # changes common/src/main/java/org/apache/uniffle/common/segment/LocalOrderSegmentSplitter.java x: 16 lines of code y: 11 # changes common/src/main/java/org/apache/uniffle/common/util/Constants.java x: 59 lines of code y: 22 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleDataRequest.java x: 86 lines of code y: 4 # changes internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleIndexResponse.java x: 19 lines of code y: 8 # changes server/src/main/java/org/apache/uniffle/server/ShuffleDataReadEvent.java x: 35 lines of code y: 4 # changes server/src/main/java/org/apache/uniffle/server/netty/ShuffleServerNettyHandler.java x: 963 lines of code y: 33 # changes server/src/main/java/org/apache/uniffle/server/storage/MultiPartLocalStorageManager.java x: 82 lines of code y: 1 # changes server/src/main/java/org/apache/uniffle/server/storage/StorageManager.java x: 29 lines of code y: 10 # changes server/src/main/java/org/apache/uniffle/server/storage/StorageManagerFactory.java x: 24 lines of code y: 8 # changes storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java x: 275 lines of code y: 23 # changes storage/src/main/java/org/apache/uniffle/storage/handler/api/ServerReadHandler.java x: 8 lines of code y: 3 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileServerReadHandler.java x: 143 lines of code y: 11 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithLinkedList.java x: 240 lines of code y: 12 # changes common/src/main/java/org/apache/uniffle/common/metrics/MetricsManager.java x: 120 lines of code y: 9 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java x: 497 lines of code y: 28 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java x: 379 lines of code y: 23 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssSendHeartBeatRequest.java x: 108 lines of code y: 10 # changes server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java x: 239 lines of code y: 18 # changes common/src/main/java/org/apache/uniffle/common/storage/StorageInfo.java x: 106 lines of code y: 3 # changes server/src/main/java/org/apache/uniffle/server/Checker.java x: 7 lines of code y: 4 # changes dashboard/src/main/webapp/src/components/LayoutPage.vue x: 137 lines of code y: 6 # changes dashboard/src/main/webapp/src/pages/CoordinatorServerPage.vue x: 246 lines of code y: 8 # changes internal-client/src/main/java/org/apache/uniffle/client/response/RssSendShuffleDataResponse.java x: 30 lines of code y: 3 # changes server/src/main/java/org/apache/uniffle/server/HugePartitionUtils.java x: 76 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporter.java x: 120 lines of code y: 6 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/CoordinatorServerResource.java x: 89 lines of code y: 8 # changes server/src/main/java/org/apache/uniffle/server/web/resource/ServerResource.java x: 61 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/Decoders.java x: 99 lines of code y: 9 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssRegisterShuffleRequest.java x: 130 lines of code y: 9 # changes server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java x: 264 lines of code y: 43 # changes deploy/kubernetes/operator/api/uniffle/v1alpha1/remoteshuffleservice_types.go x: 124 lines of code y: 13 # changes deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver.go x: 285 lines of code y: 14 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileWriter.java x: 107 lines of code y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleWriteHandler.java x: 192 lines of code y: 7 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriteHandler.java x: 142 lines of code y: 14 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriter.java x: 52 lines of code y: 5 # changes storage/src/main/java/org/apache/uniffle/storage/common/AbstractStorage.java x: 75 lines of code y: 8 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java x: 165 lines of code y: 9 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerNettyMetrics.java x: 89 lines of code y: 3 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ApplicationResource.java x: 117 lines of code y: 9 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/vo/AppInfoVO.java x: 26 lines of code y: 5 # changes storage/src/main/java/org/apache/uniffle/storage/common/Storage.java x: 19 lines of code y: 6 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RMRssShuffle.java x: 225 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/merger/Merger.java x: 188 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/merger/Segment.java x: 17 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/merger/StreamedSegment.java x: 47 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetSortedShuffleDataResponse.java x: 65 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/records/RecordsReader.java x: 49 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/records/RecordsWriter.java x: 42 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/serializer/DynBufferSerOutputStream.java x: 36 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/FileSerInputStream.java x: 95 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/writable/BufferedRawWritableDeserializationStream.java x: 74 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableDeserializationStream.java x: 59 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableSerializationStream.java x: 53 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/serializer/writable/WritableDeserializationStream.java x: 67 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/BlockFlushFileReader.java x: 402 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/DefaultMergeEventHandler.java x: 82 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/MergeEventHandler.java x: 6 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/MergedResult.java x: 116 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/Partition.java x: 434 lines of code y: 3 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java x: 490 lines of code y: 9 # changes client-tez/src/main/java/org/apache/tez/dag/app/TezRemoteShuffleManager.java x: 329 lines of code y: 13 # changes storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleWriteHandlerRequest.java x: 109 lines of code y: 5 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequest.java x: 141 lines of code y: 8 # changes deploy/kubernetes/operator/api/uniffle/v1alpha1/zz_generated.deepcopy.go x: 463 lines of code y: 12 # changes deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator.go x: 327 lines of code y: 11 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithSkipList.java x: 243 lines of code y: 12 # changes common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java x: 211 lines of code y: 19 # changes common/src/main/java/org/apache/uniffle/common/util/ByteUnit.java x: 56 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/util/UnitConverter.java x: 116 lines of code y: 6 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssAccessClusterRequest.java x: 61 lines of code y: 5 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleAssignmentsRequest.java x: 137 lines of code y: 9 # changes server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java x: 176 lines of code y: 10 # changes server/src/main/java/org/apache/uniffle/server/buffer/AbstractShuffleBuffer.java x: 149 lines of code y: 8 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBuffer.java x: 36 lines of code y: 22 # changes server/src/main/java/org/apache/uniffle/server/storage/hybrid/DefaultStorageManagerSelector.java x: 25 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/util/RssUtils.java x: 373 lines of code y: 28 # changes common/src/main/java/org/apache/uniffle/common/executor/ThreadPoolManager.java x: 265 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/ReconfigurableConfManager.java x: 165 lines of code y: 6 # changes common/src/main/java/org/apache/uniffle/common/ShufflePartitionedBlock.java x: 108 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java x: 54 lines of code y: 6 # changes client-tez/src/main/java/org/apache/tez/common/GetShuffleServerRequest.java x: 100 lines of code y: 3 # changes client-tez/src/main/java/org/apache/tez/common/RssTezConfig.java x: 202 lines of code y: 12 # changes client-tez/src/main/java/org/apache/tez/common/RssTezUtils.java x: 429 lines of code y: 16 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java x: 303 lines of code y: 4 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManager.java x: 433 lines of code y: 16 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssSorter.java x: 193 lines of code y: 9 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssUnSorter.java x: 189 lines of code y: 9 # changes client-tez/src/main/java/org/apache/tez/runtime/library/input/RMRssOrderedGroupedKVInput.java x: 248 lines of code y: 1 # changes client-tez/src/main/java/org/apache/tez/runtime/library/output/RssOrderedPartitionedKVOutput.java x: 300 lines of code y: 10 # changes common/src/main/java/org/apache/uniffle/common/config/RssConf.java x: 307 lines of code y: 14 # changes client-mr/core/src/main/java/org/apache/hadoop/mapred/RssMapOutputCollector.java x: 211 lines of code y: 6 # changes client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java x: 362 lines of code y: 6 # changes client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBufferManager.java x: 435 lines of code y: 10 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java x: 177 lines of code y: 5 # changes client-mr/core/src/main/java/org/apache/uniffle/client/shuffle/RecordCollector.java x: 288 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/metrics/SupplierGauge.java x: 65 lines of code y: 3 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java x: 86 lines of code y: 5 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java x: 238 lines of code y: 11 # changes common/src/main/java/org/apache/uniffle/common/netty/client/TransportClientFactory.java x: 202 lines of code y: 10 # changes common/src/main/java/org/apache/uniffle/common/netty/client/TransportConf.java x: 43 lines of code y: 5 # changes dashboard/src/main/webapp/src/mock/nodelistpage.js x: 406 lines of code y: 2 # changes client/src/main/java/org/apache/uniffle/client/record/Record.java x: 41 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java x: 67 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/util/GrpcNettyUtils.java x: 55 lines of code y: 3 # changes deploy/kubernetes/operator/pkg/webhook/config/config.go x: 85 lines of code y: 2 # changes deploy/kubernetes/operator/pkg/webhook/manager.go x: 180 lines of code y: 2 # changes dashboard/src/main/webapp/src/api/api.js x: 76 lines of code y: 10 # changes dashboard/src/main/webapp/src/pages/DashboardPage.vue x: 129 lines of code y: 1 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssFetcher.java x: 249 lines of code y: 5 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java x: 174 lines of code y: 18 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcher.java x: 183 lines of code y: 5 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezShuffleDataFetcher.java x: 230 lines of code y: 6 # changes dashboard/src/main/webapp/src/mock/applicationpage.js x: 79 lines of code y: 2 # changes server/src/main/java/org/apache/uniffle/server/merge/MergeEvent.java x: 60 lines of code y: 1 # changes server/src/main/java/org/apache/uniffle/server/audit/ServerRPCAuditContext.java x: 22 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/config/ConfigOptions.java x: 135 lines of code y: 8 # changes common/src/main/java/org/apache/uniffle/common/netty/handle/TransportChannelHandler.java x: 108 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/MessageWithHeader.java x: 120 lines of code y: 2 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorConf.java x: 241 lines of code y: 27 # changes common/src/main/java/org/apache/uniffle/common/exception/NoRegisterException.java x: 12 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java x: 43 lines of code y: 6 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/ClusterManager.java x: 22 lines of code y: 13 # changes dashboard/src/main/webapp/src/main.js x: 13 lines of code y: 5 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/vo/UserAppNumVO.java x: 13 lines of code y: 2 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/QuotaManager.java x: 151 lines of code y: 13 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/util/CoordinatorUtils.java x: 156 lines of code y: 5 # changes dashboard/src/main/java/org/apache/uniffle/dashboard/web/utils/DashboardUtils.java x: 35 lines of code y: 3 # changes dashboard/src/main/webapp/src/utils/http.js x: 51 lines of code y: 6 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssFetchFailedIterator.java x: 93 lines of code y: 4 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 252 lines of code y: 22 # changes internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleManagerClientFactory.java x: 20 lines of code y: 3 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssShuffleHandle.java x: 45 lines of code y: 10 # changes common/src/main/java/org/apache/uniffle/common/RemoteStorageInfo.java x: 108 lines of code y: 5 # changes common/src/main/java/org/apache/uniffle/common/ShuffleServerInfo.java x: 110 lines of code y: 12 # changes common/src/main/java/org/apache/uniffle/common/util/ThreadUtils.java x: 150 lines of code y: 7 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRUtils.java x: 301 lines of code y: 7 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssEventFetcher.java x: 131 lines of code y: 6 # changes client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutput.java x: 285 lines of code y: 9 # changes client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutput.java x: 282 lines of code y: 8 # changes client/src/main/java/org/apache/uniffle/client/util/ClientUtils.java x: 94 lines of code y: 14 # changes cli/src/main/java/org/apache/uniffle/cli/UniffleCLI.java x: 248 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/Application.java x: 131 lines of code y: 2 # changes client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedKVInput.java x: 349 lines of code y: 5 # changes client-tez/src/main/java/org/apache/tez/runtime/library/input/RssUnorderedKVInput.java x: 321 lines of code y: 6 # changes common/src/main/java/org/apache/uniffle/common/netty/TransportFrameDecoder.java x: 142 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/util/NettyUtils.java x: 129 lines of code y: 5 # changes dashboard/src/main/webapp/babel.config.js x: 3 lines of code y: 2 # changes dashboard/src/main/webapp/packagescript/fileutils.js x: 63 lines of code y: 2 # changes dashboard/src/main/webapp/vue.config.js x: 13 lines of code y: 4 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/BufferManagerOptions.java x: 107 lines of code y: 8 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessClusterLoadChecker.java x: 87 lines of code y: 7 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/AccessManager.java x: 77 lines of code y: 11 # changes common/src/main/java/org/apache/uniffle/common/netty/handle/TransportResponseHandler.java x: 88 lines of code y: 5 # changes deploy/kubernetes/operator/pkg/controller/util/util.go x: 198 lines of code y: 6 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleResultForMultiPartRequest.java x: 45 lines of code y: 4 # changes internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleResultResponse.java x: 38 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/config/ConfigUtils.java x: 169 lines of code y: 11 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerServerFactory.java x: 39 lines of code y: 6 # changes deploy/kubernetes/operator/pkg/webhook/util/util.go x: 200 lines of code y: 3 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssInMemoryRemoteMerger.java x: 172 lines of code y: 3 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssRemoteMergeManagerImpl.java x: 253 lines of code y: 4 # changes client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssShuffle.java x: 249 lines of code y: 6 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssSimpleFetchedInputAllocator.java x: 271 lines of code y: 4 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffle.java x: 431 lines of code y: 6 # changes client-tez/src/main/java/org/apache/tez/runtime/library/input/RssConcatenatedMergedKeyValueInput.java x: 79 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/ShuffleBlockInfo.java x: 139 lines of code y: 7 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexRequest.java x: 70 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataRequest.java x: 122 lines of code y: 4 # changes common/src/main/java/org/apache/uniffle/common/util/BlockIdLayout.java x: 147 lines of code y: 2 # changes client-spark/spark2/src/main/java/org/apache/spark/network/util/NettyUtils.java x: 88 lines of code y: 4 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriterBuffer.java x: 87 lines of code y: 6 # changes common/src/main/java/org/apache/uniffle/common/util/JvmPauseMonitor.java x: 154 lines of code y: 1 # changes server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManagerFallbackStrategy.java x: 22 lines of code y: 3 # changes server/src/main/java/org/apache/uniffle/server/TopNShuffleDataSizeOfAppCalcTask.java x: 111 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/ServerStatus.java x: 34 lines of code y: 4 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/conf/DynamicClientConfService.java x: 131 lines of code y: 1 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataResponse.java x: 28 lines of code y: 4 # changes internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleDataResponse.java x: 19 lines of code y: 5 # changes common/src/main/java/org/apache/uniffle/common/metrics/GRPCMetrics.java x: 64 lines of code y: 12 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorGrpcMetrics.java x: 28 lines of code y: 5 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/BasicAssignmentStrategy.java x: 72 lines of code y: 4 # changes cli/src/main/java/org/apache/uniffle/client/RestClientImpl.java x: 119 lines of code y: 5 # changes client-tez/src/main/java/org/apache/tez/common/TezClassLoader.java x: 50 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/netty/handle/TransportRequestHandler.java x: 34 lines of code y: 3 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessCandidatesChecker.java x: 135 lines of code y: 6 # changes deploy/kubernetes/operator/pkg/controller/config/config.go x: 41 lines of code y: 3 # changes cli/src/main/java/org/apache/uniffle/AbstractCustomCommandLine.java x: 81 lines of code y: 3 # changes cli/src/main/java/org/apache/uniffle/api/AdminRestApi.java x: 115 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/metrics/MetricReporterFactory.java x: 15 lines of code y: 3 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/Encoders.java x: 70 lines of code y: 4 # changes cli/src/main/java/org/apache/uniffle/cli/CLIContentUtils.java x: 160 lines of code y: 2 # changes client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedMergedKVInput.java x: 193 lines of code y: 2 # changes common/src/main/java/org/apache/uniffle/common/util/ExitUtils.java x: 33 lines of code y: 2 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorFactory.java x: 24 lines of code y: 4 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AbstractAssignmentStrategy.java x: 73 lines of code y: 3 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AbstractSelectStorageStrategy.java x: 149 lines of code y: 5 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategy.java x: 53 lines of code y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java x: 84 lines of code y: 6 # changes storage/src/main/java/org/apache/uniffle/storage/util/ShuffleStorageUtils.java x: 185 lines of code y: 13 # changes common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerTransportFilter.java x: 21 lines of code y: 4 # changes deploy/kubernetes/operator/config/manager/rss-controller.yaml x: 114 lines of code y: 2 # changes deploy/kubernetes/operator/config/manager/rss-webhook.yaml x: 137 lines of code y: 3 # changes deploy/kubernetes/operator/pkg/controller/controller/rss.go x: 772 lines of code y: 4 # changes deploy/kubernetes/operator/pkg/webhook/inspector/pod.go x: 140 lines of code y: 3 # changes spotbugs-exclude.xml x: 9 lines of code y: 8 # changes deploy/kubernetes/operator/pkg/webhook/inspector/rss.go x: 156 lines of code y: 4 # changes deploy/kubernetes/operator/pkg/utils/certs.go x: 185 lines of code y: 1 # changes deploy/kubernetes/operator/pkg/utils/config.go x: 44 lines of code y: 1 # changes deploy/kubernetes/operator/pkg/webhook/syncer/syncer.go x: 204 lines of code y: 1 # changes deploy/kubernetes/operator/api/uniffle/v1alpha1/doc.go x: 1 lines of code y: 1 # changes
108.0
# changes
  min: 1.0
  average: 5.8
  25th percentile: 1.0
  median: 2.0
  75th percentile: 6.0
  max: 108.0
0 1719.0
lines of code
min: 1.0 | average: 105.61 | 25th percentile: 18.0 | median: 49.0 | 75th percentile: 115.0 | max: 1719.0

Number of Contributors vs. Number of Changes: 719 points

client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleReadMetric.java x: 1 # contributors y: 2 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java x: 7 # contributors y: 20 # changes client-spark/extension/src/main/scala/org/apache/spark/UniffleListener.scala x: 1 # contributors y: 4 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 18 # contributors y: 32 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleReadMetricRequest.java x: 1 # contributors y: 3 # changes proto/src/main/proto/Rss.proto x: 21 # contributors y: 64 # changes server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java x: 24 # contributors y: 77 # changes client/src/main/java/org/apache/uniffle/client/factory/ShuffleClientFactory.java x: 10 # contributors y: 18 # changes client/src/main/java/org/apache/uniffle/client/impl/ShuffleReadClientImpl.java x: 10 # contributors y: 25 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ClientInfo.java x: 1 # contributors y: 1 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerClient.java x: 7 # contributors y: 8 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java x: 17 # contributors y: 53 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java x: 12 # contributors y: 31 # changes storage/src/main/java/org/apache/uniffle/storage/factory/ShuffleHandlerFactory.java x: 13 # contributors y: 23 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandler.java x: 3 # contributors y: 4 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileClientReadHandler.java x: 8 # contributors y: 12 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java x: 7 # contributors y: 12 # changes storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleReadHandlerRequest.java x: 7 # contributors y: 13 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/ServerNode.java x: 9 # contributors y: 18 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkShuffleUtils.java x: 20 # contributors y: 27 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java x: 10 # contributors y: 34 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 31 # contributors y: 108 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 21 # contributors y: 61 # changes internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleManagerClient.java x: 5 # contributors y: 14 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleManagerGrpcClient.java x: 6 # contributors y: 15 # changes common/src/main/java/org/apache/uniffle/common/web/JettyServer.java x: 8 # contributors y: 11 # changes dashboard/src/main/java/org/apache/uniffle/dashboard/web/Dashboard.java x: 2 # contributors y: 4 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/AddBlockEvent.java x: 6 # contributors y: 8 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java x: 6 # contributors y: 10 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java x: 19 # contributors y: 45 # changes client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java x: 28 # contributors y: 64 # changes client/src/main/java/org/apache/uniffle/client/response/SendShuffleDataResult.java x: 5 # contributors y: 5 # changes client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java x: 8 # contributors y: 18 # changes internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleServerClientFactory.java x: 10 # contributors y: 10 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 31 # contributors y: 89 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleScheduler.java x: 7 # contributors y: 16 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/ApplicationManager.java x: 15 # contributors y: 27 # changes storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java x: 11 # contributors y: 13 # changes storage/src/main/java/org/apache/uniffle/storage/common/DefaultStorageMediaProvider.java x: 6 # contributors y: 9 # changes client/src/main/java/org/apache/uniffle/client/util/RssClientConfig.java x: 11 # contributors y: 17 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerConf.java x: 20 # contributors y: 65 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java x: 18 # contributors y: 60 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssMergeManager.java x: 2 # contributors y: 2 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServer.java x: 26 # contributors y: 57 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/MutableShuffleHandleInfo.java x: 3 # contributors y: 5 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/ShuffleHandleInfo.java x: 2 # contributors y: 3 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/handle/StageAttemptShuffleHandleInfo.java x: 3 # contributors y: 3 # changes common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java x: 13 # contributors y: 33 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorServer.java x: 16 # contributors y: 30 # changes common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java x: 6 # contributors y: 7 # changes client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java x: 2 # contributors y: 6 # changes common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java x: 6 # contributors y: 6 # changes server/src/main/java/org/apache/uniffle/server/RegisterHeartBeat.java x: 15 # contributors y: 21 # changes server/src/main/java/org/apache/uniffle/server/storage/SingleStorageManager.java x: 9 # contributors y: 9 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java x: 19 # contributors y: 62 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerMetrics.java x: 17 # contributors y: 42 # changes server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManager.java x: 9 # contributors y: 12 # changes server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManager.java x: 18 # contributors y: 38 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleDeleteHandler.java x: 4 # contributors y: 5 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataSkippableReadHandler.java x: 7 # contributors y: 9 # changes common/src/main/java/org/apache/uniffle/common/compression/ZstdCodec.java x: 4 # contributors y: 7 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 16 # contributors y: 46 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/GrpcClient.java x: 5 # contributors y: 6 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java x: 17 # contributors y: 35 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorMetrics.java x: 5 # contributors y: 7 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 12 # contributors y: 21 # changes client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 15 # contributors y: 28 # changes internal-client/src/main/java/org/apache/uniffle/client/api/CoordinatorClient.java x: 4 # contributors y: 4 # changes internal-client/src/main/java/org/apache/uniffle/client/factory/CoordinatorClientFactory.java x: 9 # contributors y: 11 # changes dashboard/src/main/webapp/src/pages/serverstatus/NodeListPage.vue x: 4 # contributors y: 10 # changes dashboard/src/main/webapp/src/router/index.js x: 3 # contributors y: 6 # changes client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerInterface.java x: 5 # contributors y: 13 # changes client/src/main/java/org/apache/uniffle/client/api/ShuffleWriteClient.java x: 12 # contributors y: 22 # changes server/src/main/java/org/apache/uniffle/server/ShuffleTaskInfo.java x: 10 # contributors y: 21 # changes dashboard/src/main/webapp/src/pages/ApplicationPage.vue x: 3 # contributors y: 14 # changes client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java x: 19 # contributors y: 38 # changes common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java x: 4 # contributors y: 9 # changes common/src/main/java/org/apache/uniffle/common/netty/MessageEncoder.java x: 5 # contributors y: 8 # changes common/src/main/java/org/apache/uniffle/common/segment/LocalOrderSegmentSplitter.java x: 5 # contributors y: 11 # changes common/src/main/java/org/apache/uniffle/common/util/Constants.java x: 11 # contributors y: 22 # changes server/src/main/java/org/apache/uniffle/server/netty/ShuffleServerNettyHandler.java x: 14 # contributors y: 33 # changes server/src/main/java/org/apache/uniffle/server/storage/StorageManager.java x: 7 # contributors y: 10 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithLinkedList.java x: 5 # contributors y: 12 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java x: 14 # contributors y: 28 # changes internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java x: 14 # contributors y: 23 # changes internal-client/src/main/java/org/apache/uniffle/client/request/RssSendHeartBeatRequest.java x: 8 # contributors y: 10 # changes server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java x: 12 # contributors y: 18 # changes dashboard/src/main/webapp/src/pages/CoordinatorServerPage.vue x: 4 # contributors y: 8 # changes server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java x: 22 # contributors y: 43 # changes deploy/kubernetes/operator/api/uniffle/v1alpha1/remoteshuffleservice_types.go x: 6 # contributors y: 13 # changes deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver.go x: 7 # contributors y: 14 # changes storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriteHandler.java x: 8 # contributors y: 14 # changes server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java x: 8 # contributors y: 9 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ApplicationResource.java x: 3 # contributors y: 9 # changes deploy/kubernetes/operator/api/uniffle/v1alpha1/zz_generated.deepcopy.go x: 6 # contributors y: 12 # changes deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator.go x: 6 # contributors y: 11 # changes common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java x: 11 # contributors y: 19 # changes server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java x: 5 # contributors y: 10 # changes server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBuffer.java x: 10 # contributors y: 22 # changes common/src/main/java/org/apache/uniffle/common/util/RssUtils.java x: 17 # contributors y: 28 # changes common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java x: 4 # contributors y: 6 # changes client-tez/src/main/java/org/apache/tez/common/RssTezUtils.java x: 8 # contributors y: 16 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManager.java x: 11 # contributors y: 16 # changes client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssSorter.java x: 5 # contributors y: 9 # changes common/src/main/java/org/apache/uniffle/common/config/RssConf.java x: 10 # contributors y: 14 # changes client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBufferManager.java x: 9 # contributors y: 10 # changes common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java x: 3 # contributors y: 7 # changes dashboard/src/main/webapp/src/api/api.js x: 3 # contributors y: 10 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorConf.java x: 13 # contributors y: 27 # changes dashboard/src/main/webapp/src/main.js x: 1 # contributors y: 5 # changes client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 16 # contributors y: 22 # changes common/src/main/java/org/apache/uniffle/common/util/ThreadUtils.java x: 7 # contributors y: 7 # changes client/src/main/java/org/apache/uniffle/client/util/ClientUtils.java x: 11 # contributors y: 14 # changes common/src/main/java/org/apache/uniffle/common/netty/protocol/RpcResponse.java x: 2 # contributors y: 5 # changes common/src/main/java/org/apache/uniffle/common/metrics/GRPCMetrics.java x: 10 # contributors y: 12 # changes coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionBalanceAssignmentStrategy.java x: 8 # contributors y: 8 # changes storage/src/main/java/org/apache/uniffle/storage/util/ShuffleStorageUtils.java x: 10 # contributors y: 13 # changes common/src/main/java/org/apache/uniffle/common/exception/RssException.java x: 4 # contributors y: 3 # changes spotbugs-exclude.xml x: 3 # contributors y: 8 # changes
108.0
# changes
  min: 1.0
  average: 5.8
  25th percentile: 1.0
  median: 2.0
  75th percentile: 6.0
  max: 108.0
0 31.0
# contributors
min: 1.0 | average: 3.52 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 31.0

Number of Contributors vs. File Size: 719 points

client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleReadMetric.java x: 1 # contributors y: 44 lines of code client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java x: 7 # contributors y: 677 lines of code client-spark/extension/src/main/scala/org/apache/spark/UniffleListener.scala x: 1 # contributors y: 102 lines of code client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala x: 1 # contributors y: 99 lines of code client-spark/extension/src/main/scala/org/apache/spark/ui/ShufflePage.scala x: 1 # contributors y: 299 lines of code client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 18 # contributors y: 332 lines of code proto/src/main/proto/Rss.proto x: 21 # contributors y: 652 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/ShuffleServerReadCost.java x: 1 # contributors y: 69 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java x: 24 # contributors y: 957 lines of code client/src/main/java/org/apache/uniffle/client/factory/ShuffleClientFactory.java x: 10 # contributors y: 339 lines of code client/src/main/java/org/apache/uniffle/client/impl/ShuffleReadClientImpl.java x: 10 # contributors y: 287 lines of code internal-client/src/main/java/org/apache/uniffle/client/api/ClientInfo.java x: 1 # contributors y: 26 lines of code internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerClient.java x: 7 # contributors y: 52 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java x: 17 # contributors y: 1243 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java x: 12 # contributors y: 488 lines of code storage/src/main/java/org/apache/uniffle/storage/factory/ShuffleHandlerFactory.java x: 13 # contributors y: 173 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandler.java x: 3 # contributors y: 219 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileClientReadHandler.java x: 8 # contributors y: 175 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java x: 7 # contributors y: 105 lines of code storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleReadHandlerRequest.java x: 7 # contributors y: 195 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/ServerNode.java x: 9 # contributors y: 341 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkShuffleUtils.java x: 20 # contributors y: 325 lines of code client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java x: 10 # contributors y: 1314 lines of code client-spark/extension/src/main/scala/org/apache/spark/UniffleHistoryServerPlugin.scala x: 1 # contributors y: 16 lines of code client-spark/extension/src/main/scala/org/apache/spark/UnifflePlugin.scala x: 1 # contributors y: 38 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleWriteMetric.java x: 1 # contributors y: 6 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/events/UniffleEvent.java x: 1 # contributors y: 7 lines of code client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 31 # contributors y: 589 lines of code client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 21 # contributors y: 914 lines of code internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleManagerClient.java x: 5 # contributors y: 39 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleManagerGrpcClient.java x: 6 # contributors y: 144 lines of code internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleWriteMetricRequest.java x: 1 # contributors y: 51 lines of code common/src/main/java/org/apache/uniffle/common/web/JettyServer.java x: 8 # contributors y: 146 lines of code common/src/main/java/org/apache/uniffle/common/web/resource/MetricResource.java x: 3 # contributors y: 50 lines of code dashboard/src/main/java/org/apache/uniffle/dashboard/web/Dashboard.java x: 2 # contributors y: 135 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/writer/AddBlockEvent.java x: 6 # contributors y: 47 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java x: 19 # contributors y: 592 lines of code client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java x: 28 # contributors y: 1108 lines of code client/src/main/java/org/apache/uniffle/client/response/SendShuffleDataResult.java x: 5 # contributors y: 33 lines of code client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java x: 8 # contributors y: 567 lines of code internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleServerClientFactory.java x: 10 # contributors y: 52 lines of code client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java x: 31 # contributors y: 354 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssShuffleManager.java x: 6 # contributors y: 1211 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleScheduler.java x: 7 # contributors y: 1647 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/ApplicationManager.java x: 15 # contributors y: 421 lines of code server/src/main/java/org/apache/uniffle/server/merge/Shuffle.java x: 2 # contributors y: 82 lines of code server/src/main/java/org/apache/uniffle/server/merge/ShuffleMergeManager.java x: 3 # contributors y: 268 lines of code storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java x: 11 # contributors y: 95 lines of code storage/src/main/java/org/apache/uniffle/storage/common/DefaultStorageMediaProvider.java x: 6 # contributors y: 92 lines of code client/src/main/java/org/apache/uniffle/client/util/RssClientConfig.java x: 11 # contributors y: 71 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServerConf.java x: 20 # contributors y: 686 lines of code server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java x: 18 # contributors y: 765 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssMergeManager.java x: 2 # contributors y: 497 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServer.java x: 26 # contributors y: 559 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/handle/MutableShuffleHandleInfo.java x: 3 # contributors y: 315 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/handle/ShuffleHandleInfo.java x: 2 # contributors y: 17 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/handle/SimpleShuffleHandleInfo.java x: 2 # contributors y: 49 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/handle/StageAttemptShuffleHandleInfo.java x: 3 # contributors y: 103 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/handle/split/PartitionSplitInfo.java x: 1 # contributors y: 32 lines of code common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java x: 13 # contributors y: 289 lines of code common/src/main/java/org/apache/uniffle/common/config/RssBaseConf.java x: 18 # contributors y: 301 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorServer.java x: 16 # contributors y: 235 lines of code common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java x: 6 # contributors y: 95 lines of code common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoDeserializationStream.java x: 1 # contributors y: 78 lines of code common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializationStream.java x: 1 # contributors y: 57 lines of code common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializerInstance.java x: 1 # contributors y: 88 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RMRssShuffle.java x: 1 # contributors y: 207 lines of code client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java x: 2 # contributors y: 594 lines of code common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java x: 6 # contributors y: 58 lines of code server/src/main/java/org/apache/uniffle/server/LocalStorageChecker.java x: 13 # contributors y: 284 lines of code server/src/main/java/org/apache/uniffle/server/RegisterHeartBeat.java x: 15 # contributors y: 82 lines of code server/src/main/java/org/apache/uniffle/server/storage/SingleStorageManager.java x: 9 # contributors y: 132 lines of code common/src/main/java/org/apache/uniffle/common/ReconfigurableRegistry.java x: 2 # contributors y: 90 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java x: 19 # contributors y: 1719 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServerMetrics.java x: 17 # contributors y: 480 lines of code server/src/main/java/org/apache/uniffle/server/event/PurgeEvent.java x: 3 # contributors y: 46 lines of code server/src/main/java/org/apache/uniffle/server/event/ShufflePurgeEvent.java x: 2 # contributors y: 11 lines of code server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManager.java x: 9 # contributors y: 189 lines of code server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManager.java x: 18 # contributors y: 416 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleDeleteHandler.java x: 3 # contributors y: 4 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleDeleteHandler.java x: 4 # contributors y: 96 lines of code storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleDeleteHandlerRequest.java x: 3 # contributors y: 38 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataSkippableReadHandler.java x: 7 # contributors y: 77 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/PrefetchableClientReadHandler.java x: 1 # contributors y: 122 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleReadHandler.java x: 3 # contributors y: 198 lines of code common/src/main/java/org/apache/uniffle/common/compression/Codec.java x: 6 # contributors y: 35 lines of code common/src/main/java/org/apache/uniffle/common/compression/ZstdCodec.java x: 4 # contributors y: 91 lines of code client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java x: 16 # contributors y: 510 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/GrpcClient.java x: 5 # contributors y: 60 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java x: 17 # contributors y: 429 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorMetrics.java x: 5 # contributors y: 97 lines of code client-spark/spark2/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 12 # contributors y: 191 lines of code client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java x: 15 # contributors y: 269 lines of code internal-client/src/main/java/org/apache/uniffle/client/api/CoordinatorClient.java x: 4 # contributors y: 26 lines of code internal-client/src/main/java/org/apache/uniffle/client/factory/CoordinatorClientFactory.java x: 9 # contributors y: 78 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcRetryableClient.java x: 2 # contributors y: 261 lines of code tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnAppMaster.java x: 1 # contributors y: 249 lines of code tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnClient.java x: 1 # contributors y: 173 lines of code tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleTask.java x: 1 # contributors y: 159 lines of code tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/Utils.java x: 1 # contributors y: 67 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ServerResource.java x: 6 # contributors y: 217 lines of code dashboard/src/main/webapp/src/pages/ShuffleServerPage.vue x: 2 # contributors y: 209 lines of code dashboard/src/main/webapp/src/pages/serverstatus/NodeListPage.vue x: 4 # contributors y: 473 lines of code dashboard/src/main/webapp/src/router/index.js x: 3 # contributors y: 74 lines of code client-spark/common/src/main/java/org/apache/uniffle/shuffle/BlockIdSelfManagedShuffleWriteClient.java x: 3 # contributors y: 99 lines of code client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerInterface.java x: 5 # contributors y: 27 lines of code client/src/main/java/org/apache/uniffle/client/api/ShuffleWriteClient.java x: 12 # contributors y: 208 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleTaskInfo.java x: 10 # contributors y: 283 lines of code server/src/main/java/org/apache/uniffle/server/block/DefaultShuffleBlockIdManager.java x: 2 # contributors y: 177 lines of code server/src/main/java/org/apache/uniffle/server/block/ShuffleBlockIdManager.java x: 2 # contributors y: 29 lines of code dashboard/src/main/webapp/src/pages/ApplicationPage.vue x: 3 # contributors y: 182 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java x: 19 # contributors y: 427 lines of code common/src/main/java/org/apache/uniffle/common/ShuffleDataSegment.java x: 3 # contributors y: 27 lines of code common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java x: 4 # contributors y: 85 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataRequest.java x: 4 # contributors y: 133 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexV2Response.java x: 1 # contributors y: 87 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java x: 5 # contributors y: 154 lines of code common/src/main/java/org/apache/uniffle/common/segment/FixedSizeSegmentSplitter.java x: 5 # contributors y: 13 lines of code common/src/main/java/org/apache/uniffle/common/segment/LocalOrderSegmentSplitter.java x: 5 # contributors y: 16 lines of code common/src/main/java/org/apache/uniffle/common/util/Constants.java x: 11 # contributors y: 59 lines of code internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleIndexResponse.java x: 6 # contributors y: 19 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleDataReadEvent.java x: 4 # contributors y: 35 lines of code server/src/main/java/org/apache/uniffle/server/netty/ShuffleServerNettyHandler.java x: 14 # contributors y: 963 lines of code server/src/main/java/org/apache/uniffle/server/storage/HybridStorageManager.java x: 3 # contributors y: 135 lines of code server/src/main/java/org/apache/uniffle/server/storage/StorageManager.java x: 7 # contributors y: 29 lines of code server/src/main/java/org/apache/uniffle/server/storage/StorageManagerFactory.java x: 7 # contributors y: 24 lines of code storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java x: 13 # contributors y: 275 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/api/ServerReadHandler.java x: 3 # contributors y: 8 lines of code server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithLinkedList.java x: 5 # contributors y: 240 lines of code common/src/main/java/org/apache/uniffle/common/metrics/MetricsManager.java x: 7 # contributors y: 120 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java x: 14 # contributors y: 497 lines of code internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java x: 14 # contributors y: 379 lines of code internal-client/src/main/java/org/apache/uniffle/client/request/RssSendHeartBeatRequest.java x: 8 # contributors y: 108 lines of code server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java x: 12 # contributors y: 239 lines of code common/src/main/java/org/apache/uniffle/common/storage/StorageInfo.java x: 2 # contributors y: 106 lines of code server/src/main/java/org/apache/uniffle/server/Checker.java x: 4 # contributors y: 7 lines of code dashboard/src/main/webapp/src/components/LayoutPage.vue x: 3 # contributors y: 137 lines of code dashboard/src/main/webapp/src/pages/CoordinatorServerPage.vue x: 4 # contributors y: 246 lines of code internal-client/src/main/java/org/apache/uniffle/client/request/RssReassignOnBlockSendFailureRequest.java x: 2 # contributors y: 47 lines of code internal-client/src/main/java/org/apache/uniffle/client/response/RssSendShuffleDataResponse.java x: 3 # contributors y: 30 lines of code server/src/main/java/org/apache/uniffle/server/HugePartitionUtils.java x: 2 # contributors y: 76 lines of code common/src/main/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporter.java x: 6 # contributors y: 120 lines of code server/src/main/java/org/apache/uniffle/server/web/resource/ServerResource.java x: 2 # contributors y: 61 lines of code internal-client/src/main/java/org/apache/uniffle/client/request/RssRegisterShuffleRequest.java x: 7 # contributors y: 130 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java x: 22 # contributors y: 264 lines of code deploy/kubernetes/operator/api/uniffle/v1alpha1/remoteshuffleservice_types.go x: 6 # contributors y: 124 lines of code deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver.go x: 7 # contributors y: 285 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileWriter.java x: 4 # contributors y: 107 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleWriteHandler.java x: 5 # contributors y: 192 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriteHandler.java x: 8 # contributors y: 142 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriter.java x: 5 # contributors y: 52 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java x: 8 # contributors y: 165 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleServerNettyMetrics.java x: 3 # contributors y: 89 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ApplicationResource.java x: 3 # contributors y: 117 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RMRssShuffle.java x: 1 # contributors y: 225 lines of code common/src/main/java/org/apache/uniffle/common/merger/Merger.java x: 1 # contributors y: 188 lines of code server/src/main/java/org/apache/uniffle/server/merge/BlockFlushFileReader.java x: 1 # contributors y: 402 lines of code server/src/main/java/org/apache/uniffle/server/merge/MergedResult.java x: 1 # contributors y: 116 lines of code server/src/main/java/org/apache/uniffle/server/merge/Partition.java x: 1 # contributors y: 434 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java x: 6 # contributors y: 490 lines of code client-tez/src/main/java/org/apache/tez/dag/app/TezRemoteShuffleManager.java x: 7 # contributors y: 329 lines of code storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleWriteHandlerRequest.java x: 5 # contributors y: 109 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequest.java x: 5 # contributors y: 141 lines of code deploy/kubernetes/operator/api/uniffle/v1alpha1/zz_generated.deepcopy.go x: 6 # contributors y: 463 lines of code deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator.go x: 6 # contributors y: 327 lines of code server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithSkipList.java x: 6 # contributors y: 243 lines of code common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java x: 11 # contributors y: 211 lines of code common/src/main/java/org/apache/uniffle/common/util/ByteUnit.java x: 3 # contributors y: 56 lines of code common/src/main/java/org/apache/uniffle/common/util/UnitConverter.java x: 5 # contributors y: 116 lines of code internal-client/src/main/java/org/apache/uniffle/client/request/RssAccessClusterRequest.java x: 5 # contributors y: 61 lines of code server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java x: 5 # contributors y: 176 lines of code server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBuffer.java x: 10 # contributors y: 36 lines of code server/src/main/java/org/apache/uniffle/server/storage/hybrid/DefaultStorageManagerSelector.java x: 2 # contributors y: 25 lines of code common/src/main/java/org/apache/uniffle/common/util/RssUtils.java x: 17 # contributors y: 373 lines of code common/src/main/java/org/apache/uniffle/common/executor/ThreadPoolManager.java x: 1 # contributors y: 265 lines of code common/src/main/java/org/apache/uniffle/common/ReconfigurableConfManager.java x: 2 # contributors y: 165 lines of code common/src/main/java/org/apache/uniffle/common/ShufflePartitionedBlock.java x: 6 # contributors y: 108 lines of code common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java x: 4 # contributors y: 54 lines of code client-tez/src/main/java/org/apache/tez/common/RssTezConfig.java x: 5 # contributors y: 202 lines of code client-tez/src/main/java/org/apache/tez/common/RssTezUtils.java x: 8 # contributors y: 429 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java x: 4 # contributors y: 303 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManager.java x: 11 # contributors y: 433 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssUnSorter.java x: 5 # contributors y: 189 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/output/RssOrderedPartitionedKVOutput.java x: 5 # contributors y: 300 lines of code common/src/main/java/org/apache/uniffle/common/config/RssConf.java x: 10 # contributors y: 307 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapred/RssMapOutputCollector.java x: 3 # contributors y: 211 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java x: 4 # contributors y: 362 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBufferManager.java x: 9 # contributors y: 435 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java x: 4 # contributors y: 177 lines of code client-mr/core/src/main/java/org/apache/uniffle/client/shuffle/RecordCollector.java x: 1 # contributors y: 288 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java x: 3 # contributors y: 86 lines of code common/src/main/java/org/apache/uniffle/common/netty/client/TransportClientFactory.java x: 7 # contributors y: 202 lines of code common/src/main/java/org/apache/uniffle/common/netty/client/TransportConf.java x: 4 # contributors y: 43 lines of code dashboard/src/main/webapp/src/mock/nodelistpage.js x: 2 # contributors y: 406 lines of code common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java x: 3 # contributors y: 67 lines of code common/src/main/java/org/apache/uniffle/common/util/GrpcNettyUtils.java x: 2 # contributors y: 55 lines of code deploy/kubernetes/operator/pkg/webhook/manager.go x: 1 # contributors y: 180 lines of code dashboard/src/main/webapp/src/api/api.js x: 3 # contributors y: 76 lines of code dashboard/src/main/webapp/src/pages/DashboardPage.vue x: 1 # contributors y: 129 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java x: 12 # contributors y: 174 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcher.java x: 4 # contributors y: 183 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezShuffleDataFetcher.java x: 5 # contributors y: 230 lines of code common/src/main/java/org/apache/uniffle/common/config/ConfigOption.java x: 5 # contributors y: 94 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/MessageWithHeader.java x: 2 # contributors y: 120 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorConf.java x: 13 # contributors y: 241 lines of code common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java x: 5 # contributors y: 43 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/AppInfo.java x: 2 # contributors y: 69 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/QuotaManager.java x: 7 # contributors y: 151 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/util/CoordinatorUtils.java x: 5 # contributors y: 156 lines of code dashboard/src/main/java/org/apache/uniffle/dashboard/web/proxy/WebProxyServlet.java x: 4 # contributors y: 62 lines of code dashboard/src/main/java/org/apache/uniffle/dashboard/web/utils/DashboardUtils.java x: 2 # contributors y: 35 lines of code client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java x: 16 # contributors y: 252 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/RssShuffleHandle.java x: 9 # contributors y: 45 lines of code common/src/main/java/org/apache/uniffle/common/RemoteStorageInfo.java x: 5 # contributors y: 108 lines of code common/src/main/java/org/apache/uniffle/common/ShuffleServerInfo.java x: 9 # contributors y: 110 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssEventFetcher.java x: 5 # contributors y: 131 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutput.java x: 5 # contributors y: 285 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutput.java x: 5 # contributors y: 282 lines of code client/src/main/java/org/apache/uniffle/client/util/ClientUtils.java x: 11 # contributors y: 94 lines of code cli/src/main/java/org/apache/uniffle/cli/UniffleCLI.java x: 3 # contributors y: 248 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedKVInput.java x: 4 # contributors y: 349 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/input/RssUnorderedKVInput.java x: 4 # contributors y: 321 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessClusterLoadChecker.java x: 6 # contributors y: 87 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/AccessManager.java x: 8 # contributors y: 77 lines of code deploy/kubernetes/operator/pkg/controller/util/util.go x: 4 # contributors y: 198 lines of code server/src/main/java/org/apache/uniffle/server/HealthCheck.java x: 6 # contributors y: 77 lines of code common/src/main/java/org/apache/uniffle/common/config/ConfigUtils.java x: 9 # contributors y: 169 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssInMemoryRemoteMerger.java x: 3 # contributors y: 172 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssRemoteMergeManagerImpl.java x: 4 # contributors y: 253 lines of code client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssShuffle.java x: 5 # contributors y: 249 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssSimpleFetchedInputAllocator.java x: 4 # contributors y: 271 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffle.java x: 4 # contributors y: 431 lines of code common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataRequest.java x: 3 # contributors y: 122 lines of code common/src/main/java/org/apache/uniffle/common/util/BlockIdLayout.java x: 1 # contributors y: 147 lines of code common/src/main/java/org/apache/uniffle/common/BufferSegment.java x: 5 # contributors y: 73 lines of code client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriterBuffer.java x: 5 # contributors y: 87 lines of code common/src/main/java/org/apache/uniffle/common/util/RetryUtils.java x: 7 # contributors y: 86 lines of code common/src/main/java/org/apache/uniffle/common/util/JvmPauseMonitor.java x: 1 # contributors y: 154 lines of code server/src/main/java/org/apache/uniffle/server/storage/RotateStorageManagerFallbackStrategy.java x: 3 # contributors y: 20 lines of code server/src/main/java/org/apache/uniffle/server/TopNShuffleDataSizeOfAppCalcTask.java x: 1 # contributors y: 111 lines of code internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleDataResponse.java x: 4 # contributors y: 19 lines of code common/src/main/java/org/apache/uniffle/common/metrics/GRPCMetrics.java x: 10 # contributors y: 64 lines of code common/src/main/java/org/apache/uniffle/common/metrics/RPCMetrics.java x: 2 # contributors y: 148 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorGrpcMetrics.java x: 4 # contributors y: 28 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/BasicAssignmentStrategy.java x: 4 # contributors y: 72 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionBalanceAssignmentStrategy.java x: 8 # contributors y: 154 lines of code cli/src/main/java/org/apache/uniffle/client/RestClientImpl.java x: 4 # contributors y: 119 lines of code cli/src/main/java/org/apache/uniffle/api/AdminRestApi.java x: 3 # contributors y: 115 lines of code cli/src/main/java/org/apache/uniffle/cli/CLIContentUtils.java x: 2 # contributors y: 160 lines of code client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedMergedKVInput.java x: 2 # contributors y: 193 lines of code common/src/main/java/org/apache/uniffle/common/ShuffleDataDistributionType.java x: 2 # contributors y: 5 lines of code coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AbstractSelectStorageStrategy.java x: 4 # contributors y: 149 lines of code storage/src/main/java/org/apache/uniffle/storage/handler/impl/ComposedClientReadHandler.java x: 6 # contributors y: 167 lines of code storage/src/main/java/org/apache/uniffle/storage/util/ShuffleStorageUtils.java x: 10 # contributors y: 185 lines of code deploy/kubernetes/operator/config/manager/rss-webhook.yaml x: 2 # contributors y: 137 lines of code deploy/kubernetes/operator/pkg/controller/controller/rss.go x: 2 # contributors y: 772 lines of code
1719.0
lines of code
  min: 1.0
  average: 105.61
  25th percentile: 18.0
  median: 49.0
  75th percentile: 115.0
  max: 1719.0
0 31.0
# contributors
min: 1.0 | average: 3.52 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 31.0