You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jp...@apache.org on 2016/07/16 18:18:15 UTC
nifi git commit: NIFI-2174: Fix handling of time/date types in
QueryCassandra
Repository: nifi
Updated Branches:
refs/heads/master 52a961873 -> 1c5975da8
NIFI-2174: Fix handling of time/date types in QueryCassandra
This closes #661
Signed-off-by: jpercivall <jo...@yahoo.com>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1c5975da
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1c5975da
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1c5975da
Branch: refs/heads/master
Commit: 1c5975da86c6684a4f50f79dc7b7e61e89895415
Parents: 52a9618
Author: Matt Burgess <ma...@apache.org>
Authored: Fri Jul 15 15:52:37 2016 -0400
Committer: jpercivall <jo...@yahoo.com>
Committed: Sat Jul 16 13:31:21 2016 -0400
----------------------------------------------------------------------
.../nifi/processors/cassandra/AbstractCassandraProcessor.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/1c5975da/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessor.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessor.java b/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessor.java
index d703ee8..556fae9 100644
--- a/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessor.java
+++ b/nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/main/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessor.java
@@ -311,8 +311,14 @@ public abstract class AbstractCassandraProcessor extends AbstractProcessor {
return row.getDouble(i);
} else if (dataType.equals(DataType.timestamp())) {
+ return row.getTimestamp(i);
+
+ } else if (dataType.equals(DataType.date())) {
return row.getDate(i);
+ } else if (dataType.equals(DataType.time())) {
+ return row.getTime(i);
+
} else if (dataType.isCollection()) {
List<DataType> typeArguments = dataType.getTypeArguments();