Updated examples based on the API changes

GigahexHQ · Apr 28, 2018 · 3187d8b · 3187d8b
1 parent 8e1c80c
commit 3187d8b
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 17 deletions.
diff --git a/jetprobe-sample/src/main/scala/com/jetprobe/sample/HBaseSuite.scala b/jetprobe-sample/src/main/scala/com/jetprobe/sample/HBaseSuite.scala
@@ -50,8 +50,7 @@ class HBaseSuite extends TestPipeline {
 
       client.upload("/from/file/path","/to/target/file/path")
 
-      client.download("","")
-
+      client.download("/source/","/download")
 
 
     }
@@ -72,7 +71,7 @@ class HBaseSuite extends TestPipeline {
 
     }
 
-    validate("check if tables are created",hbaseConf) { hbase =>
+    validate("check table properties",hbaseConf) { hbase =>
 
       given(hbase.describe("infa:employee")) { desc =>
 

diff --git a/jetprobe-sample/src/main/scala/com/jetprobe/sample/LocalCommandPipe.scala b/jetprobe-sample/src/main/scala/com/jetprobe/sample/LocalCommandPipe.scala
@@ -3,7 +3,6 @@ package com.jetprobe.sample
 import akka.actor.ActorSystem
 import com.jetprobe.core.TestPipeline
 import com.jetprobe.core.annotation.PipelineMeta
-import com.jetprobe.core.runner.Runner
 import com.jetprobe.core.structure.PipelineBuilder
 
 /**
@@ -21,18 +20,8 @@ class LocalCommandPipe extends TestPipeline{
 
     runCmd("get maven version","mvn --version")
 
-    //show the node version
-    runCmd("yarn start","""C:\Users\samez\Documents\projects\jetprobe-gitlab\jetprobe-ui""")
-
-    //runCmd("mvn install -DskipTests",at = """C:\Users\samez\Perforce\match-nxt\code\match""")
+    runCmd("install the code","mvn install -DskipTests")
 
   }
 }
 
-object LocalCommandPipeRun extends App {
-
-  implicit val system = ActorSystem("local-cmd")
-
-  Runner().run(new LocalCommandPipe().tasks.build())
-
-}
diff --git a/jetprobe-sample/src/main/scala/com/jetprobe/sample/MongoSuite.scala b/jetprobe-sample/src/main/scala/com/jetprobe/sample/MongoSuite.scala
@@ -15,7 +15,7 @@ import org.json4s.native.JsonMethods._
 class MongoSuite extends TestPipeline with LazyLogging {
 
 
-  val mongoConf = new MongoDBConf("mongodb://<mongo.host.name>")
+  val mongoConf = new MongoDBConf("mongodb://${mongo.host.name}")
 
   case class Person(_id: Long, name: String, age: Int)
 
@@ -26,7 +26,7 @@ class MongoSuite extends TestPipeline with LazyLogging {
 
     task("Create Mongo Collection",mongoConf) { mongoDB =>
 
-      mongoDB.createCollection("foo", "bar",Seq("id","name"))
+      mongoDB.createCollection(db= "customer", collection = "purchase",indexFields = Seq("name","product"))
       mongoDB.createCollection("zoo", "baz")
 
     }