master
spark
Repository badge with A rating
View on GitHub
Limited to 5K files. Learn more.
Grade
Name
Complexity
Churn
Issues
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\statefulprocessor\StatefulProcessorHandleImplBase.scala
8 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\statefulprocessor\StatefulProcessorHandleImpl.scala
97 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateVariableUtils.scala
27 4 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateExecBase.scala
32 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateExec.scala
37 5 1
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\StateTypesEncoderUtils.scala
42 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\StateStoreColumnFamilySchemaUtils.scala
40 5 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\streamingLimits.scala
17 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\statefulOperators.scala
187 8 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\SymmetricHashJoinStateManager.scala
219 15 3
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\StreamingSymmetricHashJoinValueRowConverter.scala
13 1 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\StreamingSymmetricHashJoinHelper.scala
27 5 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\StreamingSymmetricHashJoinExec.scala
130 10 2
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\flatmapgroupswithstate\GroupStateImpl.scala
45 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\flatmapgroupswithstate\FlatMapGroupsWithStateExecHelper.scala
26 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\flatmapgroupswithstate\FlatMapGroupsWithStateExec.scala
62 3 1
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\StreamingSessionWindowStateManager.scala
38 4 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\StreamingAggregationStateManager.scala
31 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\StatefulOperatorPartitioning.scala
3 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\StatePartitionKeyExtractorFactory.scala
11 1 -