Path	Lines of Code
spark/core/src/itest/java/org/elasticsearch/spark/integration/AbstractHadoopBasicSparkTest.java	116
spark/core/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkTest.java	222
spark/core/src/itest/java/org/elasticsearch/spark/integration/ScalaUtils.java	13
spark/core/src/itest/java/org/elasticsearch/spark/integration/SparkSuite.java	12
spark/core/src/itest/java/org/elasticsearch/spark/integration/SparkUtils.java	16
spark/core/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSpark.scala	726
spark/core/src/itest/scala/org/elasticsearch/spark/integration/SparkScalaSuite.java	27
spark/core/src/itest/scala/org/elasticsearch/spark/serialization/Bean.java	28
spark/core/src/main/scala/org/elasticsearch/spark/cfg/SparkSettings.java	77
spark/core/src/main/scala/org/elasticsearch/spark/cfg/SparkSettingsManager.java	9
spark/core/src/main/scala/org/elasticsearch/spark/cfg/package-info.java	1
spark/core/src/main/scala/org/elasticsearch/spark/package.scala	44
spark/core/src/main/scala/org/elasticsearch/spark/rdd/AbstractEsRDD.scala	55
spark/core/src/main/scala/org/elasticsearch/spark/rdd/AbstractEsRDDIterator.scala	58
spark/core/src/main/scala/org/elasticsearch/spark/rdd/CompatUtils.java	89
spark/core/src/main/scala/org/elasticsearch/spark/rdd/CompatibilityLevel.scala	5
spark/core/src/main/scala/org/elasticsearch/spark/rdd/EsRDDWriter.scala	70
spark/core/src/main/scala/org/elasticsearch/spark/rdd/EsSpark.scala	75
spark/core/src/main/scala/org/elasticsearch/spark/rdd/JDKCollectionConvertersCompat.scala	18
spark/core/src/main/scala/org/elasticsearch/spark/rdd/JavaEsRDD.scala	33
spark/core/src/main/scala/org/elasticsearch/spark/rdd/Metadata.java	12
spark/core/src/main/scala/org/elasticsearch/spark/rdd/ScalaEsRDD.scala	34
spark/core/src/main/scala/org/elasticsearch/spark/rdd/api/java/JavaEsSpark.scala	40
spark/core/src/main/scala/org/elasticsearch/spark/rdd/api/java/package-info.java	1
spark/core/src/main/scala/org/elasticsearch/spark/serialization/ReflectionUtils.scala	92
spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaMapFieldExtractor.scala	27
spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaMetadataExtractor.scala	28
spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaValueReader.scala	213
spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaValueWriter.scala	114
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkSQLTest.java	153
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkStreamingTest.java	542
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/ScalaUtils.java	13
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/SparkSQLSuite.java	12
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/SparkStreamingSuite.java	12
spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/SparkUtils.java	16
spark/sql-30/src/itest/java/org/elasticsearch/spark/sql/UtilsTest.java	15
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java	412
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsScalaSparkStreaming.scala	343
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala	2151
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkStructuredStreaming.scala	531
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/SparkSQLScalaSuite.java	12
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/SparkStreamingScalaSuite.java	12
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/SparkStructuredStreamingScalaSuite.java	12
spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/SparkStructuredStreamingSuite.java	12
spark/sql-30/src/itest/scala/org/elasticsearch/spark/serialization/Bean.java	28
spark/sql-30/src/itest/scala/org/elasticsearch/spark/serialization/Garbage.scala	4
spark/sql-30/src/itest/scala/org/elasticsearch/spark/serialization/ModuleCaseClass.scala	4
spark/sql-30/src/itest/scala/org/elasticsearch/spark/serialization/Trip.scala	4
spark/sql-30/src/itest/scala/org/elasticsearch/spark/sql/SchemaUtilsTestable.scala	10
spark/sql-30/src/itest/scala/org/elasticsearch/spark/sql/ServiceLoadingTest.scala	14
spark/sql-30/src/itest/scala/org/elasticsearch/spark/sql/streaming/NetcatTestServer.java	139
spark/sql-30/src/itest/scala/org/elasticsearch/spark/sql/streaming/StreamingQueryTestHarness.scala	260
spark/sql-30/src/itest/scala/org/elasticsearch/spark/sql/streaming/api/java/JavaStreamingQueryTestHarness.java	84
spark/sql-30/src/main/scala/org/elasticsearch/spark/deploy/yarn/security/EsServiceCredentialProvider.scala	69
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DataFrameFieldExtractor.scala	31
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DataFrameValueWriter.scala	236
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource.scala	498
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource15.scala	5
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/EsDataFrameWriter.scala	16
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/EsSparkSQL.scala	65
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/RowValueReader.scala	42
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/ScalaEsRow.scala	22
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/ScalaEsRowRDD.scala	40
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/ScalaEsRowValueReader.scala	108
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/SchemaUtils.scala	251
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/SparkSQLCompatibilityLevel.scala	6
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/Utils.java	42
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/api/java/JavaEsSparkSQL.scala	28
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/api/java/package-info.java	1
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/package.scala	39
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/EsCommitProtocol.scala	42
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/EsSinkMetadataLog.scala	15
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/EsSinkStatus.scala	2
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/EsSparkSqlStreamingSink.scala	54
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/EsStreamQueryWriter.scala	45
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/NullMetadataLog.scala	9
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/SparkSqlStreamingConfigs.scala	74
spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/streaming/StructuredStreamingVersionLock.scala	25
spark/sql-30/src/main/scala/org/elasticsearch/spark/streaming/EsSparkStreaming.scala	40
spark/sql-30/src/main/scala/org/elasticsearch/spark/streaming/api/java/JavaEsSparkStreaming.scala	19
spark/sql-30/src/main/scala/org/elasticsearch/spark/streaming/api/java/package-info.java	1
spark/sql-30/src/main/scala/org/elasticsearch/spark/streaming/package.scala	27