uber / RemoteShuffleService Unit Size

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 1,545 units with 12,539 lines of code in units (73.5% of code).

5 very long units (710 lines of code)
21 long units (1,334 lines of code)
84 medium size units (2,687 lines of code)
152 small units (2,185 lines of code)
1,283 very small units (5,623 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
private void decodeImpl() in src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java	172	30	3
public void run() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	159	20	0
override def getWriter[K, V]() in src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	147	14	3
private void simulateMapperTask() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	125	20	7
public void run() in src/main/java/com/uber/rss/tools/SerializerBenchmark.java	107	17	1
private void loadStateImpl() in src/main/java/com/uber/rss/execution/ShuffleExecutor.java	90	14	5
public void channelRead() in src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java	89	14	2
public static List getReachableServers() in src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java	75	11	6
def run() in src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala	74	10	0
public static void main() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	68	24	1
public void verifyRecords() in src/main/java/com/uber/rss/tools/StreamReadClientVerify.java	68	11	2
public void run() in src/main/java/com/uber/rss/tools/PartitionFileChecker.java	65	14	0
private def createBlockDownloaderPartitionRecordIteratorWithoutRetry() in src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala	64	7	1
override def write() in src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala	63	4	2
public static StreamServerConfig buildFromArgs() in src/main/java/com/uber/rss/StreamServerConfig.java	62	26	1
private Object getControlMessage() in src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java	60	20	3
override def read() in src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala	60	7	0
public synchronized TaskDataBlock readDataBlock() in src/main/java/com/uber/rss/clients/ReplicatedReadClient.java	58	13	0
protected void connectSocket() in src/main/java/com/uber/rss/clients/ClientBase.java	58	10	0
private def fetchNextDeserializationIterator() in src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala	58	10	0
private[rss] def addRecordImpl() in src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala	56	10	3
public GetDataAvailabilityResponse waitDataAvailable() in src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	55	10	0
public void run() in src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java	55	4	0
public ChannelFuture sendFiles() in src/main/java/com/uber/rss/handlers/DownloadServerHandler.java	54	3	3
private ConnectUploadResponse connectImpl() in src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java	51	8	3
override def registerShuffle[K, V, C]() in src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	51	3	5
public static String toString4SortedIntList() in src/main/java/com/uber/rss/util/StringUtils.java	50	14	1
public synchronized void registerServer() in src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java	50	12	5
public void run() in src/main/java/com/uber/rss/StreamServer.java	50	5	0
private def simulateMapperTask() in src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala	50	4	4
public void collectMetrics() in src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java	49	10	2
private StateStoreLoadResult loadStateStoreImpl() in src/main/java/com/uber/rss/execution/ShuffleExecutor.java	49	8	0
public void shutdown() in src/main/java/com/uber/rss/StreamServer.java	48	9	1
public void connect() in src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java	48	9	0
private ConnectDownloadResponse connectImpl() in src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	47	10	0
private BaseMessage readDataItem() in src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java	47	10	0
private void run() in src/main/java/com/uber/rss/tools/FsyncPerfTest.java	47	4	0
private void addVersionDecoder() in src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java	46	9	3
private void removeExpiredApplications() in src/main/java/com/uber/rss/execution/ShuffleExecutor.java	43	7	0
public List getNonEmptyPartitionFiles() in src/main/java/com/uber/rss/handlers/DownloadServerHandler.java	43	9	1
public void channelRead() in src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java	42	7	2
public static void main() in src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java	42	13	1
public ConnectUploadResponse connect() in src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java	41	8	0
public void channelRead() in src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java	41	6	2
private void connectAndInitializeClient() in src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java	40	6	0
public void run() in src/main/java/com/uber/rss/tools/FileDescriptorStressTest.java	40	7	0
def getRssInfoFromMapOutputTracker() in src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala	40	6	4
override def getReader[K, C]() in src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	40	2	4
private void createServiceRegistry() in src/main/java/com/uber/rss/StreamServer.java	39	8	1
private NotificationListener createListener() in src/main/java/com/uber/rss/common/MemoryMonitor.java	38	5	2