From 2f98b9089237b12c4f0d9b80624c5807dc629e27 Mon Sep 17 00:00:00 2001 From: cra14 Date: Wed, 4 Sep 2013 14:09:24 +0100 Subject: Cosmetic changes --- README.md | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 6cb6e4d..98faaa8 100644 --- a/README.md +++ b/README.md @@ -280,6 +280,7 @@ e.g. To be added soon. e.g. + val jdbcSourceRead = new JDBCSource( "TABLE_01", "com.mysql.jdbc.Driver", @@ -292,7 +293,7 @@ e.g. new Fields("key", "column1", "column2", "column3"), null, null, null ) - + val jdbcSourceWrite = new JDBCSource( "TABLE_01", "com.mysql.jdbc.Driver", @@ -305,7 +306,7 @@ e.g. new Fields("key", "column1", "column2", "column3"), null, null, null ) - + 7. HBase Delete Functionality ============================= @@ -316,10 +317,12 @@ The feature can be enable by using the parameter sinkMode = SinkMode.REPLACE in You can use sinkMode = SinkMode.UPDATE to add to the HBaseTable as usual. e.g. + val eraser = toIBW(input, TABLE_SCHEMA) .write(new HBaseSource( "_TEST.SALT.01", quorum, 'key, TABLE_SCHEMA.tail.map((x: Symbol) => "data"), TABLE_SCHEMA.tail.map((x: Symbol) => new Fields(x.name)), sinkMode = SinkMode.REPLACE )) + All rows with the key will be deleted. This includes all versions too. @@ -332,6 +335,7 @@ This feature can be activated by using inputSplitType = SplitType.REGIONAL You can use inputSplitType = SplitType.GRANULAR to use the previous functionality as is. e.g. + val hbase04 = new HBaseSource( "_TEST.SALT.01", quorum, 'key, TABLE_SCHEMA.tail.map((x: Symbol) => "data"), TABLE_SCHEMA.tail.map((x: Symbol) => new Fields(x.name)), @@ -341,4 +345,5 @@ e.g. .map(('key, 'salted, 'unsalted) -> 'testData) {x: (String, String, String) => List(x._1, x._2, x._3)} .project('testData) .write(TextLine("saltTesting/ScanRangeNoSalt01")) - .groupAll(group => group.toList[List[List[String]]]('testData -> 'testData)) \ No newline at end of file + .groupAll(group => group.toList[List[List[String]]]('testData -> 'testData)) + \ No newline at end of file -- cgit v1.2.3