diff options
author | rotem <rotem.hermon@gmail.com> | 2013-06-17 16:45:19 +0300 |
---|---|---|
committer | rotem <rotem.hermon@gmail.com> | 2013-06-17 16:45:19 +0300 |
commit | d41bfefa12517df9c814f1955c20a0f65eaf863f (patch) | |
tree | 0e1c09c763eefd305803320550dc3494fa56d1b1 | |
parent | e5f8ad62804daa1a08d5fd22b79d73018fd7bea8 (diff) | |
download | SpyGlass-d41bfefa12517df9c814f1955c20a0f65eaf863f.tar.gz SpyGlass-d41bfefa12517df9c814f1955c20a0f65eaf863f.zip |
formatting
-rw-r--r-- | README.md | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -247,10 +247,10 @@ e.g. **Processing the rows** -The mapper function gets from HBaseRawSource a tuple containing two fields: (rowkey, row). -The first field is the row key, the second is the row Result object. You can then process the row as needed. -The sink will write the output fields as columns under the provided family and field name as the column name. -You can also provide the field name as a full qualifier (family:column) to specify a different family than was declared in the source. +The mapper function gets from HBaseRawSource a tuple containing two fields: (rowkey, row). +The first field is the row key, the second is the row Result object. You can then process the row as needed. +The sink will write the output fields as columns under the provided family and field name as the column name. +You can also provide the field name as a full qualifier (family:column) to specify a different family than was declared in the source. e.g. val hbaseOut = new HBaseRawSource("MY_RESULTS", "hbase-local", Array("out-family"), writeNulls=false, sinkMode = SinkMode.REPLACE) |