Netflix/spark
File Size
The distribution of size of files (measured in lines of code).
File Size Overall
  • There are 2,367 files with 315,530 lines of code.
    • 25 very long files (40,959 lines of code)
    • 89 long files (60,802 lines of code)
    • 314 medium size files (94,398 lines of code)
    • 454 small files (64,372 lines of code)
    • 1,485 very small files (54,999 lines of code)
12% | 19% | 29% | 20% | 17%
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
scala10% | 20% | 28% | 21% | 17%
py41% | 19% | 23% | 9% | 5%
g4100% | 0% | 0% | 0% | 0%
java0% | 10% | 39% | 23% | 26%
js0% | 21% | 50% | 18% | 9%
thrift0% | 100% | 0% | 0% | 0%
html0% | 0% | 80% | 11% | 8%
css0% | 0% | 74% | 0% | 25%
xml0% | 0% | 100% | 0% | 0%
bash0% | 0% | 0% | 100% | 0%
ps10% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
c0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
sql14% | 17% | 31% | 19% | 16%
python43% | 20% | 21% | 8% | 5%
core8% | 24% | 26% | 21% | 19%
mllib2% | 20% | 34% | 25% | 17%
resource-managers10% | 18% | 19% | 25% | 25%
mllib-local0% | 97% | 0% | 0% | 2%
project0% | 96% | 0% | 0% | 3%
common0% | 8% | 32% | 26% | 32%
streaming0% | 5% | 39% | 27% | 28%
launcher0% | 0% | 57% | 21% | 21%
dev0% | 0% | 57% | 27% | 14%
licenses-binary0% | 0% | 100% | 0% | 0%
graphx0% | 0% | 19% | 39% | 41%
ROOT0% | 0% | 100% | 0% | 0%
repl0% | 0% | 32% | 47% | 20%
build0% | 0% | 0% | 100% | 0%
tools0% | 0% | 0% | 0% | 100%
R0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
tests.py
in python/pyspark/sql
 5232 391
collectionOperations.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 3429 119
tests.py
in python/pyspark/ml
 2180 159
Analyzer.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis
 2003 109
Utils.scala
in core/src/main/scala/org/apache/spark/util
 1974 149
tests.py
in python/pyspark
 1903 162
AstBuilder.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser
 1809 171
stringExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1668 92
SQLConf.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/internal
 1647 26
SparkContext.scala
in core/src/main/scala/org/apache/spark
 1532 104
tests.py
in python/pyspark/mllib
 1373 90
DAGScheduler.scala
in core/src/main/scala/org/apache/spark/scheduler
 1371 71
feature.py
in python/pyspark/ml
 1370 229
objects.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects
 1270 46
tests.py
in python/pyspark/streaming
 1223 104
Dataset.scala
in sql/core/src/main/scala/org/apache/spark/sql
 1216 116
datetimeExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1190 73
BlockManager.scala
in core/src/main/scala/org/apache/spark/storage
 1172 60
Cast.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1166 36
PythonMLLibAPI.scala
in mllib/src/main/scala/org/apache/spark/mllib/api/python
 1114 93
SqlBase.g4
in sql/catalyst/src/main/antlr4/org/apache/spark/sql/catalyst/parser
 1060 -
Optimizer.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer
 1019 58
Client.scala
in resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn
 1015 35
types.py
in python/pyspark/sql
 1015 119
functions.scala
in sql/core/src/main/scala/org/apache/spark/sql
 1008 249
993 1
ALS.scala
in mllib/src/main/scala/org/apache/spark/ml/recommendation
 989 55
RDD.scala
in core/src/main/scala/org/apache/spark/rdd
 981 94
rdd.py
in python/pyspark
 971 131
LogisticRegression.scala
in mllib/src/main/scala/org/apache/spark/ml/classification
 968 31
ScalaUDF.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 966 3
CodeGenerator.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen
 965 61
mathExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 960 42
UTF8String.java
in common/unsafe/src/main/java/org/apache/spark/unsafe/types
 951 65
functions.py
in python/pyspark/sql
 936 140
HiveExternalCatalog.scala
in sql/hive/src/main/scala/org/apache/spark/sql/hive
 923 66
StagePage.scala
in core/src/main/scala/org/apache/spark/ui/jobs
 920 15
SparkSubmit.scala
in core/src/main/scala/org/apache/spark/deploy
 917 31
GeneralizedLinearRegression.scala
in mllib/src/main/scala/org/apache/spark/ml/regression
 916 53
SessionCatalog.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog
 896 85
JsonProtocol.scala
in core/src/main/scala/org/apache/spark/util
 883 76
AppStatusListener.scala
in core/src/main/scala/org/apache/spark/status
 865 48
classification.py
in python/pyspark/ml
 860 117
dataframe.py
in python/pyspark/sql
 849 103
FsHistoryProvider.scala
in core/src/main/scala/org/apache/spark/deploy/history
 848 41
SortMergeJoinExec.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/joins
 836 30
Master.scala
in core/src/main/scala/org/apache/spark/deploy/master
 801 33
HiveClientImpl.scala
in sql/hive/src/main/scala/org/apache/spark/sql/hive/client
 798 56
Matrices.scala
in mllib/src/main/scala/org/apache/spark/mllib/linalg
 774 42
DateTimeUtils.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util
 773 66
Files With Most Units (Top 50)
File# lines# units
tests.py
in python/pyspark/sql
 5232 391
functions.scala
in sql/core/src/main/scala/org/apache/spark/sql
 1008 249
feature.py
in python/pyspark/ml
 1370 229
AstBuilder.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser
 1809 171
tests.py
in python/pyspark
 1903 162
tests.py
in python/pyspark/ml
 2180 159
Utils.scala
in core/src/main/scala/org/apache/spark/util
 1974 149
functions.py
in python/pyspark/sql
 936 140
rdd.py
in python/pyspark
 971 131
regression.py
in python/pyspark/ml
 732 131
types.py
in python/pyspark/sql
 1015 119
collectionOperations.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 3429 119
classification.py
in python/pyspark/ml
 860 117
Dataset.scala
in sql/core/src/main/scala/org/apache/spark/sql
 1216 116
Analyzer.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis
 2003 109
SparkContext.scala
in core/src/main/scala/org/apache/spark
 1532 104
tests.py
in python/pyspark/streaming
 1223 104
ColumnType.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/columnar
 497 104
shared.py
in python/pyspark/ml/param
 290 103
dataframe.py
in python/pyspark/sql
 849 103
RDD.scala
in core/src/main/scala/org/apache/spark/rdd
 981 94
__init__.py
in python/pyspark/mllib/linalg
 742 94
clustering.py
in python/pyspark/ml
 516 93
PythonMLLibAPI.scala
in mllib/src/main/scala/org/apache/spark/mllib/api/python
 1114 93
stringExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1668 92
tests.py
in python/pyspark/mllib
 1373 90
SessionCatalog.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog
 896 85
__init__.py
in python/pyspark/ml/linalg
 638 79
JsonProtocol.scala
in core/src/main/scala/org/apache/spark/util
 883 76
serializers.py
in python/pyspark
 444 76
datetimeExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1190 73
DAGScheduler.scala
in core/src/main/scala/org/apache/spark/scheduler
 1371 71
params.scala
in mllib/src/main/scala/org/apache/spark/ml/param
 609 70
PairRDDFunctions.scala
in core/src/main/scala/org/apache/spark/rdd
 540 67
DateTimeUtils.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util
 773 66
HiveExternalCatalog.scala
in sql/hive/src/main/scala/org/apache/spark/sql/hive
 923 66
UTF8String.java
in common/unsafe/src/main/java/org/apache/spark/unsafe/types
 951 65
SQLContext.scala
in sql/core/src/main/scala/org/apache/spark/sql
 364 65
distributed.py
in python/pyspark/mllib/linalg
 321 62
CodeGenerator.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen
 965 61
BlockManager.scala
in core/src/main/scala/org/apache/spark/storage
 1172 60
TableChange.java
in sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog
 363 60
cloudpickle.py
in python/pyspark
 647 58
Optimizer.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer
 1019 58
RandomRDDs.scala
in mllib/src/main/scala/org/apache/spark/mllib/random
 514 57
Column.scala
in sql/core/src/main/scala/org/apache/spark/sql
 239 56
HiveClientImpl.scala
in sql/hive/src/main/scala/org/apache/spark/sql/hive/client
 798 56
SparkConf.scala
in core/src/main/scala/org/apache/spark
 477 55
context.py
in python/pyspark
 448 55
ALS.scala
in mllib/src/main/scala/org/apache/spark/ml/recommendation
 989 55
Files With Long Lines (Top 50)

There are 109 files with lines longer than 120 characters. In total, there are 520 long lines.

File# lines# units# long lines
993 1 252
shared.py
in python/pyspark/ml/param
 290 103 26
functions.scala
in sql/core/src/main/scala/org/apache/spark/sql
 1008 249 21
sharedParams.scala
in mllib/src/main/scala/org/apache/spark/ml/param/shared
 160 28 18
executorspage.js
in core/src/main/resources/org/apache/spark/ui/static
 571 38 10
executorspage-template.html
in core/src/main/resources/org/apache/spark/ui/static
 107 - 8
KryoSerializer.scala
in core/src/main/scala/org/apache/spark/serializer
 405 24 8
ScalaUDF.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 966 3 8
SqlBase.g4
in sql/catalyst/src/main/antlr4/org/apache/spark/sql/catalyst/parser
 1060 - 7
xpath.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/xml
 154 9 7
datetimeExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1190 73 7
stringExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 1668 92 7
StreamingPage.scala
in streaming/src/main/scala/org/apache/spark/streaming/ui
 434 15 5
DataFrameWriter.scala
in sql/core/src/main/scala/org/apache/spark/sql
 414 30 5
660 11 4
KubernetesDriverBuilder.scala
in resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit
 75 1 3
treeParams.scala
in mllib/src/main/scala/org/apache/spark/ml/tree
 261 11 3
235 - 3
WriteToDataSourceV2Exec.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2
 345 14 3
V2SessionCatalog.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2
 242 17 3
CLIService.java
in sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli
 357 37 3
KubernetesExecutorBuilder.scala
in resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s
 40 1 2
webui.css
in core/src/main/resources/org/apache/spark/ui/static
 215 - 2
historypage-template.html
in core/src/main/resources/org/apache/spark/ui/static
 77 - 2
SparkContext.scala
in core/src/main/scala/org/apache/spark
 1532 104 2
98 - 2
UDF20.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
UDF17.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
UDF21.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
UDF18.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
UDF22.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
UDF19.java
in sql/core/src/main/java/org/apache/spark/sql/api/java
 7 - 2
DataSourceV2Strategy.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2
 152 1 2
StreamingSymmetricHashJoinHelper.scala
in sql/core/src/main/scala/org/apache/spark/sql/execution/streaming
 153 8 2
DataFrameWriterV2.scala
in sql/core/src/main/scala/org/apache/spark/sql
 171 15 2
jsonExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 559 19 2
randomExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 88 8 2
collectionOperations.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 3429 119 2
conditionalExpressions.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 217 10 2
generators.scala
in sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
 274 15 2
HiveShim.scala
in sql/hive/src/main/scala/org/apache/spark/sql/hive/client
 610 35 2
TableSchema.java
in sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli
 62 12 2
KubernetesClientApplication.scala
in resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit
 195 7 1
LoggingPodStatusWatcher.scala
in resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit
 125 14 1
BasicExecutorFeatureStep.scala
in resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/features
 158 1 1
MasterPage.scala
in core/src/main/scala/org/apache/spark/deploy/master/ui
 273 8 1
ApplicationCache.scala
in core/src/main/scala/org/apache/spark/deploy/history
 219 13 1
NettyBlockTransferService.scala
in core/src/main/scala/org/apache/spark/network/netty
 137 6 1
Node.scala
in mllib/src/main/scala/org/apache/spark/ml/tree
 212 17 1
streaming-page.js
in streaming/src/main/resources/org/apache/spark/streaming/ui/static
 215 9 1
Correlations

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

