Uber / RemoteShuffleService
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 271 files with 17,066 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 39 files changed 6-20 times (7,066 lines of code)
    • 232 files changed 1-5 times (10,000 lines of code)
0% | 0% | 0% | 41% | 58%
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 271 files with 17,066 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 4 files changed by 6-10 contributors (1,068 lines of code)
    • 112 files changed by 2-5 contributors (10,951 lines of code)
    • 155 files changed by 1 contributor (5,047 lines of code)
0% | 0% | 6% | 64% | 29%
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, scala, md, yml, properties, txt, xml, gitignore, json
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 36% | 63%
scala0% | 0% | 0% | 74% | 25%
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
src0% | 0% | 0% | 41% | 58%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
 175 - 2020-08-20 2023-01-31 17 6 boy@uber.com mabansal@uber.com
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 184 6 2020-08-20 2021-06-16 17 3 boy@uber.com mabansal@uber.com
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
 364 8 2020-08-20 2023-01-31 16 7 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 175 5 2020-08-20 2023-01-31 14 5 boy@uber.com mabansal@uber.com
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
 181 6 2020-08-20 2023-01-31 14 7 boy@uber.com mabansal@uber.com
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
 348 10 2020-09-30 2023-01-31 14 7 boy-uber@users.noreply.gith... mabansal@uber.com
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 159 7 2020-08-20 2020-10-30 13 3 boy@uber.com boy@uber.com
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
 547 31 2020-08-20 2020-10-26 13 3 boy@uber.com boy@uber.com
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
 615 36 2020-08-20 2021-06-16 13 3 boy@uber.com mabansal@uber.com
StreamServer.java
in src/main/java/com/uber/rss
 303 21 2020-08-20 2020-10-23 12 3 boy@uber.com mabansal@uber.com
MessageConstants.java
in src/main/java/com/uber/rss/messages
 46 - 2020-08-20 2021-06-15 11 3 boy@uber.com mabansal@uber.com
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
 155 7 2020-08-20 2021-06-16 11 3 boy@uber.com mabansal@uber.com
StreamServerConfig.java
in src/main/java/com/uber/rss
 283 50 2020-08-20 2020-10-23 11 3 boy@uber.com mabansal@uber.com
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
 347 8 2020-08-20 2021-06-16 11 3 boy@uber.com mabansal@uber.com
RssUtils.scala
in src/main/scala/org/apache/spark/shuffle/rss
 82 5 2020-08-20 2020-10-15 10 3 boy@uber.com boy-uber@users.noreply.gith...
RssShuffleReader.scala
in src/main/scala/org/apache/spark/shuffle
 90 1 2020-08-20 2023-01-31 10 5 boy@uber.com mabansal@uber.com
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
 103 12 2020-08-20 2020-10-26 10 3 boy@uber.com boy@uber.com
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
 299 13 2020-08-20 2020-10-30 10 2 boy@uber.com boy@uber.com
RecordSocketReadClient.java
in src/main/java/com/uber/rss/clients
 83 7 2020-08-20 2021-06-16 9 3 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 174 4 2020-08-20 2023-01-31 9 4 boy@uber.com mabansal@uber.com
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
 151 5 2020-08-20 2021-06-16 8 3 boy@uber.com mabansal@uber.com
MapOutputRssInfo.scala
in src/main/scala/org/apache/spark/shuffle/rss
 9 - 2020-08-20 2020-10-07 7 2 boy@uber.com boy-uber@users.noreply.gith...
MapTaskCommitStatus.java
in src/main/java/com/uber/rss/common
 64 8 2020-08-20 2020-10-14 7 2 boy@uber.com boy@uber.com
ServerIdAwareSocketReadClient.java
in src/main/java/com/uber/rss/clients
 69 7 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
ShuffleFileOutputStream.java
in src/main/java/com/uber/rss/storage
 71 6 2020-08-20 2021-06-16 7 3 boy@uber.com mabansal@uber.com
RetriableSocketReadClient.java
in src/main/java/com/uber/rss/clients
 92 7 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 142 10 2020-08-20 2020-10-30 7 2 boy@uber.com boy@uber.com
ShufflePartitionWriter.java
in src/main/java/com/uber/rss/execution
 147 13 2020-08-20 2020-10-16 7 2 boy@uber.com boy@uber.com
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
 149 9 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
 156 9 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
 229 27 2020-08-20 2020-10-16 7 2 boy@uber.com boy@uber.com
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
 365 21 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
EofRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
 6 1 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
FailedFetchRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
 11 2 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
NetworkUtils.java
in src/main/java/com/uber/rss/util
 57 3 2020-08-20 2020-10-13 6 2 boy@uber.com boy@uber.com
BlockingQueueReadClient.java
in src/main/java/com/uber/rss/clients
 84 6 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
 106 9 2020-08-20 2021-06-15 6 3 boy@uber.com mabansal@uber.com
StreamServerVersionDecoder.java
in src/main/java/com/uber/rss/decoders
 113 3 2020-08-20 2020-10-26 6 3 boy@uber.com boy@uber.com
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
 332 21 2020-08-20 2020-10-09 6 2 boy@uber.com boy@uber.com
ReadClientDataOptions.java
in src/main/java/com/uber/rss/clients
 31 5 2020-08-20 2020-10-07 5 2 boy@uber.com boy-uber@users.noreply.gith...
UploadChannelManager.java
in src/main/java/com/uber/rss/handlers
 37 5 2020-08-20 2020-10-22 5 3 boy@uber.com mabansal@uber.com
MemoryMonitor.java
in src/main/java/com/uber/rss/common
 70 2 2020-08-20 2021-06-16 5 3 boy@uber.com mabansal@uber.com
StageInfoStateItem.java
in src/main/java/com/uber/rss/messages
 72 10 2020-08-20 2020-10-14 5 2 boy@uber.com boy@uber.com
StreamServerStressToolLongRun.java
in src/main/java/com/uber/rss/tools
 118 2 2020-08-20 2020-10-16 5 2 boy@uber.com boy@uber.com
ServerIdAwareSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 127 10 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
ReplicatedWriteClient.java
in src/main/java/com/uber/rss/clients
 153 12 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
MultiServerSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 160 14 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
WriteClientFactory.java
in src/main/java/com/uber/rss/clients
 4 - 2020-08-20 2020-10-09 4 2 boy@uber.com boy@uber.com
MonitorUtils.java
in src/main/java/com/uber/rss/util
 20 1 2020-08-20 2020-08-28 4 1 boy@uber.com boy@uber.com
UnpooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
 23 2 2020-08-20 2020-10-09 4 2 boy@uber.com boy@uber.com
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.scala
in src/main/scala/org/apache/spark/shuffle
 364 8 2020-08-20 2023-01-31 16 7 boy@uber.com mabansal@uber.com
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
 348 10 2020-09-30 2023-01-31 14 7 boy-uber@users.noreply.gith... mabansal@uber.com
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
 181 6 2020-08-20 2023-01-31 14 7 boy@uber.com mabansal@uber.com
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
 175 - 2020-08-20 2023-01-31 17 6 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 175 5 2020-08-20 2023-01-31 14 5 boy@uber.com mabansal@uber.com
RssShuffleReader.scala
in src/main/scala/org/apache/spark/shuffle
 90 1 2020-08-20 2023-01-31 10 5 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 174 4 2020-08-20 2023-01-31 9 4 boy@uber.com mabansal@uber.com
WriterBufferManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
 105 5 2020-09-30 2021-06-17 4 4 boy-uber@users.noreply.gith... mabansal@uber.com
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 184 6 2020-08-20 2021-06-16 17 3 boy@uber.com mabansal@uber.com
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
 615 36 2020-08-20 2021-06-16 13 3 boy@uber.com mabansal@uber.com
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
 547 31 2020-08-20 2020-10-26 13 3 boy@uber.com boy@uber.com
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 159 7 2020-08-20 2020-10-30 13 3 boy@uber.com boy@uber.com
StreamServer.java
in src/main/java/com/uber/rss
 303 21 2020-08-20 2020-10-23 12 3 boy@uber.com mabansal@uber.com
MessageConstants.java
in src/main/java/com/uber/rss/messages
 46 - 2020-08-20 2021-06-15 11 3 boy@uber.com mabansal@uber.com
StreamServerConfig.java
in src/main/java/com/uber/rss
 283 50 2020-08-20 2020-10-23 11 3 boy@uber.com mabansal@uber.com
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
 347 8 2020-08-20 2021-06-16 11 3 boy@uber.com mabansal@uber.com
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
 155 7 2020-08-20 2021-06-16 11 3 boy@uber.com mabansal@uber.com
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
 103 12 2020-08-20 2020-10-26 10 3 boy@uber.com boy@uber.com
RssUtils.scala
in src/main/scala/org/apache/spark/shuffle/rss
 82 5 2020-08-20 2020-10-15 10 3 boy@uber.com boy-uber@users.noreply.gith...
RecordSocketReadClient.java
in src/main/java/com/uber/rss/clients
 83 7 2020-08-20 2021-06-16 9 3 boy@uber.com mabansal@uber.com
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
 151 5 2020-08-20 2021-06-16 8 3 boy@uber.com mabansal@uber.com
ShuffleFileOutputStream.java
in src/main/java/com/uber/rss/storage
 71 6 2020-08-20 2021-06-16 7 3 boy@uber.com mabansal@uber.com
EofRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
 6 1 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
BlockingQueueReadClient.java
in src/main/java/com/uber/rss/clients
 84 6 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
 106 9 2020-08-20 2021-06-15 6 3 boy@uber.com mabansal@uber.com
FailedFetchRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
 11 2 2020-08-20 2021-06-16 6 3 boy@uber.com mabansal@uber.com
StreamServerVersionDecoder.java
in src/main/java/com/uber/rss/decoders
 113 3 2020-08-20 2020-10-26 6 3 boy@uber.com boy@uber.com
MemoryMonitor.java
in src/main/java/com/uber/rss/common
 70 2 2020-08-20 2021-06-16 5 3 boy@uber.com mabansal@uber.com
UploadChannelManager.java
in src/main/java/com/uber/rss/handlers
 37 5 2020-08-20 2020-10-22 5 3 boy@uber.com mabansal@uber.com
M3Stats.java
in src/main/java/com/uber/rss/metrics
 106 7 2020-08-20 2021-06-16 4 3 boy@uber.com mabansal@uber.com
MetadataClientMetrics.java
in src/main/java/com/uber/rss/metrics
 39 6 2020-08-20 2021-06-18 4 3 boy@uber.com mabansal@uber.com
ServerHandlerMetrics.java
in src/main/java/com/uber/rss/metrics
 35 5 2020-08-20 2021-06-16 4 3 boy@uber.com mabansal@uber.com
TaskByteArrayDataBlock.java
in src/main/java/com/uber/rss/clients
 48 6 2020-10-05 2021-06-16 4 3 boy@uber.com mabansal@uber.com
PartitionFileChecker.java
in src/main/java/com/uber/rss/tools
 98 2 2020-08-20 2023-01-31 4 3 boy@uber.com mabansal@uber.com
Compression.java
in src/main/java/com/uber/rss/common
 56 2 2020-08-20 2023-01-31 4 3 boy@uber.com mabansal@uber.com
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 191 15 2020-08-20 2021-07-21 4 3 boy@uber.com mabansal@uber.com
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
 93 9 2020-08-20 2021-06-18 4 3 boy@uber.com mabansal@uber.com
ServerCandidate.java
in src/main/java/com/uber/rss/common
 28 5 2020-10-13 2020-10-29 3 3 boy-uber@users.noreply.gith... mabansal@uber.com
BusyStatusSocketClient.java
in src/main/java/com/uber/rss/clients
 32 3 2020-10-13 2020-10-29 2 3 boy-uber@users.noreply.gith... mabansal@uber.com
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
 299 13 2020-08-20 2020-10-30 10 2 boy@uber.com boy@uber.com
