apache / flink-mlConditional 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 3,222 units with 22,264 lines of code in units (58.6% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
10 medium complex units (538 lines of code)
74 simple units (2,472 lines of code)
3,138 very simple units (19,254 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 static Object getPickledBytesFromJavaObject() in flink-ml-python/src/main/java/org/apache/flink/ml/python/PythonBridgeUtils.java	94	25	2
public Row map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/interaction/Interaction.java	72	15	1
def squared_distance() in flink-ml-python/pyflink/ml/linalg.py	42	14	4
public void process() in flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/agglomerativeclustering/AgglomerativeClustering.java	70	13	3
public void flatMap() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/stringindexer/StringIndexerModel.java	53	12	2
def add_jars_to_context_class_loader() in flink-ml-python/pyflink/ml/__init__.py	28	11	1
private void calculateGradient() in flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java	50	11	0
private static int hash() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java	33	11	1
private Tuple2 computeVectorSizeAndNnz() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java	52	11	1
public void flatMap() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/Bucketizer.java	44	11	2
def _equals() in flink-ml-python/pyflink/ml/linalg.py	17	10	4
public StringIndexerModelData map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/stringindexer/StringIndexer.java	50	10	1
public void endInput() in flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java	39	9	0
public void mapPartition() in flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java	52	9	2
private QuantileSummary insertHeadBuffer() in flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java	26	9	0
private static void updateBinaryMetrics() in flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassification/BinaryClassificationEvaluator.java	38	9	4
public void endInput() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/univariatefeatureselector/UnivariateFeatureSelector.java	58	9	0
private static int getResultVectorSize() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/polynomialexpansion/PolynomialExpansion.java	31	9	2
public static double norm() in flink-ml-servable-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java	23	8	2
private static void hDot() in flink-ml-servable-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java	20	8	2
public void tryReadSegmentsToMemory() in flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshot.java	28	8	2
public boolean equals() in flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/IterationRecord.java	14	8	1
def convert_to_python_obj_wrapper() in flink-ml-python/pyflink/ml/wrapper.py	23	8	2
def __init__() in flink-ml-python/pyflink/ml/linalg.py	19	8	3
private double predictLabel() in flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java	41	8	1
public void endInput() in flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/Swing.java	57	8	0
private void alignAndComputeModelData() in flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java	44	8	0
public QuantileSummary merge() in flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java	51	8	1
private Object binarizerFunc() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/binarizer/Binarizer.java	24	8	2
public Row map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizerModel.java	36	8	1
public static ParamValidator inRange() in flink-ml-servable-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java	16	7	4
default T set() in flink-ml-servable-core/src/main/java/org/apache/flink/ml/param/WithParams.java	32	7	2
private static DataStreamList createIteration() in flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/Iterations.java	98	7	6
private List parseInputChannelEvents() in flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java	42	7	1
private static DataStreamList createIteration() in flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/Iterations.java	98	7	6
def to_java() in flink-ml-python/pyflink/ml/wrapper.py	20	7	2
def to_python() in flink-ml-python/pyflink/ml/wrapper.py	25	7	2
def dot() in flink-ml-python/pyflink/ml/linalg.py	21	7	4
public Object jsonEncode() in flink-ml-core/src/main/java/org/apache/flink/ml/param/WindowsParam.java	21	7	1
public Windows jsonDecode() in flink-ml-core/src/main/java/org/apache/flink/ml/param/WindowsParam.java	25	7	1
public void endInput() in flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/CoGroupOperator.java	62	7	1
public void processElement() in flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java	29	7	1
public static Vector selectByIndices() in flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/VectorUtils.java	27	7	2
public static double regularize() in flink-ml-lib/src/main/java/org/apache/flink/ml/common/optimizer/RegularizationUtils.java	41	7	4
public Row map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java	37	7	1
public UnivariateFeatureSelectorModel fit() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/univariatefeatureselector/UnivariateFeatureSelector.java	49	7	1
private double getActualSelectionThreshold() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/univariatefeatureselector/UnivariateFeatureSelector.java	29	7	0
public Row map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerModel.java	25	7	1
public VectorIndexerModelData map() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorindexer/VectorIndexer.java	23	7	1
public boolean validate() in flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/BucketizerParams.java	16	7	1