Uber / RemoteShuffleServiceConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

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

0 very complex units (0 lines of code)
2 complex units (234 lines of code)
16 medium complex units (1,290 lines of code)
63 simple units (2,037 lines of code)
1,464 very simple units (8,978 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
private void decodeImpl() in src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java	172	30	3
public static StreamServerConfig buildFromArgs() in src/main/java/com/uber/rss/StreamServerConfig.java	62	26	1
public static void main() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	68	24	1
public void run() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	159	20	0
private void simulateMapperTask() in src/main/java/com/uber/rss/tools/StreamServerStressTool.java	125	20	7
private Object getControlMessage() in src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java	60	20	3
public void run() in src/main/java/com/uber/rss/tools/SerializerBenchmark.java	107	17	1
public void run() in src/main/java/com/uber/rss/tools/PartitionFileChecker.java	65	14	0
public static String toString4SortedIntList() in src/main/java/com/uber/rss/util/StringUtils.java	50	14	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
override def getWriter[K, V]() in src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	147	14	3
public synchronized TaskDataBlock readDataBlock() in src/main/java/com/uber/rss/clients/ReplicatedReadClient.java	58	13	0
public static void main() in src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java	42	13	1
public synchronized void registerServer() in src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java	50	12	5
public void verifyRecords() in src/main/java/com/uber/rss/tools/StreamReadClientVerify.java	68	11	2
public static Long getBytesValue() in src/main/java/com/uber/rss/util/StringUtils.java	37	11	1
public static List getReachableServers() in src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java	75	11	6
public void collectMetrics() in src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java	49	10	2
private ConnectDownloadResponse connectImpl() in src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	47	10	0
public GetDataAvailabilityResponse waitDataAvailable() in src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	55	10	0
public void close() in src/main/java/com/uber/rss/clients/ClientBase.java	37	10	0
protected void connectSocket() in src/main/java/com/uber/rss/clients/ClientBase.java	58	10	0
private BaseMessage readDataItem() in src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java	47	10	0
private[rss] def addRecordImpl() in src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala	56	10	3
def run() in src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala	74	10	0
private def fetchNextDeserializationIterator() in src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala	58	10	0
override def onJobEnd() in src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala	32	10	1
public void connect() in src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java	48	9	0
public void writeDataBlock() in src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java	34	9	2
private void connectAndInitializeClient() in src/main/java/com/uber/rss/clients/ReplicatedReadClient.java	37	9	0
public static void checkDiskFreeSpace() in src/main/java/com/uber/rss/util/FileUtils.java	37	9	2
public void shutdown() in src/main/java/com/uber/rss/StreamServer.java	48	9	1
private void addVersionDecoder() in src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java	46	9	3
public List getNonEmptyPartitionFiles() in src/main/java/com/uber/rss/handlers/DownloadServerHandler.java	43	9	1
public boolean equals() in src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java	10	8	1
private ConnectUploadResponse connectImpl() in src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java	51	8	3
private void runAllActiveClients() in src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java	34	8	1
public ConnectUploadResponse connect() in src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java	41	8	0
private void createServiceRegistry() in src/main/java/com/uber/rss/StreamServer.java	39	8	1
public boolean equals() in src/main/java/com/uber/rss/common/AppTaskAttemptId.java	10	8	1
private StateStoreLoadResult loadStateStoreImpl() in src/main/java/com/uber/rss/execution/ShuffleExecutor.java	49	8	0
private def getRssServers() in src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala	37	8	3
public static List createReplicationGroups() in src/main/java/com/uber/rss/clients/ServerReplicationGroupUtil.java	24	7	2
public TDecodeResult decode() in src/main/java/com/uber/rss/clients/StreamDecoderBase.java	21	7	0
private DataBlock readDataBlockNoCheckTaskAttemptId() in src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java	24	7	0
public synchronized long getShuffleWriteBytes() in src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java	25	7	0
private final void checkOKResponseStatus() in src/main/java/com/uber/rss/clients/ClientBase.java	18	7	1
public static void main() in src/main/java/com/uber/rss/tools/StreamReadClientVerify.java	27	7	1
public void run() in src/main/java/com/uber/rss/tools/FileDescriptorStressTest.java	40	7	0