diff options
| author | Saad Rashid <saad373@gmail.com> | 2014-02-21 15:23:48 +0000 |
|---|---|---|
| committer | Saad Rashid <saad373@gmail.com> | 2014-02-21 15:23:48 +0000 |
| commit | d09d29b7f301d8eca613dff0e62f658bcee536bc (patch) | |
| tree | fddeb9fec0b948584dfaa1af3d129300b99c8e0f /src/main/scala/parallelai/spyglass/hbase/example | |
| parent | e068f01c8e16d52eaf572b26d32730b119c325b5 (diff) | |
| download | SpyGlass-d09d29b7f301d8eca613dff0e62f658bcee536bc.tar.gz SpyGlass-d09d29b7f301d8eca613dff0e62f658bcee536bc.zip | |
Added Local Schema and Memory Tap in HBaseSource and JDBCSource to fix
the failing unit tests.
Diffstat (limited to 'src/main/scala/parallelai/spyglass/hbase/example')
| -rw-r--r-- | src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala index 2921df8..6e56c52 100644 --- a/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala +++ b/src/main/scala/parallelai/spyglass/hbase/example/SimpleHBaseSourceExample.scala @@ -20,8 +20,8 @@ class SimpleHBaseSourceExample(args: Args) extends JobBase(args) with HBasePipeC val output = args("output") - val properties = new Properties() - AppProps.setApplicationJarClass( properties, classOf[SimpleHBaseSourceExample] ); +// val properties = new Properties() +// AppProps.setApplicationJarClass( properties, classOf[SimpleHBaseSourceExample] ); val hbs = new HBaseSource( "table_name", @@ -31,6 +31,7 @@ class SimpleHBaseSourceExample(args: Args) extends JobBase(args) with HBasePipeC List(new Fields("column_name1", "column_name2")), sourceMode = SourceMode.GET_LIST, keyList = List("1", "2", "3")) .read + .debug .fromBytesWritable(new Fields("key", "column_name1", "column_name2")) .write(Tsv(output format "get_list")) |