You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sa...@apache.org on 2016/12/01 03:17:54 UTC
[1/2] storm git commit: STORM-2224 Exposed a method to override in
computing the field from given tuple in FieldSelector
Repository: storm
Updated Branches:
refs/heads/master 8048cfa11 -> 872d0a13c
STORM-2224 Exposed a method to override in computing the field from given tuple in FieldSelector
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3c309fcf
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3c309fcf
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3c309fcf
Branch: refs/heads/master
Commit: 3c309fcfaf5b37282c82e2fb3649df1c47f169d3
Parents: 8048cfa
Author: Satish Duggana <sd...@hortonworks.com>
Authored: Tue Nov 29 17:39:44 2016 +0530
Committer: Satish Duggana <sd...@hortonworks.com>
Committed: Thu Dec 1 08:43:30 2016 +0530
----------------------------------------------------------------------
.../storm/cassandra/query/selector/FieldSelector.java | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3c309fcf/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
----------------------------------------------------------------------
diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
index 835a3e8..3349bc3 100644
--- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
+++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
@@ -26,10 +26,8 @@ import java.io.Serializable;
public class FieldSelector implements Serializable {
+ protected final String field;
private String as;
-
- private String field;
-
private boolean isNow;
/**
@@ -41,7 +39,15 @@ public class FieldSelector implements Serializable {
}
public Column select(ITuple t) {
- return new Column<>(as != null ? as : field, isNow ? UUIDs.timeBased() : t.getValueByField(field));
+ return new Column<>(as != null ? as : field, isNow ? UUIDs.timeBased() : getFieldValue(t));
+ }
+
+ /**
+ * @param tuple
+ * @return Compute the value of this field from given {@code tuple}.
+ */
+ protected Object getFieldValue(ITuple tuple) {
+ return tuple.getValueByField(field);
}
/**
[2/2] storm git commit: Added STORM-2224 to CHANGELOG.md
Posted by sa...@apache.org.
Added STORM-2224 to CHANGELOG.md
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/872d0a13
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/872d0a13
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/872d0a13
Branch: refs/heads/master
Commit: 872d0a13c836391a89b3354ed1304e7b7bc80633
Parents: 3c309fc
Author: Satish Duggana <sd...@hortonworks.com>
Authored: Thu Dec 1 08:44:43 2016 +0530
Committer: Satish Duggana <sd...@hortonworks.com>
Committed: Thu Dec 1 08:44:43 2016 +0530
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/872d0a13/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 66b17aa..3a9d75a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 2.0.0
+ * STORM-2224: Exposed a method to override in computing the field from given tuple in FieldSelector
* STORM-2220: Added config support for each bolt in Cassandra bolts, fixed the bolts to be used also as sinks.
* STORM-1886: Extend KeyValueState iface with delete
* STORM-2193: Fix FilterConfiguration parameter order