You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/06/17 12:38:45 UTC
[16/43] ignite git commit: IGNITE-3215 - Added
IgniteRDD.withKeepBinary method (ScalaDoc)
IGNITE-3215 - Added IgniteRDD.withKeepBinary method (ScalaDoc)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e235298f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e235298f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e235298f
Branch: refs/heads/ignite-3335
Commit: e235298f9bc2c895e17170b57dd8ad5f90cc25e8
Parents: 0e18941
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Wed Jun 15 12:19:44 2016 +0300
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Wed Jun 15 12:19:44 2016 +0300
----------------------------------------------------------------------
.../src/main/scala/org/apache/ignite/spark/IgniteRDD.scala | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/e235298f/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteRDD.scala
----------------------------------------------------------------------
diff --git a/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteRDD.scala b/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteRDD.scala
index cad96b9..fb15ff1 100644
--- a/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteRDD.scala
+++ b/modules/spark/src/main/scala/org/apache/ignite/spark/IgniteRDD.scala
@@ -32,6 +32,7 @@ import org.apache.spark.sql._
import org.apache.spark._
import scala.collection.JavaConversions._
+import scala.reflect.macros.whitebox
/**
* Ignite RDD. Represents Ignite cache as Spark RDD abstraction.
@@ -293,6 +294,12 @@ class IgniteRDD[K, V] (
ensureCache().removeAll()
}
+ /**
+ * Returns `IgniteRDD` that will operate with binary objects. This method
+ * behaves similar to [[org.apache.ignite.IgniteCache#withKeepBinary]].
+ *
+ * @return New `IgniteRDD` instance for binary objects.
+ */
def withKeepBinary[K1, V1](): IgniteRDD[K1, V1] = {
new IgniteRDD[K1, V1](
ic.asInstanceOf[IgniteContext[K1, V1]],