Repository: ignite Updated Branches: refs/heads/master 83f9fd08b -> 18d4ecc44
Fixed compilation Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/18d4ecc4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/18d4ecc4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/18d4ecc4 Branch: refs/heads/master Commit: 18d4ecc44a895ca0add46e15d01bd547fda96d85 Parents: 83f9fd0 Author: Valentin Kulichenko <[email protected]> Authored: Tue Jun 7 14:09:19 2016 +0300 Committer: Valentin Kulichenko <[email protected]> Committed: Tue Jun 7 14:09:19 2016 +0300 ---------------------------------------------------------------------- .../src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/18d4ecc4/modules/spark/src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala ---------------------------------------------------------------------- diff --git a/modules/spark/src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala b/modules/spark/src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala index cac0e15..acc163a 100644 --- a/modules/spark/src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala +++ b/modules/spark/src/main/scala/org/apache/ignite/spark/JavaIgniteRDD.scala @@ -82,12 +82,14 @@ class JavaIgniteRDD[K, V](override val rdd: IgniteRDD[K, V]) def saveValues[T](jrdd: JavaRDD[T], f: (T, IgniteContext[K, V]) â V) = rdd.saveValues(JavaRDD.toRDD(jrdd), f) - def savePairs(jrdd: JavaPairRDD[K, V]) = { + def savePairs(jrdd: JavaPairRDD[K, V], overwrite: Boolean) = { val rrdd: RDD[(K, V)] = JavaPairRDD.toRDD(jrdd) - rdd.savePairs(rrdd) + rdd.savePairs(rrdd, overwrite) } + def savePairs(jrdd: JavaPairRDD[K, V]) : Unit = savePairs(jrdd, overwrite = false) + def savePairs[T](jrdd: JavaRDD[T], f: (T, IgniteContext[K, V]) â (K, V), overwrite: Boolean = false) = { rdd.savePairs(JavaRDD.toRDD(jrdd), f, overwrite) }
