diff options
author | Luciano Resende <lresende@apache.org> | 2017-01-18 18:11:45 -0800 |
---|---|---|
committer | Luciano Resende <lresende@apache.org> | 2017-01-18 18:11:45 -0800 |
commit | 7a261d5bdeba857ae31fd122d8cf3a759c5e8b24 (patch) | |
tree | ba7351745bfbd2b5229c5c9f54d1df9cfb69c95d | |
parent | 4612e9ba58119caf91b33e4fd6c6ad0cea38affb (diff) | |
download | toree-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.scala | 30 |
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")) + } } |