-
- Downloads
Revert "[SPARK-19413][SS] MapGroupsWithState for arbitrary stateful operations for branch-2.1"
This reverts commit 502c927b.
Showing
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationChecker.scala 1 addition, 10 deletions...k/sql/catalyst/analysis/UnsupportedOperationChecker.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/object.scala 0 additions, 49 deletions.../org/apache/spark/sql/catalyst/plans/logical/object.scala
- sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationsSuite.scala 3 additions, 21 deletions...rk/sql/catalyst/analysis/UnsupportedOperationsSuite.scala
- sql/core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupsWithStateFunction.java 0 additions, 38 deletions...ark/api/java/function/FlatMapGroupsWithStateFunction.java
- sql/core/src/main/java/org/apache/spark/api/java/function/MapGroupsWithStateFunction.java 0 additions, 38 deletions...e/spark/api/java/function/MapGroupsWithStateFunction.java
- sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala 0 additions, 113 deletions...n/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala
- sql/core/src/main/scala/org/apache/spark/sql/KeyedState.scala 0 additions, 142 deletions...core/src/main/scala/org/apache/spark/sql/KeyedState.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala 1 addition, 20 deletions...cala/org/apache/spark/sql/execution/SparkStrategies.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/objects.scala 0 additions, 22 deletions...c/main/scala/org/apache/spark/sql/execution/objects.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala 5 additions, 14 deletions.../spark/sql/execution/streaming/IncrementalExecution.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/KeyedStateImpl.scala 0 additions, 80 deletions...apache/spark/sql/execution/streaming/KeyedStateImpl.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala 1 addition, 1 deletion...ache/spark/sql/execution/streaming/ProgressReporter.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulAggregate.scala 24 additions, 110 deletions...che/spark/sql/execution/streaming/StatefulAggregate.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala 0 additions, 19 deletions...cution/streaming/state/HDFSBackedStateStoreProvider.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala 0 additions, 5 deletions...ache/spark/sql/execution/streaming/state/StateStore.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/package.scala 1 addition, 10 deletions.../apache/spark/sql/execution/streaming/state/package.scala
- sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java 0 additions, 32 deletions...test/java/test/org/apache/spark/sql/JavaDatasetSuite.java
- sql/core/src/test/scala/org/apache/spark/sql/streaming/MapGroupsWithStateSuite.scala 0 additions, 335 deletions.../apache/spark/sql/streaming/MapGroupsWithStateSuite.scala
Loading
Please register or sign in to comment