GoogleCloudPlatform / pubsub - Conditional 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 267 units with 3,090 lines of code in units (62.5% of code).

0 very complex units (0 lines of code)
1 complex units (110 lines of code)
6 medium complex units (281 lines of code)
15 simple units (608 lines of code)
245 very simple units (2,091 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 ByteString handleValue() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	110	32	3
protected boolean processMessage() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java	113	20	2
static Value encode() in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java	45	16	2
public void put() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	47	14	1
static ByteString encodeToBytes() in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java	20	13	2
private static String stringRep() in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java	22	13	2
public synchronized void shutdown() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	34	11	0
public List poll() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	58	10	0
public void start() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	88	9	1
private SourceRecord createRecordWithStruct() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	44	9	6
public void put() in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java	38	9	1
private Integer selectPartition() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	15	8	3
public static void main() in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink/PubSubExample.java	59	7	1
public synchronized void start() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	28	7	0
private void generatePublishLoad() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	53	7	0
private void doPullIteration() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	49	6	1
protected ApiFuture publish() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java	54	6	3
public void start() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	46	6	1
private Iterable getRecordHeaders() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	17	6	1
private SourceRecord createRecordWithHeaders() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	29	6	6
public static PartitionScheme getEnum() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java	15	6	1
public void ensureValid() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java	15	6	2
Subscriber createSubscriber() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java	38	5	1
private Publisher createPublisher() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java	28	5	1
protected boolean processMessage() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	37	5	2
public void flush() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	25	5	1
public void start() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java	24	5	1
List poll() in kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java	29	5	0
public static String getEmulatorEndpoint() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java	10	4	1
public void close() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java	13	4	0
public synchronized ApiFuture notifyDataAvailable() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java	12	4	0
private static Row toPubsubRow() in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java	22	4	1
private void createSubscription() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	22	4	0
private void createStreamingPullSubscribers() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	41	4	0
private void createPullSubscribers() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	23	4	0
private void createPublisher() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	38	4	0
public void stop() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	15	4	0
public static OrderingKeySource getEnum() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java	11	4	1
public void ensureValid() in kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java	12	4	2
private static ApiException toApiException() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java	20	4	1
private synchronized ApiFuture onData() in kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java	12	4	0
private void checkForUnassignedReaders() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubSplitEnumerator.java	14	3	0
private Multimap getMessages() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java	9	3	0
public RecordsBySplits fetch() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java	13	3	0
public synchronized void handleSplitsChanges() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java	8	3	1
public synchronized void notifyCheckpointComplete() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubAckTracker.java	7	3	1
public synchronized Optional pullMessage() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java	9	3	0
private synchronized void completeNotification() in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java	10	3	1
public static void main() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java	42	3	1
private void createTopic() in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	14	3	0