aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLuciano Resende <lresende@apache.org>2017-01-18 18:11:45 -0800
committerLuciano Resende <lresende@apache.org>2017-01-18 18:11:45 -0800
commit7a261d5bdeba857ae31fd122d8cf3a759c5e8b24 (patch)
treeba7351745bfbd2b5229c5c9f54d1df9cfb69c95d
parent4612e9ba58119caf91b33e4fd6c6ad0cea38affb (diff)
downloadtoree-gateway-7a261d5bdeba857ae31fd122d8cf3a759c5e8b24.tar.gz
toree-gateway-7a261d5bdeba857ae31fd122d8cf3a759c5e8b24.tar.bz2
toree-gateway-7a261d5bdeba857ae31fd122d8cf3a759c5e8b24.zip
Add more test scenarios to cover all result types
-rw-r--r--src/test/scala/com/ibm/ToreeGatewaySpec.scala30
1 files changed, 29 insertions, 1 deletions
diff --git a/src/test/scala/com/ibm/ToreeGatewaySpec.scala b/src/test/scala/com/ibm/ToreeGatewaySpec.scala
index 4ea0ada..917d4af 100644
--- a/src/test/scala/com/ibm/ToreeGatewaySpec.scala
+++ b/src/test/scala/com/ibm/ToreeGatewaySpec.scala
@@ -94,11 +94,39 @@ class ToreeGatewaySpec extends FlatSpec {
val result = toreeGateway.eval(
"""
println(1/0)
- """.stripMargin
+ """.stripMargin
).toString.stripMargin
assert(result.contains("java.lang.ArithmeticException"))
}
+ "gateway" should "receive spark version" in {
+ val result = toreeGateway.eval(
+ """
+ spark.sparkContext.version
+ """.stripMargin
+ ).toString.stripMargin
+
+ assert(result.contains("2.0.2"))
+ }
+
+ "gateway" should "receive spark configuration" in {
+ val result = toreeGateway.eval(
+ """
+ spark.conf.getAll
+ """.stripMargin
+ ).toString.stripMargin
+
+ assert(result.contains("toree-assembly-0.2.0.dev1-incubating-SNAPSHOT.jar"))
+ }
+
+ "gateway" should "receive println result" in {
+ val result = toreeGateway.eval(
+ """
+ println("Hi")
+ """.stripMargin
+ ).toString.stripMargin
+ assert(result.contains("Hi"))
+ }
}