src/main/scala/parallelai/spyglass/hbase/testing/HBaseSaltTesterRunner.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

package parallelai.spyglass.hbase.testing

import parallelai.spyglass.base.JobRunner

object HBaseSaltTesterRunner extends App {
  
//  if( args.length < 2 ) { throw new Exception("Not enough Args")}
  
  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) )

  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[HBaseSaltTester].getName, 
      "--hdfs", 
      "--app.conf.path", appPath, 
      "--job.lib.path", jobLibPath,
      "--quorum", quorum,
      "--debug", "true"
  ))
}