From 42249fad9938f5d643c53fe8d65375beed8a4de4 Mon Sep 17 00:00:00 2001 From: galarragas Date: Mon, 24 Feb 2014 15:21:28 +0000 Subject: Code review. Removed some commented code and some warning --- .../spyglass/hbase/example/SimpleHBaseSourceExample.scala | 5 +---- .../spyglass/hbase/example/SimpleHBaseSourceRunner.scala | 15 +++++++-------- 2 files changed, 8 insertions(+), 12 deletions(-) (limited to 'src/main/scala/parallelai/spyglass/hbase/example') 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 -- cgit v1.2.3