You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2016/06/07 11:09:30 UTC
ignite git commit: Fixed compilation
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 <va...@gmail.com>
Authored: Tue Jun 7 14:09:19 2016 +0300
Committer: Valentin Kulichenko <va...@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]) \u21d2 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]) \u21d2 (K, V), overwrite: Boolean = false) = {
rdd.savePairs(JavaRDD.toRDD(jrdd), f, overwrite)
}