使用Scala的Datastax Cassandra驱动程序

发布时间：2020-12-16 10:03:06 所属栏目：安全来源：网络整理

导读：我想探索使用 scala的Datastax Cassandra CQL3驱动程序,但我想我可能已经陷入了第一道障碍. 在the Javadoc中创建Cluster对象的方法中,有一个addContactPoints的重载方法,它接受一个String序列或一个java.net.InetAddress序列作为参数. 有没有一种方法可以用

我想探索使用 scala的Datastax Cassandra CQL3驱动程序,但我想我可能已经陷入了第一道障碍.

在the Javadoc中创建Cluster对象的方法中,有一个addContactPoints的重载方法,它接受一个String序列或一个java.net.InetAddress序列作为参数.
有没有一种方法可以用惯用的Scala方式对其进行建模,这样我就可以尝试对输入参数的类型和arity进行模式匹配来调用正确的方法.

同

import com.datastax.driver.core.Cluster

def cp = Cluster.builder().addContactPoint _

def cps = Cluster.builder().addContactPoints _

cp返回

cp: String => com.datastax.driver.core.Cluster.Builder

然而,cps给出了

error: ambiguous reference to overloaded definition,both method addContactPoints in class Builder of type (x$1: <repeated...>[java.net.InetAddress])com.datastax.driver.core.Cluster.Builder

and  method addContactPoints in class Builder of type (x$1: <repeated...>[String])com.datastax.driver.core.Cluster.Builder
match expected type ?

解决方法

那么明确指定函数的类型呢？

import com.datastax.driver.core.Cluster

def cp = Cluster.builder().addContactPoint _
def cps(addresses: [String]) : Cluster.Builder = Cluster.builder().addContactPoints(addresses)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!