diff options
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 |