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/09/12 18:12:18 UTC
[1/3] storm git commit: STORM-1011: Hbase default mapper should
handle null values.
Repository: storm
Updated Branches:
refs/heads/master 4c9506773 -> 0a5426e7c
STORM-1011: Hbase default mapper should handle null values.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5a1abd3b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5a1abd3b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5a1abd3b
Branch: refs/heads/master
Commit: 5a1abd3bc6b1b7d6ba7532ad7b0758f143cefde3
Parents: 528958c
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Wed Aug 26 16:34:49 2015 -0700
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Wed Aug 26 16:34:49 2015 -0700
----------------------------------------------------------------------
.../main/java/org/apache/storm/hbase/common/Utils.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/5a1abd3b/external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
----------------------------------------------------------------------
diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
index 52b86c9..8efe098 100644
--- a/external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
+++ b/external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
@@ -40,8 +40,10 @@ public class Utils {
return l;
}
- public static byte[] toBytes(Object obj){
- if(obj instanceof String){
+ public static byte[] toBytes(Object obj) {
+ if(obj == null) {
+ return null;
+ } else if(obj instanceof String){
return ((String)obj).getBytes();
} else if (obj instanceof Integer){
return Bytes.toBytes((Integer) obj);
@@ -49,16 +51,12 @@ public class Utils {
return Bytes.toBytes((Long)obj);
} else if (obj instanceof Short){
return Bytes.toBytes((Short)obj);
-
} else if (obj instanceof Float){
return Bytes.toBytes((Float)obj);
-
} else if (obj instanceof Double){
return Bytes.toBytes((Double)obj);
-
} else if (obj instanceof Boolean){
return Bytes.toBytes((Boolean)obj);
-
} else if (obj instanceof BigDecimal){
return Bytes.toBytes((BigDecimal)obj);
} else {
[3/3] storm git commit: Added STORM-1011 to CHANGELOG.
Posted by sr...@apache.org.
Added STORM-1011 to CHANGELOG.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0a5426e7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0a5426e7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0a5426e7
Branch: refs/heads/master
Commit: 0a5426e7c3796535dc9caf2163dc3944868581a9
Parents: b6e40db
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sat Sep 12 08:59:03 2015 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sat Sep 12 08:59:03 2015 -0700
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0a5426e7/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 9562200..5da9b76 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-1011: HBaseBolt default mapper should handle null values
* STORM-1019: Added missing dependency version to use of org.codehaus.mojo:make-maven-plugin
* STORM-1020: Document exceptions in ITuple & Fields
* STORM-1025: Invalid links at https://storm.apache.org/about/multi-language.html
[2/3] storm git commit: Merge branch 'STORM-1011' of
https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-1011
Posted by sr...@apache.org.
Merge branch 'STORM-1011' of https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-1011
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b6e40dbb
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b6e40dbb
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b6e40dbb
Branch: refs/heads/master
Commit: b6e40dbb7ec3e4e9e8e0d2cff12381d6acdaa8ef
Parents: 4c95067 5a1abd3
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sat Sep 12 08:40:42 2015 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sat Sep 12 08:40:42 2015 -0700
----------------------------------------------------------------------
.../main/java/org/apache/storm/hbase/common/Utils.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------