RetriableSocketReadClient.java
in src/main/java/com/uber/rss/clients
 92 7 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
 365 21 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
ServerIdAwareSocketReadClient.java
in src/main/java/com/uber/rss/clients
 69 7 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 142 10 2020-08-20 2020-10-30 7 2 boy@uber.com boy@uber.com
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
 149 9 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
 156 9 2020-08-20 2020-10-09 7 2 boy@uber.com boy@uber.com
MapTaskCommitStatus.java
in src/main/java/com/uber/rss/common
 64 8 2020-08-20 2020-10-14 7 2 boy@uber.com boy@uber.com
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
 229 27 2020-08-20 2020-10-16 7 2 boy@uber.com boy@uber.com
ShufflePartitionWriter.java
in src/main/java/com/uber/rss/execution
 147 13 2020-08-20 2020-10-16 7 2 boy@uber.com boy@uber.com
MapOutputRssInfo.scala
in src/main/scala/org/apache/spark/shuffle/rss
 9 - 2020-08-20 2020-10-07 7 2 boy@uber.com boy-uber@users.noreply.gith...
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
ClientBase.java
in src/main/java/com/uber/rss/clients
 268 17 2020-08-20 2020-09-02 3 1 boy@uber.com boy@uber.com
SerializerBenchmark.java
in src/main/java/com/uber/rss/tools
 164 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
FsyncPerfTest.java
in src/main/java/com/uber/rss/tools
 131 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
FileUtils.java
in src/main/java/com/uber/rss/util
 119 5 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
RetryUtils.java
in src/main/java/com/uber/rss/util
 96 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ConnectDownloadRequestMessage.java
in src/main/java/com/uber/rss/messages
 89 12 2021-06-12 2021-06-15 2 1 mabansal@uber.com mabansal@uber.com
StartUploadMessage.java
in src/main/java/com/uber/rss/messages
 78 12 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ByteBufUtils.java
in src/main/java/com/uber/rss/util
 77 7 2020-08-20 2020-08-26 3 1 boy@uber.com boy@uber.com
HttpChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 76 3 2020-08-20 2020-08-26 3 1 boy@uber.com boy@uber.com
AppTaskAttemptId.java
in src/main/java/com/uber/rss/common
 71 14 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
FinishApplicationJobRequestMessage.java
in src/main/java/com/uber/rss/messages
 70 11 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
FileDescriptorStressTest.java
in src/main/java/com/uber/rss/tools
 68 3 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ZooKeeperFaultTolerantServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 63 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
NotifyClient.java
in src/main/java/com/uber/rss/clients
 62 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
RegisterServerRequestMessage.java
in src/main/java/com/uber/rss/messages
 62 10 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
AppShufflePartitionId.java
in src/main/java/com/uber/rss/common
 62 10 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
InMemoryServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 62 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ShuffleStageStatus.java
in src/main/java/com/uber/rss/messages
 59 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ServerDetailCollection.java
in src/main/java/com/uber/rss/common
 56 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ServerReplicationGroupUtil.java
in src/main/java/com/uber/rss/clients
 55 2 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ServerList.java
in src/main/java/com/uber/rss/common
 55 8 2020-08-20 2020-09-08 3 1 boy@uber.com boy@uber.com
AppMapId.java
in src/main/java/com/uber/rss/common
 55 10 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
RegistryChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 55 5 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
NotifyChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 54 5 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
StateStoreLoadResult.java
in src/main/java/com/uber/rss/execution
 52 9 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
WriteClientMetrics.java
in src/main/java/com/uber/rss/metrics
 49 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
NotifyServerHandler.java
in src/main/java/com/uber/rss/handlers
 49 5 2020-08-20 2020-08-25 3 1 boy@uber.com boy@uber.com
RegistryClient.java
in src/main/java/com/uber/rss/clients
 47 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
GetDataAvailabilityResponse.java
in src/main/java/com/uber/rss/messages
 47 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
HandlerUtil.java
in src/main/java/com/uber/rss/handlers
 47 5 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ConnectUploadRequest.java
in src/main/java/com/uber/rss/messages
 46 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ConnectUploadResponse.java
in src/main/java/com/uber/rss/messages
 46 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
GetServersRequestMessage.java
in src/main/java/com/uber/rss/messages
 46 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
RegistryServerHandler.java
in src/main/java/com/uber/rss/handlers
 46 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ReadClientMetrics.java
in src/main/java/com/uber/rss/metrics
 44 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
GetServersResponseMessage.java
in src/main/java/com/uber/rss/messages
 44 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ExceptionUtils.java
in src/main/java/com/uber/rss/util
 43 5 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
PartitionFilePathAndLength.java
in src/main/java/com/uber/rss/common
 42 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
AppShuffleId.java
in src/main/java/com/uber/rss/common
 42 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ShuffleMapTaskAttemptId.java
in src/main/java/com/uber/rss/common
 42 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
MetadataClientMetricsKey.java
in src/main/java/com/uber/rss/metrics
 41 8 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
RateCounter.java
in src/main/java/com/uber/rss/util
 40 4 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ServerConnectionCacheUpdateRefresher.java
in src/main/java/com/uber/rss/clients
 39 2 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
AsyncSocketCompletionHandler.java
in src/main/java/com/uber/rss/util
 39 3 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
FinishApplicationAttemptRequestMessage.java
in src/main/java/com/uber/rss/messages
 38 7 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
StreamUtils.java
in src/main/java/com/uber/rss/util
 37 - 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
StageCorruptionStateItem.java
in src/main/java/com/uber/rss/messages
 36 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ShuffleDataWrapper.java
in src/main/java/com/uber/rss/execution
 36 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
ReadClientMetricsKey.java
in src/main/java/com/uber/rss/metrics
 35 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
WriteClientMetricsKey.java
in src/main/java/com/uber/rss/metrics
 35 6 2020-08-20 2020-08-21 2 1 boy@uber.com boy@uber.com
