apache / incubator-livyConditional 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 1,183 units with 12,469 lines of code in units (68.1% of code).

0 very complex units (0 lines of code)
1 complex units (174 lines of code)
30 medium complex units (1,541 lines of code)
87 simple units (2,437 lines of code)
1,065 very simple units (8,317 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[interactive] def prepareBuilderProp() in server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala	174	32	4
private def processSessionConf() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala	52	21	3
def start() in server/src/main/scala/org/apache/livy/server/LivyServer.scala	213	20	0
private def executeLines() in repl/src/main/scala/org/apache/livy/repl/AbstractSparkInterpreter.scala	47	19	2
private void ensureCapacity() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	51	19	0
override def process() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/AuthBridgeServer.scala	64	18	2
public Object getValues() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	25	18	0
override protected def doPost() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftHttpServlet.scala	73	17	2
public static int toJavaSQLType() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkUtils.java	37	17	1
def main() in dev/merge_livy_pr.py	69	15	0
private def startTimeoutChecker() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala	53	15	0
public static Integer getColumnSize() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkUtils.java	26	15	1
def execute_request() in repl/src/main/resources/fake_shell.py	35	14	1
private def extractTableFromJValue() in repl/src/main/scala/org/apache/livy/repl/AbstractSparkInterpreter.scala	39	14	1
private def toTTypeDesc() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/types/Schema.scala	25	14	2
override def evaluateResponse() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/PlainSaslServer.scala	50	14	1
def apply() in core/src/main/scala/org/apache/livy/sessions/SessionState.scala	14	13	1
def magic_table() in repl/src/main/resources/fake_shell.py	47	13	1
def resolve_jira_issue() in dev/merge_livy_pr.py	47	13	3
private static ChildProcess startDriver() in rsc/src/main/java/org/apache/livy/rsc/ContextLauncher.java	68	13	2
protected def initServer() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThriftBinaryCLIService.scala	103	13	0
public Object get() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	29	12	1
public ColumnBuffer extractSubset() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	61	12	1
private def setJobGroup() in repl/src/main/scala/org/apache/livy/repl/Session.scala	22	11	2
private def convertTableType() in repl/src/main/scala/org/apache/livy/repl/AbstractSparkInterpreter.scala	22	11	1
def apply() in repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala	71	11	2
public LivyClient build() in api/src/main/java/org/apache/livy/LivyClientBuilder.java	42	11	0
override def handle() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/auth/AuthBridgeServer.scala	35	11	1
def toTColumn() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/serde/ThriftResultSet.scala	41	11	1
public void add() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	38	11	1
public static StructType dataTypesToSchema() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkUtils.java	42	11	1
override protected def renderResponseBody() in server/src/main/scala/org/apache/livy/server/JsonServlet.scala	15	10	1
public synchronized void stop() in rsc/src/main/java/org/apache/livy/rsc/RSCClient.java	38	10	1
private[thriftserver] def incrementConnections() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala	37	10	3
public ColumnBuffer() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	32	10	1
private ColumnBuffer() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ColumnBuffer.java	34	10	4
public static Integer getDecimalDigits() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/SparkUtils.java	16	10	1
private def executeCode() in repl/src/main/scala/org/apache/livy/repl/Session.scala	60	9	3
private def authenticateUser() in server/src/main/scala/org/apache/livy/server/auth/LdapAuthenticationHandlerImpl.scala	25	9	2
private T get() in client-http/src/main/java/org/apache/livy/client/http/JobHandleImpl.java	29	9	3
public void run() in client-http/src/main/java/org/apache/livy/client/http/JobHandleImpl.java	38	9	0
public static void main() in rsc/src/main/java/org/apache/livy/rsc/driver/RSCDriverBootstrapper.java	45	9	1
private static File writeConfToFile() in rsc/src/main/java/org/apache/livy/rsc/ContextLauncher.java	40	9	1
private static Rpc createRpc() in rsc/src/main/java/org/apache/livy/rsc/rpc/Rpc.java	43	9	4
override def runInternal() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyExecuteStatementOperation.scala	45	9	0
override protected def afterExecute() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/cli/ThreadPoolExecutorWithOomHook.scala	17	9	2
override def init() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyCLIService.scala	29	9	1
def getInfo() in thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyCLIService.scala	13	9	2
private String toHiveString() in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ResultSet.java	34	9	2
def _poll_result() in python-api/src/main/python/livy/job_handle.py	40	8	1