Add tests for compatibility mode

src/test/scala/org/infinispan/spark/CompatibilitySuites.scala

@@ -0,0 +1,21 @@
+package org.infinispan.spark
+
+import org.infinispan.spark.suites._
+import org.infinispan.spark.test.Cluster
+import org.scalatest.{BeforeAndAfterAll, Suites}
+
+/**
+  * @author vjuranek
+  */
+class CompatibilitySuites extends Suites(new RDDCompatibilitySuite, new StreamingCompatibilitySuite) with BeforeAndAfterAll {
+
+   override protected def beforeAll(): Unit = {
+      Cluster.start()
+      super.beforeAll()
+   }
+
+   override protected def afterAll(): Unit = {
+      Cluster.shutDown()
+      super.afterAll()
+   }
+}

src/test/scala/org/infinispan/spark/suites/RDDCompatibilitySuite.scala

@@ -0,0 +1,24 @@
+package org.infinispan.spark.suites
+
+import org.infinispan.spark.test._
+import org.jboss.dmr.scala.ModelNode
+import org.scalatest.DoNotDiscover
+
+/**
+  * @author vjuranek
+  */
+@DoNotDiscover
+class RDDCompatibilitySuite extends RDDRetrievalTest with WordCache with Spark with MultipleServers {
+   override protected def getNumEntries: Int = 100
+
+   override def getCacheType = CacheType.DISTRIBUTED
+
+   override def getCacheConfig: Option[ModelNode] = Some(ModelNode(
+         "compatibility" -> ModelNode(
+            "COMPATIBILITY" -> ModelNode(
+               "enabled" -> true
+            )
+         )
+      )
+   )
+}

src/test/scala/org/infinispan/spark/suites/StreamingCompatibilitySuite.scala

@@ -0,0 +1,25 @@
+package org.infinispan.spark.suites
+
+import org.jboss.dmr.scala.ModelNode
+import org.scalatest.DoNotDiscover
+
+/**
+  * @author vjuranek
+  */
+@DoNotDiscover
+class StreamingCompatibilitySuite extends StreamingSuite {
+
+   override def getCacheConfig: Option[ModelNode] = Some(ModelNode(
+         "expiration" -> ModelNode(
+            "EXPIRATION" -> ModelNode(
+               "interval" -> 500
+            )
+         ),
+         "compatibility" -> ModelNode(
+            "COMPATIBILITY" -> ModelNode(
+               "enabled" -> true
+            )
+         )
+      )
+   )
+}

src/test/scala/org/infinispan/spark/test/InfinispanServer.scala

@@ -4,8 +4,8 @@ import java.io.File
 import java.lang.management.ManagementFactory
 import java.nio.file.Paths
 
+import org.infinispan.client.hotrod.RemoteCacheManager
 import org.infinispan.client.hotrod.configuration.ConfigurationBuilder
-import org.infinispan.client.hotrod.{RemoteCache, RemoteCacheManager}
 import org.infinispan.filter.{KeyValueFilterConverterFactory, NamedFactory}
 import org.infinispan.spark.test.TestingUtil.waitForCondition
 import org.jboss.as.controller.client.helpers.ClientConstants._
@@ -16,7 +16,6 @@ import org.jboss.shrinkwrap.api.asset.StringAsset
 import org.jboss.shrinkwrap.api.exporter.ZipExporter
 import org.jboss.shrinkwrap.api.spec.JavaArchive
 
-import scala.annotation.tailrec
 import scala.collection.mutable
 import scala.collection.mutable.ListBuffer
 import scala.concurrent.ExecutionContext.Implicits.global