You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/05/26 06:30:45 UTC
[15/17] ignite git commit: Fixed test compilation
Fixed test compilation
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/65a90b38
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/65a90b38
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/65a90b38
Branch: refs/heads/ignite-3116
Commit: 65a90b38f663dd7c3e58e8b7e13e029c36caf90b
Parents: e98dc92
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Wed May 25 14:15:44 2016 +0300
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Wed May 25 14:15:44 2016 +0300
----------------------------------------------------------------------
.../src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/65a90b38/modules/spark/src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala
----------------------------------------------------------------------
diff --git a/modules/spark/src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala b/modules/spark/src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala
index 4cc539b..4e90bc8 100644
--- a/modules/spark/src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala
+++ b/modules/spark/src/test/scala/org/apache/ignite/spark/IgniteRDDSpec.scala
@@ -170,15 +170,15 @@ class IgniteRDDSpec extends FunSpec with Matchers with BeforeAndAfterAll with Be
val sc = new SparkContext("local[*]", "test")
try {
- val ic = new IgniteContext[Integer, WithObjectField](sc,
+ val ic = new IgniteContext[String, Entity](sc,
() \u21d2 configuration("client", client = true))
- val cache: IgniteRDD[Integer, WithObjectField] = ic.fromCache(PARTITIONED_CACHE_NAME)
+ val cache: IgniteRDD[String, Entity] = ic.fromCache(PARTITIONED_CACHE_NAME)
assert(cache.count() == 0)
assert(cache.isEmpty())
- cache.savePairs(sc.parallelize(0 until 1000, 2).map(i \u21d2 (i:java.lang.Integer, new WithObjectField(i, new Entity(i, "", i)))))
+ cache.savePairs(sc.parallelize(0 until 1000, 2).map(i \u21d2 (String.valueOf(i), new Entity(i, "", i))))
assert(cache.count() == 1000)
assert(!cache.isEmpty())