aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrotem <rotem.hermon@gmail.com>2013-06-17 16:39:15 +0300
committerrotem <rotem.hermon@gmail.com>2013-06-17 16:39:15 +0300
commitaf97d309d95657a43029d9eda427b072c442672d (patch)
tree6b25612ee2813ea72dd73139f37aa83788902a97
parent0c0336e421030b59b598829c3bcaffcf7a5b6d68 (diff)
downloadSpyGlass-af97d309d95657a43029d9eda427b072c442672d.tar.gz
SpyGlass-af97d309d95657a43029d9eda427b072c442672d.zip
formatting
-rw-r--r--README.md2
1 files changed, 2 insertions, 0 deletions
diff --git a/README.md b/README.md
index 65a03e5..823ca22 100644
--- a/README.md
+++ b/README.md
@@ -236,6 +236,7 @@ HBaseRawSource is an alternative HBase source implementation that provides two m
**Passing a scan object**
HBaseRawSource object provides a helper function to encode a scan object as a base64 string, which you can pass to the source.
e.g.
+
val scan = new Scan
val key = "my_key_prefix"
scan.setStartRow(Bytes.toBytes(key))
@@ -249,6 +250,7 @@ The first field is the row key, the second is the row Result object. You can the
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)
hbaseSource.read
.mapTo(('rowkey, 'row) -> ('rowkey, "different_family:col1", 'col2)) {