apache / streampipes - 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 11,079 units with 74,837 lines of code in units (46.1% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
35 medium complex units (1,739 lines of code)
242 simple units (6,759 lines of code)
10,802 very simple units (66,339 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 int findWgsUtm_EPSG() in streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/SpReprojectionBuilder.java	30	23	1
public void run() in streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulator.java	52	20	0
public T generate() in streampipes-data-export/src/main/java/org/apache/streampipes/export/dataimport/ImportGenerator.java	69	19	1
public String generateSecureString() in streampipes-user-management/src/main/java/org/apache/streampipes/user/management/util/SecureStringGenerator.java	16	19	1
public StaticProperty staticProperty() in streampipes-model/src/main/java/org/apache/streampipes/model/util/Cloner.java	41	19	1
public boolean process() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/TerminatingBlocksFinder.java	29	19	1
public clone() in ui/src/app/core-ui/static-properties/static-property-util.service.ts	97	18	1
public boolean process() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/KeepLargestBlockFilter.java	59	18	1
public void characters() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/BoilerpipeHTMLContentHandler.java	72	18	3
public void onEvent() in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/tsfile/TsFileSink.java	89	18	1
public static EventProperty getEventProperty() in streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/util/JsonEventProperty.java	44	18	2
public void onEvent() in streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorProcessor.java	54	16	2
public boolean process() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/BlockProximityFusion.java	55	16	1
public toTemplateValue() in ui/src/app/core-ui/pipeline-element-template-config/pipeline-element-template-generator.ts	49	15	0
private void parseEnvironmentVariable() in streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/parser/OAuthConfigurationParser.java	35	15	3
public void flushBlock() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/BoilerpipeHTMLContentHandler.java	72	15	0
public static Datatypes getDataType() in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java	26	15	1
private boolean updateJwtSettings() in streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/StreamPipesEnvChecker.java	50	14	0
public selectProperty() in ui/src/app/connect/components/adapter-configuration/schema-editor/event-property-row/event-property-row.component.ts	58	14	2
public static SelectQueryParams getSelectQueryParams() in streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/ProvidedRestQueryParamConverter.java	52	14	1
def initializeFunctions() in streampipes-client-python/streampipes/functions/function_handler.py	33	14	1
public TransportProtocol getPreferredProtocol() in streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ProtocolSelector.java	28	13	0
initPlumb() in ui/src/app/editor/components/pipeline/pipeline.component.ts	133	13	0
static getLegacyTimeSelectionID() in ui/projects/streampipes/platform-services/src/lib/model/datalake/DateRange.ts	27	13	1
public static Class getTypeClass() in streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/DatatypeUtils.java	36	13	2
protected void doFilterInternal() in streampipes-service-core/src/main/java/org/apache/streampipes/service/core/filter/TokenAuthenticationFilter.java	41	13	3
public Unit getUnit() in streampipes-measurement-units/src/main/java/com/github/jqudt/onto/UnitFactory.java	38	13	1
public void startElement() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/HTMLHighlighter.java	51	13	4
public void pullData() in streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java	45	13	0
public boolean equals() in streampipes-model/src/main/java/org/apache/streampipes/model/staticproperty/FreeTextStaticProperty.java	36	12	1
public void onEvent() in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/iotdb/IotDbSink.java	50	12	1
modifyPipeline() in ui/src/app/editor/components/pipeline/pipeline.component.ts	53	11	1
copyEp() in ui/src/app/connect/dialog/edit-event-property/edit-event-property.component.ts	42	11	1
private getQueryParameters() in ui/projects/streampipes/platform-services/src/lib/apis/datalake-rest.service.ts	45	11	10
public void onEvent() in streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessor.java	32	11	2
sortData() in ui/src/app/data-explorer-shared/components/charts/table/table-widget.component.ts	29	10	1
public static input() in ui/cypress/support/utils/userInput/StaticPropertyUtils.ts	43	10	1
public int hashCode() in streampipes-model/src/main/java/org/apache/streampipes/model/staticproperty/FreeTextStaticProperty.java	13	10	0
public boolean equals() in streampipes-model/src/main/java/org/apache/streampipes/model/Response.java	27	10	1
public boolean process() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/ExpandTitleToContentFilter.java	25	10	1
public static HTMLDocument fetch() in streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/HTMLFetcher.java	36	10	1
private void initField() in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/milvus/MilvusSink.java	24	10	3
private boolean validateField() in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/milvus/MilvusSink.java	25	10	3
public GuessSchema getGuessSchema() in streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/GeoJsonParser.java	75	10	1
public void checkAndRestorePipelineElements() in streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java	71	9	0
public OutputSchemaGenerator getOuputSchemaGenerator() in streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/OutputSchemaFactory.java	21	9	0
public getTimestampTransformRules() in ui/src/app/connect/services/transformation-rule.service.ts	49	9	3
deepCopy() in ui/src/app/data-explorer/components/chart-view/designer-panel/data-settings/data-explorer-widget-data-settings.component.ts	28	9	1
public void bindRuntime() in streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntime.java	30	9	0
public boolean equals() in streampipes-model-client/src/main/java/org/apache/streampipes/model/client/matching/MatchingResultMessage.java	12	9	1