azure / azure-kusto-spark

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 216 units with 3,791 lines of code in units (72.4% of code).

5 very long units (685 lines of code)
8 long units (573 lines of code)
39 medium size units (1,254 lines of code)
44 small units (650 lines of code)
120 very small units (629 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
private[kusto] def write() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	167	17	6
private[kusto] def ingestRows() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	146	17	6
private[kusto] def finalizeIngestionWhenWorkersSucceeded() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/FinalizeHelper.scala	138	11	11
def parseSinkParameters() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	131	18	3
def moveExtentsWithRetries() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	103	18	8
private def streamRowsIntoKustoByWorkers() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	89	6	4
private def parseAuthentication() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	82	16	3
private def buildScanImpl() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoRelation.scala	79	7	6
def verifyAsyncCommandCompletion() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	78	14	8
def initializeTablesBySchema() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	77	9	7
override def createRelation() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/DefaultSource.scala	63	7	3
def pollOnResult() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/FinalizeHelper.scala	54	8	5
private[kusto] def distributedBuildScan() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala	51	6	5
def getReadParameters() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	50	7	3
def generateExportDataCommand() in connector/src/main/scala/com/microsoft/kusto/spark/utils/CslCommandsGenerator.scala	48	7	9
private[kusto] def setCsvMapping() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoIngestionUtils.scala	44	8	4
def doWhile[A]() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	43	8	1
private def refresh() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ContainerProvider.scala	41	6	1
private def writeField() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala	41	12	6
private def convertMapToJson() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala	41	6	3
private[kusto] def exportPartitionToBlob() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala	39	2	6
def processIngestionStatusResults() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/FinalizeHelper.scala	38	7	4
def parseSourceParameters() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	37	6	3
def moveExtents() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	37	2	6
private def writeDecimalField() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala	37	7	5
private def streamBytesIntoKusto() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	36	3	6
private[kusto] def mergeKeyVaultAndOptionsAuthentication() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	35	9	2
private def convertStructToJson() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala	35	7	3
private[kusto] def estimateRowsCount() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	34	7	4
def toIngestionProperties() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/SparkIngestionProperties.scala	34	9	2
private def exportToStorage() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala	34	2	5
override def createRelation() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/DefaultSource.scala	34	5	5
private[kusto] def setupBlobAccess() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala	33	8	2
private def ingestRowsIntoTempTbl() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	31	4	4
def findErrorInResult() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	30	10	1
private[kusto] def setMappingOnStagingTableIfNeeded() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	30	5	5
private def dirExist() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala	30	6	4
override def buildScan() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoRelation.scala	30	5	2
private def ingestToTemporaryTableByWorkers() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	27	1	5
def readPfx() in connector/src/main/scala/com/microsoft/kusto/spark/utils/CertUtils.scala	26	6	2
private[kusto] def reportExceptionAndThrow() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala	26	7	8
private def ingestRowsIntoKusto() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	25	2	6
private def getValueTransformer() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoResponseDeserializer.scala	25	20	1
def retryAsyncOp() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	24	1	7
private def createBlobWriter() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoWriter.scala	24	1	6
def buildFilterExpression() in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoFilter.scala	24	19	2
def shouldIngestData() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	23	8	4
def writeRowAsCSV() in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala	23	4	4
def shouldUseMaterializedViewFlag() in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala	22	2	3
private def getAadAppParamsFromKeyVaultImpl() in connector/src/main/scala/com/microsoft/kusto/spark/utils/KeyVaultUtils.scala	21	6	2