calcite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mm...@apache.org
Subject calcite git commit: [CALCITE-1855] Fix float values in Cassandra adapter
Date Wed, 21 Jun 2017 04:19:50 GMT
Repository: calcite
Updated Branches:
  refs/heads/master d5c713c5c -> 43e32fa5a


[CALCITE-1855] Fix float values in Cassandra adapter


Project: http://git-wip-us.apache.org/repos/asf/calcite/repo
Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/43e32fa5
Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/43e32fa5
Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/43e32fa5

Branch: refs/heads/master
Commit: 43e32fa5a4d5828370dbdf9cffe3bb295ffc475a
Parents: d5c713c
Author: Michael Mior <mmior@uwaterloo.ca>
Authored: Wed Jun 21 00:19:22 2017 -0400
Committer: Michael Mior <mmior@uwaterloo.ca>
Committed: Wed Jun 21 00:19:22 2017 -0400

----------------------------------------------------------------------
 .../apache/calcite/adapter/cassandra/CassandraEnumerator.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/calcite/blob/43e32fa5/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraEnumerator.java
----------------------------------------------------------------------
diff --git a/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraEnumerator.java
b/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraEnumerator.java
index 0c06800..a7436fd 100644
--- a/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraEnumerator.java
+++ b/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraEnumerator.java
@@ -83,8 +83,10 @@ class CassandraEnumerator implements Enumerator<Object> {
       return current.getInt(index);
     } else if (type == DataType.bigint()) {
       return current.getLong(index);
-    } else if (type == DataType.cdouble() || type == DataType.cfloat()) {
+    } else if (type == DataType.cdouble()) {
       return current.getDouble(index);
+    } else if (type == DataType.cfloat()) {
+      return current.getFloat(index);
     } else if (type == DataType.uuid() || type == DataType.timeuuid()) {
       return current.getUUID(index).toString();
     } else {


Mime
View raw message