aboutsummaryrefslogtreecommitdiffstats
path: root/README.md
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 /README.md
parent0c0336e421030b59b598829c3bcaffcf7a5b6d68 (diff)
downloadSpyGlass-af97d309d95657a43029d9eda427b072c442672d.tar.gz
SpyGlass-af97d309d95657a43029d9eda427b072c442672d.zip
formatting
Diffstat (limited to 'README.md')
-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)) {