Correlations

File Size vs. Number of Changes: 271 points

src/main/java/com/uber/rss/common/Compression.java x: 56 lines of code y: 4 # changes src/main/java/com/uber/rss/tools/PartitionFileChecker.java x: 98 lines of code y: 4 # changes src/main/scala/org/apache/spark/shuffle/RssOpts.scala x: 175 lines of code y: 17 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala x: 364 lines of code y: 16 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala x: 90 lines of code y: 10 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala x: 181 lines of code y: 14 # changes src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala x: 175 lines of code y: 14 # changes src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala x: 174 lines of code y: 9 # changes src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala x: 348 lines of code y: 14 # changes src/main/java/com/uber/rss/clients/LazyWriteClient.java x: 70 lines of code y: 2 # changes src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java x: 191 lines of code y: 4 # changes src/main/java/com/uber/rss/metadata/ServiceRegistryWrapper.java x: 93 lines of code y: 4 # changes src/main/java/com/uber/rss/metrics/MetadataClientMetrics.java x: 39 lines of code y: 4 # changes src/main/scala/org/apache/spark/shuffle/RssServiceRegistry.scala x: 63 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationImpl.scala x: 99 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationManager.scala x: 32 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala x: 105 lines of code y: 4 # changes src/main/scala/org/apache/spark/shuffle/rss/WriterNoAggregationManager.scala x: 14 lines of code y: 2 # changes src/main/java/com/uber/rss/common/MemoryMonitor.java x: 70 lines of code y: 5 # changes src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java x: 347 lines of code y: 11 # changes src/main/java/com/uber/rss/handlers/DownloadServerHandler.java x: 155 lines of code y: 11 # changes src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java x: 184 lines of code y: 17 # changes src/main/java/com/uber/rss/metrics/M3Stats.java x: 106 lines of code y: 4 # changes src/main/java/com/uber/rss/metrics/ServerHandlerMetrics.java x: 35 lines of code y: 4 # changes src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java x: 71 lines of code y: 7 # changes src/main/java/com/uber/rss/tools/StreamServerStressTool.java x: 615 lines of code y: 13 # changes src/main/java/com/uber/rss/clients/RecordSocketReadClient.java x: 83 lines of code y: 9 # changes src/main/java/com/uber/rss/clients/BlockingQueueReadClient.java x: 84 lines of code y: 6 # changes src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java x: 6 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/BlockingSingleServerReadClient.java x: 5 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/EofRecordKeyValuePair.java x: 6 lines of code y: 6 # changes src/main/java/com/uber/rss/clients/FailedFetchRecordKeyValuePair.java x: 11 lines of code y: 6 # changes src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java x: 48 lines of code y: 4 # changes src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java x: 151 lines of code y: 8 # changes src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java x: 106 lines of code y: 6 # changes src/main/java/com/uber/rss/clients/StreamDecoderBase.java x: 117 lines of code y: 4 # changes src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java x: 89 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/GetDataAvailabilityRequestMessage.java x: 21 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/MessageConstants.java x: 46 lines of code y: 11 # changes src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java x: 299 lines of code y: 10 # changes src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java x: 142 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/HeartbeatSocketClient.java x: 34 lines of code y: 2 # changes src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java x: 159 lines of code y: 13 # changes src/main/java/com/uber/rss/common/ServerCandidate.java x: 28 lines of code y: 3 # changes src/main/java/com/uber/rss/execution/LocalFileStateStore.java x: 204 lines of code y: 4 # changes src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java x: 173 lines of code y: 3 # changes src/main/java/com/uber/rss/execution/ShuffleExecutor.java x: 547 lines of code y: 13 # changes src/main/java/com/uber/rss/handlers/UploadServerHandler.java x: 103 lines of code y: 10 # changes src/main/java/com/uber/rss/clients/PlainShuffleDataSocketReadClient.java x: 18 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/PlainShuffleDataSyncWriteClient.java x: 26 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java x: 83 lines of code y: 2 # changes src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java x: 113 lines of code y: 6 # changes src/main/java/com/uber/rss/handlers/ChannelFutureCloseListener.java x: 17 lines of code y: 1 # changes src/main/java/com/uber/rss/handlers/ChannelIdleCheck.java x: 52 lines of code y: 1 # changes src/main/java/com/uber/rss/StreamServer.java x: 303 lines of code y: 12 # changes src/main/java/com/uber/rss/StreamServerConfig.java x: 283 lines of code y: 11 # changes src/main/java/com/uber/rss/clients/ClientConstants.java x: 4 lines of code y: 3 # changes src/main/java/com/uber/rss/handlers/UploadChannelManager.java x: 37 lines of code y: 5 # changes src/main/java/com/uber/rss/execution/ExecutorShuffleStageState.java x: 229 lines of code y: 7 # changes src/main/java/com/uber/rss/execution/ShufflePartitionWriter.java x: 147 lines of code y: 7 # changes src/main/java/com/uber/rss/storage/ShuffleOutputStream.java x: 7 lines of code y: 3 # changes src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java x: 118 lines of code y: 5 # changes src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala x: 82 lines of code y: 10 # changes src/main/java/com/uber/rss/common/MapTaskCommitStatus.java x: 64 lines of code y: 7 # changes src/main/java/com/uber/rss/execution/StagePersistentInfo.java x: 35 lines of code y: 3 # changes src/main/java/com/uber/rss/execution/StateStore.java x: 15 lines of code y: 3 # changes src/main/java/com/uber/rss/execution/TaskAttemptCollection.java x: 23 lines of code y: 3 # changes src/main/java/com/uber/rss/execution/TaskAttemptIdAndState.java x: 40 lines of code y: 3 # changes src/main/java/com/uber/rss/messages/StageInfoStateItem.java x: 72 lines of code y: 5 # changes src/main/java/com/uber/rss/messages/TaskAttemptCommitStateItem.java x: 78 lines of code y: 3 # changes src/main/java/com/uber/rss/messages/GetBusyStatusRequest.java x: 30 lines of code y: 1 # changes src/main/java/com/uber/rss/messages/GetBusyStatusResponse.java x: 60 lines of code y: 1 # changes src/main/java/com/uber/rss/util/MovingAverageCalculator.java x: 33 lines of code y: 1 # changes src/main/java/com/uber/rss/util/NetworkUtils.java x: 57 lines of code y: 6 # changes src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java x: 85 lines of code y: 3 # changes src/main/java/com/uber/rss/messages/FinishUploadMessage.java x: 47 lines of code y: 4 # changes src/main/java/com/uber/rss/messages/GetDataAvailabilityRequest.java x: 21 lines of code y: 3 # changes src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java x: 332 lines of code y: 6 # changes src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java x: 149 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java x: 160 lines of code y: 5 # changes src/main/java/com/uber/rss/clients/PooledShuffleDataSyncWriteClient.java x: 113 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java x: 253 lines of code y: 4 # changes src/main/java/com/uber/rss/clients/ReplicatedReadClient.java x: 365 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java x: 153 lines of code y: 5 # changes src/main/java/com/uber/rss/clients/RetriableSocketReadClient.java x: 92 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/ServerIdAwareSocketReadClient.java x: 69 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java x: 127 lines of code y: 5 # changes src/main/java/com/uber/rss/clients/ShuffleDataReader.java x: 6 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClient.java x: 16 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClientBase.java x: 86 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/ShuffleDataWriter.java x: 10 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/SingleServerReadClient.java x: 5 lines of code y: 3 # changes src/main/java/com/uber/rss/clients/TaskDataBlock.java x: 48 lines of code y: 1 # changes src/main/java/com/uber/rss/clients/UnpooledWriteClientFactory.java x: 23 lines of code y: 4 # changes src/main/java/com/uber/rss/clients/WriteClientFactory.java x: 4 lines of code y: 4 # changes src/main/java/com/uber/rss/tools/StreamReadClientVerify.java x: 156 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/ReadClientDataOptions.java x: 31 lines of code y: 5 # changes src/main/scala/org/apache/spark/shuffle/rss/MapOutputRssInfo.scala x: 9 lines of code y: 7 # changes src/main/java/com/uber/rss/clients/ShuffleWriteConfig.java x: 31 lines of code y: 4 # changes src/main/java/com/uber/rss/metrics/M3DummyScope.java x: 92 lines of code y: 4 # changes src/main/java/com/uber/rss/metrics/M3DummyScopeBuilder.java x: 40 lines of code y: 4 # changes src/main/java/com/uber/rss/storage/ShuffleFileStorage.java x: 82 lines of code y: 4 # changes src/main/java/com/uber/rss/tools/TestUtils.java x: 48 lines of code y: 3 # changes src/main/java/com/uber/rss/clients/MultiServerHeartbeatClient.java x: 115 lines of code y: 1 # changes src/main/java/com/uber/rss/common/MapTaskRssInfo.java x: 62 lines of code y: 2 # changes src/main/java/com/uber/rss/common/ServerDetail.java x: 65 lines of code y: 3 # changes src/main/java/com/uber/rss/messages/ConnectDownloadResponse.java x: 81 lines of code y: 3 # changes src/main/java/com/uber/rss/messages/HeartbeatMessage.java x: 54 lines of code y: 1 # changes src/main/java/com/uber/rss/metadata/StandaloneServiceRegistryClient.java x: 53 lines of code y: 3 # changes src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java x: 97 lines of code y: 4 # changes src/main/java/com/uber/rss/util/ServerHostAndPort.java x: 57 lines of code y: 1 # changes src/main/java/com/uber/rss/util/StringUtils.java x: 95 lines of code y: 3 # changes src/main/scala/org/apache/spark/shuffle/MockTaskContext.scala x: 50 lines of code y: 1 # changes src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala x: 111 lines of code y: 3 # changes src/main/java/com/uber/rss/common/ServerList.java x: 55 lines of code y: 3 # changes src/main/java/com/uber/rss/clients/ClientBase.java x: 268 lines of code y: 3 # changes src/main/java/com/uber/rss/util/MonitorUtils.java x: 20 lines of code y: 4 # changes src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java x: 76 lines of code y: 3 # changes src/main/java/com/uber/rss/util/ByteBufUtils.java x: 77 lines of code y: 3 # changes src/main/java/com/uber/rss/handlers/NotifyServerHandler.java x: 49 lines of code y: 3 # changes src/main/scala/org/apache/spark/shuffle/RssEmptyShuffleReader.scala x: 19 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/RssServerSelectionResult.scala x: 3 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleBlockResolver.scala x: 10 lines of code y: 2 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleServerHandle.scala x: 7 lines of code y: 2 # changes src/main/java/com/uber/rss/RssBuildInfo.java x: 24 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/ClientRetryOptions.java x: 28 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/RegistryClient.java x: 47 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/ServerConnectionCacheUpdateRefresher.java x: 39 lines of code y: 2 # changes src/main/java/com/uber/rss/clients/ServerReplicationGroupUtil.java x: 55 lines of code y: 2 # changes src/main/java/com/uber/rss/common/AppShuffleId.java x: 42 lines of code y: 2 # changes src/main/java/com/uber/rss/common/FilePathAndLength.java x: 35 lines of code y: 2 # changes src/main/java/com/uber/rss/common/LowMemoryListener.java x: 4 lines of code y: 2 # changes src/main/java/com/uber/rss/common/ServerDetailCollection.java x: 56 lines of code y: 2 # changes src/main/java/com/uber/rss/exceptions/ExceptionWrapper.java x: 16 lines of code y: 2 # changes src/main/java/com/uber/rss/exceptions/RssDiskSpaceException.java x: 17 lines of code y: 2 # changes src/main/java/com/uber/rss/exceptions/RssFileCorruptedException.java x: 9 lines of code y: 2 # changes src/main/java/com/uber/rss/exceptions/RssInvalidMapStatusException.java x: 8 lines of code y: 2 # changes src/main/java/com/uber/rss/exceptions/RssMaxConnectionsException.java x: 29 lines of code y: 2 # changes src/main/java/com/uber/rss/execution/ExecutorAppState.java x: 33 lines of code y: 2 # changes src/main/java/com/uber/rss/execution/ShuffleDataWrapper.java x: 36 lines of code y: 2 # changes src/main/java/com/uber/rss/execution/StateStoreLoadResult.java x: 52 lines of code y: 2 # changes src/main/java/com/uber/rss/handlers/NotifyChannelInboundHandler.java x: 54 lines of code y: 2 # changes src/main/java/com/uber/rss/handlers/RegistryServerHandler.java x: 46 lines of code y: 2 # changes src/main/java/com/uber/rss/handlers/ResponseStatusAndMessage.java x: 22 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/AppDeletionStateItem.java x: 30 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/FinishApplicationAttemptRequestMessage.java x: 38 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/GetServersResponseMessage.java x: 44 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/ServerResponseMessage.java x: 13 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/ShuffleStageStatus.java x: 59 lines of code y: 2 # changes src/main/java/com/uber/rss/messages/StartUploadMessage.java x: 78 lines of code y: 2 # changes src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetrics.java x: 27 lines of code y: 2 # changes src/main/java/com/uber/rss/metrics/ExceptionMetricGroupContainer.java x: 12 lines of code y: 2 # changes src/main/java/com/uber/rss/metrics/MetadataClientMetricsKey.java x: 41 lines of code y: 2 # changes src/main/java/com/uber/rss/metrics/MetricGroup.java x: 15 lines of code y: 2 # changes src/main/java/com/uber/rss/metrics/WriteClientMetrics.java x: 49 lines of code y: 2 # changes src/main/java/com/uber/rss/storage/ShuffleFileUtils.java x: 23 lines of code y: 2 # changes src/main/java/com/uber/rss/tools/FileDescriptorStressTest.java x: 68 lines of code y: 2 # changes src/main/java/com/uber/rss/tools/FsyncPerfTest.java x: 131 lines of code y: 2 # changes src/main/java/com/uber/rss/tools/SerializerBenchmark.java x: 164 lines of code y: 2 # changes src/main/java/com/uber/rss/util/ExceptionUtils.java x: 43 lines of code y: 2 # changes src/main/java/com/uber/rss/util/FileUtils.java x: 119 lines of code y: 2 # changes src/main/java/com/uber/rss/util/RetryUtils.java x: 96 lines of code y: 2 # changes src/main/java/com/uber/rss/util/StreamUtils.java x: 37 lines of code y: 2 # changes
17.0
# changes
  min: 1.0
  average: 3.37
  25th percentile: 2.0
  median: 2.0
  75th percentile: 4.0
  max: 17.0
