azure / azure-event-hubs-spark
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 0% | 49% | 24% | 26%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
scala0% | 0% | 49% | 24% | 26%
sbt0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
core0% | 0% | 49% | 24% | 26%
project0% | 0% | 0% | 0% | 100%
Longest Files (Top 39)
File# lines# units
EventHubsConf.scala
in core/src/main/scala/org/apache/spark/eventhubs
 354 37
EventHubsSource.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 349 11
CachedEventHubsReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 311 15
PartitionsStatusTracker.scala
in core/src/main/scala/org/apache/spark/eventhubs
 285 13
EventHubsClient.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 252 11
ConnectionStringBuilder.scala
in core/src/main/scala/org/apache/spark/eventhubs
 223 12
EventHubsSourceProvider.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 190 7
EventHubsWriteTask.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 165 6
EventHubsDirectDStream.scala
in core/src/main/scala/org/apache/spark/streaming/eventhubs
 145 11
EventHubsUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs
 130 10
ClientConnectionPool.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 127 10
SimulatedEventHubs.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 112 9
EventHubsTestUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 98 10
EventHubsRDD.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 84 3
RetryUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 82 4
JsonUtils.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 62 3
package.scala
in core/src/main/scala/org/apache/spark/eventhubs
 60 -
EventHubsForeachWriter.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 59 4
SimulatedClient.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 55 3
OffsetRange.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 55 7
EventPosition.scala
in core/src/main/scala/org/apache/spark/eventhubs
 49 4
EventHubsWriter.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 43 2
PartitionPerformanceReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs
 43 2
EventHubsRelation.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 40 1
SimpleThrottlingStatusPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 28 2
EventHubsSourceOffset.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 26 3
SimulatedPartitionStatusTracker.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 23 2
SimpleLogMetricPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 22 2
NameAndPartition.scala
in core/src/main/scala/org/apache/spark/eventhubs
 22 3
EventHubsSink.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 18 1
ThrottlingStatusPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 17 -
Client.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 17 -
MetricPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 15 -
SimulatedCachedReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 14 1
EventHubsRDDPartition.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 14 -
TaskContextSlim.scala
in core/src/main/scala/org/apache/spark/eventhubs
 11 -
PartitionContext.scala
in core/src/main/scala/org/apache/spark/eventhubs
 8 -
AadAuthenticationCallback.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 5 -
plugins.sbt
in project
 2 -
Files With Most Units (Top 30)
File# lines# units
EventHubsConf.scala
in core/src/main/scala/org/apache/spark/eventhubs
 354 37
CachedEventHubsReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 311 15
PartitionsStatusTracker.scala
in core/src/main/scala/org/apache/spark/eventhubs
 285 13
ConnectionStringBuilder.scala
in core/src/main/scala/org/apache/spark/eventhubs
 223 12
EventHubsSource.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 349 11
EventHubsClient.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 252 11
EventHubsDirectDStream.scala
in core/src/main/scala/org/apache/spark/streaming/eventhubs
 145 11
EventHubsTestUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 98 10
EventHubsUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs
 130 10
ClientConnectionPool.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 127 10
SimulatedEventHubs.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 112 9
EventHubsSourceProvider.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 190 7
OffsetRange.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 55 7
EventHubsWriteTask.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 165 6
EventHubsForeachWriter.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 59 4
RetryUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 82 4
EventPosition.scala
in core/src/main/scala/org/apache/spark/eventhubs
 49 4
JsonUtils.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 62 3
EventHubsSourceOffset.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 26 3
SimulatedClient.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 55 3
NameAndPartition.scala
in core/src/main/scala/org/apache/spark/eventhubs
 22 3
EventHubsRDD.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 84 3
EventHubsWriter.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 43 2
SimulatedPartitionStatusTracker.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 23 2
SimpleThrottlingStatusPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 28 2
SimpleLogMetricPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 22 2
PartitionPerformanceReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs
 43 2
EventHubsRelation.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 40 1
EventHubsSink.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 18 1
SimulatedCachedReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 14 1
Files With Long Lines (Top 10)

There are 10 files with lines longer than 120 characters. In total, there are 21 long lines.

File# lines# units# long lines
CachedEventHubsReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 311 15 5
PartitionsStatusTracker.scala
in core/src/main/scala/org/apache/spark/eventhubs
 285 13 4
EventHubsClient.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 252 11 4
EventHubsWriteTask.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 165 6 2
EventHubsSource.scala
in core/src/main/scala/org/apache/spark/sql/eventhubs
 349 11 1
SimpleLogMetricPlugin.scala
in core/src/main/scala/org/apache/spark/eventhubs/utils
 22 2 1
EventHubsUtils.scala
in core/src/main/scala/org/apache/spark/eventhubs
 130 10 1
ClientConnectionPool.scala
in core/src/main/scala/org/apache/spark/eventhubs/client
 127 10 1
PartitionPerformanceReceiver.scala
in core/src/main/scala/org/apache/spark/eventhubs
 43 2 1
EventHubsRDD.scala
in core/src/main/scala/org/apache/spark/eventhubs/rdd
 84 3 1
Correlations

File Size vs. Commits (all time): 39 points

