ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject ignite git commit: Fixed compilation
Date Tue, 07 Jun 2016 11:09:30 GMT
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 <valentin.lulichenko@gmail.com>
Authored: Tue Jun 7 14:09:19 2016 +0300
Committer: Valentin Kulichenko <valentin.lulichenko@gmail.com>
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)
     }


Mime
View raw message