elastic / elasticsearch-hadoop - 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 3,423 units with 30,962 lines of code in units (72.5% of code).

0 very complex units (0 lines of code)
7 complex units (719 lines of code)
65 medium complex units (3,041 lines of code)
153 simple units (4,156 lines of code)
3,198 very simple units (23,046 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 def translateFilter() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource.scala	135	48	3
private def convertField() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/SchemaUtils.scala	78	45	7
private def doWriteScala() in spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaValueWriter.scala	93	32	3
public BulkResponse tryFlush() in mr/src/main/java/org/elasticsearch/hadoop/rest/bulk/BulkProcessor.java	176	28	0
public Response execute() in mr/src/main/java/org/elasticsearch/hadoop/rest/commonshttp/CommonsHttpTransport.java	108	28	1
override def unhandledFilters() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource.scala	31	27	1
protected Result doWrite() in mr/src/main/java/org/elasticsearch/hadoop/serialization/builder/JdkValueWriter.java	98	27	3
def readValue() in spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaValueReader.scala	35	25	3
public Result write() in mr/src/main/java/org/elasticsearch/hadoop/mr/WritableValueWriter.java	79	24	2
private def extract() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource.scala	39	23	3
public static Writable toWritable() in mr/src/main/java/org/elasticsearch/hadoop/util/WritableUtils.java	80	23	1
public Resource() in mr/src/main/java/org/elasticsearch/hadoop/rest/Resource.java	75	23	2
private void initExtractorsFromSettings() in mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/AbstractBulkFactory.java	101	22	1
public int run() in mr/src/main/java/org/elasticsearch/hadoop/cli/Keytool.java	91	21	3
public Object readValue() in mr/src/main/java/org/elasticsearch/hadoop/serialization/builder/JdkValueReader.java	44	21	3
public Object createArray() in mr/src/main/java/org/elasticsearch/hadoop/mr/WritableValueReader.java	51	20	1
public static Object fromWritable() in mr/src/main/java/org/elasticsearch/hadoop/util/WritableUtils.java	65	20	1
private def inferType() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DataFrameValueWriter.scala	22	19	1
public static Result filter() in mr/src/main/java/org/elasticsearch/hadoop/serialization/field/FieldFilter.java	46	19	4
private static void doFind() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ParsingUtils.java	60	19	4
private String assemble() in mr/src/main/java/org/elasticsearch/hadoop/rest/SearchRequestBuilder.java	69	19	0
private void addHttpAuth() in mr/src/main/java/org/elasticsearch/hadoop/rest/commonshttp/CommonsHttpTransport.java	77	19	3
public static int execute() in mr/src/main/java/org/elasticsearch/hadoop/cli/Keytool.java	47	17	2
public BytesRef writeBulkEntry() in mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/BulkEntryWriter.java	76	17	1
public boolean equals() in mr/src/main/java/org/elasticsearch/hadoop/rest/query/QueryStringQueryBuilder.java	15	17	1
public Result write() in hive/src/main/java/org/elasticsearch/hadoop/hive/HiveWritableValueWriter.java	39	17	2
private[spark] def writePrimitive() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DataFrameValueWriter.scala	26	16	3
private Scroll read() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ScrollReader.java	91	16	2
private Result write() in hive/src/main/java/org/elasticsearch/hadoop/hive/HiveValueWriter.java	62	16	3
void runHdfsDfsCp() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/fixture/hadoop/tasks/DfsCopy.groovy	43	15	0
public void checkDependencies() in buildSrc/src/main/java/org/elasticsearch/hadoop/gradle/buildtools/DependencyLicensesTask.java	40	15	0
public boolean equals() in mr/src/main/java/org/elasticsearch/hadoop/util/ecs/HostData.java	12	15	1
private Token convertToken() in mr/src/main/java/org/elasticsearch/hadoop/serialization/json/JacksonJsonParser.java	32	15	1
public ClusterInfo mainInfo() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestClient.java	45	15	0
static void applyURIParameter() in mr/src/main/java/org/elasticsearch/hadoop/rest/query/SimpleQueryParser.java	19	15	3
public boolean equals() in mr/src/main/java/org/elasticsearch/hadoop/security/EsToken.java	11	14	1
public static int levenshteinDistance() in mr/src/main/java/org/elasticsearch/hadoop/util/StringUtils.java	53	14	3
static int oversize() in mr/src/main/java/org/elasticsearch/hadoop/util/ArrayUtils.java	41	14	2
private FieldType mapping() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ScrollReader.java	50	14	2
public static PartitionReader createReader() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestService.java	62	14	3
static SearchRequestBuilder applyAliasMetadata() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestService.java	53	14	5
private static RestRepository initSingleIndex() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestService.java	61	14	4
static in mr/src/main/java/org/elasticsearch/hadoop/util/Version.java	53	13	0
public static boolean sliceEquals() in mr/src/main/java/org/elasticsearch/hadoop/util/ArrayUtils.java	21	13	6
public boolean equals() in mr/src/main/java/org/elasticsearch/hadoop/serialization/dto/ShardInfo.java	28	13	1
private static Field parseField() in mr/src/main/java/org/elasticsearch/hadoop/serialization/dto/mapping/FieldParser.java	37	13	2
void doWrite() in mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/AbstractBulkFactory.java	24	13	1
protected Object map() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ScrollReader.java	58	13	2
public HandlerResult onError() in mr/src/main/java/org/elasticsearch/hadoop/handler/impl/DropAndLog.java	35	13	2
static Object hiveFromWritable() in hive/src/main/java/org/elasticsearch/hadoop/hive/EsSerDe.java	54	13	3