You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2017/11/08 14:55:43 UTC
[1/2] storm git commit: Fixing markup for HBase bolt README in Storm
Repository: storm
Updated Branches:
refs/heads/master 8bf8a2f95 -> 566db743d
Fixing markup for HBase bolt README in Storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6e15670a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6e15670a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6e15670a
Branch: refs/heads/master
Commit: 6e15670a90466e6439beb612092c12a1142438f8
Parents: 1b8f67c
Author: Lawrence Craft <la...@gmail.com>
Authored: Tue Oct 31 16:39:06 2017 +0000
Committer: Lawrence Craft <la...@gmail.com>
Committed: Tue Oct 31 16:39:20 2017 +0000
----------------------------------------------------------------------
external/storm-hbase/README.md | 22 +++++++++++-----------
1 file changed, 11 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6e15670a/external/storm-hbase/README.md
----------------------------------------------------------------------
diff --git a/external/storm-hbase/README.md b/external/storm-hbase/README.md
index d7cec31..0326bcd 100644
--- a/external/storm-hbase/README.md
+++ b/external/storm-hbase/README.md
@@ -1,4 +1,4 @@
-#Storm HBase
+# Storm HBase
Storm/Trident integration for [Apache HBase](https://hbase.apache.org)
@@ -46,7 +46,7 @@ config.put("storm.kerberos.principal", "$principal");
StormSubmitter.submitTopology("$topologyName", config, builder.createTopology());
```
-##Working with Secure HBASE using delegation tokens.
+## Working with Secure HBASE using delegation tokens.
If your topology is going to interact with secure HBase, your bolts/states needs to be authenticated by HBase.
The approach described above requires that all potential worker hosts have "storm.keytab.file" on them. If you have
multiple topologies on a cluster , each with different hbase user, you will have to create multiple keytabs and distribute
@@ -131,17 +131,17 @@ HBaseBolt hbase = new HBaseBolt("WordCount", mapper);
HBaseBolt params
-|Arg |Description | Type | Default |
-|--- |--- |---
-|writeToWAL | To turn Durability SYNC_WAL or SKIP_WAL | Boolean (Optional) | True |
-|configKey | Any Hbase related configs | Map (Optional) | |
-|batchSize | Max no.of Tuples batched together to write to HBase | Int (Optional) | 15000 |
-|flushIntervalSecs| (In seconds) If > 0 HBase Bolt will periodically flush transaction batches. Enabling this is recommended to avoid tuple timeouts while waiting for a batch to fill up. | Int (Optional) | 0 |
+| Arg | Description | Type | Default |
+| ---------------- |---------------------------------------------------- |------------------- | ------- |
+| writeToWAL | To turn Durability SYNC_WAL or SKIP_WAL | Boolean (Optional) | True |
+| configKey | Any Hbase related configs | Map (Optional) | |
+| batchSize | Max no.of Tuples batched together to write to HBase | Int (Optional) | 15000 |
+| flushIntervalSecs| (In seconds) If > 0 HBase Bolt will periodically flush transaction batches. Enabling this is recommended to avoid tuple timeouts while waiting for a batch to fill up. | Int (Optional) | 0 |
The `HBaseBolt` will delegate to the `mapper` instance to figure out how to persist tuple data to HBase.
-###HBaseValueMapper
+### HBaseValueMapper
This class allows you to transform the HBase lookup result into storm Values that will be emitted by the `HBaseLookupBolt`.
```java
@@ -158,7 +158,7 @@ The `declareOutputFields` should be used to declare the outputFields of the `HBa
There is an example implementation in `examples/storm-hbase-examples/src/main/java` directory.
-###HBaseProjectionCriteria
+### HBaseProjectionCriteria
This class allows you to specify the projection criteria for your HBase Get function. This is optional parameter
for the lookupBolt and if you do not specify this instance all the columns will be returned by `HBaseLookupBolt`.
@@ -183,7 +183,7 @@ HBaseProjectionCriteria projectionCriteria = new HBaseProjectionCriteria()
.addColumnFamily("cf2");
```
-###HBaseLookupBolt
+### HBaseLookupBolt
To use the `HBaseLookupBolt`, Construct it with the name of the table to write to, an implementation of `HBaseMapper`
and an implementation of `HBaseRowToStormValueMapper`. You can optionally specify a `HBaseProjectionCriteria`.
[2/2] storm git commit: Merge branch 'master' of
https://github.com/lawrencecraft/storm
Posted by bo...@apache.org.
Merge branch 'master' of https://github.com/lawrencecraft/storm
Fixing markdown for HBase bolt README in Storm
This closes #2396
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/566db743
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/566db743
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/566db743
Branch: refs/heads/master
Commit: 566db743de29d8463c9a8c68a359cb34ce01d900
Parents: 8bf8a2f 6e15670
Author: Robert Evans <ev...@yahoo-inc.com>
Authored: Wed Nov 8 08:55:24 2017 -0600
Committer: Robert Evans <ev...@yahoo-inc.com>
Committed: Wed Nov 8 08:55:24 2017 -0600
----------------------------------------------------------------------
external/storm-hbase/README.md | 22 +++++++++++-----------
1 file changed, 11 insertions(+), 11 deletions(-)
----------------------------------------------------------------------