master
spark
Repository badge with A rating
View on GitHub
Grade
Name
Complexity
Churn
Issues
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\MergingSortWithSessionWindowStateIterator.scala
23 2 -
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\StreamingAggregationStateManager.scala
31 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\StreamingSessionWindowStateManager.scala
38 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\flatmapgroupswithstate\FlatMapGroupsWithStateExec.scala
62 2 1
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\flatmapgroupswithstate\FlatMapGroupsWithStateExecHelper.scala
26 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\join\StreamingSymmetricHashJoinExec.scala
101 4 2
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\StreamingSymmetricHashJoinHelper.scala
27 3 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\join\SymmetricHashJoinStateManager.scala
116 6 1
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\statefulOperators.scala
184 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\transformwithstate\StateStoreColumnFamilySchemaUtils.scala
17 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\StateTypesEncoderUtils.scala
27 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateExec.scala
37 4 1
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateExecBase.scala
29 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\TransformWithStateVariableUtils.scala
25 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\statefulprocessor\StatefulProcessorHandleImplBase.scala
8 2 -
A
sql\core\src\main\scala\org\apache\spark\sql\execution\streaming\operators\stateful\transformwithstate\statevariables\ListStateImpl.scala
11 2 -