aboutsummaryrefslogtreecommitdiffstats
path: root/scald-mvp
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2018-05-21 19:19:14 -0700
committerBryan Newbold <bnewbold@archive.org>2018-05-21 19:19:14 -0700
commit3b64d9c4f852b29964eca0e215d636bc37f0d856 (patch)
tree68881216fe8780085eecbba50722ef4d5402c246 /scald-mvp
parentaafec7a8307342479cacfc5aa6a794068b799823 (diff)
downloadsandcrawler-3b64d9c4f852b29964eca0e215d636bc37f0d856.tar.gz
sandcrawler-3b64d9c4f852b29964eca0e215d636bc37f0d856.zip
point SimpleHBaseSourceExample to actual zookeeper quorum host
Diffstat (limited to 'scald-mvp')
-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")),