apache/spark

master

spark

Limited to 5K files. Learn more.

Grade	Name	Complexity	Churn	Issues
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\StreamExecution.scala	101	6	2
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\ResolveWriteToStream.scala	22	6	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\RealTimeModeAllowlist.scala	17	1	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\ProgressReporter.scala		9	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\MicroBatchExecution.scala	190	25	4
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\MetricsReporter.scala	3	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\MetadataLogFileIndex.scala	4	3	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\IncrementalExecution.scala	30	15	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\FileStreamSourceOffset.scala	5	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\FileStreamSourceLog.scala	12	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\FileStreamSource.scala	89	4	1
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\FileStreamOptions.scala	6	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\ErrorNotifier.scala		3	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\ContinuousRecordEndpoint.scala	4	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\CompactibleFileStreamLog.scala	43	4	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\AvailableNowDataStreamWrapper.scala	21	3	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\AsyncStreamingQueryCheckpointMetadata.scala		3	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\AsyncProgressTrackingMicroBatchExecution.scala		6	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\AsyncLogPurge.scala	12	2	-
A	sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\runtime\AcceptsLatestSeenOffsetHandler.scala	7	3	-