标签: datastax-java-driver

使用TokenAwarePolicy比当前默认的RoundRobinPolicy有缺点吗？

在我看来,对路由密钥标识为副本的节点的路由请求应始终是可取的,而TokenAwarePolicy包装的RoundRobinPolicy应该是默认的？

我的代码,适用于2.1版本的驱动程序,在2.2-rc2上失败.

这是堆栈跟踪:

Exception occurred in target VM: Value accountExpiryDate is of type timestamp 
com.datastax.driver.core.exceptions.InvalidTypeException: Value accountExpiryDate is of type timestamp
    at com.datastax.driver.core.AbstractGettableByIndexData.checkType(AbstractGettableByIndexData.java:75)
    at com.datastax.driver.core.AbstractGettableByIndexData.getDate(AbstractGettableByIndexData.java:192)
    at com.datastax.driver.core.AbstractGettableData.getDate(AbstractGettableData.java:26)
    at com.datastax.driver.core.AbstractGettableData.getDate(AbstractGettableData.java:113)

Java DSE GraphFrame API不完全支持从GraphTraversal到DataFrame。

下面GraphTraversal来DataFrame是可能的：

gf().E().df()

但是，这不是：

gf().E().hasLabel("foo").df()

这是因为hasLabel()返回GraphTraversal而不是com.datastax.bdp.graph.spark.graphframe.DseGraphTraversal并且GraphTraversal没有df()方法。

每个文档应该有可能

若要完成遍历并返回到DataFrame API（而不是list或迭代器），请使用.df（）方法：

graph.V（）。df（）

我使用的是dse-graph-frames:5.1.4同一起dse-byos_2.11:5.1.4。

这是预期的吗？我真正想要的只是进行一些图遍历并将其转换为DataFrame。

我需要从AWS C *表中插入和提取数据。我的数据生产者是通过Java 8的Spring Boot定义的。

因此，我应该在稳定和高效的项目中使用哪一个。我有办法（我猜这里）1. Sprinda-data-JPA。2. datastax的cassandra-driver-core。

我正在使用 spark-sql 2.4.1、spark-cassandra-connector_2.11-2.4.1.jar 和 java8。当我试图从表中获取数据时，我遇到了

java.io.IOException: Failed to write statements to keyspace1.model_vals. The
latest exception was
  An unexpected error occurred server side on cassandra-node1: com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.util.concurrent.UncheckedExecutionException: java.lang.RuntimeException: org.apache.cassandra.exceptions.ReadTimeoutException: Operation timed out - received only 0 responses.

那么如何从火花代码建立到 Cassandra db 的区域/直流感知连接？

YML

现有的

spring:
  data:
      cassandra:
        keyspace-name: raproduct
        contact-points:
                    - cassandra-node1
                    - cassandra-node2
        port: 9042 

变成

spring:
  data:
      cassandra:
        connection:
          local_dc: southeast-1
        keyspace-name: raproduct
        contact-points:
                    - cassandra-node1
                    - cassandra-node2
        port: 9042 

题

但它没有反映/应用更改后的“local_dc”。如何在 spring-data 中做到这一点？

我知道有人问过这个问题（http://www.datastax.com/support-forums/topic/java-driver-cql-3-bound-statements-in-clause#post-13114，在 IN 中收集的准备好的语句Datastax Cassandra CQL 驱动程序中的子句）

但是，我仍然不知道如何绑定数据。例如，我的 prepareStatement 是

select * from cf where key in (?)

我想要的是绑定数据，cql 看起来像

select * from cf where key in ('key1', 'key2')

现在我有一个 boundStatement。

当我使用 boundStatment.bind() api 时。我试着绑定？但是，对于列表或数组，它说：

列值为 varchar 类型，不能设置为列表

好的，我设置了一个字符串并像这样使用 boundStatement.bind：

boundStatement.bind("'key1','key2'");

没有例外，但结果集是空的。为什么？我认为是因为驱动程序将其解析为

select * from cf where key in (''key1', 'key2'')

（注意一个多余的引号，因为它认为所有的“'key1'和'key2'”都是一个字符串）。

所以，我知道 datastax 在条款中有支持。但我找不到一些例子..

任何人都可以帮助我吗？谢谢！