diff --git a/core/src/main/scala/org/apache/spark/rdd/SlidedRDD.scala b/core/src/main/scala/org/apache/spark/rdd/SlidedRDD.scala index e89f4cc0936de..5d14bcdfdcb66 100644 --- a/core/src/main/scala/org/apache/spark/rdd/SlidedRDD.scala +++ b/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) partitions.toArray } } + + // TODO: Override methods such as aggregate, which only requires one Spark job. }