Uber / RemoteShuffleService
File Size

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

Intro
Learn more...
File Size Overall
0% | 6% | 21% | 25% | 47%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 7% | 19% | 22% | 50%
scala0% | 0% | 33% | 43% | 23%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
src0% | 6% | 21% | 25% | 47%
Longest Files (Top 50)
File# lines# units
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
 615 36
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
 547 31
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
 365 21
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
 364 8
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
 348 10
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
 347 8
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
 332 21
StreamServer.java
in src/main/java/com/uber/rss
 303 21
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
 299 13
StreamServerConfig.java
in src/main/java/com/uber/rss
 283 50
ClientBase.java
in src/main/java/com/uber/rss/clients
 268 17
PooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
 253 30
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
 229 27
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
 204 15
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 191 15
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 184 6
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
 181 6
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
 175 -
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 175 5
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 174 4
LocalFileStateStoreIterator.java
in src/main/java/com/uber/rss/execution
 173 8
SerializerBenchmark.java
in src/main/java/com/uber/rss/tools
 164 4
MultiServerSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 160 14
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 159 7
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
 156 9
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
 155 7
ReplicatedWriteClient.java
in src/main/java/com/uber/rss/clients
 153 12
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
 151 5
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
 149 9
ShufflePartitionWriter.java
in src/main/java/com/uber/rss/execution
 147 13
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 142 10
FsyncPerfTest.java
in src/main/java/com/uber/rss/tools
 131 4
ServerIdAwareSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 127 10
FileUtils.java
in src/main/java/com/uber/rss/util
 119 5
StreamServerStressToolLongRun.java
in src/main/java/com/uber/rss/tools
 118 2
StreamDecoderBase.java
in src/main/java/com/uber/rss/clients
 117 9
MultiServerHeartbeatClient.java
in src/main/java/com/uber/rss/clients
 115 12
PooledShuffleDataSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 113 16
StreamServerVersionDecoder.java
in src/main/java/com/uber/rss/decoders
 113 3
RssSparkListener.scala
in src/main/scala/org/apache/spark/shuffle/rss
 111 6
M3Stats.java
in src/main/java/com/uber/rss/metrics
 106 7
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
 106 9
WriterBufferManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
 105 5
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
 103 12
WriterAggregationImpl.scala
in src/main/scala/org/apache/spark/shuffle/rss
 99 6
PartitionFileChecker.java
in src/main/java/com/uber/rss/tools
 98 2
ScheduledMetricCollector.java
in src/main/java/com/uber/rss/metrics
 97 3
RetryUtils.java
in src/main/java/com/uber/rss/util
 96 4
StringUtils.java
in src/main/java/com/uber/rss/util
 95 2
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
 93 9
Files With Most Units (Top 50)
File# lines# units
StreamServerConfig.java
in src/main/java/com/uber/rss
 283 50
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
 615 36
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
 547 31
PooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
 253 30
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
 229 27
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
 332 21
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
 365 21
StreamServer.java
in src/main/java/com/uber/rss
 303 21
ClientBase.java
in src/main/java/com/uber/rss/clients
 268 17
PooledShuffleDataSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 113 16
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
 204 15
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 191 15
ShuffleDataSyncWriteClientBase.java
in src/main/java/com/uber/rss/clients
 86 14
MultiServerSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 160 14
AppTaskAttemptId.java
in src/main/java/com/uber/rss/common
 71 14
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
 299 13
ShufflePartitionWriter.java
in src/main/java/com/uber/rss/execution
 147 13
MockTaskContext.scala
in src/main/scala/org/apache/spark/shuffle
 50 13
MultiServerHeartbeatClient.java
in src/main/java/com/uber/rss/clients
 115 12
ReplicatedWriteClient.java
in src/main/java/com/uber/rss/clients
 153 12
ConnectDownloadRequest.java
in src/main/java/com/uber/rss/messages
 85 12
