datastax 相关问题

DataStax Enterprise是一个大数据平台,由开源工具组成,如Apache,Cassandra,Solr和Hadoop(以及其他几个)。

java.lang.ClassNotFoundException: com.datastax.spark.connector.rdd.partitioner.CassandraPartition。

我已经使用Cassandra工作了一段时间,现在我正在尝试设置spark和spark-cassandra-connector。我正在使用IntelliJ IDEA来做这件事(第一次使用IntelliJ IDEA和Scala),在 ...

回答 1 投票 0

Cassandra - 有没有办法限制异步查询的次数?

我想知道是否有办法限制cassandra java驱动同时执行的查询数量?目前,我执行了很多查询,如下所示。... PreparedStatement ...

回答 2 投票 4

使用dsbulk将数据加载到Cassandra的第一步

我按照这个指南来设置dsbulk:https:/docs.datastax.comendsbulkdocdsbulkdsbulkSimpleLoad.html 我在这部分感到困惑:dsbulk load -url export.csv -k k ks1 -t table1 \ ...

回答 1 投票 0

dse火花-提交到特定的工作池,而不是 "默认"。

我能够从https:/github.comdatastaxSparkBuildExamplestreemasterscalasbtdsesrcmainscalacomdatastaxsparkexample成功地构建示例项目,我也成功地在...

回答 1 投票 0

如何验证重建操作后数据是否同步?

我在dc-1有一个cassandra集群,现在我已经把我的集群扩展到dc-2,并且扩展了所有的keyspaces,然后在dc-2的所有节点上运行nodetool重建dc-1。现在有没有一种方法,我可以...

回答 1 投票 0

Cassandra 3.11.3.5116

我使用的是Datastax的python驱动版本:3.23 Cassandra版本,DSE版本5.1.16。cqlsh的输出结果如下: [cqlsh 5.0.1]。

回答 1 投票 0

Pyspark使用datastax连接器在Cassandra中插入时间。

我从Pyspark插入数据到Cassandra使用:com.datastax.spark:spark-cassandra-connector_2.11:2.4.0在我插入的变量中也有时间,而连接器不......

回答 1 投票 0

从Hive表读取并写入Cassandra表

我在Cloudera群集的Hive中有一些外部表,按Daily_date列划分。我也有DataStax Enterprise Cassandra集群,在其中创建了与Hive表结构相同的表。 ...

回答 1 投票 0

Cassandra LWT写入产生不正确的数据

我们有一个3节点的Cassandra群集(单个DC),以及一个供运行在不同节点上的应用程序访问(用于读/写)的表。在重负载下,当应用程序的两个实例都是...

回答 1 投票 0

有什么方法可以使用Cassandra压力插入csv文件数据?

我已经使用yaml文件在cassandra压力工具上进行了探索,并且工作正常。我只是想知道是否可以在yaml配置文件中指定任何外部csv文件的位置...

回答 1 投票 0

Cassandra(Datastax)CQL忽略TEXT列的大小写

我已经使用下面的CQL创建了表格:我想运行查询以按演员名称查找所有视频(不区分大小写)。创建表video_by_actor(演员文本,添加的日期时间戳,video_id timeuuid,...

回答 1 投票 0

Cassandra用户定义类型上的Django Queryset引发类型错误

我正在使用DataStax Python驱动程序和Django Cassandra Engine的组合,通过Django应用程序与Cassandra进行通信。这是我如何使用“用户定义的类型”列定义模型的方法(...

回答 1 投票 1

如何使用Cassandra Java驱动程序为所有查询设置一致性级别?

在较早的版本中,我将执行以下操作:QueryOptions queryOptions = new QueryOptions(); queryOptions.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE)cluster = Cluster.builder()....

回答 1 投票 1

Datastax cassandra-driver(python)导入失败

导入datastax cassandra-driver(python)时出现以下错误错误文件“ cassandra.py”,第1行, 从cassandra.cluster导入群集文件“ / home / vagrant / cassandra ... >

回答 2 投票 8

如何使用DSE搜索6.8创建搜索索引

我已经使用Datastax 6.7了几个月。使用经典图形创建搜索索引需要您通过solr admin创建schema.xml和Solrconfig.xml,这很好用。 ...

回答 1 投票 0

从Cassandra columnfamily中的冻结集合列中获取不同的字段值

[嗨,请帮我获得以下要求的cql查询-列族包含以下列:deptid(datatype:uuid emplList(datatype:set Frozen(employee))我将如何获得所有不同的员工姓名...

回答 1 投票 0

为Apache TinkerPop的Spark-Gremlin指定工作池-DataStax-Enterprise Graph-Analytics

我需要指定一个特定的工作池来运行gremlin olap查询。当我使用gremlin控制台或datastax Studio运行gremlin olap查询时,它在默认池下运行(这不是我的...

回答 1 投票 0

dsbulk卸载问题

使用dsbulk卸载时,我收到以下消息。我无法弄清楚这是什么意思[s0 | 347101951 | 0]发送取消请求时出错。这并不重要(请求将...

回答 1 投票 1

Cassandra使用LocalDate截断毫秒

我一直试图在Cassandra中存储直到毫秒的时间戳记值,但是我只能通过DataStax驱动程序获取到LocalDate为止,毫秒部分被省略了。这是我的...

回答 1 投票 0

如何使用spark-cassandra-connector将数据集写入Cassandra表中?

我正在尝试将结构化蒸汽数据集保存到给定的Cassandra表中。我正在使用datastax cassandra连接器版本spark-cassandra-connector_2-11.jar在尝试保存dataSet时,如下所示...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.