0 615.0
lines of code
min: 3.0 | average: 62.97 | 25th percentile: 17.0 | median: 35.0 | 75th percentile: 76.0 | max: 615.0

Number of Contributors vs. Number of Changes: 271 points

src/main/java/com/uber/rss/common/Compression.java x: 3 # contributors y: 4 # changes src/main/scala/org/apache/spark/shuffle/RssOpts.scala x: 6 # contributors y: 17 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala x: 7 # contributors y: 16 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala x: 5 # contributors y: 10 # changes src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala x: 7 # contributors y: 14 # changes src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala x: 5 # contributors y: 14 # changes src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala x: 4 # contributors y: 9 # changes src/main/java/com/uber/rss/clients/LazyWriteClient.java x: 2 # contributors y: 2 # changes src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala x: 4 # contributors y: 4 # changes src/main/java/com/uber/rss/common/MemoryMonitor.java x: 3 # contributors y: 5 # changes src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java x: 3 # contributors y: 11 # changes src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java x: 3 # contributors y: 17 # changes src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java x: 3 # contributors y: 7 # changes src/main/java/com/uber/rss/tools/StreamServerStressTool.java x: 3 # contributors y: 13 # changes src/main/java/com/uber/rss/clients/RecordSocketReadClient.java x: 3 # contributors y: 9 # changes src/main/java/com/uber/rss/clients/BlockingQueueReadClient.java x: 3 # contributors y: 6 # changes src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java x: 1 # contributors y: 2 # changes src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java x: 3 # contributors y: 8 # changes src/main/java/com/uber/rss/clients/StreamDecoderBase.java x: 2 # contributors y: 4 # changes src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java x: 2 # contributors y: 10 # changes src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java x: 2 # contributors y: 7 # changes src/main/java/com/uber/rss/clients/BusyStatusSocketClient.java x: 3 # contributors y: 2 # changes src/main/java/com/uber/rss/common/ServerCandidate.java x: 3 # contributors y: 3 # changes src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java x: 2 # contributors y: 3 # changes src/main/java/com/uber/rss/handlers/UploadServerHandler.java x: 3 # contributors y: 10 # changes src/main/java/com/uber/rss/handlers/ChannelFutureCloseListener.java x: 2 # contributors y: 1 # changes src/main/java/com/uber/rss/StreamServer.java x: 3 # contributors y: 12 # changes src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java x: 2 # contributors y: 5 # changes src/main/java/com/uber/rss/util/NetworkUtils.java x: 2 # contributors y: 6 # changes src/main/java/com/uber/rss/common/ServerList.java x: 1 # contributors y: 3 # changes src/main/java/com/uber/rss/util/MonitorUtils.java x: 1 # contributors y: 4 # changes
17.0
# changes
  min: 1.0
  average: 3.37
  25th percentile: 2.0
  median: 2.0
  75th percentile: 4.0
  max: 17.0