ConnectDownloadRequestMessage.java
in src/main/java/com/uber/rss/messages
 89 12
StartUploadMessage.java
in src/main/java/com/uber/rss/messages
 78 12
FixedLengthInputStream.java
in src/main/java/com/uber/rss/common
 86 12
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
 103 12
ConnectDownloadResponse.java
in src/main/java/com/uber/rss/messages
 81 11
FinishApplicationJobRequestMessage.java
in src/main/java/com/uber/rss/messages
 70 11
ShuffleFileStorage.java
in src/main/java/com/uber/rss/storage
 82 11
ServerIdAwareSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 127 10
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 142 10
RegisterServerRequestMessage.java
in src/main/java/com/uber/rss/messages
 62 10
StageInfoStateItem.java
in src/main/java/com/uber/rss/messages
 72 10
AppMapId.java
in src/main/java/com/uber/rss/common
 55 10
ServerDetail.java
in src/main/java/com/uber/rss/common
 65 10
AppShufflePartitionId.java
in src/main/java/com/uber/rss/common
 62 10
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
 348 10
StreamDecoderBase.java
in src/main/java/com/uber/rss/clients
 117 9
LazyWriteClient.java
in src/main/java/com/uber/rss/clients
 70 9
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
 106 9
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
 149 9
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
 156 9
HeartbeatMessage.java
in src/main/java/com/uber/rss/messages
 54 9
MapTaskRssInfo.java
in src/main/java/com/uber/rss/common
 62 9
StateStoreLoadResult.java
in src/main/java/com/uber/rss/execution
 52 9
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
 93 9
WriteClientMetrics.java
in src/main/java/com/uber/rss/metrics
 49 8
MetadataClientMetricsKey.java
in src/main/java/com/uber/rss/metrics
 41 8
M3DummyScope.java
in src/main/java/com/uber/rss/metrics
 92 8
ConnectUploadRequest.java
in src/main/java/com/uber/rss/messages
 46 8
FinishUploadMessage.java
in src/main/java/com/uber/rss/messages
 47 8
Files With Long Lines (Top 50)

There are 99 files with lines longer than 120 characters. In total, there are 341 long lines.

File# lines# units# long lines
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
 615 36 25
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
 364 8 20
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
 332 21 16
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 175 5 14
ClientBase.java
in src/main/java/com/uber/rss/clients
 268 17 11
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
 155 7 11
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
 299 13 10
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
 159 7 10
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
 365 21 9
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
 174 4 8
PooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
 253 30 7
RssUtils.scala
in src/main/scala/org/apache/spark/shuffle/rss
 82 5 7
ScheduledMetricCollector.java
in src/main/java/com/uber/rss/metrics
 97 3 6
ServerConnectionCacheUpdateRefresher.java
in src/main/java/com/uber/rss/clients
 39 2 6
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 142 10 6
ReplicatedWriteClient.java
in src/main/java/com/uber/rss/clients
 153 12 6
ServerIdAwareSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 127 10 5
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
 149 9 5
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
 547 31 5
ZooKeeperFaultTolerantServiceRegistry.java
in src/main/java/com/uber/rss/metadata
 63 8 5
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
 175 - 5
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
 348 10 5
ServerReplicationGroupUtil.java
in src/main/java/com/uber/rss/clients
 55 2 4
StreamDecoderBase.java
in src/main/java/com/uber/rss/clients
 117 9 4
MultiServerHeartbeatClient.java
in src/main/java/com/uber/rss/clients
 115 12 4
NotifyClient.java
in src/main/java/com/uber/rss/clients
 62 6 4
RegistryClient.java
in src/main/java/com/uber/rss/clients
 47 4 4
MultiServerSyncWriteClient.java
in src/main/java/com/uber/rss/clients
 160 14 4
RetryUtils.java
in src/main/java/com/uber/rss/util
 96 4 4
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
 151 5 4
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
 93 9 4
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
 181 6 4
