Path	Lines of Code
core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala	223
core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	354
core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala	130
core/src/main/scala/org/apache/spark/eventhubs/EventPosition.scala	49
core/src/main/scala/org/apache/spark/eventhubs/NameAndPartition.scala	22
core/src/main/scala/org/apache/spark/eventhubs/PartitionContext.scala	8
core/src/main/scala/org/apache/spark/eventhubs/PartitionPerformanceReceiver.scala	43
core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	285
core/src/main/scala/org/apache/spark/eventhubs/TaskContextSlim.scala	11
core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	311
core/src/main/scala/org/apache/spark/eventhubs/client/Client.scala	17
core/src/main/scala/org/apache/spark/eventhubs/client/ClientConnectionPool.scala	127
core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	252
core/src/main/scala/org/apache/spark/eventhubs/package.scala	60
core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala	84
core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDDPartition.scala	14
core/src/main/scala/org/apache/spark/eventhubs/rdd/OffsetRange.scala	55
core/src/main/scala/org/apache/spark/eventhubs/utils/AadAuthenticationCallback.scala	5
core/src/main/scala/org/apache/spark/eventhubs/utils/EventHubsTestUtils.scala	98
core/src/main/scala/org/apache/spark/eventhubs/utils/MetricPlugin.scala	15
core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala	82
core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleLogMetricPlugin.scala	22
core/src/main/scala/org/apache/spark/eventhubs/utils/SimpleThrottlingStatusPlugin.scala	28
core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedCachedReceiver.scala	14
core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedClient.scala	55
core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala	112
core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedPartitionStatusTracker.scala	23
core/src/main/scala/org/apache/spark/eventhubs/utils/ThrottlingStatusPlugin.scala	17
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala	59
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsRelation.scala	40
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSink.scala	18
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	349
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceOffset.scala	26
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala	190
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	165
core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala	43
core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	62
core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala	145
project/plugins.sbt	2