apache/spark

master

spark

Grade	Name	Complexity	Churn	Issues
A	connector\kafka-0-10\src\test\scala\org\apache\spark\streaming\kafka010\DirectKafkaStreamSuite.scala	25	1	-
A	sql\core\src\test\scala\org\apache\spark\sql\DataFrameWindowFunctionsSuite.scala	25	7	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\datasources\csv\CSVFileFormat.scala	25	13	-
A	connector\kinesis-asl\src\main\scala\org\apache\spark\streaming\kinesis\KinesisReceiver.scala	25	3	-
A	sql\catalyst\src\main\scala\org\apache\spark\sql\catalyst\analysis\v2ResolutionPlans.scala	25	7	-
A	sql\core\src\test\scala\org\apache\spark\sql\execution\columnar\compression\CompressionSchemeBenchmark.scala	25	2	-
A	core\src\test\scala\org\apache\spark\storage\BlockManagerDecommissionIntegrationSuite.scala	25	4	1
A	connector\protobuf\src\main\scala\org\apache\spark\sql\protobuf\ProtobufDataToCatalyst.scala	25	2	-
A	sql\catalyst\src\main\scala\org\apache\spark\sql\catalyst\analysis\resolver\UnpivotResolver.scala	25	1	-
A	sql\core\src\test\scala\org\apache\spark\sql\execution\SQLExecutionSuite.scala	25	3	-
A	sql\core\src\test\scala\org\apache\spark\sql\connector\ChangelogResolutionSuite.scala	25	11	-
A	core\src\main\java\org\apache\spark\shuffle\sort\io\LocalDiskShuffleMapOutputWriter.java	25	2	-
A	core\src\main\java\org\apache\spark\util\collection\unsafe\sort\UnsafeSorterBoundedSpillMerger.java	25	2	-
A	sql\core\src\test\java\test\org\apache\spark\sql\JavaHigherOrderFunctionsSuite.java	25	1	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\aggregate\BaseAggregateExec.scala	24	3	-
A	mllib\src\main\scala\org\apache\spark\ml\feature\MaxAbsScaler.scala	24	6	-
A	mllib\src\main\scala\org\apache\spark\ml\feature\VarianceThresholdSelector.scala	24	6	-
A	sql\catalyst\src\main\scala\org\apache\spark\sql\catalyst\analysis\resolver\HavingResolver.scala	24	4	-
A	core\src\main\scala\org\apache\spark\deploy\PythonRunner.scala	24	1	-
A	python\pyspark\sql\worker\write_into_data_source.py	24	12	2