-
- Downloads
[SPARK-17643] Remove comparable requirement from Offset
For some sources, it is difficult to provide a global ordering based only on the data in the offset. Since we don't use comparison for correctness, lets remove it. Author: Michael Armbrust <michael@databricks.com> Closes #15207 from marmbrus/removeComparable.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/CompositeOffset.scala 0 additions, 30 deletions...pache/spark/sql/execution/streaming/CompositeOffset.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/LongOffset.scala 0 additions, 6 deletions...org/apache/spark/sql/execution/streaming/LongOffset.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Offset.scala 4 additions, 15 deletions...ala/org/apache/spark/sql/execution/streaming/Offset.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala 5 additions, 4 deletions...pache/spark/sql/execution/streaming/StreamExecution.scala
- sql/core/src/test/scala/org/apache/spark/sql/streaming/OffsetSuite.scala 0 additions, 39 deletions...st/scala/org/apache/spark/sql/streaming/OffsetSuite.scala
Loading
Please register or sign in to comment