apache / flink-statefunConditional 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 2,482 units with 15,386 lines of code in units (62.4% of code).

0 very complex units (0 lines of code)
1 complex units (213 lines of code)
5 medium complex units (329 lines of code)
43 simple units (1,025 lines of code)
2,433 very simple units (13,819 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
func file_request_reply_proto_init() in statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go	213	48	0
func file_types_proto_init() in statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go	97	21	0
func() in statefun-sdk-go/v3/pkg/statefun/types.go	74	19	1
func() in statefun-sdk-go/v3/pkg/statefun/types.go	73	19	1
func() in statefun-sdk-go/v3/pkg/statefun/message.go	45	12	1
def __init__() in statefun-sdk-python/statefun/core.py	40	11	5
func() in statefun-sdk-go/v3/pkg/statefun/handler.go	69	10	1
static fromOpts() in statefun-sdk-js/src/core.ts	18	10	4
def kafka_egress_message() in statefun-sdk-python/statefun/egress_io.py	31	9	9
export function messageBuilder() in statefun-sdk-js/src/message.ts	20	9	4
func() in statefun-sdk-go/v3/pkg/statefun/handler.go	41	8	1
func() in statefun-sdk-go/v3/pkg/statefun/handler.go	27	8	1
func encodeKafkaValue() in statefun-sdk-go/v3/pkg/statefun/egress.go	28	8	1
def kinesis_egress_message() in statefun-sdk-python/statefun/egress_io.py	31	8	9
public V get() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	23	8	1
public V remove() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	26	8	1
private int find() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	23	8	1
public int hashCode() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	20	8	0
func() in statefun-sdk-go/v3/pkg/statefun/egress.go	34	7	1
func() in statefun-sdk-go/v3/pkg/statefun/types.go	19	7	1
func newStorageFactory() in statefun-sdk-go/v3/pkg/statefun/storage.go	31	7	2
def resolve() in statefun-sdk-python/statefun/storage.py	13	7	3
static parseTypedValue() in statefun-sdk-js/src/types.ts	19	7	2
export function parseTypeName() in statefun-sdk-js/src/core.ts	15	7	1
export function kinesisEgressMessage() in statefun-sdk-js/src/egress.ts	25	7	6
public static Map longPropertiesAt() in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/Selectors.java	27	7	2
public boolean equals() in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java	13	7	1
public boolean containsKey() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	23	7	1
private void shiftKeys() in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java	22	7	1
func() in statefun-sdk-go/v3/pkg/statefun/egress.go	33	6	1
func encodeKinesisValue() in statefun-sdk-go/v3/pkg/statefun/egress.go	22	6	1
func file_kinesis_egress_proto_init() in statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go	37	6	0
func file_kafka_egress_proto_init() in statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go	37	6	0
protected boolean matchesSafely() in statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/matchers/MessagesSentToAddress.java	18	6	1
CompletableFuture handleInternally() in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandler.java	28	6	1
private static String deserializeStringWrapperCompatibleString() in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java	26	6	1
public boolean equals() in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/SideEffects.java	8	6	1
def message_builder() in statefun-sdk-python/statefun/messages.py	21	6	3
def collect_failure() in statefun-sdk-python/statefun/request_reply_v3.py	21	6	1
static fromOpts() in statefun-sdk-js/src/core.ts	15	6	3
export async function handle() in statefun-sdk-js/src/handler.ts	33	6	2
export function trySerializerForEgress() in statefun-sdk-js/src/egress.ts	17	6	2
export function kafkaEgressMessage() in statefun-sdk-js/src/egress.ts	21	6	5
public boolean equals() in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/TypeName.java	8	6	1
public boolean equals() in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java	12	6	1
public boolean equals() in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java	12	6	1
public KafkaIngressStartupPosition deserialize() in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java	23	6	2
private static void configureStartupPosition() in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSourceProvider.java	20	6	2
void validate() in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseValidator.java	15	6	1
public static KafkaTopicPartition fromString() in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaTopicPartition.java	28	5	1