diff options
Diffstat (limited to 'src/main/scala/parallelai/spyglass/hbase/example')
| -rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala | 5 | ||||
| -rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceRunner.scala | 15 | 
2 files changed, 8 insertions, 12 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala index 6e56c52..9deedaf 100644 --- a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala +++ b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala @@ -19,10 +19,7 @@ class SimpleHBaseSourceExample(args: Args) extends JobBase(args) with HBasePipeC     if (isDebug) Logger.getRootLogger.setLevel(Level.DEBUG)     val output = args("output") -    -//   val properties = new Properties() -//   AppProps.setApplicationJarClass( properties, classOf[SimpleHBaseSourceExample] ); -    +     val hbs = new HBaseSource(       "table_name",       "quorum_name:2181", diff --git a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceRunner.scala b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceRunner.scala index bbcf96d..12f1982 100644 --- a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceRunner.scala +++ b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceRunner.scala @@ -10,17 +10,16 @@ object SimpleHBaseSourceRunner extends App {    val log = LoggerFactory.getLogger(this.getClass.getName) - -    log.info("Starting HBaseSource Import Process Test...")    val start1 = System.currentTimeMillis -  JobRunner.main((classOf[SimpleHBaseSourceExample].getName :: mArgs.toList).toArray) - -  val end = System.currentTimeMillis +  try { +    JobRunner.main((classOf[SimpleHBaseSourceExample].getName :: mArgs.toList).toArray) +  } finally { +    val end = System.currentTimeMillis -  log.info("HBaseSource Import process finished successfully.") -  log.info("HBaseSource Import process : " + (end - start1) + " milliseconds to complete") -   +    log.info("HBaseSource Import process finished successfully.") +    log.info("HBaseSource Import process : " + (end - start1) + " milliseconds to complete") +  }  }
\ No newline at end of file  | 
