[calcite] branch master updated: [CALCITE-2805] Allow string ports in Cassandra adapter schema

[mmior]

This is an automated email from the ASF dual-hosted git repository.

mmior pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/calcite.git


The following commit(s) were added to refs/heads/master by this push:
     new cd01913  [CALCITE-2805] Allow string ports in Cassandra adapter schema
cd01913 is described below

commit cd01913c2c2333ea120b3b5dedcdacf40c618de4
Author: Michael Mior <mm...@cs.rit.edu>
AuthorDate: Fri Jan 25 15:41:48 2019 -0500

    [CALCITE-2805] Allow string ports in Cassandra adapter schema
---
 .../apache/calcite/adapter/cassandra/CassandraSchemaFactory.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraSchemaFactory.java
 
b/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraSchemaFactory.java
index 3b2ab96..eb94ef5 100644
--- 
a/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraSchemaFactory.java
+++ 
b/cassandra/src/main/java/org/apache/calcite/adapter/cassandra/CassandraSchemaFactory.java
@@ -39,7 +39,13 @@ public class CassandraSchemaFactory implements SchemaFactory 
{
     String password = (String) map.get("password");
 
     if (map.containsKey("port")) {
-      int port = (int) map.get("port");
+      Object portObj = map.get("port");
+      int port;
+      if (portObj instanceof String) {
+        port = Integer.parseInt((String) portObj);
+      } else {
+        port = (int) portObj;
+      }
       return new CassandraSchema(host, port, keyspace, username, password, 
parentSchema, name);
     } else {
       return new CassandraSchema(host, keyspace, username, password, 
parentSchema, name);