apache / flink-trainingConditional 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 130 units with 972 lines of code in units (67.7% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
3 medium complex units (86 lines of code)
2 simple units (47 lines of code)
125 very simple units (839 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
public boolean equals() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java	19	13	1
public boolean equals() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiFare.java	17	11	1
public static List mapToGridCellsOnWay() in common/src/main/java/org/apache/flink/training/exercises/common/utils/GeoUtils.java	50	11	4
public void processElement() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	22	6	3
override def processElement() in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala	25	6	5
public int compareTo() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java	19	5	1
public void run() in common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java	24	5	1
public boolean equals() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/RideAndFare.java	7	3	1
public static boolean ultimateCauseIsMissingSolution() in common/src/main/java/org/apache/flink/training/exercises/common/utils/MissingSolutionException.java	10	3	1
public static boolean isInNYC() in common/src/main/java/org/apache/flink/training/exercises/common/utils/GeoUtils.java	3	3	2
public void run() in common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiFareGenerator.java	12	3	1
private long getTimerTime() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	7	2	1
public TaxiRide() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java	13	2	2
public String toString() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java	21	2	0
public double getEuclideanDistance() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java	9	2	2
public String paymentType() in common/src/main/java/org/apache/flink/training/exercises/common/utils/DataGenerator.java	3	2	0
public float tolls() in common/src/main/java/org/apache/flink/training/exercises/common/utils/DataGenerator.java	3	2	0
private long aLong() in common/src/main/java/org/apache/flink/training/exercises/common/utils/DataGenerator.java	8	2	4
private float aFloat() in common/src/main/java/org/apache/flink/training/exercises/common/utils/DataGenerator.java	8	2	5
public boolean filter() in ride-cleansing/src/solution/java/org/apache/flink/training/solutions/ridecleansing/RideCleansingSolution.java	4	2	1
public void process() in hourly-tips/src/solution/java/org/apache/flink/training/solutions/hourlytips/HourlyTipsSolution.java	11	2	4
public JobExecutionResult execute() in hourly-tips/src/main/java/org/apache/flink/training/exercises/hourlytips/HourlyTipsExercise.java	8	2	0
def execute() in hourly-tips/src/main/scala/org/apache/flink/training/exercises/hourlytips/scala/HourlyTipsExercise.scala	8	2	0
public void flatMap1() in rides-and-fares/src/solution/java/org/apache/flink/training/solutions/ridesandfares/RidesAndFaresSolution.java	9	2	2
public void flatMap2() in rides-and-fares/src/solution/java/org/apache/flink/training/solutions/ridesandfares/RidesAndFaresSolution.java	9	2	2
override def flatMap1() in rides-and-fares/src/solution/scala/org/apache/flink/training/solutions/ridesandfares/scala/RidesAndFaresSolution.scala	9	2	2
override def flatMap2() in rides-and-fares/src/solution/scala/org/apache/flink/training/solutions/ridesandfares/scala/RidesAndFaresSolution.scala	9	2	2
public LongRidesSolution() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	4	1	2
public JobExecutionResult execute() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	13	1	0
public static void main() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	5	1	1
public void open() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	5	1	1
public void onTimer() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	5	1	3
private boolean rideTooLong() in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java	5	1	2
def execute() in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala	16	1	0
def main() in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala	4	1	1
override def open() in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala	5	1	1
override def onTimer() in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala	8	1	5
public LongRidesExercise() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	4	1	2
public JobExecutionResult execute() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	13	1	0
public static void main() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	5	1	1
public void open() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	3	1	1
public void processElement() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	2	1	3
public void onTimer() in long-ride-alerts/src/main/java/org/apache/flink/training/exercises/longrides/LongRidesExercise.java	2	1	3
def execute() in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala	16	1	0
def main() in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala	4	1	1
override def open() in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala	3	1	1
override def processElement() in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala	5	1	5
override def onTimer() in long-ride-alerts/src/main/scala/org/apache/flink/training/exercises/longrides/scala/LongRidesExercise.scala	5	1	5
public RideAndFare() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/RideAndFare.java	1	1	0
public RideAndFare() in common/src/main/java/org/apache/flink/training/exercises/common/datatypes/RideAndFare.java	4	1	2