Path	Lines of Code
src/main/scala/com/uber/rss/test/AggOrderingShuffleTestApp.scala	73
src/main/scala/com/uber/rss/test/MapCombinerShuffleTestApp.scala	92
src/main/scala/com/uber/rss/test/MultiStageShuffleTestApp.scala	75
src/main/scala/com/uber/rss/test/ReducerAggShuffleTestApp.scala	85
src/main/scala/com/uber/rss/test/RepartitionShuffleTestApp.scala	90
src/main/scala/com/uber/rss/test/ShuffleTestAppBase.scala	189
src/main/scala/com/uber/rss/test/util/KeyValueGenerator.scala	54
src/test/java/com/uber/rss/PackageJarFileITCase.java	69
src/test/java/com/uber/rss/RssBuildInfoTest.java	13
src/test/java/com/uber/rss/StreamServerCleanupTest.java	67
src/test/java/com/uber/rss/StreamServerConfigTest.java	15
src/test/java/com/uber/rss/StreamServerHttpTest.java	33
src/test/java/com/uber/rss/StreamServerMultiAttemptTest.java	227
src/test/java/com/uber/rss/StreamServerTest.java	100
src/test/java/com/uber/rss/StreamServerWritingTooMuchDataTest.java	68
src/test/java/com/uber/rss/clients/BlockingServerReadClientTest.java	558
src/test/java/com/uber/rss/clients/BusyStatusSocketClientTest.java	29
src/test/java/com/uber/rss/clients/DataBlockSocketReadClientTest.java	681
src/test/java/com/uber/rss/clients/DataBlockSyncWriteClientTest.java	111
src/test/java/com/uber/rss/clients/DownloadRequestClient.java	244
src/test/java/com/uber/rss/clients/HeartbeatSocketClientTest.java	56
src/test/java/com/uber/rss/clients/MultiServerAsyncWriteClientTest.java	373
src/test/java/com/uber/rss/clients/MultiServerHeartbeatClientTest.java	90
src/test/java/com/uber/rss/clients/MultiServerSocketReadClientTest.java	558
src/test/java/com/uber/rss/clients/MultiServerSyncWriteClientTest.java	244
src/test/java/com/uber/rss/clients/NotifyClientTest.java	34
src/test/java/com/uber/rss/clients/PooledWriteClientFactoryRandomTest.java	62
src/test/java/com/uber/rss/clients/PooledWriteClientFactoryTest.java	177
src/test/java/com/uber/rss/clients/RecordSocketReadClientTest.java	365
src/test/java/com/uber/rss/clients/RegistryClientTest.java	30
src/test/java/com/uber/rss/clients/ReplicatedReadClientTest.java	462
src/test/java/com/uber/rss/clients/ReplicatedWriteClientTest.java	410
src/test/java/com/uber/rss/clients/RetriableSocketReadClientTest.java	368
src/test/java/com/uber/rss/clients/ServerIdAwareSocketReadClientTest.java	132
src/test/java/com/uber/rss/clients/ServerIdAwareSyncWriteClientTest.java	191
src/test/java/com/uber/rss/clients/ServerIdleTimeoutTest.java	45
src/test/java/com/uber/rss/clients/ServerReplicationGroupUtilTest.java	368
src/test/java/com/uber/rss/clients/ShuffleDataSocketReadClientTest.java	365
src/test/java/com/uber/rss/clients/WriteClientEdgeCaseTest.java	205
src/test/java/com/uber/rss/common/FixedLengthInputStreamTest.java	132
src/test/java/com/uber/rss/common/MapTaskRssInfoTest.java	18
src/test/java/com/uber/rss/common/ServerDetailCollectionTest.java	22
src/test/java/com/uber/rss/execution/LocalFileLocalFileStateStoreIteratorTest.java	214
src/test/java/com/uber/rss/execution/LocalFileStateStoreStressTest.java	92
src/test/java/com/uber/rss/execution/LocalFileStateStoreTest.java	203
src/test/java/com/uber/rss/execution/ShuffleExecutorTest.java	174
src/test/java/com/uber/rss/metadata/InMemoryServiceRegistryTest.java	90
src/test/java/com/uber/rss/metadata/ServiceRegistryTestUtil.java	30
src/test/java/com/uber/rss/metadata/ServiceRegistryUtilsTest.java	67
src/test/java/com/uber/rss/metadata/StandalongServiceRegistryClientTest.java	39
src/test/java/com/uber/rss/metadata/ZooKeeperFaultTolerantServiceRegistryTest.java	84
src/test/java/com/uber/rss/metadata/ZooKeeperServiceRegistryTest.java	193
src/test/java/com/uber/rss/testutil/ClientTestUtils.java	68
src/test/java/com/uber/rss/testutil/NettyMemoryExperiments.java	23
src/test/java/com/uber/rss/testutil/RssMiniCluster.java	104
src/test/java/com/uber/rss/testutil/RssZookeeperCluster.java	83
src/test/java/com/uber/rss/testutil/StreamServerTestUtils.java	62
src/test/java/com/uber/rss/testutil/TestConstants.java	10
src/test/java/com/uber/rss/testutil/TestStreamServer.java	138
src/test/java/com/uber/rss/testutil/ZooKeeperTestCluster.java	33
src/test/java/com/uber/rss/tools/StreamServerStressToolTest.java	16
src/test/java/com/uber/rss/util/ByteBufUtilsTest.java	25
src/test/java/com/uber/rss/util/ExceptionUtilsTest.java	23
src/test/java/com/uber/rss/util/FileUtilsTest.java	52
src/test/java/com/uber/rss/util/MonitorUtilsTest.java	18
src/test/java/com/uber/rss/util/MovingAverageCalculatorTest.java	61
src/test/java/com/uber/rss/util/NetworkUtilsTest.java	26
src/test/java/com/uber/rss/util/RateCounterTest.java	29
src/test/java/com/uber/rss/util/RetryUtilsTest.java	35
src/test/java/com/uber/rss/util/ServerHostAndPortTest.java	48
src/test/java/com/uber/rss/util/StringUtilsTest.java	25
src/test/scala/org/apache/spark/shuffle/EmptyPartitionShuffleTest.scala	74
src/test/scala/org/apache/spark/shuffle/LazyWriteClientTest.scala	51
src/test/scala/org/apache/spark/shuffle/RssOptsTest.scala	11
src/test/scala/org/apache/spark/shuffle/RssShuffleManagerReplicateServerGroupTest.scala	188
src/test/scala/org/apache/spark/shuffle/RssShuffleManagerServerRestartTest.scala	266
src/test/scala/org/apache/spark/shuffle/RssShuffleManagerTest.scala	195
src/test/scala/org/apache/spark/shuffle/RssShuffleManagerWithStandaloneRegistryServerTest.scala	114
src/test/scala/org/apache/spark/shuffle/ShuffleWithAggregationTest.scala	263
src/test/scala/org/apache/spark/shuffle/ShuffleWithOrderingTest.scala	57
src/test/scala/org/apache/spark/shuffle/ShuffleWithSparkSqlLargeDataTest.scala	62
src/test/scala/org/apache/spark/shuffle/ShuffleWithSparkSqlRandomTest.scala	71
src/test/scala/org/apache/spark/shuffle/ShuffleWithSparkSqlTest.scala	113
src/test/scala/org/apache/spark/shuffle/ShuffleWithZstdCompressionTest.scala	53
src/test/scala/org/apache/spark/shuffle/TestUdfs.scala	19
src/test/scala/org/apache/spark/shuffle/TestUtil.scala	27
src/test/scala/org/apache/spark/shuffle/ZeroMapperShuffleTest.scala	52
src/test/scala/org/apache/spark/shuffle/rss/MapOutputRssInfoTest.scala	14
src/test/scala/org/apache/spark/shuffle/rss/WriteBufferManagerTest.scala	145