azure / azure-event-hubs-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 209 units with 2,153 lines of code in units (59.6% of code).

0 very long units (0 lines of code)
6 long units (415 lines of code)
16 medium size units (459 lines of code)
32 small units (475 lines of code)
155 very small units (804 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
override def getBatch() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	82	16	2
override def translate() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	81	12	3
private def parseConnectionString() in core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala	79	24	1
def toInternalRow() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala	64	19	1
private def receive() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	57	6	2
private def checkCursor() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	52	8	1
private def rateLimit() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	49	8	7
final def retryScala[T]() in core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala	42	11	5
private[eventhubs] override def receive() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	42	8	4
def partitionsPerformancePercentage() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	38	5	0
private def errBeginAfterEnd() in core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala	28	3	1
override def createRelation() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala	27	3	5
def addorUpdateBatch() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	27	3	2
override def compute() in core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala	27	4	1
private def parseLogVersion() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	26	7	2
override def count: Long = offsetRanges.map() in core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala	25	4	1
override def buildScan() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsRelation.scala	22	1	0
def close() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	22	4	0
private def closeInner() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala	21	5	1
def aadAuthCallback() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	21	2	0
def createReceiverInner() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala	21	2	6
override def send() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	21	6	5
def partitions() in core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	20	1	1
private def createReceiver() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	20	1	1
private def receiveOne() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	20	3	2
private def createRpcEndpoint() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala	19	4	0
def updatePartitionPerformance() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	19	3	4
def createEventData() in core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala	18	2	4
override def deserialize() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	17	3	1
def partitions() in core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	17	4	1
protected def sendRow() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	17	2	2
def partitionSeqNos() in core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	16	5	1
private[utils] def send() in core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala	16	3	4
private def removeBatch() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	16	2	1
override def allBoundedSeqNos: Map[PartitionId,() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	16	4	2
private def adjustStartingOffset() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	15	3	2
private def validateQuery() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala	14	3	3
def write() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala	14	1	4
private def toProperties() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	14	4	1
private[eventhubs] def set[T]() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	14	5	2
override def close() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	14	3	0
private[utils] def send() in core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala	13	2	4
def setDefaultValuesInTracker() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	13	1	4
private def awaitReceiveMessage[T]() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	13	3	2
private def sendPartitionPerformanceToDriver() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	13	3	1
override def createPartitionSender() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	13	3	1
private def latestSeqNoF() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	13	4	1
def getEventHubsConfWithoutStartingPositions() in core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala	12	1	1
final def after[T]() in core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala	12	1	1
private def recreateReceiver() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	12	2	1