M3Stats.java
in src/main/java/com/uber/rss/metrics
 106 7 3
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
 106 9 3
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
 156 9 3
ConnectDownloadRequest.java
in src/main/java/com/uber/rss/messages
 85 12 3
ConnectDownloadResponse.java
in src/main/java/com/uber/rss/messages
 81 11 3
ServerDetailCollection.java
in src/main/java/com/uber/rss/common
 56 7 3
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
 204 15 3
RecordSocketReadClient.java
in src/main/java/com/uber/rss/clients
 83 7 2
ShuffleDataSyncWriteClientBase.java
in src/main/java/com/uber/rss/clients
 86 14 2
ServerIdAwareSocketReadClient.java
in src/main/java/com/uber/rss/clients
 69 7 2
PlainShuffleDataSocketReadClient.java
in src/main/java/com/uber/rss/clients
 18 2 2
ShuffleDataSocketReadClient.java
in src/main/java/com/uber/rss/clients
 83 7 2
StreamServerStressToolLongRun.java
in src/main/java/com/uber/rss/tools
 118 2 2
FileDescriptorStressTest.java
in src/main/java/com/uber/rss/tools
 68 3 2
FsyncPerfTest.java
in src/main/java/com/uber/rss/tools
 131 4 2
FinishApplicationJobRequestMessage.java
in src/main/java/com/uber/rss/messages
 70 11 2
StartUploadMessage.java
in src/main/java/com/uber/rss/messages
 78 12 2
FileUtils.java
in src/main/java/com/uber/rss/util
 119 5 2
Correlations

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