0 7.0
# contributors
min: 1.0 | average: 1.65 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0

Number of Contributors vs. File Size: 271 points

src/main/java/com/uber/rss/common/Compression.java x: 3 # contributors y: 56 lines of code src/main/java/com/uber/rss/tools/PartitionFileChecker.java x: 3 # contributors y: 98 lines of code src/main/scala/org/apache/spark/shuffle/RssOpts.scala x: 6 # contributors y: 175 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala x: 7 # contributors y: 364 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala x: 5 # contributors y: 90 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala x: 7 # contributors y: 181 lines of code src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala x: 5 # contributors y: 175 lines of code src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala x: 4 # contributors y: 174 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala x: 7 # contributors y: 348 lines of code src/main/java/com/uber/rss/clients/LazyWriteClient.java x: 2 # contributors y: 70 lines of code src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java x: 3 # contributors y: 191 lines of code src/main/java/com/uber/rss/metadata/ServiceRegistryWrapper.java x: 3 # contributors y: 93 lines of code src/main/java/com/uber/rss/metrics/MetadataClientMetrics.java x: 3 # contributors y: 39 lines of code src/main/scala/org/apache/spark/shuffle/RssServiceRegistry.scala x: 2 # contributors y: 63 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationImpl.scala x: 2 # contributors y: 99 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationManager.scala x: 2 # contributors y: 32 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala x: 4 # contributors y: 105 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterNoAggregationManager.scala x: 2 # contributors y: 14 lines of code src/main/java/com/uber/rss/common/MemoryMonitor.java x: 3 # contributors y: 70 lines of code src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java x: 3 # contributors y: 347 lines of code src/main/java/com/uber/rss/handlers/DownloadServerHandler.java x: 3 # contributors y: 155 lines of code src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java x: 3 # contributors y: 184 lines of code src/main/java/com/uber/rss/metrics/M3Stats.java x: 3 # contributors y: 106 lines of code src/main/java/com/uber/rss/metrics/ServerHandlerMetrics.java x: 3 # contributors y: 35 lines of code src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java x: 3 # contributors y: 71 lines of code src/main/java/com/uber/rss/tools/StreamServerStressTool.java x: 3 # contributors y: 615 lines of code src/main/java/com/uber/rss/clients/RecordSocketReadClient.java x: 3 # contributors y: 83 lines of code src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java x: 1 # contributors y: 6 lines of code src/main/java/com/uber/rss/clients/EofRecordKeyValuePair.java x: 3 # contributors y: 6 lines of code src/main/java/com/uber/rss/clients/FailedFetchRecordKeyValuePair.java x: 3 # contributors y: 11 lines of code src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java x: 3 # contributors y: 48 lines of code src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java x: 3 # contributors y: 151 lines of code src/main/java/com/uber/rss/clients/StreamDecoderBase.java x: 2 # contributors y: 117 lines of code src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java x: 1 # contributors y: 89 lines of code src/main/java/com/uber/rss/messages/GetDataAvailabilityRequestMessage.java x: 1 # contributors y: 21 lines of code src/main/java/com/uber/rss/messages/MessageConstants.java x: 3 # contributors y: 46 lines of code src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java x: 2 # contributors y: 299 lines of code src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java x: 2 # contributors y: 142 lines of code src/main/java/com/uber/rss/clients/HeartbeatSocketClient.java x: 2 # contributors y: 34 lines of code src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java x: 3 # contributors y: 159 lines of code src/main/java/com/uber/rss/clients/BusyStatusSocketClient.java x: 3 # contributors y: 32 lines of code src/main/java/com/uber/rss/common/ServerCandidate.java x: 3 # contributors y: 28 lines of code src/main/java/com/uber/rss/execution/LocalFileStateStore.java x: 2 # contributors y: 204 lines of code src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java x: 2 # contributors y: 173 lines of code src/main/java/com/uber/rss/execution/ShuffleExecutor.java x: 3 # contributors y: 547 lines of code src/main/java/com/uber/rss/handlers/UploadServerHandler.java x: 3 # contributors y: 103 lines of code src/main/java/com/uber/rss/clients/PlainShuffleDataSocketReadClient.java x: 2 # contributors y: 18 lines of code src/main/java/com/uber/rss/clients/PlainShuffleDataSyncWriteClient.java x: 2 # contributors y: 26 lines of code src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java x: 2 # contributors y: 83 lines of code src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java x: 3 # contributors y: 113 lines of code src/main/java/com/uber/rss/handlers/ChannelIdleCheck.java x: 2 # contributors y: 52 lines of code src/main/java/com/uber/rss/StreamServer.java x: 3 # contributors y: 303 lines of code src/main/java/com/uber/rss/StreamServerConfig.java x: 3 # contributors y: 283 lines of code src/main/java/com/uber/rss/clients/ClientConstants.java x: 2 # contributors y: 4 lines of code src/main/java/com/uber/rss/handlers/UploadChannelManager.java x: 3 # contributors y: 37 lines of code src/main/java/com/uber/rss/execution/ExecutorShuffleStageState.java x: 2 # contributors y: 229 lines of code src/main/java/com/uber/rss/execution/ShufflePartitionWriter.java x: 2 # contributors y: 147 lines of code src/main/java/com/uber/rss/storage/ShuffleOutputStream.java x: 2 # contributors y: 7 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala x: 3 # contributors y: 82 lines of code src/main/java/com/uber/rss/execution/StateStore.java x: 2 # contributors y: 15 lines of code src/main/java/com/uber/rss/execution/TaskAttemptCollection.java x: 2 # contributors y: 23 lines of code src/main/java/com/uber/rss/execution/TaskAttemptIdAndState.java x: 2 # contributors y: 40 lines of code src/main/java/com/uber/rss/messages/StageInfoStateItem.java x: 2 # contributors y: 72 lines of code src/main/java/com/uber/rss/messages/TaskAttemptCommitStateItem.java x: 2 # contributors y: 78 lines of code src/main/java/com/uber/rss/messages/GetBusyStatusRequest.java x: 2 # contributors y: 30 lines of code src/main/java/com/uber/rss/messages/GetBusyStatusResponse.java x: 2 # contributors y: 60 lines of code src/main/java/com/uber/rss/util/NetworkUtils.java x: 2 # contributors y: 57 lines of code src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java x: 2 # contributors y: 85 lines of code src/main/java/com/uber/rss/messages/FinishUploadMessage.java x: 2 # contributors y: 47 lines of code src/main/java/com/uber/rss/messages/GetDataAvailabilityRequest.java x: 2 # contributors y: 21 lines of code src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java x: 2 # contributors y: 332 lines of code src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java x: 2 # contributors y: 149 lines of code src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java x: 2 # contributors y: 160 lines of code src/main/java/com/uber/rss/clients/PooledShuffleDataSyncWriteClient.java x: 2 # contributors y: 113 lines of code src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java x: 2 # contributors y: 253 lines of code src/main/java/com/uber/rss/clients/ReplicatedReadClient.java x: 2 # contributors y: 365 lines of code src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java x: 2 # contributors y: 153 lines of code src/main/java/com/uber/rss/clients/RetriableSocketReadClient.java x: 2 # contributors y: 92 lines of code src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java x: 2 # contributors y: 127 lines of code src/main/java/com/uber/rss/clients/ShuffleDataWriter.java x: 2 # contributors y: 10 lines of code src/main/java/com/uber/rss/tools/StreamReadClientVerify.java x: 2 # contributors y: 156 lines of code src/main/scala/org/apache/spark/shuffle/rss/MapOutputRssInfo.scala x: 2 # contributors y: 9 lines of code src/main/java/com/uber/rss/storage/ShuffleFileStorage.java x: 2 # contributors y: 82 lines of code src/main/java/com/uber/rss/clients/MultiServerHeartbeatClient.java x: 2 # contributors y: 115 lines of code src/main/java/com/uber/rss/common/MapTaskRssInfo.java x: 2 # contributors y: 62 lines of code src/main/java/com/uber/rss/messages/HeartbeatMessage.java x: 2 # contributors y: 54 lines of code src/main/java/com/uber/rss/util/StringUtils.java x: 2 # contributors y: 95 lines of code src/main/scala/org/apache/spark/shuffle/MockTaskContext.scala x: 2 # contributors y: 50 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala x: 2 # contributors y: 111 lines of code src/main/java/com/uber/rss/common/ServerList.java x: 1 # contributors y: 55 lines of code src/main/java/com/uber/rss/clients/ClientBase.java x: 1 # contributors y: 268 lines of code src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java x: 1 # contributors y: 76 lines of code src/main/java/com/uber/rss/common/DataBlockHeader.java x: 1 # contributors y: 35 lines of code src/main/java/com/uber/rss/handlers/NotifyServerHandler.java x: 1 # contributors y: 49 lines of code src/main/scala/org/apache/spark/shuffle/RssEmptyShuffleReader.scala x: 1 # contributors y: 19 lines of code src/main/scala/org/apache/spark/shuffle/RssServerSelectionResult.scala x: 1 # contributors y: 3 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleBlockResolver.scala x: 1 # contributors y: 10 lines of code src/main/java/com/uber/rss/RssBuildInfo.java x: 1 # contributors y: 24 lines of code src/main/java/com/uber/rss/clients/ClientRetryOptions.java x: 1 # contributors y: 28 lines of code src/main/java/com/uber/rss/clients/NotifyClient.java x: 1 # contributors y: 62 lines of code src/main/java/com/uber/rss/clients/RegistryClient.java x: 1 # contributors y: 47 lines of code src/main/java/com/uber/rss/clients/ServerConnectionCacheUpdateRefresher.java x: 1 # contributors y: 39 lines of code src/main/java/com/uber/rss/common/AppShuffleId.java x: 1 # contributors y: 42 lines of code src/main/java/com/uber/rss/common/AppTaskAttemptId.java x: 1 # contributors y: 71 lines of code src/main/java/com/uber/rss/common/DownloadServerVerboseInfo.java x: 1 # contributors y: 32 lines of code src/main/java/com/uber/rss/common/ServerDetailCollection.java x: 1 # contributors y: 56 lines of code src/main/java/com/uber/rss/exceptions/ExceptionWrapper.java x: 1 # contributors y: 16 lines of code src/main/java/com/uber/rss/exceptions/RssFileCorruptedException.java x: 1 # contributors y: 9 lines of code src/main/java/com/uber/rss/execution/StateStoreLoadResult.java x: 1 # contributors y: 52 lines of code src/main/java/com/uber/rss/handlers/RegistryServerHandler.java x: 1 # contributors y: 46 lines of code src/main/java/com/uber/rss/messages/AppDeletionStateItem.java x: 1 # contributors y: 30 lines of code src/main/java/com/uber/rss/messages/FinishApplicationAttemptRequestMessage.java x: 1 # contributors y: 38 lines of code src/main/java/com/uber/rss/messages/FinishApplicationJobRequestMessage.java x: 1 # contributors y: 70 lines of code src/main/java/com/uber/rss/messages/ServerResponseMessage.java x: 1 # contributors y: 13 lines of code src/main/java/com/uber/rss/messages/ShuffleStageStatus.java x: 1 # contributors y: 59 lines of code src/main/java/com/uber/rss/messages/StartUploadMessage.java x: 1 # contributors y: 78 lines of code src/main/java/com/uber/rss/metadata/ZooKeeperFaultTolerantServiceRegistry.java x: 1 # contributors y: 63 lines of code src/main/java/com/uber/rss/tools/FsyncPerfTest.java x: 1 # contributors y: 131 lines of code src/main/java/com/uber/rss/tools/SerializerBenchmark.java x: 1 # contributors y: 164 lines of code src/main/java/com/uber/rss/util/FileUtils.java x: 1 # contributors y: 119 lines of code src/main/java/com/uber/rss/util/RetryUtils.java x: 1 # contributors y: 96 lines of code
615.0
lines of code
  min: 3.0
  average: 62.97
  25th percentile: 17.0
  median: 35.0
  75th percentile: 76.0
  max: 615.0
0 7.0
# contributors
min: 1.0 | average: 1.65 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0