sql/catalyst/src/main/antlr4/org/apache/spark/sql/catalyst/parser/SqlBase.g4 x: 122 commits (all time) y: 1060 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AstBuilder.scala x: 118 commits (all time) y: 1809 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableChange.java x: 3 commits (all time) y: 363 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala x: 105 commits (all time) y: 558 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCatalogs.scala x: 8 commits (all time) y: 164 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statements.scala x: 6 commits (all time) y: 212 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogV2Util.scala x: 7 commits (all time) y: 241 lines of code sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveSessionCatalog.scala x: 10 commits (all time) y: 488 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsCatalogOptions.java x: 1 commits (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala x: 153 commits (all time) y: 272 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala x: 167 commits (all time) y: 414 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala x: 165 commits (all time) y: 1647 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala x: 365 commits (all time) y: 2003 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2Commands.scala x: 4 commits (all time) y: 298 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Strategy.scala x: 23 commits (all time) y: 152 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowNamespacesExec.scala x: 2 commits (all time) y: 32 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/CommandUtils.scala x: 12 commits (all time) y: 111 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2SessionCatalog.scala x: 4 commits (all time) y: 242 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala x: 127 commits (all time) y: 896 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/interface.scala x: 95 commits (all time) y: 444 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala x: 3 commits (all time) y: 94 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala x: 36 commits (all time) y: 218 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/LookupCatalog.scala x: 7 commits (all time) y: 86 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/IdentifierImpl.java x: 2 commits (all time) y: 47 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DataWriter.java x: 2 commits (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2Exec.scala x: 7 commits (all time) y: 345 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ProjectionOverSchema.scala x: 1 commits (all time) y: 43 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SchemaPruning.scala x: 1 commits (all time) y: 73 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PushDownUtils.scala x: 2 commits (all time) y: 75 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriterV2.scala x: 3 commits (all time) y: 171 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala x: 103 commits (all time) y: 411 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala x: 109 commits (all time) y: 543 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParseDriver.scala x: 20 commits (all time) y: 183 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala x: 132 commits (all time) y: 593 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala x: 91 commits (all time) y: 596 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala x: 107 commits (all time) y: 798 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala x: 44 commits (all time) y: 610 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/PartitionTransforms.scala x: 1 commits (all time) y: 25 lines of code sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala x: 236 commits (all time) y: 1216 lines of code sql/core/src/main/scala/org/apache/spark/sql/functions.scala x: 275 commits (all time) y: 1008 lines of code core/src/main/scala/org/apache/spark/util/Utils.scala x: 383 commits (all time) y: 1974 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala x: 116 commits (all time) y: 197 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala x: 76 commits (all time) y: 146 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourcePartitioning.scala x: 5 commits (all time) y: 30 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceRDD.scala x: 13 commits (all time) y: 52 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala x: 300 commits (all time) y: 1019 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala x: 16 commits (all time) y: 29 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala x: 23 commits (all time) y: 56 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/package.scala x: 92 commits (all time) y: 267 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala x: 95 commits (all time) y: 556 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/rules.scala x: 77 commits (all time) y: 394 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/BaseSessionStateBuilder.scala x: 16 commits (all time) y: 152 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala x: 12 commits (all time) y: 74 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/util/SchemaUtils.scala x: 3 commits (all time) y: 144 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveHints.scala x: 15 commits (all time) y: 74 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala x: 71 commits (all time) y: 278 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala x: 38 commits (all time) y: 288 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala x: 64 commits (all time) y: 94 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/StructType.scala x: 53 commits (all time) y: 293 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java x: 1 commits (all time) y: 106 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/util/CaseInsensitiveStringMap.java x: 1 commits (all time) y: 126 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala x: 4 commits (all time) y: 31 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NoSuchItemException.scala x: 10 commits (all time) y: 38 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/expressions/expressions.scala x: 1 commits (all time) y: 176 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java x: 1 commits (all time) y: 350 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java x: 1 commits (all time) y: 91 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarArray.java x: 1 commits (all time) y: 147 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatch.java x: 1 commits (all time) y: 195 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala x: 17 commits (all time) y: 181 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowWriter.scala x: 9 commits (all time) y: 260 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/AggregateInPandasExec.scala x: 6 commits (all time) y: 100 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowEvalPythonExec.scala x: 14 commits (all time) y: 72 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonRunner.scala x: 13 commits (all time) y: 128 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInPandasExec.scala x: 11 commits (all time) y: 78 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasExec.scala x: 5 commits (all time) y: 113 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/MutableColumnarRow.java x: 8 commits (all time) y: 216 lines of code sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala x: 85 commits (all time) y: 446 lines of code sql/core/src/main/java/org/apache/spark/sql/sources/v2/StreamWriteSupport.java x: 4 commits (all time) y: 15 lines of code sql/core/src/main/java/org/apache/spark/sql/sources/v2/reader/streaming/ContinuousReader.java x: 7 commits (all time) y: 15 lines of code sql/core/src/main/java/org/apache/spark/sql/sources/v2/reader/streaming/MicroBatchReader.java x: 5 commits (all time) y: 12 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToMicroBatchDataSourceV2Exec.scala x: 2 commits (all time) y: 110 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala x: 8 commits (all time) y: 62 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala x: 9 commits (all time) y: 124 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousRateStreamSource.scala x: 21 commits (all time) y: 130 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousTextSocketSource.scala x: 4 commits (all time) y: 206 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala x: 7 commits (all time) y: 56 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochCoordinator.scala x: 12 commits (all time) y: 139 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala x: 53 commits (all time) y: 206 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ForeachWriterProvider.scala x: 8 commits (all time) y: 95 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/MicroBatchWriter.scala x: 8 commits (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/PackedRowWriterFactory.scala x: 8 commits (all time) y: 24 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamMicroBatchReader.scala x: 12 commits (all time) y: 167 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/memoryV2.scala x: 20 commits (all time) y: 119 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/socket.scala x: 10 commits (all time) y: 198 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala x: 34 commits (all time) y: 379 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala x: 26 commits (all time) y: 231 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala x: 34 commits (all time) y: 282 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/DataStreamReader.scala x: 46 commits (all time) y: 77 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/DataStreamWriter.scala x: 40 commits (all time) y: 211 lines of code python/pyspark/version.py x: 45 commits (all time) y: 1 lines of code core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala x: 190 commits (all time) y: 661 lines of code python/pyspark/sql/dataframe.py x: 206 commits (all time) y: 849 lines of code python/pyspark/sql/tests.py x: 295 commits (all time) y: 5232 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CheckpointFileManager.scala x: 3 commits (all time) y: 221 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala x: 111 commits (all time) y: 766 lines of code core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala x: 350 commits (all time) y: 1371 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/LinearSVC.scala x: 17 commits (all time) y: 230 lines of code core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala x: 153 commits (all time) y: 917 lines of code python/pyspark/sql/functions.py x: 210 commits (all time) y: 936 lines of code dev/sparktestsupport/modules.py x: 61 commits (all time) y: 466 lines of code python/pyspark/streaming/tests.py x: 65 commits (all time) y: 1223 lines of code core/src/main/resources/org/apache/spark/ui/static/executorspage-template.html x: 4 commits (all time) y: 107 lines of code core/src/main/resources/org/apache/spark/ui/static/executorspage.js x: 10 commits (all time) y: 571 lines of code core/src/main/resources/org/apache/spark/ui/static/webui.css x: 45 commits (all time) y: 215 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousCoalesceRDD.scala x: 4 commits (all time) y: 86 lines of code core/src/main/scala/org/apache/spark/status/AppStatusStore.scala x: 14 commits (all time) y: 422 lines of code python/pyspark/tests.py x: 223 commits (all time) y: 1903 lines of code core/src/main/scala/org/apache/spark/scheduler/Task.scala x: 92 commits (all time) y: 124 lines of code core/src/main/scala/org/apache/spark/deploy/history/HistoryServer.scala x: 48 commits (all time) y: 196 lines of code core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala x: 169 commits (all time) y: 644 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ObjectAggregationIterator.scala x: 7 commits (all time) y: 219 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/Vectors.scala x: 16 commits (all time) y: 506 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/Vectors.scala x: 73 commits (all time) y: 668 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/view.scala x: 12 commits (all time) y: 29 lines of code core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala x: 123 commits (all time) y: 405 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeArrayData.java x: 25 commits (all time) y: 433 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java x: 66 commits (all time) y: 489 lines of code core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala x: 184 commits (all time) y: 920 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilters.scala x: 30 commits (all time) y: 434 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeUtils.scala x: 61 commits (all time) y: 773 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/types/CalendarInterval.java x: 8 commits (all time) y: 274 lines of code core/src/main/scala/org/apache/spark/ui/JettyUtils.scala x: 67 commits (all time) y: 415 lines of code python/pyspark/ml/linalg/__init__.py x: 10 commits (all time) y: 638 lines of code common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java x: 10 commits (all time) y: 208 lines of code core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala x: 92 commits (all time) y: 848 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala x: 40 commits (all time) y: 383 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileScanRDD.scala x: 27 commits (all time) y: 155 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/GaussianMixture.scala x: 35 commits (all time) y: 426 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringExpressions.scala x: 71 commits (all time) y: 1668 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala x: 40 commits (all time) y: 365 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala x: 134 commits (all time) y: 711 lines of code mllib/src/main/scala/org/apache/spark/mllib/feature/Word2Vec.scala x: 55 commits (all time) y: 513 lines of code python/pyspark/sql/readwriter.py x: 116 commits (all time) y: 337 lines of code core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriter.scala x: 6 commits (all time) y: 245 lines of code python/pyspark/sql/column.py x: 35 commits (all time) y: 265 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala x: 71 commits (all time) y: 447 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala x: 66 commits (all time) y: 442 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVDataSource.scala x: 17 commits (all time) y: 292 lines of code core/src/main/scala/org/apache/spark/api/python/PythonUtils.scala x: 21 commits (all time) y: 41 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala x: 37 commits (all time) y: 1015 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala x: 59 commits (all time) y: 318 lines of code mllib/src/main/scala/org/apache/spark/ml/evaluation/ClusteringEvaluator.scala x: 7 commits (all time) y: 263 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala x: 18 commits (all time) y: 661 lines of code common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java x: 11 commits (all time) y: 116 lines of code common/network-common/src/main/java/org/apache/spark/network/util/TransportConf.java x: 17 commits (all time) y: 134 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/AggregateEstimation.scala x: 14 commits (all time) y: 39 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/bitwiseExpressions.scala x: 11 commits (all time) y: 96 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java x: 3 commits (all time) y: 302 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java x: 6 commits (all time) y: 257 lines of code core/src/main/scala/org/apache/spark/status/AppStatusListener.scala x: 28 commits (all time) y: 865 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/GroupStateImpl.scala x: 5 commits (all time) y: 143 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala x: 49 commits (all time) y: 487 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala x: 126 commits (all time) y: 1166 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/nullExpressions.scala x: 33 commits (all time) y: 352 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala x: 21 commits (all time) y: 88 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/regexpExpressions.scala x: 29 commits (all time) y: 343 lines of code core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala x: 19 commits (all time) y: 454 lines of code mllib/src/main/scala/org/apache/spark/mllib/evaluation/BinaryClassificationMetrics.scala x: 16 commits (all time) y: 114 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala x: 22 commits (all time) y: 158 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/LinearRegression.scala x: 114 commits (all time) y: 548 lines of code dev/create-release/releaseutils.py x: 14 commits (all time) y: 188 lines of code core/src/main/scala/org/apache/spark/deploy/rest/SubmitRestProtocolMessage.scala x: 6 commits (all time) y: 70 lines of code core/src/main/scala/org/apache/spark/status/api/v1/JacksonMessageWriter.scala x: 8 commits (all time) y: 58 lines of code common/network-common/src/main/java/org/apache/spark/network/crypto/TransportCipher.java x: 6 commits (all time) y: 275 lines of code core/src/main/scala/org/apache/spark/security/CryptoStreamUtils.scala x: 7 commits (all time) y: 180 lines of code python/run-tests.py x: 22 commits (all time) y: 226 lines of code core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala x: 20 commits (all time) y: 158 lines of code core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala x: 10 commits (all time) y: 136 lines of code project/SparkBuild.scala x: 881 commits (all time) y: 660 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala x: 144 commits (all time) y: 623 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala x: 168 commits (all time) y: 735 lines of code core/src/main/scala/org/apache/spark/SparkConf.scala x: 128 commits (all time) y: 477 lines of code core/src/main/scala/org/apache/spark/executor/Executor.scala x: 255 commits (all time) y: 578 lines of code core/src/main/scala/org/apache/spark/internal/config/package.scala x: 85 commits (all time) y: 520 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala x: 26 commits (all time) y: 566 lines of code core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeExternalSorter.java x: 64 commits (all time) y: 505 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala x: 30 commits (all time) y: 114 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala x: 28 commits (all time) y: 609 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala x: 18 commits (all time) y: 494 lines of code core/src/main/scala/org/apache/spark/deploy/Client.scala x: 48 commits (all time) y: 173 lines of code core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala x: 172 commits (all time) y: 451 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala x: 88 commits (all time) y: 3429 lines of code core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala x: 52 commits (all time) y: 514 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeCreator.scala x: 65 commits (all time) y: 406 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala x: 255 commits (all time) y: 228 lines of code common/network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java x: 11 commits (all time) y: 229 lines of code common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java x: 13 commits (all time) y: 171 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala x: 185 commits (all time) y: 965 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLAppStatusListener.scala x: 13 commits (all time) y: 316 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningUtils.scala x: 45 commits (all time) y: 319 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala x: 23 commits (all time) y: 173 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/Statistics.scala x: 19 commits (all time) y: 129 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala x: 35 commits (all time) y: 197 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala x: 50 commits (all time) y: 432 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala x: 43 commits (all time) y: 742 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceivedBlockTracker.scala x: 22 commits (all time) y: 178 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FailureSafeParser.scala x: 4 commits (all time) y: 49 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonDataSource.scala x: 18 commits (all time) y: 180 lines of code graphx/src/main/scala/org/apache/spark/graphx/impl/EdgeRDDImpl.scala x: 14 commits (all time) y: 87 lines of code graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala x: 15 commits (all time) y: 190 lines of code graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala x: 29 commits (all time) y: 145 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala x: 32 commits (all time) y: 154 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryRelation.scala x: 28 commits (all time) y: 142 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/OptimizeMetadataOnlyQuery.scala x: 15 commits (all time) y: 116 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/RowMatrix.scala x: 49 commits (all time) y: 434 lines of code python/pyspark/mllib/linalg/__init__.py x: 21 commits (all time) y: 742 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala x: 32 commits (all time) y: 201 lines of code python/pyspark/context.py x: 240 commits (all time) y: 448 lines of code core/src/main/scala/org/apache/spark/scheduler/cluster/StandaloneSchedulerBackend.scala x: 45 commits (all time) y: 171 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala x: 111 commits (all time) y: 330 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/patterns.scala x: 54 commits (all time) y: 164 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala x: 120 commits (all time) y: 599 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala x: 16 commits (all time) y: 358 lines of code core/src/main/scala/org/apache/spark/api/python/PythonGatewayServer.scala x: 5 commits (all time) y: 52 lines of code python/pyspark/accumulators.py x: 69 commits (all time) y: 117 lines of code python/pyspark/java_gateway.py x: 92 commits (all time) y: 121 lines of code core/src/main/scala/org/apache/spark/ui/jobs/JobPage.scala x: 26 commits (all time) y: 367 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/UnsafeWriter.java x: 6 commits (all time) y: 147 lines of code sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala x: 39 commits (all time) y: 172 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/ReplaceExceptWithFilter.scala x: 4 commits (all time) y: 67 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala x: 22 commits (all time) y: 403 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala x: 39 commits (all time) y: 200 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala x: 65 commits (all time) y: 591 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/ShuffledHashJoinExec.scala x: 10 commits (all time) y: 43 lines of code python/pyspark/ml/feature.py x: 125 commits (all time) y: 1370 lines of code core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java x: 38 commits (all time) y: 568 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala x: 20 commits (all time) y: 366 lines of code python/pyspark/serializers.py x: 126 commits (all time) y: 444 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala x: 19 commits (all time) y: 62 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/Platform.java x: 15 commits (all time) y: 177 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala x: 37 commits (all time) y: 249 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/FilterEstimation.scala x: 20 commits (all time) y: 517 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/Metadata.scala x: 11 commits (all time) y: 175 lines of code python/pyspark/worker.py x: 137 commits (all time) y: 284 lines of code python/pyspark/broadcast.py x: 54 commits (all time) y: 110 lines of code core/src/main/scala/org/apache/spark/util/CompletionIterator.scala x: 19 commits (all time) y: 24 lines of code core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala x: 59 commits (all time) y: 510 lines of code core/src/main/scala/org/apache/spark/status/LiveEntity.scala x: 14 commits (all time) y: 595 lines of code core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala x: 115 commits (all time) y: 416 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala x: 35 commits (all time) y: 155 lines of code core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionClient.scala x: 14 commits (all time) y: 331 lines of code streaming/src/main/scala/org/apache/spark/streaming/rdd/WriteAheadLogBackedBlockRDD.scala x: 18 commits (all time) y: 123 lines of code project/MimaBuild.scala x: 30 commits (all time) y: 58 lines of code project/MimaExcludes.scala x: 324 commits (all time) y: 993 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala x: 78 commits (all time) y: 230 lines of code core/src/main/scala/org/apache/spark/storage/DiskStore.scala x: 83 commits (all time) y: 249 lines of code core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala x: 28 commits (all time) y: 579 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/Matrices.scala x: 57 commits (all time) y: 774 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/IsolatedClientLoader.scala x: 40 commits (all time) y: 199 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeansModel.scala x: 42 commits (all time) y: 146 lines of code mllib/src/main/scala/org/apache/spark/ml/stat/Summarizer.scala x: 5 commits (all time) y: 416 lines of code python/pyspark/ml/stat.py x: 7 commits (all time) y: 112 lines of code core/src/main/scala/org/apache/spark/storage/BlockManager.scala x: 274 commits (all time) y: 1172 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/jsonExpressions.scala x: 48 commits (all time) y: 559 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/BisectingKMeansModel.scala x: 13 commits (all time) y: 157 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala x: 196 commits (all time) y: 503 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala x: 61 commits (all time) y: 644 lines of code core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala x: 47 commits (all time) y: 233 lines of code dev/run-tests.py x: 74 commits (all time) y: 344 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/BisectingKMeans.scala x: 30 commits (all time) y: 174 lines of code python/pyspark/ml/clustering.py x: 49 commits (all time) y: 516 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala x: 40 commits (all time) y: 966 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala x: 2 commits (all time) y: 201 lines of code sql/core/src/main/scala/org/apache/spark/sql/expressions/UserDefinedFunction.scala x: 16 commits (all time) y: 82 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/JavaTypeInference.scala x: 30 commits (all time) y: 353 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScanExec.scala x: 26 commits (all time) y: 143 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala x: 37 commits (all time) y: 456 lines of code sql/core/src/main/scala/org/apache/spark/sql/Column.scala x: 110 commits (all time) y: 239 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala x: 103 commits (all time) y: 248 lines of code python/pyspark/sql/udf.py x: 21 commits (all time) y: 192 lines of code core/src/main/scala/org/apache/spark/storage/RDDInfo.scala x: 18 commits (all time) y: 48 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala x: 46 commits (all time) y: 1190 lines of code python/pyspark/sql/context.py x: 92 commits (all time) y: 188 lines of code python/pyspark/sql/session.py x: 57 commits (all time) y: 423 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DecimalPrecision.scala x: 12 commits (all time) y: 188 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala x: 66 commits (all time) y: 131 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/LDA.scala x: 42 commits (all time) y: 471 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/GBTClassifier.scala x: 52 commits (all time) y: 263 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/RandomForestClassifier.scala x: 47 commits (all time) y: 216 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/DecisionTreeRegressor.scala x: 42 commits (all time) y: 179 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/GBTRegressor.scala x: 48 commits (all time) y: 211 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/RandomForestRegressor.scala x: 43 commits (all time) y: 176 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/Node.scala x: 18 commits (all time) y: 212 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/impl/RandomForest.scala x: 35 commits (all time) y: 687 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/treeModels.scala x: 20 commits (all time) y: 247 lines of code core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java x: 27 commits (all time) y: 382 lines of code core/src/main/scala/org/apache/spark/MapOutputTracker.scala x: 122 commits (all time) y: 535 lines of code core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala x: 29 commits (all time) y: 73 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala x: 260 commits (all time) y: 420 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala x: 27 commits (all time) y: 111 lines of code streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala x: 125 commits (all time) y: 280 lines of code core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala x: 30 commits (all time) y: 137 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/RowQueue.scala x: 4 commits (all time) y: 200 lines of code resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesConf.scala x: 7 commits (all time) y: 188 lines of code resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesClientApplication.scala x: 9 commits (all time) y: 195 lines of code dev/merge_spark_pr.py x: 43 commits (all time) y: 346 lines of code python/pyspark/ml/classification.py x: 106 commits (all time) y: 860 lines of code python/pyspark/ml/fpm.py x: 8 commits (all time) y: 117 lines of code python/pyspark/ml/regression.py x: 82 commits (all time) y: 732 lines of code python/pyspark/mllib/clustering.py x: 65 commits (all time) y: 327 lines of code python/pyspark/mllib/feature.py x: 43 commits (all time) y: 262 lines of code python/pyspark/rdd.py x: 322 commits (all time) y: 971 lines of code python/pyspark/shell.py x: 106 commits (all time) y: 36 lines of code python/pyspark/sql/streaming.py x: 64 commits (all time) y: 381 lines of code python/pyspark/sql/types.py x: 85 commits (all time) y: 1015 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala x: 25 commits (all time) y: 224 lines of code core/src/main/scala/org/apache/spark/util/ClosureCleaner.scala x: 42 commits (all time) y: 335 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVOptions.scala x: 47 commits (all time) y: 149 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala x: 103 commits (all time) y: 156 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.scala x: 91 commits (all time) y: 85 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/memory/MemoryBlock.java x: 7 commits (all time) y: 23 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java x: 24 commits (all time) y: 951 lines of code core/src/main/java/org/apache/spark/memory/TaskMemoryManager.java x: 29 commits (all time) y: 264 lines of code core/src/main/java/org/apache/spark/shuffle/sort/ShuffleInMemorySorter.java x: 13 commits (all time) y: 118 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/hash.scala x: 21 commits (all time) y: 722 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/createDataSourceTables.scala x: 53 commits (all time) y: 136 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoHadoopFsRelationCommand.scala x: 31 commits (all time) y: 186 lines of code core/src/main/scala/org/apache/spark/Partitioner.scala x: 74 commits (all time) y: 223 lines of code core/src/main/scala/org/apache/spark/rdd/MapPartitionsRDD.scala x: 33 commits (all time) y: 28 lines of code core/src/main/scala/org/apache/spark/rdd/RDD.scala x: 284 commits (all time) y: 981 lines of code python/pyspark/ml/tests.py x: 117 commits (all time) y: 2180 lines of code core/src/main/scala/org/apache/spark/executor/ExecutorSource.scala x: 52 commits (all time) y: 97 lines of code core/src/main/scala/org/apache/spark/deploy/ExternalShuffleService.scala x: 17 commits (all time) y: 90 lines of code core/src/main/scala/org/apache/spark/deploy/LocalSparkCluster.scala x: 65 commits (all time) y: 46 lines of code core/src/main/scala/org/apache/spark/TaskContext.scala x: 68 commits (all time) y: 64 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/ArrayData.scala x: 6 commits (all time) y: 165 lines of code mllib/src/main/scala/org/apache/spark/mllib/fpm/AssociationRules.scala x: 15 commits (all time) y: 86 lines of code mllib/src/main/scala/org/apache/spark/mllib/feature/ChiSqSelector.scala x: 30 commits (all time) y: 205 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala x: 60 commits (all time) y: 296 lines of code core/src/main/scala/org/apache/spark/rdd/UnionRDD.scala x: 31 commits (all time) y: 71 lines of code core/src/main/scala/org/apache/spark/util/ThreadUtils.scala x: 19 commits (all time) y: 154 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SparkPlanGraph.scala x: 20 commits (all time) y: 138 lines of code python/pyspark/__init__.py x: 79 commits (all time) y: 48 lines of code repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala x: 84 commits (all time) y: 220 lines of code python/pyspark/sql/utils.py x: 20 commits (all time) y: 97 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala x: 51 commits (all time) y: 159 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ExtractPythonUDFs.scala x: 25 commits (all time) y: 154 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala x: 76 commits (all time) y: 141 lines of code core/src/main/scala/org/apache/spark/TestUtils.scala x: 28 commits (all time) y: 208 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala x: 24 commits (all time) y: 429 lines of code python/pyspark/streaming/dstream.py x: 17 commits (all time) y: 279 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala x: 62 commits (all time) y: 528 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala x: 23 commits (all time) y: 367 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala x: 29 commits (all time) y: 506 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala x: 23 commits (all time) y: 255 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala x: 6 commits (all time) y: 297 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala x: 36 commits (all time) y: 109 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetReadSupport.scala x: 12 commits (all time) y: 217 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVFileFormat.scala x: 25 commits (all time) y: 134 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonParser.scala x: 17 commits (all time) y: 258 lines of code resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesDriverBuilder.scala x: 7 commits (all time) y: 75 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/TypeUtils.scala x: 17 commits (all time) y: 54 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/LogisticRegression.scala x: 130 commits (all time) y: 968 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/NaiveBayes.scala x: 32 commits (all time) y: 258 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/AFTSurvivalRegression.scala x: 45 commits (all time) y: 344 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/BisectingKMeans.scala x: 16 commits (all time) y: 332 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala x: 75 commits (all time) y: 343 lines of code core/src/main/scala/org/apache/spark/SparkContext.scala x: 611 commits (all time) y: 1532 lines of code core/src/main/scala/org/apache/spark/scheduler/SchedulerBackend.scala x: 25 commits (all time) y: 19 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosFineGrainedSchedulerBackend.scala x: 9 commits (all time) y: 330 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala x: 54 commits (all time) y: 62 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/javaCode.scala x: 6 commits (all time) y: 190 lines of code sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala x: 63 commits (all time) y: 318 lines of code core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala x: 90 commits (all time) y: 520 lines of code core/src/main/scala/org/apache/spark/deploy/master/Master.scala x: 209 commits (all time) y: 801 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/CountVectorizer.scala x: 28 commits (all time) y: 229 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaConverter.scala x: 12 commits (all time) y: 308 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetWriteSupport.scala x: 7 commits (all time) y: 284 lines of code core/src/main/scala/org/apache/spark/util/ListenerBus.scala x: 12 commits (all time) y: 59 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerUtils.scala x: 9 commits (all time) y: 390 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java x: 6 commits (all time) y: 706 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/GeneralizedLinearRegression.scala x: 54 commits (all time) y: 916 lines of code core/src/main/scala/org/apache/spark/deploy/SparkHadoopUtil.scala x: 127 commits (all time) y: 284 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala x: 28 commits (all time) y: 161 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala x: 58 commits (all time) y: 102 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/windowExpressions.scala x: 38 commits (all time) y: 415 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java x: 28 commits (all time) y: 496 lines of code core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala x: 36 commits (all time) y: 502 lines of code sql/core/src/main/scala/org/apache/spark/sql/RelationalGroupedDataset.scala x: 35 commits (all time) y: 236 lines of code core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala x: 75 commits (all time) y: 202 lines of code core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala x: 148 commits (all time) y: 309 lines of code core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala x: 98 commits (all time) y: 247 lines of code core/src/main/scala/org/apache/spark/rdd/ReliableCheckpointRDD.scala x: 13 commits (all time) y: 206 lines of code core/src/main/scala/org/apache/spark/shuffle/BlockStoreShuffleReader.scala x: 21 commits (all time) y: 74 lines of code mllib/src/main/scala/org/apache/spark/ml/source/libsvm/LibSVMRelation.scala x: 37 commits (all time) y: 136 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala x: 63 commits (all time) y: 26 lines of code core/src/main/scala/org/apache/spark/util/collection/OpenHashSet.scala x: 58 commits (all time) y: 181 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala x: 126 commits (all time) y: 333 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRelation.scala x: 24 commits (all time) y: 193 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcRelationProvider.scala x: 15 commits (all time) y: 58 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala x: 32 commits (all time) y: 275 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/generators.scala x: 54 commits (all time) y: 274 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/ExecutorAllocationManager.scala x: 4 commits (all time) y: 154 lines of code sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala x: 25 commits (all time) y: 237 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/Column.java x: 2 commits (all time) y: 376 lines of code scalastyle-config.xml x: 49 commits (all time) y: 235 lines of code core/src/main/scala/org/apache/spark/rdd/ShuffledRDD.scala x: 57 commits (all time) y: 65 lines of code core/src/main/scala/org/apache/spark/scheduler/ActiveJob.scala x: 14 commits (all time) y: 20 lines of code core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala x: 72 commits (all time) y: 45 lines of code core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala x: 106 commits (all time) y: 66 lines of code core/src/main/scala/org/apache/spark/scheduler/Stage.scala x: 59 commits (all time) y: 41 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskDescription.scala x: 18 commits (all time) y: 84 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala x: 62 commits (all time) y: 299 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala x: 57 commits (all time) y: 638 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/OneVsRest.scala x: 33 commits (all time) y: 317 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/KMeans.scala x: 50 commits (all time) y: 236 lines of code mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala x: 78 commits (all time) y: 989 lines of code mllib/src/main/scala/org/apache/spark/ml/tuning/CrossValidator.scala x: 50 commits (all time) y: 269 lines of code mllib/src/main/scala/org/apache/spark/ml/tuning/TrainValidationSplit.scala x: 25 commits (all time) y: 259 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/HashingTF.scala x: 28 commits (all time) y: 60 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Interaction.scala x: 16 commits (all time) y: 201 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/OneHotEncoder.scala x: 28 commits (all time) y: 79 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/RFormula.scala x: 44 commits (all time) y: 373 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Tokenizer.scala x: 26 commits (all time) y: 78 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/VectorAssembler.scala x: 34 commits (all time) y: 219 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SortOrder.scala x: 36 commits (all time) y: 165 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala x: 99 commits (all time) y: 513 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala x: 31 commits (all time) y: 265 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala x: 81 commits (all time) y: 1270 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/AbstractDataType.scala x: 23 commits (all time) y: 67 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/ArrayType.scala x: 20 commits (all time) y: 79 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnType.scala x: 10 commits (all time) y: 497 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala x: 94 commits (all time) y: 923 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala x: 75 commits (all time) y: 274 lines of code mllib/src/main/scala/org/apache/spark/mllib/recommendation/MatrixFactorizationModel.scala x: 55 commits (all time) y: 227 lines of code core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala x: 114 commits (all time) y: 281 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormat.scala x: 12 commits (all time) y: 86 lines of code core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala x: 45 commits (all time) y: 51 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CatalystTypeConverters.scala x: 35 commits (all time) y: 321 lines of code python/pyspark/mllib/linalg/distributed.py x: 12 commits (all time) y: 321 lines of code python/pyspark/ml/util.py x: 28 commits (all time) y: 281 lines of code licenses-binary/LICENSE-javassist.html x: 1 commits (all time) y: 369 lines of code licenses-binary/LICENSE-jtransforms.html x: 1 commits (all time) y: 379 lines of code python/pyspark/ml/param/shared.py x: 38 commits (all time) y: 290 lines of code python/pyspark/mllib/classification.py x: 61 commits (all time) y: 261 lines of code core/src/main/scala/org/apache/spark/ui/jobs/AllJobsPage.scala x: 43 commits (all time) y: 553 lines of code streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala x: 23 commits (all time) y: 350 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala x: 7 commits (all time) y: 160 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/CatalogImpl.scala x: 42 commits (all time) y: 258 lines of code core/src/main/scala/org/apache/spark/SecurityManager.scala x: 38 commits (all time) y: 200 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoDataSourceCommand.scala x: 10 commits (all time) y: 20 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala x: 42 commits (all time) y: 204 lines of code core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala x: 47 commits (all time) y: 180 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java x: 34 commits (all time) y: 423 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/MasterWebUI.scala x: 62 commits (all time) y: 39 lines of code core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerWebUI.scala x: 78 commits (all time) y: 34 lines of code core/src/main/scala/org/apache/spark/ui/SparkUI.scala x: 86 commits (all time) y: 124 lines of code core/src/main/scala/org/apache/spark/ui/WebUI.scala x: 35 commits (all time) y: 102 lines of code launcher/src/main/java/org/apache/spark/launcher/SparkSubmitCommandBuilder.java x: 26 commits (all time) y: 348 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TypedAggregateExpression.scala x: 23 commits (all time) y: 220 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileSourceStrategy.scala x: 40 commits (all time) y: 141 lines of code common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java x: 14 commits (all time) y: 289 lines of code python/pyspark/shuffle.py x: 18 commits (all time) y: 423 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java x: 22 commits (all time) y: 236 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnarBatchReader.java x: 6 commits (all time) y: 451 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/MonotonicallyIncreasingID.scala x: 20 commits (all time) y: 42 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateSafeProjection.scala x: 34 commits (all time) y: 155 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/mathExpressions.scala x: 33 commits (all time) y: 960 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala x: 31 commits (all time) y: 836 lines of code core/src/main/scala/org/apache/spark/TaskEndReason.scala x: 67 commits (all time) y: 130 lines of code core/src/main/scala/org/apache/spark/util/JsonProtocol.scala x: 94 commits (all time) y: 883 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala x: 57 commits (all time) y: 122 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala x: 31 commits (all time) y: 273 lines of code core/src/main/scala/org/apache/spark/ui/exec/ExecutorsTab.scala x: 30 commits (all time) y: 32 lines of code core/src/main/scala/org/apache/spark/ui/jobs/AllStagesPage.scala x: 21 commits (all time) y: 120 lines of code core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala x: 34 commits (all time) y: 41 lines of code core/src/main/scala/org/apache/spark/ui/jobs/PoolTable.scala x: 47 commits (all time) y: 39 lines of code core/src/main/scala/org/apache/spark/ui/storage/RDDPage.scala x: 45 commits (all time) y: 256 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveUtils.scala x: 34 commits (all time) y: 348 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java x: 10 commits (all time) y: 521 lines of code python/pyspark/cloudpickle.py x: 25 commits (all time) y: 647 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala x: 50 commits (all time) y: 561 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala x: 35 commits (all time) y: 349 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java x: 12 commits (all time) y: 160 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala x: 23 commits (all time) y: 15 lines of code core/src/main/scala/org/apache/spark/api/r/RRunner.scala x: 10 commits (all time) y: 308 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LocalRelation.scala x: 24 commits (all time) y: 53 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/EstimationUtils.scala x: 15 commits (all time) y: 250 lines of code mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala x: 22 commits (all time) y: 413 lines of code mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala x: 138 commits (all time) y: 1114 lines of code python/pyspark/mllib/tests.py x: 77 commits (all time) y: 1373 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalogWithListener.scala x: 1 commits (all time) y: 221 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala x: 58 commits (all time) y: 490 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/HiveAuthFactory.java x: 3 commits (all time) y: 343 lines of code core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala x: 77 commits (all time) y: 136 lines of code mllib/src/main/scala/org/apache/spark/ml/optim/WeightedLeastSquares.scala x: 19 commits (all time) y: 352 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Bucketizer.scala x: 31 commits (all time) y: 184 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/IDF.scala x: 24 commits (all time) y: 118 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/QuantileDiscretizer.scala x: 32 commits (all time) y: 141 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/StringIndexer.scala x: 48 commits (all time) y: 279 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala x: 31 commits (all time) y: 359 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Word2Vec.scala x: 42 commits (all time) y: 243 lines of code mllib/src/main/scala/org/apache/spark/ml/param/params.scala x: 56 commits (all time) y: 609 lines of code mllib/src/main/scala/org/apache/spark/ml/util/ReadWrite.scala x: 36 commits (all time) y: 361 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateMutableProjection.scala x: 49 commits (all time) y: 98 lines of code core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala x: 127 commits (all time) y: 227 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSink.scala x: 25 commits (all time) y: 94 lines of code mllib/src/main/scala/org/apache/spark/ml/Predictor.scala x: 23 commits (all time) y: 98 lines of code python/pyspark/conf.py x: 31 commits (all time) y: 88 lines of code python/pyspark/ml/evaluation.py x: 32 commits (all time) y: 182 lines of code python/pyspark/mllib/regression.py x: 56 commits (all time) y: 247 lines of code python/pyspark/mllib/tree.py x: 31 commits (all time) y: 149 lines of code python/pyspark/mllib/util.py x: 28 commits (all time) y: 167 lines of code core/src/main/scala/org/apache/spark/status/api/v1/api.scala x: 34 commits (all time) y: 289 lines of code core/src/main/scala/org/apache/spark/internal/config/ConfigBuilder.scala x: 11 commits (all time) y: 159 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerId.scala x: 24 commits (all time) y: 81 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/JoinEstimation.scala x: 9 commits (all time) y: 240 lines of code core/src/main/scala/org/apache/spark/status/storeTypes.scala x: 10 commits (all time) y: 363 lines of code core/src/main/scala/org/apache/spark/storage/StorageUtils.scala x: 44 commits (all time) y: 115 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/compressionSchemes.scala x: 5 commits (all time) y: 669 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java x: 32 commits (all time) y: 211 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala x: 47 commits (all time) y: 454 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/execution/UnsafeExternalRowSorter.java x: 34 commits (all time) y: 178 lines of code python/pyspark/ml/param/__init__.py x: 27 commits (all time) y: 279 lines of code sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala x: 22 commits (all time) y: 54 lines of code core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala x: 71 commits (all time) y: 60 lines of code core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala x: 46 commits (all time) y: 126 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBTypeInfo.java x: 3 commits (all time) y: 287 lines of code core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala x: 58 commits (all time) y: 59 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/objects.scala x: 25 commits (all time) y: 340 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParserUtils.scala x: 15 commits (all time) y: 141 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/commands.scala x: 44 commits (all time) y: 102 lines of code launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java x: 18 commits (all time) y: 251 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/Matrices.scala x: 14 commits (all time) y: 765 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetRowConverter.scala x: 8 commits (all time) y: 417 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/RawInputDStream.scala x: 35 commits (all time) y: 69 lines of code core/src/main/scala/org/apache/spark/SparkEnv.scala x: 185 commits (all time) y: 324 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/LogicalRelation.scala x: 24 commits (all time) y: 38 lines of code core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedClusterMessage.scala x: 42 commits (all time) y: 64 lines of code streaming/src/main/scala/org/apache/spark/status/api/v1/streaming/ApiStreamingRootResource.scala x: 2 commits (all time) y: 158 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLListener.scala x: 27 commits (all time) y: 44 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/impl/DecisionTreeMetadata.scala x: 7 commits (all time) y: 140 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/RandomForest.scala x: 31 commits (all time) y: 125 lines of code core/src/main/scala/org/apache/spark/ui/storage/StorageTab.scala x: 21 commits (all time) y: 8 lines of code python/pyspark/sql/__init__.py x: 19 commits (all time) y: 16 lines of code core/src/main/scala/org/apache/spark/io/CompressionCodec.scala x: 55 commits (all time) y: 135 lines of code core/src/main/scala/org/apache/spark/storage/BlockId.scala x: 39 commits (all time) y: 90 lines of code core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala x: 88 commits (all time) y: 119 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala x: 90 commits (all time) y: 152 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala x: 39 commits (all time) y: 64 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/udaf.scala x: 21 commits (all time) y: 327 lines of code core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala x: 51 commits (all time) y: 133 lines of code streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala x: 184 commits (all time) y: 453 lines of code common/sketch/src/main/java/org/apache/spark/util/sketch/CountMinSketchImpl.java x: 10 commits (all time) y: 277 lines of code core/src/main/scala/org/apache/spark/api/python/SerDeUtil.scala x: 18 commits (all time) y: 194 lines of code common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java x: 15 commits (all time) y: 274 lines of code sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala x: 311 commits (all time) y: 364 lines of code core/src/main/scala/org/apache/spark/api/java/JavaDoubleRDD.scala x: 65 commits (all time) y: 82 lines of code core/src/main/scala/org/apache/spark/deploy/worker/WorkerArguments.scala x: 39 commits (all time) y: 127 lines of code core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala x: 101 commits (all time) y: 121 lines of code core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala x: 190 commits (all time) y: 540 lines of code sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala x: 45 commits (all time) y: 235 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala x: 79 commits (all time) y: 202 lines of code core/src/main/scala/org/apache/spark/util/BoundedPriorityQueue.scala x: 20 commits (all time) y: 39 lines of code core/src/main/scala/org/apache/spark/api/r/SerDe.scala x: 20 commits (all time) y: 372 lines of code core/src/main/scala/org/apache/spark/deploy/worker/CommandUtils.scala x: 37 commits (all time) y: 73 lines of code core/src/main/scala/org/apache/spark/package.scala x: 39 commits (all time) y: 50 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala x: 53 commits (all time) y: 52 lines of code graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala x: 47 commits (all time) y: 251 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala x: 63 commits (all time) y: 185 lines of code mllib/src/main/scala/org/apache/spark/mllib/util/MLUtils.scala x: 58 commits (all time) y: 351 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala x: 44 commits (all time) y: 147 lines of code core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala x: 89 commits (all time) y: 158 lines of code core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala x: 61 commits (all time) y: 118 lines of code mllib/src/main/scala/org/apache/spark/mllib/optimization/GradientDescent.scala x: 38 commits (all time) y: 159 lines of code sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala x: 104 commits (all time) y: 85 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnStats.scala x: 4 commits (all time) y: 250 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/BLAS.scala x: 4 commits (all time) y: 569 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/BLAS.scala x: 23 commits (all time) y: 560 lines of code graphx/src/main/scala/org/apache/spark/graphx/Pregel.scala x: 31 commits (all time) y: 53 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveInspectors.scala x: 75 commits (all time) y: 767 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/Type.java x: 2 commits (all time) y: 232 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala x: 41 commits (all time) y: 51 lines of code core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala x: 42 commits (all time) y: 104 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerSource.scala x: 43 commits (all time) y: 33 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala x: 210 commits (all time) y: 20 lines of code mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala x: 86 commits (all time) y: 224 lines of code core/src/main/scala/org/apache/spark/deploy/FaultToleranceTest.scala x: 52 commits (all time) y: 330 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/model/treeEnsembleModels.scala x: 29 commits (all time) y: 269 lines of code core/src/main/scala/org/apache/spark/scheduler/JobWaiter.scala x: 39 commits (all time) y: 32 lines of code mllib/src/main/scala/org/apache/spark/mllib/optimization/Gradient.scala x: 36 commits (all time) y: 144 lines of code core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js x: 20 commits (all time) y: 340 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/loss/LogLoss.scala x: 12 commits (all time) y: 18 lines of code streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala x: 60 commits (all time) y: 148 lines of code core/src/main/scala/org/apache/spark/storage/StorageLevel.scala x: 49 commits (all time) y: 159 lines of code core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala x: 106 commits (all time) y: 407 lines of code core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala x: 117 commits (all time) y: 276 lines of code graphx/src/main/scala/org/apache/spark/graphx/Graph.scala x: 47 commits (all time) y: 95 lines of code mllib/src/main/scala/org/apache/spark/mllib/random/RandomRDDs.scala x: 14 commits (all time) y: 514 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala x: 74 commits (all time) y: 194 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala x: 51 commits (all time) y: 110 lines of code core/src/main/scala/org/apache/spark/ContextCleaner.scala x: 25 commits (all time) y: 167 lines of code core/src/main/scala/org/apache/spark/broadcast/BroadcastFactory.scala x: 32 commits (all time) y: 10 lines of code mllib/src/main/scala/org/apache/spark/mllib/classification/NaiveBayes.scala x: 63 commits (all time) y: 273 lines of code core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala x: 69 commits (all time) y: 56 lines of code core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala x: 51 commits (all time) y: 37 lines of code core/src/main/scala/org/apache/spark/scheduler/InputFormatInfo.scala x: 46 commits (all time) y: 111 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala x: 79 commits (all time) y: 382 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala x: 130 commits (all time) y: 274 lines of code mllib/src/main/scala/org/apache/spark/mllib/classification/LogisticRegression.scala x: 55 commits (all time) y: 253 lines of code sql/core/src/main/scala/org/apache/spark/sql/package.scala x: 20 commits (all time) y: 9 lines of code core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala x: 28 commits (all time) y: 36 lines of code core/src/main/scala/org/apache/spark/deploy/master/ApplicationState.scala x: 35 commits (all time) y: 5 lines of code mllib/src/main/scala/org/apache/spark/mllib/util/SVMDataGenerator.scala x: 23 commits (all time) y: 39 lines of code core/src/main/scala/org/apache/spark/serializer/SerializationDebugger.scala x: 10 commits (all time) y: 262 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/TransformedDStream.scala x: 38 commits (all time) y: 34 lines of code mllib/src/main/scala/org/apache/spark/mllib/regression/Lasso.scala x: 33 commits (all time) y: 107 lines of code mllib/src/main/scala/org/apache/spark/mllib/regression/RidgeRegression.scala x: 37 commits (all time) y: 107 lines of code sql/hive-thriftserver/if/TCLIService.thrift x: 2 commits (all time) y: 518 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java x: 3 commits (all time) y: 563 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ColumnValue.java x: 1 commits (all time) y: 254 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/Operation.java x: 1 commits (all time) y: 227 lines of code core/src/main/scala/org/apache/spark/util/collection/OpenHashMap.scala x: 30 commits (all time) y: 102 lines of code core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperPersistenceEngine.scala x: 56 commits (all time) y: 47 lines of code core/src/main/scala/org/apache/spark/rdd/OrderedRDDFunctions.scala x: 35 commits (all time) y: 35 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/ReducedWindowedDStream.scala x: 34 commits (all time) y: 100 lines of code core/src/main/scala/org/apache/spark/deploy/master/FileSystemPersistenceEngine.scala x: 38 commits (all time) y: 53 lines of code core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperLeaderElectionAgent.scala x: 42 commits (all time) y: 56 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala x: 28 commits (all time) y: 94 lines of code streaming/src/main/scala/org/apache/spark/streaming/util/RawTextSender.scala x: 33 commits (all time) y: 50 lines of code core/src/main/scala/org/apache/spark/rdd/SubtractedRDD.scala x: 48 commits (all time) y: 82 lines of code core/src/main/scala/org/apache/spark/rdd/ZippedPartitionsRDD.scala x: 47 commits (all time) y: 114 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/FlatMapValuedDStream.scala x: 27 commits (all time) y: 15 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/ShuffledDStream.scala x: 40 commits (all time) y: 24 lines of code core/src/main/scala/org/apache/spark/deploy/master/MasterSource.scala x: 31 commits (all time) y: 19 lines of code core/src/main/scala/org/apache/spark/Aggregator.scala x: 75 commits (all time) y: 32 lines of code core/src/main/scala/org/apache/spark/rdd/CartesianRDD.scala x: 34 commits (all time) y: 62 lines of code core/src/main/java/org/apache/spark/util/collection/TimSort.java x: 3 commits (all time) y: 470 lines of code core/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala x: 77 commits (all time) y: 12 lines of code core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerSource.scala x: 46 commits (all time) y: 25 lines of code core/src/main/scala/org/apache/spark/util/MutablePair.scala x: 15 commits (all time) y: 17 lines of code core/src/main/resources/org/apache/spark/ui/static/bootstrap-tooltip.js x: 2 commits (all time) y: 251 lines of code core/src/main/scala/org/apache/spark/util/collection/SizeTrackingAppendOnlyMap.scala x: 17 commits (all time) y: 18 lines of code core/src/main/scala/org/apache/spark/util/collection/PrimitiveKeyOpenHashMap.scala x: 33 commits (all time) y: 73 lines of code core/src/main/scala/org/apache/spark/deploy/master/ApplicationSource.scala x: 29 commits (all time) y: 17 lines of code core/src/main/scala/org/apache/spark/deploy/worker/WorkerSource.scala x: 31 commits (all time) y: 22 lines of code core/src/main/scala/org/apache/spark/util/collection/PrimitiveVector.scala x: 34 commits (all time) y: 51 lines of code
5232.0
lines of code
  min: 1.0
  average: 133.3
  25th percentile: 23.0
  median: 64.0
  75th percentile: 152.0
  max: 5232.0
0 881.0
commits (all time)
min: 1.0 | average: 20.35 | 25th percentile: 2.0 | median: 7.0 | 75th percentile: 22.0 | max: 881.0

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

sql/catalyst/src/main/antlr4/org/apache/spark/sql/catalyst/parser/SqlBase.g4 x: 47 contributors (all time) y: 1060 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/AstBuilder.scala x: 42 contributors (all time) y: 1809 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/TableChange.java x: 2 contributors (all time) y: 363 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala x: 35 contributors (all time) y: 558 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveCatalogs.scala x: 4 contributors (all time) y: 164 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statements.scala x: 4 contributors (all time) y: 212 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogV2Util.scala x: 4 contributors (all time) y: 241 lines of code sql/core/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveSessionCatalog.scala x: 4 contributors (all time) y: 488 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsCatalogOptions.java x: 1 contributors (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala x: 51 contributors (all time) y: 272 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala x: 61 contributors (all time) y: 414 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala x: 58 contributors (all time) y: 1647 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala x: 84 contributors (all time) y: 2003 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/v2Commands.scala x: 3 contributors (all time) y: 298 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Strategy.scala x: 8 contributors (all time) y: 152 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowNamespacesExec.scala x: 2 contributors (all time) y: 32 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/CommandUtils.scala x: 10 contributors (all time) y: 111 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2SessionCatalog.scala x: 3 contributors (all time) y: 242 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala x: 44 contributors (all time) y: 896 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/interface.scala x: 29 contributors (all time) y: 444 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogManager.scala x: 2 contributors (all time) y: 94 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala x: 14 contributors (all time) y: 218 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/IdentifierImpl.java x: 2 contributors (all time) y: 47 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/catalog/CatalogV2Implicits.scala x: 3 contributors (all time) y: 90 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DataWriter.java x: 2 contributors (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/WriteToDataSourceV2Exec.scala x: 4 contributors (all time) y: 345 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ProjectionOverSchema.scala x: 1 contributors (all time) y: 43 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SchemaPruning.scala x: 1 contributors (all time) y: 73 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/PushDownUtils.scala x: 2 contributors (all time) y: 75 lines of code sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriterV2.scala x: 3 contributors (all time) y: 171 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala x: 37 contributors (all time) y: 411 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala x: 37 contributors (all time) y: 543 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParseDriver.scala x: 11 contributors (all time) y: 183 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala x: 38 contributors (all time) y: 593 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/SupportsNamespaces.java x: 3 contributors (all time) y: 36 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala x: 25 contributors (all time) y: 596 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala x: 38 contributors (all time) y: 798 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala x: 24 contributors (all time) y: 610 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/PartitionTransforms.scala x: 1 contributors (all time) y: 25 lines of code sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala x: 72 contributors (all time) y: 1216 lines of code sql/core/src/main/scala/org/apache/spark/sql/functions.scala x: 84 contributors (all time) y: 1008 lines of code core/src/main/scala/org/apache/spark/util/Utils.scala x: 142 contributors (all time) y: 1974 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala x: 31 contributors (all time) y: 197 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala x: 32 contributors (all time) y: 146 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceRDD.scala x: 7 contributors (all time) y: 52 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala x: 72 contributors (all time) y: 1019 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala x: 13 contributors (all time) y: 29 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlanner.scala x: 13 contributors (all time) y: 56 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/package.scala x: 43 contributors (all time) y: 267 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala x: 35 contributors (all time) y: 556 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/rules.scala x: 27 contributors (all time) y: 394 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/BaseSessionStateBuilder.scala x: 10 contributors (all time) y: 152 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala x: 8 contributors (all time) y: 74 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/util/SchemaUtils.scala x: 2 contributors (all time) y: 144 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala x: 31 contributors (all time) y: 278 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/DataType.scala x: 16 contributors (all time) y: 288 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/SessionState.scala x: 17 contributors (all time) y: 94 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/StructType.scala x: 30 contributors (all time) y: 293 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/DelegatingCatalogExtension.java x: 1 contributors (all time) y: 106 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/util/CaseInsensitiveStringMap.java x: 1 contributors (all time) y: 126 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NoSuchItemException.scala x: 5 contributors (all time) y: 38 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/connector/expressions/expressions.scala x: 1 contributors (all time) y: 176 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java x: 1 contributors (all time) y: 350 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java x: 1 contributors (all time) y: 91 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarArray.java x: 1 contributors (all time) y: 147 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatch.java x: 1 contributors (all time) y: 195 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala x: 8 contributors (all time) y: 181 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowWriter.scala x: 5 contributors (all time) y: 260 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/AggregateInPandasExec.scala x: 5 contributors (all time) y: 100 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowEvalPythonExec.scala x: 6 contributors (all time) y: 72 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonRunner.scala x: 7 contributors (all time) y: 128 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInPandasExec.scala x: 5 contributors (all time) y: 78 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasExec.scala x: 4 contributors (all time) y: 113 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/MutableColumnarRow.java x: 3 contributors (all time) y: 216 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/ParserInterface.scala x: 4 contributors (all time) y: 23 lines of code sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala x: 31 contributors (all time) y: 446 lines of code sql/core/src/main/java/org/apache/spark/sql/sources/v2/reader/streaming/ContinuousReader.java x: 4 contributors (all time) y: 15 lines of code sql/core/src/main/java/org/apache/spark/sql/sources/v2/reader/streaming/MicroBatchReader.java x: 3 contributors (all time) y: 12 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala x: 3 contributors (all time) y: 62 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala x: 4 contributors (all time) y: 124 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousRateStreamSource.scala x: 11 contributors (all time) y: 130 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala x: 4 contributors (all time) y: 56 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala x: 22 contributors (all time) y: 206 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ConsoleWriter.scala x: 6 contributors (all time) y: 36 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/ForeachWriterProvider.scala x: 6 contributors (all time) y: 95 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/MicroBatchWriter.scala x: 5 contributors (all time) y: 10 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/socket.scala x: 6 contributors (all time) y: 198 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala x: 13 contributors (all time) y: 379 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala x: 12 contributors (all time) y: 231 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala x: 11 contributors (all time) y: 282 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/DataStreamReader.scala x: 25 contributors (all time) y: 77 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/DataStreamWriter.scala x: 20 contributors (all time) y: 211 lines of code python/pyspark/version.py x: 8 contributors (all time) y: 1 lines of code core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala x: 60 contributors (all time) y: 661 lines of code python/pyspark/sql/dataframe.py x: 72 contributors (all time) y: 849 lines of code python/pyspark/sql/tests.py x: 82 contributors (all time) y: 5232 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala x: 34 contributors (all time) y: 766 lines of code core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala x: 90 contributors (all time) y: 1371 lines of code core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala x: 61 contributors (all time) y: 917 lines of code python/pyspark/sql/functions.py x: 70 contributors (all time) y: 936 lines of code dev/sparktestsupport/modules.py x: 33 contributors (all time) y: 466 lines of code python/pyspark/streaming/tests.py x: 33 contributors (all time) y: 1223 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/HadoopFsRelation.scala x: 10 contributors (all time) y: 48 lines of code core/src/main/resources/org/apache/spark/ui/static/executorspage.js x: 7 contributors (all time) y: 571 lines of code core/src/main/resources/org/apache/spark/ui/static/webui.css x: 26 contributors (all time) y: 215 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousCoalesceRDD.scala x: 4 contributors (all time) y: 86 lines of code core/src/main/scala/org/apache/spark/status/AppStatusStore.scala x: 6 contributors (all time) y: 422 lines of code python/pyspark/tests.py x: 75 contributors (all time) y: 1903 lines of code core/src/main/scala/org/apache/spark/scheduler/Task.scala x: 45 contributors (all time) y: 124 lines of code core/src/main/scala/org/apache/spark/deploy/history/HistoryServer.scala x: 30 contributors (all time) y: 196 lines of code core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala x: 66 contributors (all time) y: 644 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ObjectAggregationIterator.scala x: 5 contributors (all time) y: 219 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/Vectors.scala x: 11 contributors (all time) y: 506 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/Vectors.scala x: 37 contributors (all time) y: 668 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/view.scala x: 8 contributors (all time) y: 29 lines of code core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala x: 58 contributors (all time) y: 405 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeArrayData.java x: 13 contributors (all time) y: 433 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java x: 16 contributors (all time) y: 489 lines of code core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala x: 63 contributors (all time) y: 920 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala x: 12 contributors (all time) y: 185 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilters.scala x: 12 contributors (all time) y: 434 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeUtils.scala x: 31 contributors (all time) y: 773 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/types/CalendarInterval.java x: 7 contributors (all time) y: 274 lines of code core/src/main/scala/org/apache/spark/ui/JettyUtils.scala x: 41 contributors (all time) y: 415 lines of code python/pyspark/ml/linalg/__init__.py x: 9 contributors (all time) y: 638 lines of code common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java x: 8 contributors (all time) y: 208 lines of code core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala x: 50 contributors (all time) y: 848 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala x: 23 contributors (all time) y: 383 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileScanRDD.scala x: 19 contributors (all time) y: 155 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/GaussianMixture.scala x: 18 contributors (all time) y: 426 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/stringExpressions.scala x: 34 contributors (all time) y: 1668 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/Decimal.scala x: 22 contributors (all time) y: 365 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala x: 46 contributors (all time) y: 711 lines of code mllib/src/main/scala/org/apache/spark/mllib/feature/Word2Vec.scala x: 29 contributors (all time) y: 513 lines of code python/pyspark/sql/readwriter.py x: 52 contributors (all time) y: 337 lines of code core/src/main/scala/org/apache/spark/internal/io/SparkHadoopWriter.scala x: 6 contributors (all time) y: 245 lines of code python/pyspark/sql/column.py x: 19 contributors (all time) y: 265 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala x: 32 contributors (all time) y: 447 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFileFormat.scala x: 30 contributors (all time) y: 442 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVDataSource.scala x: 10 contributors (all time) y: 292 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala x: 21 contributors (all time) y: 1015 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/hiveUDFs.scala x: 29 contributors (all time) y: 318 lines of code mllib/src/main/scala/org/apache/spark/ml/evaluation/ClusteringEvaluator.scala x: 6 contributors (all time) y: 263 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterScheduler.scala x: 13 contributors (all time) y: 661 lines of code common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java x: 9 contributors (all time) y: 116 lines of code common/network-common/src/main/java/org/apache/spark/network/util/TransportConf.java x: 13 contributors (all time) y: 134 lines of code core/src/main/scala/org/apache/spark/ui/env/EnvironmentPage.scala x: 7 contributors (all time) y: 85 lines of code mllib/src/main/scala/org/apache/spark/ml/util/Instrumentation.scala x: 10 contributors (all time) y: 137 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/AggregateEstimation.scala x: 7 contributors (all time) y: 39 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/bitwiseExpressions.scala x: 8 contributors (all time) y: 96 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/KVTypeInfo.java x: 2 contributors (all time) y: 115 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java x: 3 contributors (all time) y: 257 lines of code core/src/main/scala/org/apache/spark/status/AppStatusListener.scala x: 13 contributors (all time) y: 865 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala x: 23 contributors (all time) y: 487 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala x: 37 contributors (all time) y: 1166 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/nullExpressions.scala x: 18 contributors (all time) y: 352 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/randomExpressions.scala x: 13 contributors (all time) y: 88 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/regexpExpressions.scala x: 19 contributors (all time) y: 343 lines of code core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala x: 12 contributors (all time) y: 454 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala x: 14 contributors (all time) y: 158 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/LinearRegression.scala x: 43 contributors (all time) y: 548 lines of code dev/create-release/releaseutils.py x: 9 contributors (all time) y: 188 lines of code core/src/main/scala/org/apache/spark/rdd/RDDOperationScope.scala x: 7 contributors (all time) y: 79 lines of code core/src/main/scala/org/apache/spark/status/api/v1/JacksonMessageWriter.scala x: 6 contributors (all time) y: 58 lines of code common/network-common/src/main/java/org/apache/spark/network/crypto/AuthEngine.java x: 2 contributors (all time) y: 216 lines of code common/network-common/src/main/java/org/apache/spark/network/crypto/TransportCipher.java x: 5 contributors (all time) y: 275 lines of code core/src/main/scala/org/apache/spark/security/CryptoStreamUtils.scala x: 4 contributors (all time) y: 180 lines of code python/run-tests.py x: 16 contributors (all time) y: 226 lines of code core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala x: 12 contributors (all time) y: 158 lines of code core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala x: 8 contributors (all time) y: 136 lines of code project/SparkBuild.scala x: 146 contributors (all time) y: 660 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskSchedulerImpl.scala x: 64 contributors (all time) y: 623 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala x: 64 contributors (all time) y: 735 lines of code core/src/main/scala/org/apache/spark/SparkConf.scala x: 57 contributors (all time) y: 477 lines of code core/src/main/scala/org/apache/spark/executor/Executor.scala x: 83 contributors (all time) y: 578 lines of code core/src/main/scala/org/apache/spark/internal/config/package.scala x: 45 contributors (all time) y: 520 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala x: 15 contributors (all time) y: 566 lines of code core/src/main/scala/org/apache/spark/ui/UIUtils.scala x: 48 contributors (all time) y: 447 lines of code core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeExternalSorter.java x: 22 contributors (all time) y: 505 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ExpressionInfo.java x: 4 contributors (all time) y: 82 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/DStreamCheckpointData.scala x: 14 contributors (all time) y: 93 lines of code sql/core/src/main/scala/org/apache/spark/sql/internal/SharedState.scala x: 12 contributors (all time) y: 114 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala x: 15 contributors (all time) y: 609 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala x: 14 contributors (all time) y: 494 lines of code core/src/main/scala/org/apache/spark/deploy/Client.scala x: 24 contributors (all time) y: 173 lines of code core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala x: 72 contributors (all time) y: 451 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala x: 33 contributors (all time) y: 3429 lines of code core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala x: 32 contributors (all time) y: 514 lines of code core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeSorterSpillReader.java x: 13 contributors (all time) y: 113 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeRowJoiner.scala x: 11 contributors (all time) y: 158 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeCreator.scala x: 25 contributors (all time) y: 406 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala x: 59 contributors (all time) y: 228 lines of code common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java x: 6 contributors (all time) y: 135 lines of code common/network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java x: 9 contributors (all time) y: 229 lines of code common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java x: 9 contributors (all time) y: 171 lines of code core/src/main/scala/org/apache/spark/network/netty/NettyBlockRpcServer.scala x: 10 contributors (all time) y: 68 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala x: 44 contributors (all time) y: 965 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SQLAppStatusListener.scala x: 11 contributors (all time) y: 316 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningUtils.scala x: 22 contributors (all time) y: 319 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/orc/OrcDeserializer.scala x: 2 contributors (all time) y: 181 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala x: 16 contributors (all time) y: 173 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala x: 20 contributors (all time) y: 197 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala x: 27 contributors (all time) y: 432 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala x: 26 contributors (all time) y: 742 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceivedBlockTracker.scala x: 13 contributors (all time) y: 178 lines of code sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala x: 22 contributors (all time) y: 248 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/UnivocityParser.scala x: 9 contributors (all time) y: 217 lines of code graphx/src/main/scala/org/apache/spark/graphx/impl/EdgeRDDImpl.scala x: 10 contributors (all time) y: 87 lines of code graphx/src/main/scala/org/apache/spark/graphx/lib/SVDPlusPlus.scala x: 15 contributors (all time) y: 145 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryRelation.scala x: 16 contributors (all time) y: 142 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/RowMatrix.scala x: 21 contributors (all time) y: 434 lines of code mllib/src/main/scala/org/apache/spark/mllib/evaluation/RankingMetrics.scala x: 11 contributors (all time) y: 94 lines of code python/pyspark/mllib/linalg/__init__.py x: 19 contributors (all time) y: 742 lines of code repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala x: 23 contributors (all time) y: 163 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLog.scala x: 14 contributors (all time) y: 201 lines of code python/pyspark/context.py x: 84 contributors (all time) y: 448 lines of code core/src/main/scala/org/apache/spark/scheduler/cluster/StandaloneSchedulerBackend.scala x: 23 contributors (all time) y: 171 lines of code sql/core/src/main/scala/org/apache/spark/sql/jdbc/PostgresDialect.scala x: 12 contributors (all time) y: 77 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala x: 26 contributors (all time) y: 330 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning/patterns.scala x: 29 contributors (all time) y: 164 lines of code python/pyspark/ml/image.py x: 6 contributors (all time) y: 118 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala x: 39 contributors (all time) y: 599 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala x: 9 contributors (all time) y: 358 lines of code core/src/main/scala/org/apache/spark/api/python/PythonGatewayServer.scala x: 5 contributors (all time) y: 52 lines of code python/pyspark/accumulators.py x: 34 contributors (all time) y: 117 lines of code python/pyspark/java_gateway.py x: 39 contributors (all time) y: 121 lines of code core/src/main/scala/org/apache/spark/ui/jobs/JobPage.scala x: 20 contributors (all time) y: 367 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Canonicalize.scala x: 8 contributors (all time) y: 44 lines of code sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala x: 22 contributors (all time) y: 172 lines of code core/src/main/java/org/apache/spark/util/collection/unsafe/sort/PrefixComparators.java x: 8 contributors (all time) y: 116 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/CostBasedJoinReorder.scala x: 5 contributors (all time) y: 247 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala x: 12 contributors (all time) y: 403 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala x: 12 contributors (all time) y: 200 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala x: 22 contributors (all time) y: 591 lines of code python/pyspark/ml/feature.py x: 51 contributors (all time) y: 1370 lines of code core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java x: 14 contributors (all time) y: 568 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/higherOrderFunctions.scala x: 7 contributors (all time) y: 366 lines of code python/pyspark/serializers.py x: 45 contributors (all time) y: 444 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala x: 12 contributors (all time) y: 249 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/FilterEstimation.scala x: 10 contributors (all time) y: 517 lines of code python/pyspark/worker.py x: 48 contributors (all time) y: 284 lines of code python/pyspark/broadcast.py x: 29 contributors (all time) y: 110 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/PartitioningAwareFileIndex.scala x: 12 contributors (all time) y: 130 lines of code core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala x: 31 contributors (all time) y: 510 lines of code core/src/main/scala/org/apache/spark/status/LiveEntity.scala x: 6 contributors (all time) y: 595 lines of code core/src/main/scala/org/apache/spark/ui/jobs/StageTable.scala x: 50 contributors (all time) y: 416 lines of code core/src/main/scala/org/apache/spark/ui/storage/StoragePage.scala x: 14 contributors (all time) y: 184 lines of code core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionClient.scala x: 11 contributors (all time) y: 331 lines of code project/MimaBuild.scala x: 17 contributors (all time) y: 58 lines of code project/MimaExcludes.scala x: 107 contributors (all time) y: 993 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala x: 26 contributors (all time) y: 230 lines of code core/src/main/scala/org/apache/spark/storage/DiskStore.scala x: 39 contributors (all time) y: 249 lines of code core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala x: 15 contributors (all time) y: 579 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/Matrices.scala x: 30 contributors (all time) y: 774 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/client/IsolatedClientLoader.scala x: 22 contributors (all time) y: 199 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeansModel.scala x: 22 contributors (all time) y: 146 lines of code core/src/main/scala/org/apache/spark/scheduler/BlacklistTracker.scala x: 6 contributors (all time) y: 282 lines of code mllib/src/main/scala/org/apache/spark/ml/r/AFTSurvivalRegressionWrapper.scala x: 7 contributors (all time) y: 103 lines of code mllib/src/main/scala/org/apache/spark/ml/stat/Summarizer.scala x: 4 contributors (all time) y: 416 lines of code core/src/main/scala/org/apache/spark/storage/BlockManager.scala x: 75 contributors (all time) y: 1172 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/jsonExpressions.scala x: 21 contributors (all time) y: 559 lines of code sql/core/src/main/scala/org/apache/spark/sql/expressions/Window.scala x: 9 contributors (all time) y: 41 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala x: 64 contributors (all time) y: 503 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala x: 24 contributors (all time) y: 644 lines of code core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala x: 30 contributors (all time) y: 233 lines of code dev/run-tests.py x: 31 contributors (all time) y: 344 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/BisectingKMeans.scala x: 17 contributors (all time) y: 174 lines of code python/pyspark/ml/clustering.py x: 24 contributors (all time) y: 516 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala x: 21 contributors (all time) y: 966 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala x: 2 contributors (all time) y: 201 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/JavaTypeInference.scala x: 17 contributors (all time) y: 353 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScanExec.scala x: 18 contributors (all time) y: 143 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala x: 19 contributors (all time) y: 456 lines of code sql/core/src/main/scala/org/apache/spark/sql/Column.scala x: 43 contributors (all time) y: 239 lines of code core/src/main/scala/org/apache/spark/scheduler/ReplayListenerBus.scala x: 14 contributors (all time) y: 80 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala x: 32 contributors (all time) y: 248 lines of code core/src/main/scala/org/apache/spark/storage/RDDInfo.scala x: 12 contributors (all time) y: 48 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeExpressions.scala x: 28 contributors (all time) y: 1190 lines of code python/pyspark/sql/context.py x: 32 contributors (all time) y: 188 lines of code python/pyspark/sql/session.py x: 28 contributors (all time) y: 423 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/DecimalPrecision.scala x: 8 contributors (all time) y: 188 lines of code core/src/main/scala/org/apache/spark/scheduler/MapStatus.scala x: 16 contributors (all time) y: 151 lines of code core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala x: 27 contributors (all time) y: 387 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala x: 23 contributors (all time) y: 131 lines of code core/src/main/scala/org/apache/spark/api/r/RRDD.scala x: 15 contributors (all time) y: 126 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/LDA.scala x: 27 contributors (all time) y: 471 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/DecisionTreeClassifier.scala x: 21 contributors (all time) y: 182 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/GBTClassifier.scala x: 26 contributors (all time) y: 263 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/RandomForestClassifier.scala x: 25 contributors (all time) y: 216 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/DecisionTreeRegressor.scala x: 19 contributors (all time) y: 179 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/GBTRegressor.scala x: 21 contributors (all time) y: 211 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/Node.scala x: 10 contributors (all time) y: 212 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/impl/RandomForest.scala x: 23 contributors (all time) y: 687 lines of code mllib/src/main/scala/org/apache/spark/ml/tree/treeModels.scala x: 10 contributors (all time) y: 247 lines of code core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java x: 17 contributors (all time) y: 382 lines of code core/src/main/scala/org/apache/spark/MapOutputTracker.scala x: 48 contributors (all time) y: 535 lines of code core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala x: 17 contributors (all time) y: 73 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala x: 62 contributors (all time) y: 420 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala x: 15 contributors (all time) y: 111 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/RowQueue.scala x: 4 contributors (all time) y: 200 lines of code dev/merge_spark_pr.py x: 24 contributors (all time) y: 346 lines of code python/pyspark/ml/classification.py x: 37 contributors (all time) y: 860 lines of code python/pyspark/ml/regression.py x: 30 contributors (all time) y: 732 lines of code python/pyspark/mllib/clustering.py x: 34 contributors (all time) y: 327 lines of code python/pyspark/mllib/feature.py x: 21 contributors (all time) y: 262 lines of code python/pyspark/rdd.py x: 102 contributors (all time) y: 971 lines of code python/pyspark/shell.py x: 50 contributors (all time) y: 36 lines of code python/pyspark/sql/streaming.py x: 28 contributors (all time) y: 381 lines of code python/pyspark/sql/types.py x: 36 contributors (all time) y: 1015 lines of code python/pyspark/storagelevel.py x: 17 contributors (all time) y: 30 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala x: 10 contributors (all time) y: 35 lines of code sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala x: 12 contributors (all time) y: 224 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVOptions.scala x: 18 contributors (all time) y: 149 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala x: 42 contributors (all time) y: 156 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.scala x: 31 contributors (all time) y: 85 lines of code common/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java x: 15 contributors (all time) y: 951 lines of code core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorter.java x: 18 contributors (all time) y: 255 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/XXH64.java x: 5 contributors (all time) y: 137 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/codegen/UTF8StringBuilder.java x: 3 contributors (all time) y: 45 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/hash.scala x: 12 contributors (all time) y: 722 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OffHeapColumnVector.java x: 15 contributors (all time) y: 414 lines of code mllib/src/main/scala/org/apache/spark/ml/image/ImageSchema.scala x: 3 contributors (all time) y: 121 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonGenerator.scala x: 7 contributors (all time) y: 167 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/createDataSourceTables.scala x: 17 contributors (all time) y: 136 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InsertIntoHadoopFsRelationCommand.scala x: 17 contributors (all time) y: 186 lines of code core/src/main/scala/org/apache/spark/Partitioner.scala x: 40 contributors (all time) y: 223 lines of code core/src/main/scala/org/apache/spark/rdd/MapPartitionsRDD.scala x: 21 contributors (all time) y: 28 lines of code core/src/main/scala/org/apache/spark/rdd/RDD.scala x: 100 contributors (all time) y: 981 lines of code python/pyspark/ml/tests.py x: 43 contributors (all time) y: 2180 lines of code core/src/main/scala/org/apache/spark/executor/ExecutorSource.scala x: 22 contributors (all time) y: 97 lines of code core/src/main/scala/org/apache/spark/deploy/ExternalShuffleService.scala x: 16 contributors (all time) y: 90 lines of code core/src/main/scala/org/apache/spark/deploy/LocalSparkCluster.scala x: 34 contributors (all time) y: 46 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala x: 9 contributors (all time) y: 72 lines of code core/src/main/scala/org/apache/spark/TaskContext.scala x: 32 contributors (all time) y: 64 lines of code mllib/src/main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala x: 19 contributors (all time) y: 197 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala x: 17 contributors (all time) y: 296 lines of code core/src/main/scala/org/apache/spark/rdd/UnionRDD.scala x: 21 contributors (all time) y: 71 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ui/SparkPlanGraph.scala x: 9 contributors (all time) y: 138 lines of code python/pyspark/__init__.py x: 40 contributors (all time) y: 48 lines of code repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala x: 29 contributors (all time) y: 220 lines of code core/src/main/scala/org/apache/spark/input/PortableDataStream.scala x: 11 contributors (all time) y: 118 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala x: 28 contributors (all time) y: 159 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/ExtractPythonUDFs.scala x: 9 contributors (all time) y: 154 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/types/DecimalType.scala x: 14 contributors (all time) y: 132 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFileOperator.scala x: 11 contributors (all time) y: 73 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala x: 30 contributors (all time) y: 141 lines of code core/src/main/scala/org/apache/spark/TestUtils.scala x: 15 contributors (all time) y: 208 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala x: 16 contributors (all time) y: 429 lines of code python/pyspark/streaming/dstream.py x: 12 contributors (all time) y: 279 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala x: 28 contributors (all time) y: 528 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Projection.scala x: 20 contributors (all time) y: 114 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala x: 5 contributors (all time) y: 367 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala x: 14 contributors (all time) y: 506 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala x: 9 contributors (all time) y: 255 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala x: 6 contributors (all time) y: 297 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala x: 16 contributors (all time) y: 109 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/JacksonParser.scala x: 11 contributors (all time) y: 258 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/MultilayerPerceptronClassifier.scala x: 21 contributors (all time) y: 189 lines of code mllib/src/main/scala/org/apache/spark/ml/classification/LogisticRegression.scala x: 41 contributors (all time) y: 968 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/AFTSurvivalRegression.scala x: 23 contributors (all time) y: 344 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala x: 39 contributors (all time) y: 343 lines of code core/src/main/scala/org/apache/spark/SparkContext.scala x: 162 contributors (all time) y: 1532 lines of code core/src/main/scala/org/apache/spark/scheduler/SchedulerBackend.scala x: 18 contributors (all time) y: 19 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosFineGrainedSchedulerBackend.scala x: 9 contributors (all time) y: 330 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/BoundAttribute.scala x: 16 contributors (all time) y: 62 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/javaCode.scala x: 3 contributors (all time) y: 190 lines of code sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala x: 38 contributors (all time) y: 318 lines of code core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala x: 50 contributors (all time) y: 520 lines of code core/src/main/scala/org/apache/spark/deploy/master/Master.scala x: 73 contributors (all time) y: 801 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/CountVectorizer.scala x: 19 contributors (all time) y: 229 lines of code core/src/main/scala/org/apache/spark/util/collection/ExternalAppendOnlyMap.scala x: 32 contributors (all time) y: 398 lines of code graphx/src/main/scala/org/apache/spark/graphx/util/BytecodeUtils.scala x: 13 contributors (all time) y: 76 lines of code python/pyspark/ml/tuning.py x: 26 contributors (all time) y: 386 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetSchemaConverter.scala x: 9 contributors (all time) y: 308 lines of code common/network-common/src/main/java/org/apache/spark/network/sasl/SaslEncryption.java x: 7 contributors (all time) y: 212 lines of code core/src/main/scala/org/apache/spark/util/ListenerBus.scala x: 11 contributors (all time) y: 59 lines of code python/pyspark/mllib/stat/_statistics.py x: 9 contributors (all time) y: 84 lines of code resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosSchedulerUtils.scala x: 9 contributors (all time) y: 390 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamingSymmetricHashJoinHelper.scala x: 5 contributors (all time) y: 153 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java x: 6 contributors (all time) y: 706 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/MinHashLSH.scala x: 5 contributors (all time) y: 122 lines of code mllib/src/main/scala/org/apache/spark/ml/regression/GeneralizedLinearRegression.scala x: 22 contributors (all time) y: 916 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/metric/SQLMetrics.scala x: 19 contributors (all time) y: 109 lines of code core/src/main/scala/org/apache/spark/deploy/SparkHadoopUtil.scala x: 52 contributors (all time) y: 284 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala x: 23 contributors (all time) y: 196 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala x: 29 contributors (all time) y: 102 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/First.scala x: 9 contributors (all time) y: 60 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/windowExpressions.scala x: 19 contributors (all time) y: 415 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala x: 24 contributors (all time) y: 152 lines of code common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java x: 6 contributors (all time) y: 212 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java x: 18 contributors (all time) y: 496 lines of code core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala x: 15 contributors (all time) y: 502 lines of code python/pyspark/sql/group.py x: 14 contributors (all time) y: 110 lines of code sql/core/src/main/scala/org/apache/spark/sql/RelationalGroupedDataset.scala x: 21 contributors (all time) y: 236 lines of code core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala x: 57 contributors (all time) y: 309 lines of code core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala x: 25 contributors (all time) y: 120 lines of code core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala x: 47 contributors (all time) y: 247 lines of code mllib/src/main/scala/org/apache/spark/ml/source/libsvm/LibSVMRelation.scala x: 21 contributors (all time) y: 136 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TungstenAggregationIterator.scala x: 18 contributors (all time) y: 227 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryTableScanExec.scala x: 19 contributors (all time) y: 221 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala x: 28 contributors (all time) y: 201 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFileFormat.scala x: 16 contributors (all time) y: 251 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskScheduler.scala x: 31 contributors (all time) y: 26 lines of code core/src/main/scala/org/apache/spark/util/collection/OpenHashSet.scala x: 26 contributors (all time) y: 181 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRelation.scala x: 16 contributors (all time) y: 193 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/generators.scala x: 24 contributors (all time) y: 274 lines of code sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala x: 14 contributors (all time) y: 237 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/Column.java x: 2 contributors (all time) y: 376 lines of code scalastyle-config.xml x: 16 contributors (all time) y: 235 lines of code core/src/main/scala/org/apache/spark/rdd/ShuffledRDD.scala x: 29 contributors (all time) y: 65 lines of code core/src/main/scala/org/apache/spark/scheduler/ActiveJob.scala x: 11 contributors (all time) y: 20 lines of code core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala x: 37 contributors (all time) y: 45 lines of code core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala x: 42 contributors (all time) y: 66 lines of code core/src/main/scala/org/apache/spark/scheduler/Stage.scala x: 27 contributors (all time) y: 41 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskDescription.scala x: 12 contributors (all time) y: 84 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala x: 38 contributors (all time) y: 299 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala x: 30 contributors (all time) y: 638 lines of code sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala x: 20 contributors (all time) y: 80 lines of code mllib/src/main/scala/org/apache/spark/ml/clustering/KMeans.scala x: 27 contributors (all time) y: 236 lines of code mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala x: 34 contributors (all time) y: 989 lines of code mllib/src/main/scala/org/apache/spark/ml/tuning/CrossValidator.scala x: 25 contributors (all time) y: 269 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Interaction.scala x: 11 contributors (all time) y: 201 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/OneHotEncoder.scala x: 18 contributors (all time) y: 79 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/RFormula.scala x: 21 contributors (all time) y: 373 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/VectorAssembler.scala x: 18 contributors (all time) y: 219 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SortOrder.scala x: 18 contributors (all time) y: 165 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala x: 34 contributors (all time) y: 513 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala x: 13 contributors (all time) y: 265 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala x: 23 contributors (all time) y: 1270 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnType.scala x: 8 contributors (all time) y: 497 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala x: 32 contributors (all time) y: 923 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FlatMapGroupsWithStateExec.scala x: 2 contributors (all time) y: 157 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreConf.scala x: 6 contributors (all time) y: 16 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/literals.scala x: 26 contributors (all time) y: 274 lines of code mllib/src/main/scala/org/apache/spark/mllib/recommendation/MatrixFactorizationModel.scala x: 31 contributors (all time) y: 227 lines of code core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala x: 43 contributors (all time) y: 281 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/json/JsonFileFormat.scala x: 13 contributors (all time) y: 148 lines of code core/src/main/scala/org/apache/spark/rdd/BlockRDD.scala x: 26 contributors (all time) y: 51 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/CatalystTypeConverters.scala x: 16 contributors (all time) y: 321 lines of code python/pyspark/mllib/linalg/distributed.py x: 8 contributors (all time) y: 321 lines of code licenses-binary/LICENSE-javassist.html x: 1 contributors (all time) y: 369 lines of code licenses-binary/LICENSE-jtransforms.html x: 1 contributors (all time) y: 379 lines of code python/pyspark/ml/param/shared.py x: 16 contributors (all time) y: 290 lines of code python/pyspark/mllib/classification.py x: 30 contributors (all time) y: 261 lines of code core/src/main/scala/org/apache/spark/ui/jobs/AllJobsPage.scala x: 29 contributors (all time) y: 553 lines of code streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala x: 15 contributors (all time) y: 350 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala x: 6 contributors (all time) y: 160 lines of code sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/xml/UDFXPathUtil.java x: 3 contributors (all time) y: 163 lines of code core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala x: 27 contributors (all time) y: 81 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java x: 14 contributors (all time) y: 423 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/MasterWebUI.scala x: 34 contributors (all time) y: 39 lines of code core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerWebUI.scala x: 33 contributors (all time) y: 34 lines of code core/src/main/scala/org/apache/spark/ui/SparkUI.scala x: 44 contributors (all time) y: 124 lines of code core/src/main/scala/org/apache/spark/ui/WebUI.scala x: 21 contributors (all time) y: 102 lines of code launcher/src/main/java/org/apache/spark/launcher/SparkSubmitCommandBuilder.java x: 14 contributors (all time) y: 348 lines of code core/src/main/scala/org/apache/spark/util/AccumulatorV2.scala x: 14 contributors (all time) y: 253 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/TypedAggregateExpression.scala x: 11 contributors (all time) y: 220 lines of code repl/src/main/scala/org/apache/spark/repl/Main.scala x: 15 contributors (all time) y: 80 lines of code common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java x: 12 contributors (all time) y: 289 lines of code python/pyspark/shuffle.py x: 8 contributors (all time) y: 423 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java x: 15 contributors (all time) y: 236 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnarBatchReader.java x: 3 contributors (all time) y: 451 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/MonotonicallyIncreasingID.scala x: 16 contributors (all time) y: 42 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodegenFallback.scala x: 11 contributors (all time) y: 41 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateSafeProjection.scala x: 20 contributors (all time) y: 155 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/mathExpressions.scala x: 20 contributors (all time) y: 960 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala x: 19 contributors (all time) y: 836 lines of code core/src/main/scala/org/apache/spark/TaskEndReason.scala x: 32 contributors (all time) y: 130 lines of code core/src/main/scala/org/apache/spark/util/JsonProtocol.scala x: 39 contributors (all time) y: 883 lines of code core/src/main/scala/org/apache/spark/deploy/history/HistoryPage.scala x: 23 contributors (all time) y: 72 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/ApplicationPage.scala x: 35 contributors (all time) y: 122 lines of code core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala x: 21 contributors (all time) y: 273 lines of code core/src/main/scala/org/apache/spark/deploy/worker/ui/WorkerPage.scala x: 10 contributors (all time) y: 167 lines of code core/src/main/scala/org/apache/spark/ui/exec/ExecutorsTab.scala x: 19 contributors (all time) y: 32 lines of code core/src/main/scala/org/apache/spark/ui/jobs/PoolPage.scala x: 22 contributors (all time) y: 41 lines of code core/src/main/scala/org/apache/spark/ui/storage/RDDPage.scala x: 28 contributors (all time) y: 256 lines of code streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala x: 17 contributors (all time) y: 434 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveUtils.scala x: 17 contributors (all time) y: 348 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java x: 7 contributors (all time) y: 521 lines of code python/pyspark/cloudpickle.py x: 17 contributors (all time) y: 647 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAModel.scala x: 20 contributors (all time) y: 561 lines of code mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala x: 18 contributors (all time) y: 349 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/Encoder.scala x: 10 contributors (all time) y: 15 lines of code core/src/main/scala/org/apache/spark/api/r/RRunner.scala x: 8 contributors (all time) y: 308 lines of code python/pyspark/daemon.py x: 22 contributors (all time) y: 136 lines of code mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala x: 12 contributors (all time) y: 413 lines of code mllib/src/main/scala/org/apache/spark/mllib/api/python/PythonMLLibAPI.scala x: 47 contributors (all time) y: 1114 lines of code python/pyspark/mllib/tests.py x: 38 contributors (all time) y: 1373 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalogWithListener.scala x: 1 contributors (all time) y: 221 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala x: 22 contributors (all time) y: 490 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/HiveAuthFactory.java x: 3 contributors (all time) y: 343 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java x: 9 contributors (all time) y: 420 lines of code core/src/main/scala/org/apache/spark/deploy/worker/ExecutorRunner.scala x: 41 contributors (all time) y: 136 lines of code mllib/src/main/scala/org/apache/spark/ml/optim/WeightedLeastSquares.scala x: 14 contributors (all time) y: 352 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/StringIndexer.scala x: 22 contributors (all time) y: 279 lines of code mllib/src/main/scala/org/apache/spark/ml/feature/Word2Vec.scala x: 24 contributors (all time) y: 243 lines of code mllib/src/main/scala/org/apache/spark/ml/param/params.scala x: 21 contributors (all time) y: 609 lines of code mllib/src/main/scala/org/apache/spark/ml/util/ReadWrite.scala x: 16 contributors (all time) y: 361 lines of code sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateMutableProjection.scala x: 18 contributors (all time) y: 98 lines of code python/pyspark/ml/wrapper.py x: 17 contributors (all time) y: 164 lines of code core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala x: 56 contributors (all time) y: 227 lines of code resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnSchedulerBackend.scala x: 5 contributors (all time) y: 197 lines of code python/pyspark/ml/evaluation.py x: 20 contributors (all time) y: 182 lines of code python/pyspark/mllib/recommendation.py x: 24 contributors (all time) y: 96 lines of code python/pyspark/mllib/regression.py x: 29 contributors (all time) y: 247 lines of code python/pyspark/mllib/util.py x: 15 contributors (all time) y: 167 lines of code core/src/main/scala/org/apache/spark/status/api/v1/api.scala x: 21 contributors (all time) y: 289 lines of code core/src/main/scala/org/apache/spark/internal/config/ConfigBuilder.scala x: 7 contributors (all time) y: 159 lines of code core/src/main/scala/org/apache/spark/rdd/CoalescedRDD.scala x: 28 contributors (all time) y: 221 lines of code core/src/main/scala/org/apache/spark/status/storeTypes.scala x: 4 contributors (all time) y: 363 lines of code core/src/main/scala/org/apache/spark/storage/StorageUtils.scala x: 26 contributors (all time) y: 115 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/compression/compressionSchemes.scala x: 5 contributors (all time) y: 669 lines of code sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java x: 13 contributors (all time) y: 211 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala x: 23 contributors (all time) y: 454 lines of code python/pyspark/ml/param/__init__.py x: 18 contributors (all time) y: 279 lines of code core/src/main/scala/org/apache/spark/scheduler/SparkListener.scala x: 41 contributors (all time) y: 192 lines of code core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala x: 30 contributors (all time) y: 60 lines of code core/src/main/scala/org/apache/spark/ui/jobs/ExecutorTable.scala x: 29 contributors (all time) y: 126 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/python/UserDefinedPythonFunction.scala x: 7 contributors (all time) y: 19 lines of code common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBTypeInfo.java x: 2 contributors (all time) y: 287 lines of code core/src/main/scala/org/apache/spark/ui/jobs/StagesTab.scala x: 12 contributors (all time) y: 35 lines of code core/src/main/scala/org/apache/spark/scheduler/StageInfo.scala x: 23 contributors (all time) y: 59 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/command/commands.scala x: 19 contributors (all time) y: 102 lines of code launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java x: 10 contributors (all time) y: 251 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java x: 6 contributors (all time) y: 336 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/Matrices.scala x: 11 contributors (all time) y: 765 lines of code core/src/main/scala/org/apache/spark/deploy/history/ApplicationHistoryProvider.scala x: 14 contributors (all time) y: 37 lines of code core/src/main/scala/org/apache/spark/SparkEnv.scala x: 53 contributors (all time) y: 324 lines of code core/src/main/scala/org/apache/spark/serializer/SerializerManager.scala x: 24 contributors (all time) y: 126 lines of code core/src/main/scala/org/apache/spark/ui/storage/StorageTab.scala x: 13 contributors (all time) y: 8 lines of code core/src/main/scala/org/apache/spark/io/CompressionCodec.scala x: 28 contributors (all time) y: 135 lines of code core/src/main/scala/org/apache/spark/FutureAction.scala x: 27 contributors (all time) y: 187 lines of code core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala x: 40 contributors (all time) y: 152 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/udaf.scala x: 10 contributors (all time) y: 327 lines of code streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala x: 59 contributors (all time) y: 453 lines of code mllib/src/main/scala/org/apache/spark/mllib/evaluation/RegressionMetrics.scala x: 15 contributors (all time) y: 59 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListenerBus.scala x: 14 contributors (all time) y: 51 lines of code core/src/main/scala/org/apache/spark/metrics/sink/GraphiteSink.scala x: 18 contributors (all time) y: 58 lines of code core/src/main/scala/org/apache/spark/api/python/SerDeUtil.scala x: 15 contributors (all time) y: 194 lines of code sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala x: 67 contributors (all time) y: 364 lines of code core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala x: 36 contributors (all time) y: 121 lines of code core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala x: 66 contributors (all time) y: 540 lines of code mllib/src/main/scala/org/apache/spark/mllib/regression/LabeledPoint.scala x: 16 contributors (all time) y: 41 lines of code core/src/main/scala/org/apache/spark/ui/PagedTable.scala x: 6 contributors (all time) y: 173 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CompactibleFileStreamLog.scala x: 7 contributors (all time) y: 187 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala x: 37 contributors (all time) y: 202 lines of code core/src/main/scala/org/apache/spark/api/r/SerDe.scala x: 12 contributors (all time) y: 372 lines of code core/src/main/scala/org/apache/spark/package.scala x: 20 contributors (all time) y: 50 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskResult.scala x: 29 contributors (all time) y: 52 lines of code graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala x: 17 contributors (all time) y: 251 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala x: 27 contributors (all time) y: 185 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/StateDStream.scala x: 24 contributors (all time) y: 72 lines of code core/src/main/scala/org/apache/spark/rdd/SequenceFileRDDFunctions.scala x: 20 contributors (all time) y: 37 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala x: 16 contributors (all time) y: 333 lines of code mllib/src/main/scala/org/apache/spark/mllib/util/MLUtils.scala x: 36 contributors (all time) y: 351 lines of code core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala x: 33 contributors (all time) y: 158 lines of code core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala x: 30 contributors (all time) y: 118 lines of code mllib/src/main/scala/org/apache/spark/mllib/optimization/GradientDescent.scala x: 25 contributors (all time) y: 159 lines of code sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala x: 26 contributors (all time) y: 85 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala x: 20 contributors (all time) y: 372 lines of code sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnStats.scala x: 4 contributors (all time) y: 250 lines of code mllib-local/src/main/scala/org/apache/spark/ml/linalg/BLAS.scala x: 4 contributors (all time) y: 569 lines of code mllib/src/main/scala/org/apache/spark/mllib/linalg/BLAS.scala x: 16 contributors (all time) y: 560 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/Type.java x: 2 contributors (all time) y: 232 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala x: 25 contributors (all time) y: 51 lines of code sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala x: 51 contributors (all time) y: 20 lines of code core/src/main/scala/org/apache/spark/InterruptibleIterator.scala x: 14 contributors (all time) y: 11 lines of code mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala x: 38 contributors (all time) y: 224 lines of code core/src/main/scala/org/apache/spark/deploy/FaultToleranceTest.scala x: 29 contributors (all time) y: 330 lines of code core/src/main/scala/org/apache/spark/scheduler/TaskInfo.scala x: 19 contributors (all time) y: 66 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/model/treeEnsembleModels.scala x: 15 contributors (all time) y: 269 lines of code core/src/main/scala/org/apache/spark/scheduler/JobWaiter.scala x: 24 contributors (all time) y: 32 lines of code mllib/src/main/scala/org/apache/spark/ml/attribute/attributes.scala x: 8 contributors (all time) y: 362 lines of code mllib/src/main/scala/org/apache/spark/mllib/optimization/Gradient.scala x: 25 contributors (all time) y: 144 lines of code core/src/main/resources/org/apache/spark/ui/static/spark-dag-viz.js x: 8 contributors (all time) y: 340 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/loss/LogLoss.scala x: 9 contributors (all time) y: 18 lines of code streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala x: 13 contributors (all time) y: 194 lines of code core/src/main/scala/org/apache/spark/storage/StorageLevel.scala x: 31 contributors (all time) y: 159 lines of code core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala x: 41 contributors (all time) y: 407 lines of code core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala x: 44 contributors (all time) y: 276 lines of code mllib/src/main/scala/org/apache/spark/mllib/random/RandomRDDs.scala x: 9 contributors (all time) y: 514 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/DecisionTree.scala x: 23 contributors (all time) y: 110 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala x: 25 contributors (all time) y: 194 lines of code core/src/main/scala/org/apache/spark/broadcast/BroadcastFactory.scala x: 16 contributors (all time) y: 10 lines of code mllib/src/main/scala/org/apache/spark/mllib/classification/NaiveBayes.scala x: 27 contributors (all time) y: 273 lines of code core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala x: 28 contributors (all time) y: 56 lines of code core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala x: 25 contributors (all time) y: 37 lines of code core/src/main/scala/org/apache/spark/scheduler/InputFormatInfo.scala x: 22 contributors (all time) y: 111 lines of code mllib/src/main/scala/org/apache/spark/mllib/classification/SVM.scala x: 27 contributors (all time) y: 133 lines of code mllib/src/main/scala/org/apache/spark/mllib/tree/configuration/Strategy.scala x: 17 contributors (all time) y: 105 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala x: 33 contributors (all time) y: 382 lines of code streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala x: 37 contributors (all time) y: 274 lines of code mllib/src/main/scala/org/apache/spark/mllib/classification/LogisticRegression.scala x: 31 contributors (all time) y: 253 lines of code sql/core/src/main/scala/org/apache/spark/sql/package.scala x: 12 contributors (all time) y: 9 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java x: 3 contributors (all time) y: 125 lines of code streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobGenerator.scala x: 24 contributors (all time) y: 192 lines of code core/src/main/scala/org/apache/spark/TaskState.scala x: 17 contributors (all time) y: 8 lines of code core/src/main/scala/org/apache/spark/util/collection/BitSet.scala x: 19 contributors (all time) y: 136 lines of code core/src/main/scala/org/apache/spark/deploy/master/ApplicationState.scala x: 21 contributors (all time) y: 5 lines of code core/src/main/scala/org/apache/spark/serializer/SerializationDebugger.scala x: 7 contributors (all time) y: 262 lines of code core/src/main/scala/org/apache/spark/rdd/PipedRDD.scala x: 26 contributors (all time) y: 157 lines of code mllib/src/main/scala/org/apache/spark/mllib/regression/Lasso.scala x: 21 contributors (all time) y: 107 lines of code sql/hive-thriftserver/if/TCLIService.thrift x: 2 contributors (all time) y: 518 lines of code core/src/main/scala/org/apache/spark/deploy/master/MasterMessages.scala x: 15 contributors (all time) y: 11 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java x: 2 contributors (all time) y: 563 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/ColumnValue.java x: 1 contributors (all time) y: 254 lines of code sql/hive-thriftserver/src/main/java/org/apache/hive/service/cli/operation/Operation.java x: 1 contributors (all time) y: 227 lines of code core/src/main/scala/org/apache/spark/deploy/master/PersistenceEngine.scala x: 18 contributors (all time) y: 40 lines of code core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperPersistenceEngine.scala x: 27 contributors (all time) y: 47 lines of code core/src/main/scala/org/apache/spark/rdd/OrderedRDDFunctions.scala x: 23 contributors (all time) y: 35 lines of code core/src/main/scala/org/apache/spark/deploy/master/FileSystemPersistenceEngine.scala x: 24 contributors (all time) y: 53 lines of code core/src/main/scala/org/apache/spark/deploy/master/ZooKeeperLeaderElectionAgent.scala x: 22 contributors (all time) y: 56 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala x: 20 contributors (all time) y: 94 lines of code streaming/src/main/scala/org/apache/spark/streaming/util/RawTextSender.scala x: 19 contributors (all time) y: 50 lines of code streaming/src/main/scala/org/apache/spark/streaming/dstream/QueueInputDStream.scala x: 21 contributors (all time) y: 45 lines of code core/src/main/java/org/apache/spark/util/collection/TimSort.java x: 3 contributors (all time) y: 470 lines of code core/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala x: 28 contributors (all time) y: 12 lines of code core/src/main/resources/org/apache/spark/ui/static/bootstrap-tooltip.js x: 2 contributors (all time) y: 251 lines of code core/src/main/scala/org/apache/spark/deploy/master/WorkerState.scala x: 19 contributors (all time) y: 5 lines of code python/pyspark/files.py x: 20 contributors (all time) y: 18 lines of code
5232.0
lines of code
  min: 1.0
  average: 133.3
  25th percentile: 23.0
  median: 64.0
  75th percentile: 152.0
  max: 5232.0
0 162.0
contributors (all time)
min: 1.0 | average: 10.02 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 13.0 | max: 162.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".

About This Analysis
  • File size measurements show the distribution of size of files.
  • Files are classified in four categories based on their size (lines of code): 1-100 (very small files), 101-200 (small files), 201-500 (medium size files), 501-1000 (long files), 1001+(very long files).
  • It is a good practice to keep files small. Long files may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.
Learn more...