core/src/main/scala/org/apache/spark/eventhubs/package.scala x: 35 commits (all time) y: 60 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala x: 33 commits (all time) y: 354 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala x: 36 commits (all time) y: 311 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala x: 32 commits (all time) y: 349 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala x: 34 commits (all time) y: 252 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/ClientConnectionPool.scala x: 16 commits (all time) y: 127 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala x: 12 commits (all time) y: 130 lines of code core/src/main/scala/org/apache/spark/eventhubs/TaskContextSlim.scala x: 3 commits (all time) y: 11 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedClient.scala x: 6 commits (all time) y: 55 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionContext.scala x: 2 commits (all time) y: 8 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionPerformanceReceiver.scala x: 2 commits (all time) y: 43 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala x: 2 commits (all time) y: 285 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleThrottlingStatusPlugin.scala x: 2 commits (all time) y: 28 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/ThrottlingStatusPlugin.scala x: 2 commits (all time) y: 17 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala x: 11 commits (all time) y: 165 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala x: 5 commits (all time) y: 43 lines of code core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala x: 11 commits (all time) y: 145 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala x: 14 commits (all time) y: 190 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala x: 11 commits (all time) y: 98 lines of code core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala x: 3 commits (all time) y: 223 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/AadAuthenticationCallback.scala x: 1 commits (all time) y: 5 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala x: 8 commits (all time) y: 82 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedPartitionStatusTracker.scala x: 1 commits (all time) y: 23 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/MetricPlugin.scala x: 3 commits (all time) y: 15 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleLogMetricPlugin.scala x: 2 commits (all time) y: 22 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala x: 6 commits (all time) y: 59 lines of code core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala x: 9 commits (all time) y: 84 lines of code core/src/main/scala/org/apache/spark/eventhubs/rdd/OffsetRange.scala x: 4 commits (all time) y: 55 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala x: 4 commits (all time) y: 112 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsRelation.scala x: 11 commits (all time) y: 40 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/Client.scala x: 7 commits (all time) y: 17 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSink.scala x: 5 commits (all time) y: 18 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedCachedReceiver.scala x: 2 commits (all time) y: 14 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala x: 3 commits (all time) y: 62 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventPosition.scala x: 5 commits (all time) y: 49 lines of code core/src/main/scala/org/apache/spark/eventhubs/NameAndPartition.scala x: 3 commits (all time) y: 22 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceOffset.scala x: 2 commits (all time) y: 26 lines of code project/plugins.sbt x: 4 commits (all time) y: 2 lines of code
354.0
lines of code
  min: 2.0
  average: 92.69
  25th percentile: 18.0
  median: 55.0
  75th percentile: 130.0
  max: 354.0
0 36.0
commits (all time)
min: 1.0 | average: 9.08 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 11.0 | max: 36.0

File Size vs. Contributors (all time): 39 points

core/src/main/scala/org/apache/spark/eventhubs/package.scala x: 8 contributors (all time) y: 60 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala x: 7 contributors (all time) y: 354 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala x: 6 contributors (all time) y: 311 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala x: 7 contributors (all time) y: 349 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala x: 7 contributors (all time) y: 252 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/ClientConnectionPool.scala x: 5 contributors (all time) y: 127 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala x: 4 contributors (all time) y: 130 lines of code core/src/main/scala/org/apache/spark/eventhubs/TaskContextSlim.scala x: 2 contributors (all time) y: 11 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedClient.scala x: 4 contributors (all time) y: 55 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionContext.scala x: 1 contributors (all time) y: 8 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionPerformanceReceiver.scala x: 1 contributors (all time) y: 43 lines of code core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala x: 1 contributors (all time) y: 285 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleThrottlingStatusPlugin.scala x: 1 contributors (all time) y: 28 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/ThrottlingStatusPlugin.scala x: 1 contributors (all time) y: 17 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala x: 6 contributors (all time) y: 165 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala x: 3 contributors (all time) y: 43 lines of code core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala x: 4 contributors (all time) y: 145 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala x: 6 contributors (all time) y: 190 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala x: 4 contributors (all time) y: 98 lines of code core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala x: 2 contributors (all time) y: 223 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/AadAuthenticationCallback.scala x: 1 contributors (all time) y: 5 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala x: 3 contributors (all time) y: 82 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedPartitionStatusTracker.scala x: 1 contributors (all time) y: 23 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/MetricPlugin.scala x: 2 contributors (all time) y: 15 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleLogMetricPlugin.scala x: 1 contributors (all time) y: 22 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala x: 3 contributors (all time) y: 59 lines of code core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala x: 3 contributors (all time) y: 84 lines of code core/src/main/scala/org/apache/spark/eventhubs/rdd/OffsetRange.scala x: 2 contributors (all time) y: 55 lines of code core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala x: 2 contributors (all time) y: 112 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsRelation.scala x: 3 contributors (all time) y: 40 lines of code core/src/main/scala/org/apache/spark/eventhubs/client/Client.scala x: 2 contributors (all time) y: 17 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala x: 2 contributors (all time) y: 62 lines of code core/src/main/scala/org/apache/spark/eventhubs/EventPosition.scala x: 1 contributors (all time) y: 49 lines of code core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDDPartition.scala x: 1 contributors (all time) y: 14 lines of code core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceOffset.scala x: 1 contributors (all time) y: 26 lines of code project/plugins.sbt x: 2 contributors (all time) y: 2 lines of code
354.0
lines of code
  min: 2.0
  average: 92.69
  25th percentile: 18.0
  median: 55.0
  75th percentile: 130.0
  max: 354.0
0 8.0
contributors (all time)
min: 1.0 | average: 2.95 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 8.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".