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 <sdugg...@hortonworks.com> Authored: Tue Nov 29 17:39:44 2016 +0530 Committer: Satish Duggana <sdugg...@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); } /**
