blob: bbcf96daac056ee85cbd8a65d50c2d492c206309 (
plain)
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
|
package parallelai.spyglass.hbase.example
import com.twitter.scalding.Args
import org.slf4j.LoggerFactory
import parallelai.spyglass.base.JobRunner
object SimpleHBaseSourceRunner extends App {
val mArgs = Args(args)
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
log.info("HBaseSource Import process finished successfully.")
log.info("HBaseSource Import process : " + (end - start1) + " milliseconds to complete")
}
|
