diff options
author | Chandan Rajah <chandan.rajah@gmail.com> | 2013-06-06 12:50:30 +0100 |
---|---|---|
committer | Chandan Rajah <chandan.rajah@gmail.com> | 2013-06-06 12:50:30 +0100 |
commit | 5a2965bfcb5d6944d661dff7b05e8b89dc629342 (patch) | |
tree | 952013bc6d5faa399903ea31dd21baf1b58e4ea3 /src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala | |
parent | cb34790ac23210bbed815847b8732e0ad657ec6b (diff) | |
download | SpyGlass-5a2965bfcb5d6944d661dff7b05e8b89dc629342.tar.gz SpyGlass-5a2965bfcb5d6944d661dff7b05e8b89dc629342.zip |
Updated examples
Diffstat (limited to 'src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala')
-rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala b/src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala index aa77caa..50cd4f1 100644 --- a/src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala +++ b/src/main/scala/parallelai/spyglass/hbase/testing/HBaseSourceShouldReadRunner.scala @@ -3,8 +3,17 @@ package parallelai.spyglass.hbase.testing import parallelai.spyglass.base.JobRunner object HBaseSourceShouldReadRunner extends App { - val appConfig = "/projects/applications.conf" - val libPath = "/media/sf__CHANDAN_RAJAH_/Dropbox/_WORK_/_SKY_/_BIG_DATA_/_SOURCES_/big_data/commons/commons.hbase.skybase/alternateLocation" + val appPath = System.getenv("BIGDATA_APPCONF_PATH") + assert (appPath != null, {"Environment Variable BIGDATA_APPCONF_PATH is undefined or Null"}) + println( "Application Path is [%s]".format(appPath) ) + + val jobLibPath = System.getenv("BIGDATA_JOB_LIB_PATH") + assert (jobLibPath != null, {"Environment Variable BIGDATA_JOB_LIB_PATH is undefined or Null"}) + println( "Job Library Path Path is [%s]".format(jobLibPath) ) - JobRunner.main(Array(classOf[HBaseSourceShouldRead].getName, "--hdfs", "--app.conf.path", appConfig, "--job.lib.path", libPath)) + val quorum = System.getenv("BIGDATA_QUORUM_NAMES") + assert (quorum != null, {"Environment Variable BIGDATA_QUORUM_NAMES is undefined or Null"}) + println( "Quorum is [%s]".format(quorum) ) + + JobRunner.main(Array(classOf[HBaseSourceShouldRead].getName, "--hdfs", "--app.conf.path", appPath, "--job.lib.path", jobLibPath, "--quorum", quorum)) }
\ No newline at end of file |