diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-01-14 13:31:32 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-14 13:31:32 -0800 |
| commit | ae5290f4a2fbeb51f5dc6e7add38f9c012ab7311 (patch) | |
| tree | 7950d744ce79c63dfbb1c6eed57ebc5c140953a8 /streaming | |
| parent | 6069446356d1daf28054b87ff1a3bf724a22df03 (diff) | |
| download | spark-ae5290f4a2fbeb51f5dc6e7add38f9c012ab7311.tar.gz spark-ae5290f4a2fbeb51f5dc6e7add38f9c012ab7311.tar.bz2 spark-ae5290f4a2fbeb51f5dc6e7add38f9c012ab7311.zip | |
Bug fix
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala index 16b476ec90..6f4336a011 100644 --- a/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala +++ b/streaming/src/main/scala/spark/streaming/api/java/JavaPairDStream.scala @@ -419,7 +419,6 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])( dstream.countByKeyAndWindow(windowDuration, slideDuration, numPartitions) } - // TODO: Update State def mapValues[U](f: JFunction[V, U]): JavaPairDStream[K, U] = { @@ -443,7 +442,7 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])( * of partitions. */ def cogroup[W: ClassManifest](other: DStream[(K, W)]): DStream[(K, (Seq[V], Seq[W]))] = { - cogroup(other, defaultPartitioner()) + dstream.cogroup(other) } /** |