You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/02/25 19:52:51 UTC
[03/13] storm git commit: STORM-539. Storm hive bolt and trident
state. Hive version to 0.14 and update README.
STORM-539. Storm hive bolt and trident state. Hive version to 0.14 and
update README.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/dfb8e370
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/dfb8e370
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/dfb8e370
Branch: refs/heads/master
Commit: dfb8e3709d27691a2f97bbc3e49491f13a9769d1
Parents: 01ab7b1
Author: Sriharsha Chintalapani <ma...@harsha.io>
Authored: Mon Dec 15 15:23:30 2014 -0800
Committer: Sriharsha Chintalapani <ma...@harsha.io>
Committed: Mon Dec 15 15:23:30 2014 -0800
----------------------------------------------------------------------
external/storm-hive/README.md | 10 +++++-----
pom.xml | 2 +-
2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/dfb8e370/external/storm-hive/README.md
----------------------------------------------------------------------
diff --git a/external/storm-hive/README.md b/external/storm-hive/README.md
index 6461462..aec0a89 100644
--- a/external/storm-hive/README.md
+++ b/external/storm-hive/README.md
@@ -13,7 +13,7 @@
```
-## HiveBolt
+## HiveBolt (org.apache.storm.hive.bolt.HiveBolt)
HiveBolt streams tuples directly into hive. Tuples are written using Hive Transactions.
Partiions to which HiveBolt will stream to can either created or pre-created or optionally
@@ -32,8 +32,8 @@ HiveBolt hiveBolt = new HiveBolt(hiveOptions);
There are two implementaitons available
- 1) DelimitedRecordHiveMapper
- 2) JsonRecordHiveMapper
+ + DelimitedRecordHiveMapper (org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper)
+ + JsonRecordHiveMapper (org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper)
```java
DelimitedRecordHiveMapper mapper = new DelimitedRecordHiveMapper()
@@ -51,7 +51,7 @@ HiveBolt hiveBolt = new HiveBolt(hiveOptions);
|withPartitionFields| field names in a tuple can be mapped to hive table partitions | Fields |
|withTimeAsPartitionField| users can select system time as partition in hive table| String . Date format|
-### HiveOptions
+### HiveOptions (org.apache.storm.hive.common.HiveOptions)
HiveBolt takes in HiveOptions as a constructor arg.
@@ -82,7 +82,7 @@ HiveOptions params
-## HiveState
+## HiveState (org.apache.storm.hive.trident.HiveTrident)
Hive Trident state also follows similar pattern to HiveBolt it takes in HiveOptions as an arg.
http://git-wip-us.apache.org/repos/asf/storm/blob/dfb8e370/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 603f772..2f02860 100644
--- a/pom.xml
+++ b/pom.xml
@@ -213,7 +213,7 @@
<conjure.version>2.1.3</conjure.version>
<clojure-data-codec.version>0.1.0</clojure-data-codec.version>
<clojure-contrib.version>1.2.0</clojure-contrib.version>
- <hive.version>0.13.0</hive.version>
+ <hive.version>0.14.0</hive.version>
<hadoop.version>2.6.0</hadoop.version>
</properties>