apache/spark

master

spark

Grade	Name	Complexity	Churn	Issues
A	python\pyspark\sql\tests\streaming\test_streaming_foreach_batch.py	12	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\python\MapInBatchEvaluatorFactory.scala	4	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\python\MapInBatchExec.scala	6	4	-
A	common\network-common\src\main\java\org\apache\spark\network\crypto\AuthRpcHandler.java	8	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\python\streaming\PythonForeachWriter.scala	24	4	-
A	core\src\main\resources\org\apache\spark\ui\static\flamegraph.js		4	-
A	python\pyspark\sql\tests\test_dataframe.py	5	4	-
A	sql\core\src\test\scala\org\apache\spark\sql\streaming\StreamingQueryStatusAndProgressSuite.scala	5	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\checkpointing\CheckpointFileManager.scala	66	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\checkpointing\HDFSMetadataLog.scala	65	4	-
A	sql\core\src\test\scala\org\apache\spark\sql\streaming\StreamTest.scala	122	4	1
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\StreamingSymmetricHashJoinExec.scala	101	4	2
A	core\src\main\resources\org\apache\spark\ui\static\stagepage.js		4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\timers\TimerStateImpl.scala	16	4	-
A	common\network-shuffle\src\test\java\org\apache\spark\network\shuffle\RemoteBlockPushResolverSuite.java	22	4	-
A	python\pyspark\sql\tests\udf_type_tests\test_udf_input_types.py	24	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\ResolveWriteToStream.scala	16	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\StreamMetadata.scala	9	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\TriggerExecutor.scala	15	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\WatermarkPropagator.scala	54	4	-