First public release of Spy Glass code base

1 files changed, 34 insertions, 0 deletions

diff --git a/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala b/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala
new file mode 100644
index 0000000..d6b762e
--- /dev/null
+++ b/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala
@@ -0,0 +1,34 @@
+package parallelai.spyglass.hbase.example
+
+import com.twitter.scalding.Tool
+import org.joda.time.format.DateTimeFormat
+import java.util.Formatter.DateTime
+
+object HBaseExampleRunner extends App {
+  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 modeString = if( args.length == 0 ) { "--hdfs" } else { args(0) match {
+    case "hdfs" => "--hdfs"
+    case _ => "--local"
+  }}
+  
+  println(modeString)
+  
+  val jobLibPath = modeString match {
+    case "--hdfs" => {
+      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) )
+      jobLibPath
+    }
+    case _ => ""
+  }
+
+  val output = "HBaseTest.%s.tsv"
+
+  Tool.main(Array(classOf[HBaseExample].getName, modeString, "--app.conf.path", appPath,
+    "--output", output, "--debug", "true", "--job.lib.path", jobLibPath ))
+ 
+}
\ No newline at end of file