blob: c50bbc73435a60ccfcc3523402df2b5c4058b551 [file] [log] [blame]
package unittest.io.pivotal.gemfire.spark.connector
import io.pivotal.gemfire.spark.connector._
import org.apache.spark.SparkContext
import org.apache.spark.sql.SQLContext
import org.scalatest.FunSuite
import org.scalatest.mock.MockitoSugar
import org.scalatest.Matchers
class ConnectorImplicitsTest extends FunSuite with Matchers with MockitoSugar {
test("implicit map2Properties") {
verifyProperties(Map.empty)
verifyProperties(Map("One" -> "1", "Two" -> "2", "Three" ->"3"))
}
def verifyProperties(map: Map[String, String]): Unit = {
val props: java.util.Properties = map
assert(props.size() == map.size)
map.foreach(p => assert(props.getProperty(p._1) == p._2))
}
test("Test Implicit SparkContext Conversion") {
val mockSparkContext = mock[SparkContext]
val gfscf: GemFireSparkContextFunctions = mockSparkContext
assert(gfscf.isInstanceOf[GemFireSparkContextFunctions])
}
test("Test Implicit SQLContext Conversion") {
val mockSQLContext = mock[SQLContext]
val gfscf: GemFireSQLContextFunctions = mockSQLContext
assert(gfscf.isInstanceOf[GemFireSQLContextFunctions])
}
}