We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d2a600d commit 5ee6001Copy full SHA for 5ee6001
core/src/main/scala/org/apache/spark/rdd/SlidedRDD.scala
@@ -97,4 +97,6 @@ class SlidedRDD[T: ClassTag](@transient val parent: RDD[T], val windowSize: Int)
97
partitions.toArray
98
}
99
100
+
101
+ // TODO: Override methods such as aggregate, which only requires one Spark job.
102
0 commit comments