DataStax Enterprise是一个大数据平台,由开源工具组成,如Apache,Cassandra,Solr和Hadoop(以及其他几个)。
我想知道是否有办法限制cassandra java驱动同时执行的查询数量?目前,我执行了很多查询,如下所示。... PreparedStatement ...
我按照这个指南来设置dsbulk:https:/docs.datastax.comendsbulkdocdsbulkdsbulkSimpleLoad.html 我在这部分感到困惑:dsbulk load -url export.csv -k k ks1 -t table1 \ ...
我能够从https:/github.comdatastaxSparkBuildExamplestreemasterscalasbtdsesrcmainscalacomdatastaxsparkexample成功地构建示例项目,我也成功地在...
我在dc-1有一个cassandra集群,现在我已经把我的集群扩展到dc-2,并且扩展了所有的keyspaces,然后在dc-2的所有节点上运行nodetool重建dc-1。现在有没有一种方法,我可以...
我使用的是Datastax的python驱动版本:3.23 Cassandra版本,DSE版本5.1.16。cqlsh的输出结果如下: [cqlsh 5.0.1]。
Pyspark使用datastax连接器在Cassandra中插入时间。
我从Pyspark插入数据到Cassandra使用:com.datastax.spark:spark-cassandra-connector_2.11:2.4.0在我插入的变量中也有时间,而连接器不......
我在Cloudera群集的Hive中有一些外部表,按Daily_date列划分。我也有DataStax Enterprise Cassandra集群,在其中创建了与Hive表结构相同的表。 ...
我们有一个3节点的Cassandra群集(单个DC),以及一个供运行在不同节点上的应用程序访问(用于读/写)的表。在重负载下,当应用程序的两个实例都是...
有什么方法可以使用Cassandra压力插入csv文件数据?
我已经使用yaml文件在cassandra压力工具上进行了探索,并且工作正常。我只是想知道是否可以在yaml配置文件中指定任何外部csv文件的位置...
Cassandra(Datastax)CQL忽略TEXT列的大小写
我已经使用下面的CQL创建了表格:我想运行查询以按演员名称查找所有视频(不区分大小写)。创建表video_by_actor(演员文本,添加的日期时间戳,video_id timeuuid,...
Cassandra用户定义类型上的Django Queryset引发类型错误
我正在使用DataStax Python驱动程序和Django Cassandra Engine的组合,通过Django应用程序与Cassandra进行通信。这是我如何使用“用户定义的类型”列定义模型的方法(...
如何使用Cassandra Java驱动程序为所有查询设置一致性级别?
在较早的版本中,我将执行以下操作:QueryOptions queryOptions = new QueryOptions(); queryOptions.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE)cluster = Cluster.builder()....
Datastax cassandra-driver(python)导入失败
导入datastax cassandra-driver(python)时出现以下错误错误文件“ cassandra.py”,第1行, 从cassandra.cluster导入群集文件“ / home / vagrant / cassandra ... >
我已经使用Datastax 6.7了几个月。使用经典图形创建搜索索引需要您通过solr admin创建schema.xml和Solrconfig.xml,这很好用。 ...
从Cassandra columnfamily中的冻结集合列中获取不同的字段值
[嗨,请帮我获得以下要求的cql查询-列族包含以下列:deptid(datatype:uuid emplList(datatype:set Frozen(employee))我将如何获得所有不同的员工姓名...
为Apache TinkerPop的Spark-Gremlin指定工作池-DataStax-Enterprise Graph-Analytics
我需要指定一个特定的工作池来运行gremlin olap查询。当我使用gremlin控制台或datastax Studio运行gremlin olap查询时,它在默认池下运行(这不是我的...
使用dsbulk卸载时,我收到以下消息。我无法弄清楚这是什么意思[s0 | 347101951 | 0]发送取消请求时出错。这并不重要(请求将...
我一直试图在Cassandra中存储直到毫秒的时间戳记值,但是我只能通过DataStax驱动程序获取到LocalDate为止,毫秒部分被省略了。这是我的...
如何使用spark-cassandra-connector将数据集写入Cassandra表中?
我正在尝试将结构化蒸汽数据集保存到给定的Cassandra表中。我正在使用datastax cassandra连接器版本spark-cassandra-connector_2-11.jar在尝试保存dataSet时,如下所示...
重启Ubuntu 16.04计算机后无法启动Cassandra 3.11.6服务
我在Ubuntu 16.04中有Cassandra 3.11.6。一旦我在第一时间安装了Cassandra,就可以正常工作。但是我重新启动机器,然后尝试连接它时显示如下错误:('...