Path	Lines of Code
build/sbt-launch-lib.bash	148
common/network-common/src/main/java/org/apache/spark/network/buffer/ManagedBuffer.java	13
common/network-common/src/main/java/org/apache/spark/network/crypto/AuthClientBootstrap.java	72
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java	1654
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlock.java	79
common/sketch/src/main/java/org/apache/spark/util/sketch/BloomFilterImpl.java	204
common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationAwareUTF8String.java	921
common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationSupport.java	642
common/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java	1414
common/utils/src/main/scala/org/apache/spark/storage/StorageLevel.scala	150
common/utils/src/main/scala/org/apache/spark/util/ClosureCleaner.scala	618
common/utils/src/main/scala/org/apache/spark/util/SparkClassUtils.scala	70
connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchStream.scala	290
connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala	284
connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/consumer/InternalKafkaConsumerPool.scala	109
connector/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaDataConsumer.scala	219
connector/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala	234
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/ProtobufDeserializer.scala	431
core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java	275
core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java	590
core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeExternalSorter.java	582
core/src/main/resources/org/apache/spark/ui/static/dataTables.rowsGroup.js	128
core/src/main/resources/org/apache/spark/ui/static/executorspage.js	710
core/src/main/resources/org/apache/spark/ui/static/historypage.js	209
core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js	362
core/src/main/resources/org/apache/spark/ui/static/utils.js	239
core/src/main/scala/org/apache/spark/BarrierCoordinator.scala	149
core/src/main/scala/org/apache/spark/Dependency.scala	126
core/src/main/scala/org/apache/spark/ExecutorAllocationClient.scala	43
core/src/main/scala/org/apache/spark/MapOutputTracker.scala	1131
core/src/main/scala/org/apache/spark/SecurityManager.scala	251
core/src/main/scala/org/apache/spark/SparkConf.scala	505
core/src/main/scala/org/apache/spark/SparkContext.scala	1923
core/src/main/scala/org/apache/spark/TestUtils.scala	309
core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala	733
core/src/main/scala/org/apache/spark/api/python/PythonWorkerFactory.scala	399
core/src/main/scala/org/apache/spark/api/r/BaseRRunner.scala	247
core/src/main/scala/org/apache/spark/api/r/RBackendHandler.scala	198
core/src/main/scala/org/apache/spark/deploy/Client.scala	219
core/src/main/scala/org/apache/spark/deploy/ClientArguments.scala	85
core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala	883
core/src/main/scala/org/apache/spark/deploy/client/StandaloneAppClient.scala	236
core/src/main/scala/org/apache/spark/deploy/master/Master.scala	1095
core/src/main/scala/org/apache/spark/deploy/worker/CommandUtils.scala	81
core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala	201
core/src/main/scala/org/apache/spark/executor/Executor.scala	952
core/src/main/scala/org/apache/spark/executor/ExecutorExitCode.scala	37
core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala	207
core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriterUtils.scala	67
core/src/main/scala/org/apache/spark/memory/ExecutionMemoryPool.scala	76
core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala	179
core/src/main/scala/org/apache/spark/rdd/LocalRDDCheckpointData.scala	28
core/src/main/scala/org/apache/spark/rdd/OrderedRDDFunctions.scala	45
core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala	103
core/src/main/scala/org/apache/spark/rdd/RDD.scala	1080
core/src/main/scala/org/apache/spark/rdd/RDDBarrier.scala	40
core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala	37
core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala	230
core/src/main/scala/org/apache/spark/rdd/SequenceFileRDDFunctions.scala	38
core/src/main/scala/org/apache/spark/rdd/ShuffledRDD.scala	67
core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala	75
core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala	540
core/src/main/scala/org/apache/spark/scheduler/AccumulableInfo.scala	11
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala	2113
core/src/main/scala/org/apache/spark/scheduler/ExecutorResourcesAmounts.scala	106
core/src/main/scala/org/apache/spark/scheduler/Task.scala	132
core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala	886
core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala	1010
core/src/main/scala/org/apache/spark/scheduler/dynalloc/ExecutorMonitor.scala	440
core/src/main/scala/org/apache/spark/shuffle/ShuffleReader.scala	4
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala	1100
core/src/main/scala/org/apache/spark/storage/BlockManager.scala	1544
core/src/main/scala/org/apache/spark/storage/BlockManagerDecommissioner.scala	336
core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala	818
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala	1103
core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala	471
core/src/main/scala/org/apache/spark/ui/scope/RDDOperationGraph.scala	193
core/src/main/scala/org/apache/spark/util/AccumulatorV2.scala	253
core/src/main/scala/org/apache/spark/util/JsonProtocol.scala	1419
core/src/main/scala/org/apache/spark/util/SizeEstimator.scala	231
core/src/main/scala/org/apache/spark/util/Utils.scala	2154
core/src/main/scala/org/apache/spark/util/collection/AppendOnlyMap.scala	215
core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala	534
core/src/main/scala/org/apache/spark/util/collection/SortDataFormat.scala	37
core/src/main/scala/org/apache/spark/util/random/SamplingUtils.scala	73
core/src/main/scala/org/apache/spark/util/random/StratifiedSamplingUtils.scala	198
graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala	244
graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala	145
graphx/src/main/scala/org/apache/spark/graphx/package.scala	7
launcher/src/main/java/org/apache/spark/launcher/CommandBuilderUtils.java	240
mllib/src/main/scala/org/apache/spark/ml/Predictor.scala	96
mllib/src/main/scala/org/apache/spark/ml/ann/BreezeUtil.scala	21
mllib/src/main/scala/org/apache/spark/ml/ann/Layer.scala	425
mllib/src/main/scala/org/apache/spark/ml/classification/ClassificationSummary.scala	110
mllib/src/main/scala/org/apache/spark/ml/classification/Classifier.scala	103
mllib/src/main/scala/org/apache/spark/ml/classification/LogisticRegression.scala	929
mllib/src/main/scala/org/apache/spark/ml/classification/RandomForestClassifier.scala	346
mllib/src/main/scala/org/apache/spark/ml/clustering/GaussianMixture.scala	455
mllib/src/main/scala/org/apache/spark/ml/clustering/LDA.scala	533
mllib/src/main/scala/org/apache/spark/ml/feature/BucketedRandomProjectionLSH.scala	150
mllib/src/main/scala/org/apache/spark/ml/feature/LSH.scala	166
mllib/src/main/scala/org/apache/spark/ml/feature/MinHashLSH.scala	161
mllib/src/main/scala/org/apache/spark/ml/feature/Selector.scala	230
mllib/src/main/scala/org/apache/spark/ml/feature/UnivariateFeatureSelector.scala	308
mllib/src/main/scala/org/apache/spark/ml/feature/VectorAssembler.scala	228
mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala	370
mllib/src/main/scala/org/apache/spark/ml/fpm/FPGrowth.scala	263
mllib/src/main/scala/org/apache/spark/ml/optim/WeightedLeastSquares.scala	362
mllib/src/main/scala/org/apache/spark/ml/param/params.scala	603
mllib/src/main/scala/org/apache/spark/ml/param/shared/SharedParamsCodeGen.scala	220
mllib/src/main/scala/org/apache/spark/ml/r/AFTSurvivalRegressionWrapper.scala	105
mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala	1062
mllib/src/main/scala/org/apache/spark/ml/regression/GBTRegressor.scala	237
mllib/src/main/scala/org/apache/spark/ml/regression/GeneralizedLinearRegression.scala	967
mllib/src/main/scala/org/apache/spark/ml/regression/RandomForestRegressor.scala	219
mllib/src/main/scala/org/apache/spark/ml/regression/Regressor.scala	11
mllib/src/main/scala/org/apache/spark/ml/stat/Summarizer.scala	544
mllib/src/main/scala/org/apache/spark/ml/tree/Node.scala	239
mllib/src/main/scala/org/apache/spark/ml/tree/impl/BaggedPoint.scala	81
mllib/src/main/scala/org/apache/spark/ml/tree/impl/DTStatsAggregator.scala	78
mllib/src/main/scala/org/apache/spark/ml/tree/impl/RandomForest.scala	827
mllib/src/main/scala/org/apache/spark/ml/tree/treeModels.scala	331
mllib/src/main/scala/org/apache/spark/ml/tree/treeParams.scala	297
mllib/src/main/scala/org/apache/spark/ml/tuning/CrossValidator.scala	304
mllib/src/main/scala/org/apache/spark/ml/tuning/TrainValidationSplit.scala	278
mllib/src/main/scala/org/apache/spark/ml/util/DatasetUtils.scala	147
mllib/src/main/scala/org/apache/spark/ml/util/ReadWrite.scala	524
mllib/src/main/scala/org/apache/spark/ml/util/SchemaUtils.scala	136
mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala	1122
mllib/src/main/scala/org/apache/spark/mllib/clustering/BisectingKMeans.scala	348
mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeansModel.scala	163
mllib/src/main/scala/org/apache/spark/mllib/clustering/LDA.scala	169
mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala	540
mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala	370
mllib/src/main/scala/org/apache/spark/mllib/feature/ChiSqSelector.scala	203
mllib/src/main/scala/org/apache/spark/mllib/feature/IDF.scala	150
mllib/src/main/scala/org/apache/spark/mllib/feature/StandardScaler.scala	98
mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala	422
mllib/src/main/scala/org/apache/spark/mllib/linalg/EigenValueDecomposition.scala	78
mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala	346
mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/RowMatrix.scala	560
mllib/src/main/scala/org/apache/spark/mllib/optimization/LBFGS.scala	143
mllib/src/main/scala/org/apache/spark/mllib/random/RandomRDDs.scala	506
mllib/src/main/scala/org/apache/spark/mllib/rdd/SlidingRDD.scala	67
mllib/src/main/scala/org/apache/spark/mllib/recommendation/MatrixFactorizationModel.scala	235
mllib/src/main/scala/org/apache/spark/mllib/regression/GeneralizedLinearAlgorithm.scala	155
mllib/src/main/scala/org/apache/spark/mllib/stat/correlation/PearsonCorrelation.scala	56
mllib/src/main/scala/org/apache/spark/mllib/tree/model/DecisionTreeModel.scala	219
mllib/src/main/scala/org/apache/spark/mllib/tree/model/treeEnsembleModels.scala	269
mllib/src/main/scala/org/apache/spark/mllib/util/MLUtils.scala	397
project/SparkBuild.scala	1460
python/pyspark/cloudpickle/cloudpickle.py	793
python/pyspark/core/rdd.py	1451
python/pyspark/core/status.py	36
python/pyspark/ml/classification.py	2173
python/pyspark/ml/connect/classification.py	248
python/pyspark/ml/connect/tuning.py	318
python/pyspark/ml/feature.py	3621
python/pyspark/ml/functions.py	301
python/pyspark/ml/linalg/__init__.py	779
python/pyspark/ml/param/_shared_params_code_gen.py	308
python/pyspark/ml/torch/data.py	66
python/pyspark/ml/torch/distributor.py	630
python/pyspark/ml/torch/log_communication.py	126
python/pyspark/ml/tuning.py	1133
python/pyspark/ml/util.py	714
python/pyspark/mllib/linalg/__init__.py	908
python/pyspark/pandas/_typing.py	23
python/pyspark/pandas/accessors.py	434
python/pyspark/pandas/base.py	601
python/pyspark/pandas/datetimes.py	190
python/pyspark/pandas/generic.py	991
python/pyspark/pandas/groupby.py	1800
python/pyspark/pandas/indexes/base.py	988
python/pyspark/pandas/indexes/multi.py	527
python/pyspark/pandas/indexing.py	1210
python/pyspark/pandas/mlflow.py	81
python/pyspark/pandas/namespace.py	1517
python/pyspark/pandas/plot/matplotlib.py	597
python/pyspark/pandas/series.py	2215
python/pyspark/pandas/sql_processor.py	137
python/pyspark/pandas/supported_api_gen.py	195
python/pyspark/pandas/typedef/typehints.py	409
python/pyspark/pandas/window.py	539
python/pyspark/shuffle.py	446
python/pyspark/sql/connect/client/artifact.py	282
python/pyspark/sql/connect/client/core.py	1449
python/pyspark/sql/connect/dataframe.py	1945
python/pyspark/sql/connect/proto/commands_pb2.pyi	2053
python/pyspark/sql/connect/protobuf/functions.py	115
python/pyspark/sql/connect/session.py	838
python/pyspark/sql/connect/udf.py	226
python/pyspark/sql/pandas/types.py	920
python/pyspark/sql/session.py	921
python/pyspark/sql/types.py	1984
python/pyspark/sql/udf.py	464
python/pyspark/sql/worker/analyze_udtf.py	187
python/pyspark/streaming/dstream.py	489
python/pyspark/worker.py	1728
python/run-tests.py	287
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features/DriverKubernetesCredentialsFeatureStep.scala	161
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorPodsAllocator.scala	410
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala	732
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala	1227
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala	64
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala	160
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocatorNodeHealthTracker.scala	92
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala	139
resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnSchedulerBackend.scala	263
sql/api/src/main/java/org/apache/spark/sql/types/SQLUserDefinedType.java	9
sql/api/src/main/scala/org/apache/spark/sql/ForeachWriter.scala	6
sql/api/src/main/scala/org/apache/spark/sql/Row.scala	242
sql/api/src/main/scala/org/apache/spark/sql/catalyst/JavaTypeInference.scala	120
sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala	81
sql/api/src/main/scala/org/apache/spark/sql/catalyst/util/SparkParserUtils.scala	144
sql/api/src/main/scala/org/apache/spark/sql/types/UpCastRule.scala	41
sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeMapData.java	101
sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/util/HadoopCompressionCodec.java	37
sql/catalyst/src/main/java/org/apache/spark/sql/connector/util/V2ExpressionSQLBuilder.java	313
sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarArray.java	154
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/DeserializerBuildHelper.scala	407
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SerializerBuildHelper.scala	418
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala	2889
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/BooleanEqualityTypeCoercion.scala	56
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala	920
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DeduplicateRelations.scala	394
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCatalogs.scala	112
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveColumnDefaultInCommandInputQuery.scala	100
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveLateralColumnAliasReference.scala	140
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveReferencesInAggregate.scala	101
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveSetVariable.scala	46
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala	439
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/AggregateResolver.scala	192
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/ProjectResolver.scala	119
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/resolver/UnsupportedExpressionInOperatorValidation.scala	43
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/v2ResolutionPlans.scala	164
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala	533
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala	1490
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/interface.scala	813
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/package.scala	399
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala	189
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala	62
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala	1905
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala	827
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/TryEval.scala	239
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/V2ExpressionUtils.scala	319
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Mode.scala	268
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/collect.scala	399
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/datasketchesAggregates.scala	217
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala	1210
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala	298
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala	368
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala	1547
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala	1057
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala	315
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/subquery.scala	347
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/DecorrelateInnerQuery.scala	529
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/EliminateResolvedHint.scala	57
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/NormalizeFloatingNumbers.scala	139
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala	1683
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushDownLeftSemiAntiJoin.scala	170
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceExceptWithFilter.scala	69
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteWithExpression.scala	139
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala	783
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala	757
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AstBuilder.scala	4715
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/QueryPlanner.scala	37
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/patterns.scala	272
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/DistinctKeyVisitor.scala	104
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/EventTimeWatermark.scala	67
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala	1503
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/object.scala	682
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/FilterEstimation.scala	514
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/JoinEstimation.scala	242
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/broadcastMode.scala	14
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala	847
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ArrayBasedMapBuilder.scala	96
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/GenericArrayData.scala	123
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/V2ExpressionBuilder.scala	402
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/StaxXmlParser.scala	873
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/xml/XmlInferSchema.scala	432
sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala	103
sql/catalyst/src/main/scala/org/apache/spark/sql/internal/connector/SupportsStreamingUpdateAsAppend.scala	4
sql/catalyst/src/main/scala/org/apache/spark/sql/util/SchemaUtils.scala	250
sql/connect/common/src/main/protobuf/spark/connect/commands.proto	448
sql/connect/common/src/main/scala/org/apache/spark/sql/connect/Dataset.scala	1025
sql/connect/common/src/main/scala/org/apache/spark/sql/connect/SparkSession.scala	598
sql/connect/common/src/main/scala/org/apache/spark/sql/connect/UdfToProtoUtils.scala	80
sql/connect/common/src/main/scala/org/apache/spark/sql/connect/client/arrow/ArrowSerializer.scala	499
sql/connect/common/src/main/scala/org/apache/spark/sql/connect/columnNodeSupport.scala	248
sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/SparkConnectPlanner.scala	3468
sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/StreamingForeachBatchHelper.scala	181
sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/StreamingQueryListenerHelper.scala	74
sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/ExecuteEventsManager.scala	225
sql/core/src/main/java/org/apache/parquet/filter2/predicate/SparkFilterApi.java	28
sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java	215
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java	216
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java	296
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java	326
sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedValuesReader.java	56
sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java	599
sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala	188
sql/core/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala	404
sql/core/src/main/scala/org/apache/spark/sql/avro/AvroFileFormat.scala	135
sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveDataSource.scala	103
sql/core/src/main/scala/org/apache/spark/sql/classic/Catalog.scala	568
sql/core/src/main/scala/org/apache/spark/sql/classic/DataFrameNaFunctions.scala	185
sql/core/src/main/scala/org/apache/spark/sql/classic/DataStreamWriter.scala	323
sql/core/src/main/scala/org/apache/spark/sql/classic/Dataset.scala	1498
sql/core/src/main/scala/org/apache/spark/sql/classic/SQLContext.scala	232
sql/core/src/main/scala/org/apache/spark/sql/classic/SparkSession.scala	665
sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala	611
sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala	220
sql/core/src/main/scala/org/apache/spark/sql/execution/GenerateExec.scala	231
sql/core/src/main/scala/org/apache/spark/sql/execution/InsertSortForLimitAndOffset.scala	63
sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala	440
sql/core/src/main/scala/org/apache/spark/sql/execution/ShuffledRowRDD.scala	153
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala	81
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala	378
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala	60
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala	1040
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala	806
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEPropagateEmptyRelation.scala	57
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/AQEShuffleReadExec.scala	201
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/CoalesceShufflePartitions.scala	141
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/LogicalQueryStage.scala	47
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeShuffleWithLocalRead.scala	98
sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeSkewedJoin.scala	176
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/AggregationIterator.scala	214
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/RowBasedHashMapGenerator.scala	139
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TypedAggregateExpression.scala	219
sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala	642
sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnStats.scala	276
sql/core/src/main/scala/org/apache/spark/sql/execution/command/CommandUtils.scala	375
sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala	734
sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala	992
sql/core/src/main/scala/org/apache/spark/sql/execution/command/v2/V2CommandStrategy.scala	17
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala	617
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala	613
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormat.scala	178
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileScanRDD.scala	210
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningUtils.scala	400
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala	213
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala	374
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRowConverter.scala	675
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/rules.scala	558
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/BatchScanExec.scala	224
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ContinuousScanExec.scala	43
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceRDD.scala	140
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Utils.scala	152
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileDataSourceV2.scala	90
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileWrite.scala	109
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/MicroBatchScanExec.scala	34
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowTablesExtendedExec.scala	139
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TableCapabilityCheck.scala	61
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2Writes.scala	146
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCScanBuilder.scala	137
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/jdbc/JDBCWriteBuilder.scala	26
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StateDataSource.scala	443
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/state/StreamStreamJoinStatePartitionReader.scala	123
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchangeExec.scala	283
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala	663
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala	795
sql/core/src/main/scala/org/apache/spark/sql/execution/python/streaming/TransformWithStateInPySparkExec.scala	403
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CommitLog.scala	40
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala	467
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala	701
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala	446
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StateTypesEncoderUtils.scala	179
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala	483
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/TransformWithStateExec.scala	539
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala	345
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala	130
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala	801
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/OperatorStateMetadata.scala	348
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreChangelog.scala	413
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala	1059
sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecutionContext.scala	125
sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecutionNode.scala	707
sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingLocalVariableManager.scala	74
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/CLIServiceClient.java	24
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/FetchOrientation.java	25
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/HiveSQLException.java	143
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/OperationType.java	29
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/TableSchema.java	64
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/Operation.java	253
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java	233
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java	637
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIServiceClient.java	390
sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java	154
sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala	333
sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala	510
sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala	998
sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveInspectors.scala	875
sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveUtils.scala	369
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClient.scala	138
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala	1102
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala	1277
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/IsolatedClientLoader.scala	229
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala	77
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveFileFormat.scala	127
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala	176
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/PruneHiveTablePartitions.scala	79
sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala	337
sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFileOperator.scala	88
streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala	541
streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala	457
streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListenerBus.scala	51