From d41bfefa12517df9c814f1955c20a0f65eaf863f Mon Sep 17 00:00:00 2001 From: rotem Date: Mon, 17 Jun 2013 16:45:19 +0300 Subject: formatting --- README.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'README.md') diff --git a/README.md b/README.md index e6d9af8..9674d90 100644 --- a/README.md +++ b/README.md @@ -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) -- cgit v1.2.3