Configuration for MongoDB added.

scalaoop · Feb 5, 2015 · 7e67b09 · 7e67b09
1 parent 0d162bf
commit 7e67b09
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/src/main/resources/application.conf b/src/main/resources/application.conf
@@ -21,6 +21,10 @@ file {
   path=""
 }
 
+mongo {
+  mongo.input.uri="mongodb://127.0.0.1:27017/beowulf.input"
+}
+
 mysql {
   url="127.0.0.1:8889"
   database="analytics"    

diff --git a/src/main/scala/de/kp/spark/fsm/Configuration.scala b/src/main/scala/de/kp/spark/fsm/Configuration.scala
@@ -63,6 +63,16 @@ object Configuration extends CoreConf {
 
   }
 
+  override def mongo:HConf = {
+
+    val cfg = config.getConfig("mongo")
+    val conf = new HConf()                          
+
+    conf.set("mongo.input.uri",cfg.getString("mongo.input.uri"))
+    conf
+
+  }
+
   override def mysql:(String,String,String,String) = {
 
    val cfg = config.getConfig("mysql")
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,6 +21,10 @@ file { @@
       path=""
     }
+    mongo {
+      mongo.input.uri="mongodb://127.0.0.1:27017/beowulf.input"
+    }
     mysql {
       url="127.0.0.1:8889"
       database="analytics"
@@ Expand Down @@