apache / pulsar-prestoConditional 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 285 units with 2,489 lines of code in units (69.1% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
7 medium complex units (319 lines of code)
16 simple units (508 lines of code)
262 very simple units (1,662 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
static List getColumns() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	84	15	6
public boolean equals() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java	31	14	1
static Type convertPulsarType() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	32	14	1
private List getPredicatedPartitions() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	45	12	2
static Type convertType() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	31	12	2
public static PredicatePushdownInfo getPredicatePushdownInfo() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	66	11	5
public long getLong() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	30	11	1
public boolean advanceNextPosition() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	46	10	0
private ConnectorTableMetadata getTableMetadata() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	52	10	2
public boolean equals() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java	25	10	1
public void run() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	48	8	0
public void close() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	26	8	0
static boolean isPrimitiveType() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	10	8	1
Collection getSplitsForTopic() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	69	7	8
public int hashCode() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java	11	7	0
public boolean equals() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java	13	7	1
public void run() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	29	7	0
public static T createInstance() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java	26	7	3
public List listTables() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	32	7	2
static SchemaHandler newPulsarSchemaHandler() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSchemaHandlers.java	29	7	4
public ConnectorSplitSource getSplits() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	46	6	4
public PulsarAdmin getPulsarAdmin() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java	20	6	0
public Object extractField() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/JSONSchemaHandler.java	26	6	2
public boolean equals() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java	11	5	1
public ManagedLedgerConfig getManagedLedgerConfig() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java	21	5	3
Collection getSplitsPartitionedTopic() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	28	4	6
public boolean equals() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java	10	4	1
public Object extractField() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/AvroSchemaHandler.java	18	4	2
public boolean hasFinished() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	4	4	0
Object getRecord() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	19	4	1
private LedgerOffloader initManagedLedgerOffloader() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java	31	4	2
public Object deserialize() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPrimitiveSchemaHandler.java	13	4	1
public List listSchemaNames() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	17	4	1
static List getPulsarColumns() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	15	4	4
static List getPulsarColumnsFromStructSchema() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java	25	4	4
public int hashCode() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java	9	4	0
public CompletableFuture getSchemaByVersion() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java	12	3	1
public final void shutdown() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java	12	3	0
public PulsarConnectorMetricsTracker() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java	32	3	1
private static PositionImpl findPosition() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java	22	3	2
public Object extractField() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java	10	3	2
public PulsarRecordCursor() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	26	3	3
public Slice getSlice() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java	12	3	1
public Object deserialize() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/JSONSchemaHandler.java	15	3	1
public Connector create() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java	23	3	3
public static ClassLayout parseClass() in presto-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java	9	2	1
public CompletableFuture getLatestSchema() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java	10	2	0
public Object getData() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java	3	2	1
public Object getData() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java	7	2	1
public void start_ENTRY_QUEUE_DEQUEUE_WAIT_TIME() in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java	5	2	0