path	# lines of code
src/main/java/com/uber/rss/metrics/WriteClientMetrics.java	49
src/main/java/com/uber/rss/metrics/NettyServerSideMetricsKey.java	28
src/main/java/com/uber/rss/metrics/M3DummyScopeBuilder.java	40
src/main/java/com/uber/rss/metrics/ReadClientMetricsKey.java	35
src/main/java/com/uber/rss/metrics/WriteClientMetricsKey.java	35
src/main/java/com/uber/rss/metrics/NettyServerSideMetricGroupContainer.java	14
src/main/java/com/uber/rss/metrics/MetadataClientMetricsKey.java	41
src/main/java/com/uber/rss/metrics/NotifyServerMetricsContainer.java	19
src/main/java/com/uber/rss/metrics/ExceptionMetricsKey.java	35
src/main/java/com/uber/rss/metrics/ClientConnectMetrics.java	28
src/main/java/com/uber/rss/metrics/ExceptionMetricGroupContainer.java	12
src/main/java/com/uber/rss/metrics/ApplicationMetrics.java	22
src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetrics.java	27
src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java	97
src/main/java/com/uber/rss/metrics/ReadClientMetrics.java	44
src/main/java/com/uber/rss/metrics/MetricGroup.java	15
src/main/java/com/uber/rss/metrics/MetadataClientMetricsContainer.java	12
src/main/java/com/uber/rss/metrics/NotifyClientMetrics.java	22
src/main/java/com/uber/rss/metrics/NotifyClientMetricsKey.java	35
src/main/java/com/uber/rss/metrics/M3Stats.java	106
src/main/java/com/uber/rss/metrics/M3DummyScope.java	92
src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetricsKey.java	35
src/main/java/com/uber/rss/metrics/MetricGroupContainer.java	19
src/main/java/com/uber/rss/metrics/ExceptionMetrics.java	29
src/main/java/com/uber/rss/metrics/ApplicationMetricsKey.java	35
src/main/java/com/uber/rss/metrics/MetadataClientMetrics.java	39
src/main/java/com/uber/rss/metrics/ShuffleClientStageMetricsKey.java	35
src/main/java/com/uber/rss/metrics/ServerHandlerMetrics.java	35
src/main/java/com/uber/rss/metrics/ClientConnectMetricsKey.java	35
src/main/java/com/uber/rss/metrics/ShuffleClientStageMetrics.java	34
src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClient.java	16
src/main/java/com/uber/rss/clients/EofRecordKeyValuePair.java	6
src/main/java/com/uber/rss/clients/ServerReplicationGroupUtil.java	55
src/main/java/com/uber/rss/clients/RetriableSocketReadClient.java	92
src/main/java/com/uber/rss/clients/StreamDecoderBase.java	117
src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java	332
src/main/java/com/uber/rss/clients/ServerConnectionCacheUpdateRefresher.java	39
src/main/java/com/uber/rss/clients/ServerConnectionRefresher.java	5
src/main/java/com/uber/rss/clients/ReplicatedReadClient.java	365
src/main/java/com/uber/rss/clients/BlockingSingleServerReadClient.java	5
src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java	253
src/main/java/com/uber/rss/clients/MultiServerHeartbeatClient.java	115
src/main/java/com/uber/rss/clients/BusyStatusSocketClient.java	32
src/main/java/com/uber/rss/clients/LazyWriteClient.java	70
src/main/java/com/uber/rss/clients/SingleServerReadClient.java	5
src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	299
src/main/java/com/uber/rss/clients/ShuffleDataReader.java	6
src/main/java/com/uber/rss/clients/RecordSocketReadClient.java	83
src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java	48
src/main/java/com/uber/rss/clients/ClientRetryOptions.java	28
src/main/java/com/uber/rss/clients/SingleServerWriteClient.java	5
src/main/java/com/uber/rss/clients/NotifyClient.java	62
src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClientBase.java	86
src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java	127
src/main/java/com/uber/rss/clients/ServerIdAwareSocketReadClient.java	69
src/main/java/com/uber/rss/clients/PlainShuffleDataSocketReadClient.java	18
src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java	83
src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java	6
src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java	142
src/main/java/com/uber/rss/clients/ShuffleDataWriter.java	10
src/main/java/com/uber/rss/clients/MultiServerReadClient.java	4
src/main/java/com/uber/rss/clients/BlockingQueueReadClient.java	84
src/main/java/com/uber/rss/clients/ServerConnectionStringCache.java	28
src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java	153
src/main/java/com/uber/rss/clients/RegistryClient.java	47
src/main/java/com/uber/rss/clients/WriteClientFactory.java	4
src/main/java/com/uber/rss/clients/PooledShuffleDataSyncWriteClient.java	113
src/main/java/com/uber/rss/clients/MultiServerWriteClient.java	4
src/main/java/com/uber/rss/clients/ClientConstants.java	4
src/main/java/com/uber/rss/clients/ServerConnectionStringResolver.java	5
src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java	106
src/main/java/com/uber/rss/clients/TaskDataBlock.java	48
src/main/java/com/uber/rss/clients/PlainShuffleDataSyncWriteClient.java	26
src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java	149
src/main/java/com/uber/rss/clients/ReadClientDataOptions.java	31
src/main/java/com/uber/rss/clients/ClientBase.java	268
src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java	160
src/main/java/com/uber/rss/clients/ShuffleWriteConfig.java	31
src/main/java/com/uber/rss/clients/HeartbeatSocketClient.java	34
src/main/java/com/uber/rss/clients/FailedFetchRecordKeyValuePair.java	11
src/main/java/com/uber/rss/clients/UnpooledWriteClientFactory.java	23
src/main/java/com/uber/rss/tools/TestUtils.java	48
src/main/java/com/uber/rss/tools/StreamReadClientVerify.java	156
src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java	118
src/main/java/com/uber/rss/tools/PartitionFileChecker.java	98
src/main/java/com/uber/rss/tools/StreamServerStressToolWrite64GB.java	29
src/main/java/com/uber/rss/tools/FileDescriptorStressTest.java	68
src/main/java/com/uber/rss/tools/StreamServerStressTool.java	615
src/main/java/com/uber/rss/tools/FsyncPerfTest.java	131
src/main/java/com/uber/rss/tools/SerializerBenchmark.java	164
src/main/java/com/uber/rss/messages/AppDeletionStateItem.java	30
src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java	85
src/main/java/com/uber/rss/messages/BaseMessage.java	4
src/main/java/com/uber/rss/messages/StageCorruptionStateItem.java	36
src/main/java/com/uber/rss/messages/ConnectUploadRequest.java	46
src/main/java/com/uber/rss/messages/ShuffleDataWrapper.java	31
src/main/java/com/uber/rss/messages/ConnectRegistryRequest.java	30
src/main/java/com/uber/rss/messages/GetDataAvailabilityResponse.java	47
src/main/java/com/uber/rss/messages/GetDataAvailabilityRequestMessage.java	21
src/main/java/com/uber/rss/messages/ServerResponseMessage.java	13
src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java	89
src/main/java/com/uber/rss/messages/FinishApplicationAttemptRequestMessage.java	38
src/main/java/com/uber/rss/messages/FinishUploadMessage.java	47
src/main/java/com/uber/rss/messages/RegisterServerResponseMessage.java	30
src/main/java/com/uber/rss/messages/GetDataAvailabilityRequest.java	21
src/main/java/com/uber/rss/messages/ConnectUploadResponse.java	46
src/main/java/com/uber/rss/messages/HeartbeatMessage.java	54
src/main/java/com/uber/rss/messages/ShuffleStageStatus.java	59
src/main/java/com/uber/rss/messages/ConnectNotifyResponse.java	30
src/main/java/com/uber/rss/messages/GetBusyStatusResponse.java	60
src/main/java/com/uber/rss/messages/ConnectNotifyRequest.java	30
src/main/java/com/uber/rss/messages/ConnectDownloadResponse.java	81
src/main/java/com/uber/rss/messages/FinishApplicationJobRequestMessage.java	70
src/main/java/com/uber/rss/messages/RegisterServerRequestMessage.java	62
src/main/java/com/uber/rss/messages/GetServersRequestMessage.java	46
src/main/java/com/uber/rss/messages/GetServersResponseMessage.java	44
src/main/java/com/uber/rss/messages/StageInfoStateItem.java	72
src/main/java/com/uber/rss/messages/MessageConstants.java	46
src/main/java/com/uber/rss/messages/SerializableMessage.java	5
src/main/java/com/uber/rss/messages/ConnectRegistryResponse.java	30
src/main/java/com/uber/rss/messages/TaskAttemptCommitStateItem.java	78
src/main/java/com/uber/rss/messages/ControlMessage.java	3
src/main/java/com/uber/rss/messages/StartUploadMessage.java	78
src/main/java/com/uber/rss/messages/GetBusyStatusRequest.java	30
src/main/java/com/uber/rss/util/SystemUtils.java	14
src/main/java/com/uber/rss/util/StringUtils.java	95
src/main/java/com/uber/rss/util/StreamUtils.java	37
src/main/java/com/uber/rss/util/AsyncSocketCompletionHandler.java	39
src/main/java/com/uber/rss/util/NetworkUtils.java	57
src/main/java/com/uber/rss/util/RateCounter.java	40
src/main/java/com/uber/rss/util/MovingAverageCalculator.java	33
src/main/java/com/uber/rss/util/ObjectWrapper.java	30
src/main/java/com/uber/rss/util/CountedOutputStream.java	31
src/main/java/com/uber/rss/util/AsyncSocketState.java	32
src/main/java/com/uber/rss/util/RetryUtils.java	96
src/main/java/com/uber/rss/util/FileUtils.java	119
src/main/java/com/uber/rss/util/MonitorUtils.java	20
src/main/java/com/uber/rss/util/ExceptionUtils.java	43
src/main/java/com/uber/rss/util/SocketAsyncWriteCallback.java	3
src/main/java/com/uber/rss/util/NettyUtils.java	14
src/main/java/com/uber/rss/util/ServerHostAndPort.java	57
src/main/java/com/uber/rss/util/ThreadUtils.java	15
src/main/java/com/uber/rss/util/ByteBufUtils.java	77
src/main/java/com/uber/rss/util/JsonUtils.java	35
src/main/java/com/uber/rss/util/SocketUtils.java	78
src/main/java/com/uber/rss/util/HttpUtils.java	29
src/main/java/com/uber/rss/util/LogUtils.java	9
src/main/java/com/uber/rss/StreamServer.java	303
src/main/java/com/uber/rss/StreamServerConfig.java	283
src/main/java/com/uber/rss/exceptions/RssInvalidServerIdException.java	11
src/main/java/com/uber/rss/exceptions/RssTooMuchDataException.java	8
src/main/java/com/uber/rss/exceptions/RssAggregateException.java	24
src/main/java/com/uber/rss/exceptions/RssUnsupportedCompressionException.java	17
src/main/java/com/uber/rss/exceptions/RssDiskSpaceException.java	17
src/main/java/com/uber/rss/exceptions/RssInvalidMapStatusException.java	8
src/main/java/com/uber/rss/exceptions/RssNetworkException.java	17
src/main/java/com/uber/rss/exceptions/RssShuffleDataNotAvailableException.java	9
src/main/java/com/uber/rss/exceptions/ExceptionWrapper.java	16
src/main/java/com/uber/rss/exceptions/RssFileCorruptedException.java	9
src/main/java/com/uber/rss/exceptions/RssInconsistentReplicaException.java	11
src/main/java/com/uber/rss/exceptions/RssServerResolveException.java	11
src/main/java/com/uber/rss/exceptions/RssInvalidServerVersionException.java	11
src/main/java/com/uber/rss/exceptions/RssStaleTaskAttemptException.java	9
src/main/java/com/uber/rss/exceptions/RssQueueNotReadyException.java	11
src/main/java/com/uber/rss/exceptions/RssNoActiveReadClientException.java	11
src/main/java/com/uber/rss/exceptions/RssDuplicateAppTaskAttemptException.java	17
src/main/java/com/uber/rss/exceptions/RssInvalidStateException.java	17
src/main/java/com/uber/rss/exceptions/RssMissingShuffleWriteConfigException.java	9
src/main/java/com/uber/rss/exceptions/RssOperationQueueFullException.java	17
src/main/java/com/uber/rss/exceptions/RssNonRecoverableException.java	11
src/main/java/com/uber/rss/exceptions/RssException.java	17
src/main/java/com/uber/rss/exceptions/RssFinishUploadException.java	11
src/main/java/com/uber/rss/exceptions/RssRetryTimeoutException.java	11
src/main/java/com/uber/rss/exceptions/RssInvalidDataException.java	17
src/main/java/com/uber/rss/exceptions/RssServerBusyException.java	8
src/main/java/com/uber/rss/exceptions/RssNoServerAvailableException.java	8
src/main/java/com/uber/rss/exceptions/RssMaxConnectionsException.java	29
src/main/java/com/uber/rss/exceptions/RssEndOfStreamException.java	17
src/main/java/com/uber/rss/exceptions/RssStreamReadException.java	17
src/main/java/com/uber/rss/exceptions/RssWriteRecordException.java	11
src/main/java/com/uber/rss/exceptions/RssUberEnvironmentException.java	11
src/main/java/com/uber/rss/exceptions/RssShuffleCorruptedException.java	9
src/main/java/com/uber/rss/exceptions/RssServerDownException.java	8
src/main/java/com/uber/rss/exceptions/RssRetryableSparkTaskException.java	11
src/main/java/com/uber/rss/exceptions/RssShuffleStageNotStartedException.java	9
src/main/java/com/uber/rss/storage/ShuffleFileUtils.java	23
src/main/java/com/uber/rss/storage/ShuffleStorage.java	14
src/main/java/com/uber/rss/storage/ShuffleFileStorage.java	82
src/main/java/com/uber/rss/storage/ShuffleOutputStream.java	7
src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java	71
src/main/java/com/uber/rss/common/DataBlockHeader.java	35
src/main/java/com/uber/rss/common/FilePathAndLength.java	35
src/main/java/com/uber/rss/common/ServerReplicationGroup.java	18
src/main/java/com/uber/rss/common/MapTaskRssInfo.java	62
src/main/java/com/uber/rss/common/ServerList.java	55
src/main/java/com/uber/rss/common/AppMapId.java	55
src/main/java/com/uber/rss/common/MemoryMonitor.java	70
src/main/java/com/uber/rss/common/ServerDetailCollection.java	56
src/main/java/com/uber/rss/common/AppTaskAttemptId.java	71
src/main/java/com/uber/rss/common/ServerCandidate.java	28
src/main/java/com/uber/rss/common/PartitionFilePathAndLength.java	42
src/main/java/com/uber/rss/common/Compression.java	56
src/main/java/com/uber/rss/common/LowMemoryListener.java	4
src/main/java/com/uber/rss/common/AppShuffleId.java	42
src/main/java/com/uber/rss/common/MapTaskCommitStatus.java	64
src/main/java/com/uber/rss/common/ServerDetail.java	65
src/main/java/com/uber/rss/common/ServerRole.java	6
src/main/java/com/uber/rss/common/FixedLengthInputStream.java	86
src/main/java/com/uber/rss/common/DownloadServerVerboseInfo.java	32
src/main/java/com/uber/rss/common/AppShufflePartitionId.java	62
src/main/java/com/uber/rss/common/DataBlock.java	21
src/main/java/com/uber/rss/common/ShuffleMapTaskAttemptId.java	42
src/main/java/com/uber/rss/execution/ShuffleExecutor.java	547
src/main/java/com/uber/rss/execution/StateStoreLoadResult.java	52
src/main/java/com/uber/rss/execution/ExecutorShuffleStageState.java	229
src/main/java/com/uber/rss/execution/ShuffleDataWrapper.java	36
src/main/java/com/uber/rss/execution/ShufflePartitionWriter.java	147
src/main/java/com/uber/rss/execution/StagePersistentInfo.java	35
src/main/java/com/uber/rss/execution/TaskAttemptCollection.java	23
src/main/java/com/uber/rss/execution/StateStore.java	15
src/main/java/com/uber/rss/execution/LocalFileStateStore.java	204
src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java	173
src/main/java/com/uber/rss/execution/ExecutorAppState.java	33
src/main/java/com/uber/rss/execution/TaskAttemptIdAndState.java	40
src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java	347
src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java	113
src/main/java/com/uber/rss/RssBuildInfo.java	24
src/main/java/com/uber/rss/metadata/ZooKeeperFaultTolerantServiceRegistry.java	63
src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java	151
src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java	191
src/main/java/com/uber/rss/metadata/ServiceRegistry.java	21
src/main/java/com/uber/rss/metadata/InMemoryServiceRegistry.java	62
src/main/java/com/uber/rss/metadata/StandaloneServiceRegistryClient.java	53
src/main/java/com/uber/rss/metadata/ServiceRegistryWrapper.java	93
src/main/java/com/uber/rss/metadata/ZooKeeperServerNodeData.java	24
src/main/java/com/uber/rss/handlers/ChannelIdleCheck.java	52
src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java	159
src/main/java/com/uber/rss/handlers/NotifyChannelInboundHandler.java	54
src/main/java/com/uber/rss/handlers/ResponseStatusAndMessage.java	22
src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java	184
src/main/java/com/uber/rss/handlers/NotifyServerHandler.java	49
src/main/java/com/uber/rss/handlers/DownloadServerHandler.java	155
src/main/java/com/uber/rss/handlers/UploadChannelManager.java	37
src/main/java/com/uber/rss/handlers/ChannelFutureCloseListener.java	17
src/main/java/com/uber/rss/handlers/RegistryServerHandler.java	46
src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java	76
src/main/java/com/uber/rss/handlers/RegistryChannelInboundHandler.java	55
src/main/java/com/uber/rss/handlers/UploadServerHandler.java	103
src/main/java/com/uber/rss/handlers/HandlerUtil.java	47
src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	364
src/main/scala/org/apache/spark/shuffle/RssEmptyShuffleReader.scala	19
src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala	90
src/main/scala/org/apache/spark/shuffle/RssOpts.scala	175
src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationImpl.scala	99
src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala	105
src/main/scala/org/apache/spark/shuffle/rss/MapOutputRssInfo.scala	9
src/main/scala/org/apache/spark/shuffle/rss/EmptyRecordIterator.scala	11
src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationManager.scala	32
src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala	175
src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala	82
src/main/scala/org/apache/spark/shuffle/rss/WriterNoAggregationManager.scala	14
src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala	348
src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala	174
src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala	111
src/main/scala/org/apache/spark/shuffle/RssServiceRegistry.scala	63
src/main/scala/org/apache/spark/shuffle/RssShuffleServerHandle.scala	7
src/main/scala/org/apache/spark/shuffle/RssShuffleHandle.scala	19
src/main/scala/org/apache/spark/shuffle/MockTaskContext.scala	50
src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala	181
src/main/scala/org/apache/spark/shuffle/RssServerSelectionResult.scala	3
src/main/scala/org/apache/spark/shuffle/RssShuffleBlockResolver.scala	10