aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--scald-mvp/src/main/scala/example/SimpleHBaseSourceExample.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/scald-mvp/src/main/scala/example/SimpleHBaseSourceExample.scala b/scald-mvp/src/main/scala/example/SimpleHBaseSourceExample.scala
index 697805d..fe2a120 100644
--- a/scald-mvp/src/main/scala/example/SimpleHBaseSourceExample.scala
+++ b/scald-mvp/src/main/scala/example/SimpleHBaseSourceExample.scala
@@ -22,7 +22,8 @@ class SimpleHBaseSourceExample(args: Args) extends JobBase(args) with HBasePipeC
val hbs = new HBaseSource(
"table_name",
- "quorum_name:2181",
+ //"quorum_name:2181",
+ "mtrcs-zk1.us.archive.org:2181", // HBase Zookeeper server (to get runtime config info; can be array?)
new Fields("key"),
List("column_family"),
List(new Fields("column_name1", "column_name2")),