src/main/java/com/uber/rss/common/Compression.java x: 4 commits (all time) y: 56 lines of code src/main/java/com/uber/rss/tools/PartitionFileChecker.java x: 4 commits (all time) y: 98 lines of code src/main/scala/org/apache/spark/shuffle/RssOpts.scala x: 23 commits (all time) y: 175 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala x: 21 commits (all time) y: 364 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala x: 11 commits (all time) y: 90 lines of code src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala x: 19 commits (all time) y: 181 lines of code src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala x: 16 commits (all time) y: 175 lines of code src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala x: 11 commits (all time) y: 174 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala x: 21 commits (all time) y: 348 lines of code src/main/java/com/uber/rss/clients/LazyWriteClient.java x: 2 commits (all time) y: 70 lines of code src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java x: 4 commits (all time) y: 191 lines of code src/main/java/com/uber/rss/metadata/ServiceRegistryWrapper.java x: 4 commits (all time) y: 93 lines of code src/main/java/com/uber/rss/metrics/MetadataClientMetrics.java x: 4 commits (all time) y: 39 lines of code src/main/scala/org/apache/spark/shuffle/RssServiceRegistry.scala x: 2 commits (all time) y: 63 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationImpl.scala x: 2 commits (all time) y: 99 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationManager.scala x: 2 commits (all time) y: 32 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala x: 7 commits (all time) y: 105 lines of code src/main/scala/org/apache/spark/shuffle/rss/WriterNoAggregationManager.scala x: 2 commits (all time) y: 14 lines of code src/main/java/com/uber/rss/common/MemoryMonitor.java x: 8 commits (all time) y: 70 lines of code src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java x: 17 commits (all time) y: 347 lines of code src/main/java/com/uber/rss/handlers/DownloadServerHandler.java x: 17 commits (all time) y: 155 lines of code src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java x: 27 commits (all time) y: 184 lines of code src/main/java/com/uber/rss/metrics/M3Stats.java x: 6 commits (all time) y: 106 lines of code src/main/java/com/uber/rss/metrics/ServerHandlerMetrics.java x: 6 commits (all time) y: 35 lines of code src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java x: 10 commits (all time) y: 71 lines of code src/main/java/com/uber/rss/tools/StreamServerStressTool.java x: 24 commits (all time) y: 615 lines of code src/main/java/com/uber/rss/clients/RecordSocketReadClient.java x: 12 commits (all time) y: 83 lines of code src/main/java/com/uber/rss/clients/BlockingQueueReadClient.java x: 6 commits (all time) y: 84 lines of code src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java x: 2 commits (all time) y: 6 lines of code src/main/java/com/uber/rss/clients/EofRecordKeyValuePair.java x: 6 commits (all time) y: 6 lines of code src/main/java/com/uber/rss/clients/FailedFetchRecordKeyValuePair.java x: 6 commits (all time) y: 11 lines of code src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java x: 4 commits (all time) y: 48 lines of code src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java x: 12 commits (all time) y: 151 lines of code src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java x: 8 commits (all time) y: 106 lines of code src/main/java/com/uber/rss/clients/StreamDecoderBase.java x: 4 commits (all time) y: 117 lines of code src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java x: 2 commits (all time) y: 89 lines of code src/main/java/com/uber/rss/messages/GetDataAvailabilityRequestMessage.java x: 3 commits (all time) y: 21 lines of code src/main/java/com/uber/rss/messages/MessageConstants.java x: 17 commits (all time) y: 46 lines of code src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java x: 16 commits (all time) y: 299 lines of code src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java x: 9 commits (all time) y: 142 lines of code src/main/java/com/uber/rss/clients/HeartbeatSocketClient.java x: 4 commits (all time) y: 34 lines of code src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java x: 20 commits (all time) y: 159 lines of code src/main/java/com/uber/rss/clients/BusyStatusSocketClient.java x: 4 commits (all time) y: 32 lines of code src/main/java/com/uber/rss/common/ServerCandidate.java x: 6 commits (all time) y: 28 lines of code src/main/java/com/uber/rss/execution/LocalFileStateStore.java x: 6 commits (all time) y: 204 lines of code src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java x: 4 commits (all time) y: 173 lines of code src/main/java/com/uber/rss/execution/ShuffleExecutor.java x: 20 commits (all time) y: 547 lines of code src/main/java/com/uber/rss/handlers/UploadServerHandler.java x: 15 commits (all time) y: 103 lines of code src/main/java/com/uber/rss/clients/PlainShuffleDataSocketReadClient.java x: 4 commits (all time) y: 18 lines of code src/main/java/com/uber/rss/clients/PlainShuffleDataSyncWriteClient.java x: 4 commits (all time) y: 26 lines of code src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java x: 4 commits (all time) y: 83 lines of code src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java x: 8 commits (all time) y: 113 lines of code src/main/java/com/uber/rss/handlers/ChannelFutureCloseListener.java x: 2 commits (all time) y: 17 lines of code src/main/java/com/uber/rss/handlers/ChannelIdleCheck.java x: 2 commits (all time) y: 52 lines of code src/main/java/com/uber/rss/StreamServer.java x: 17 commits (all time) y: 303 lines of code src/main/java/com/uber/rss/StreamServerConfig.java x: 15 commits (all time) y: 283 lines of code src/main/java/com/uber/rss/clients/ClientConstants.java x: 4 commits (all time) y: 4 lines of code src/main/java/com/uber/rss/handlers/UploadChannelManager.java x: 7 commits (all time) y: 37 lines of code src/main/java/com/uber/rss/execution/ExecutorShuffleStageState.java x: 10 commits (all time) y: 229 lines of code src/main/java/com/uber/rss/execution/ShufflePartitionWriter.java x: 10 commits (all time) y: 147 lines of code src/main/java/com/uber/rss/storage/ShuffleOutputStream.java x: 4 commits (all time) y: 7 lines of code src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java x: 6 commits (all time) y: 118 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala x: 11 commits (all time) y: 82 lines of code src/main/java/com/uber/rss/common/MapTaskCommitStatus.java x: 9 commits (all time) y: 64 lines of code src/main/java/com/uber/rss/execution/StateStore.java x: 4 commits (all time) y: 15 lines of code src/main/java/com/uber/rss/execution/TaskAttemptCollection.java x: 4 commits (all time) y: 23 lines of code src/main/java/com/uber/rss/messages/StageInfoStateItem.java x: 6 commits (all time) y: 72 lines of code src/main/java/com/uber/rss/messages/TaskAttemptCommitStateItem.java x: 4 commits (all time) y: 78 lines of code src/main/java/com/uber/rss/messages/GetBusyStatusRequest.java x: 2 commits (all time) y: 30 lines of code src/main/java/com/uber/rss/messages/GetBusyStatusResponse.java x: 2 commits (all time) y: 60 lines of code src/main/java/com/uber/rss/util/NetworkUtils.java x: 9 commits (all time) y: 57 lines of code src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java x: 4 commits (all time) y: 85 lines of code src/main/java/com/uber/rss/messages/FinishUploadMessage.java x: 5 commits (all time) y: 47 lines of code src/main/java/com/uber/rss/messages/GetDataAvailabilityRequest.java x: 4 commits (all time) y: 21 lines of code src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java x: 9 commits (all time) y: 332 lines of code src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java x: 10 commits (all time) y: 149 lines of code src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java x: 8 commits (all time) y: 160 lines of code src/main/java/com/uber/rss/clients/PooledShuffleDataSyncWriteClient.java x: 2 commits (all time) y: 113 lines of code src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java x: 6 commits (all time) y: 253 lines of code src/main/java/com/uber/rss/clients/ReplicatedReadClient.java x: 10 commits (all time) y: 365 lines of code src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java x: 8 commits (all time) y: 153 lines of code src/main/java/com/uber/rss/clients/RetriableSocketReadClient.java x: 10 commits (all time) y: 92 lines of code src/main/java/com/uber/rss/clients/ServerIdAwareSocketReadClient.java x: 10 commits (all time) y: 69 lines of code src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java x: 8 commits (all time) y: 127 lines of code src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClient.java x: 2 commits (all time) y: 16 lines of code src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClientBase.java x: 2 commits (all time) y: 86 lines of code src/main/java/com/uber/rss/clients/ShuffleDataWriter.java x: 2 commits (all time) y: 10 lines of code src/main/java/com/uber/rss/clients/TaskDataBlock.java x: 2 commits (all time) y: 48 lines of code src/main/java/com/uber/rss/clients/UnpooledWriteClientFactory.java x: 6 commits (all time) y: 23 lines of code src/main/java/com/uber/rss/clients/WriteClientFactory.java x: 6 commits (all time) y: 4 lines of code src/main/java/com/uber/rss/tools/StreamReadClientVerify.java x: 10 commits (all time) y: 156 lines of code src/main/java/com/uber/rss/clients/ReadClientDataOptions.java x: 6 commits (all time) y: 31 lines of code src/main/scala/org/apache/spark/shuffle/rss/MapOutputRssInfo.scala x: 8 commits (all time) y: 9 lines of code src/main/java/com/uber/rss/clients/ShuffleWriteConfig.java x: 4 commits (all time) y: 31 lines of code src/main/java/com/uber/rss/metrics/M3DummyScope.java x: 4 commits (all time) y: 92 lines of code src/main/java/com/uber/rss/storage/ShuffleFileStorage.java x: 4 commits (all time) y: 82 lines of code src/main/java/com/uber/rss/clients/MultiServerHeartbeatClient.java x: 3 commits (all time) y: 115 lines of code src/main/java/com/uber/rss/common/FixedLengthInputStream.java x: 3 commits (all time) y: 86 lines of code src/main/java/com/uber/rss/common/MapTaskRssInfo.java x: 3 commits (all time) y: 62 lines of code src/main/java/com/uber/rss/common/ServerDetail.java x: 4 commits (all time) y: 65 lines of code src/main/java/com/uber/rss/messages/HeartbeatMessage.java x: 2 commits (all time) y: 54 lines of code src/main/java/com/uber/rss/metadata/StandaloneServiceRegistryClient.java x: 4 commits (all time) y: 53 lines of code src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java x: 6 commits (all time) y: 97 lines of code src/main/java/com/uber/rss/util/ServerHostAndPort.java x: 3 commits (all time) y: 57 lines of code src/main/java/com/uber/rss/util/StringUtils.java x: 4 commits (all time) y: 95 lines of code src/main/scala/org/apache/spark/shuffle/MockTaskContext.scala x: 2 commits (all time) y: 50 lines of code src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala x: 4 commits (all time) y: 111 lines of code src/main/java/com/uber/rss/common/ServerList.java x: 3 commits (all time) y: 55 lines of code src/main/java/com/uber/rss/clients/ClientBase.java x: 3 commits (all time) y: 268 lines of code src/main/java/com/uber/rss/util/MonitorUtils.java x: 5 commits (all time) y: 20 lines of code src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java x: 4 commits (all time) y: 76 lines of code src/main/java/com/uber/rss/common/DataBlockHeader.java x: 3 commits (all time) y: 35 lines of code src/main/java/com/uber/rss/util/ByteBufUtils.java x: 3 commits (all time) y: 77 lines of code src/main/java/com/uber/rss/handlers/NotifyServerHandler.java x: 4 commits (all time) y: 49 lines of code src/main/scala/org/apache/spark/shuffle/RssServerSelectionResult.scala x: 2 commits (all time) y: 3 lines of code src/main/java/com/uber/rss/RssBuildInfo.java x: 2 commits (all time) y: 24 lines of code src/main/java/com/uber/rss/clients/ClientRetryOptions.java x: 2 commits (all time) y: 28 lines of code src/main/java/com/uber/rss/clients/NotifyClient.java x: 2 commits (all time) y: 62 lines of code src/main/java/com/uber/rss/clients/ServerConnectionCacheUpdateRefresher.java x: 2 commits (all time) y: 39 lines of code src/main/java/com/uber/rss/common/AppShuffleId.java x: 2 commits (all time) y: 42 lines of code src/main/java/com/uber/rss/common/AppTaskAttemptId.java x: 2 commits (all time) y: 71 lines of code src/main/java/com/uber/rss/common/DataBlock.java x: 2 commits (all time) y: 21 lines of code src/main/java/com/uber/rss/common/FilePathAndLength.java x: 2 commits (all time) y: 35 lines of code src/main/java/com/uber/rss/common/ServerDetailCollection.java x: 2 commits (all time) y: 56 lines of code src/main/java/com/uber/rss/exceptions/RssFileCorruptedException.java x: 2 commits (all time) y: 9 lines of code src/main/java/com/uber/rss/handlers/RegistryServerHandler.java x: 2 commits (all time) y: 46 lines of code src/main/java/com/uber/rss/messages/FinishApplicationAttemptRequestMessage.java x: 2 commits (all time) y: 38 lines of code src/main/java/com/uber/rss/messages/StartUploadMessage.java x: 2 commits (all time) y: 78 lines of code src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetrics.java x: 3 commits (all time) y: 27 lines of code src/main/java/com/uber/rss/tools/FsyncPerfTest.java x: 2 commits (all time) y: 131 lines of code src/main/java/com/uber/rss/tools/SerializerBenchmark.java x: 2 commits (all time) y: 164 lines of code src/main/java/com/uber/rss/util/FileUtils.java x: 3 commits (all time) y: 119 lines of code src/main/java/com/uber/rss/util/RetryUtils.java x: 2 commits (all time) 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 27.0
commits (all time)
min: 2.0 | average: 4.27 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 4.0 | max: 27.0

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

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

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

No data for "commits (30d)" vs. "lines of code".

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

No data for "contributors (30d)" vs. "lines of code".

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

No data for "commits (90d)" vs. "lines of code".

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

No data for "contributors (90d)" vs. "lines of code".