diff options
| author | galarragas <galarragas@gmail.com> | 2014-02-24 15:21:28 +0000 |
|---|---|---|
| committer | galarragas <galarragas@gmail.com> | 2014-02-24 15:21:28 +0000 |
| commit | 42249fad9938f5d643c53fe8d65375beed8a4de4 (patch) | |
| tree | 14339e6cbd1a65a493deed10a2287e0adbfbd80c /src/main/scala/parallelai/spyglass/hbase/example | |
| parent | d09d29b7f301d8eca613dff0e62f658bcee536bc (diff) | |
| download | SpyGlass-42249fad9938f5d643c53fe8d65375beed8a4de4.tar.gz SpyGlass-42249fad9938f5d643c53fe8d65375beed8a4de4.zip | |
Code review. Removed some commented code and some warning
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 |