Updated Branches: refs/heads/master a2b47dae6 -> fad6aacfb
Added setter method setGenerator to JavaRDD. Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/aae8a014 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/aae8a014 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/aae8a014 Branch: refs/heads/master Commit: aae8a014259b0ae71afd7052c8e22797cfebc82e Parents: e6ed13f Author: eklavya <sr.ekla...@gmail.com> Authored: Mon Jan 13 17:53:35 2014 +0530 Committer: eklavya <sr.ekla...@gmail.com> Committed: Mon Jan 13 17:53:35 2014 +0530 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/aae8a014/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala index 7d48ce0..6c91eda 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala @@ -133,6 +133,11 @@ JavaRDDLike[T, JavaRDD[T]] { rdd.setName(name) this } + + /** Reset generator*/ + def setGenerator(_generator: String) = { + rdd.generator = _generator + } } object JavaRDD {
