cassandra 相关问题

Cassandra是一个高度可扩展,最终一致,分布式,结构化的行/列存储。

带有排序查询建模的Cassandra过滤器

我是Cassandra的新手,我正在尝试在卡桑德拉建模。我的查询看起来像下面的查询#1:从TableA中选择*其中Id =“123”查询#2:从TableA中选择*其中name =“test”...

回答 1 投票 0

无法使用Python导出Cassandra表

我正在尝试使用Python将Cassandra表导出为CSV格式。但我不能这样做。但是,我能够从Python执行'select'语句。我使用了以下代码:来自cassandra ....

回答 1 投票 2

CASSANDRA-12813的解决方法:auth中的NPE用于自举节点

我有一个cassandra 3.9生产集群,我正在尝试向该集群添加一个节点。但是我看到了这个问题。 CASSANDRA-12813 NPE in auth for bootstrapping node https://issues.apache.org / ...

回答 1 投票 0

cubernetes cassandra操作员错误

我为kubernetes创建cassandra运算符时遇到错误。 #kubectl create -f example-cassandra-cluster.yaml错误:无法识别“example-cassandra-cluster.yaml”:没有匹配...

回答 1 投票 1

这是因为Node.js的异步性质还是有任何其他方法来实现这一点?

这就是我想要做的。我有一个空数组var send_data = [];我正在使用node.js的“sync-each”npm库之前我正在使用map回调进行迭代...

回答 1 投票 0

创建数据库生成的查询中缺少Cassandra phantom-dsl派生列

我有以下表定义导入com.outworkers.phantom.builder.primitives.Primitive import com.outworkers.phantom.dsl._ abstract class DST [V,P

回答 1 投票 0

将大量有序时间序列数据存储在大型衍生品中

我试图弄清楚这些新的数据存储如bigtable,hbase和cassandra到底是什么。我处理大量股票市场数据,数十亿行价格/ ......

回答 6 投票 39

cassandra.yaml中的群集配置问题,用于多节点群集,其中只有1个公共IP

我想知道cassandra.yaml的配置参数,即特定场景中各个节点上的listen_address broadcast_address rpc_address broadcast_rpc_address。 ...

回答 1 投票 0

由于未知的列族,卡桑德拉没有开始

在向键空间添加/删除表和视图之后,出现了与先前删除的表不一致和错误的问题。我们尝试重新启动集群节点,只导致节点...

回答 1 投票 0

在Cassandra 3.0多节点集群中回收磁盘空间的最佳实践

在我的5节点集群上,我发布了各种drop table 。 命令。在该操作之后,他们在各个节点上的数据仍然存在于/ var / lib / cassandra / data // I ...

回答 3 投票 2

Elassandra - Kibana创建索引和可视化的问题

我们尝试将Elassandra(2017-05-22版本2.4.5.1 Elasticsearch 2.4.5 + Cassandra 3.0.13)与Kibana(4..6.4)集成在一起。但我们正在努力解决以下问题。 log [10:01:51.003] [...

回答 1 投票 0

java.lang.AssertionError:Cassandra守护程序未在超时内启动

我的测试类:公共类NetworkSettingsDaoTest {@Rule public CassandraCQLUnit cassandraCQLUnit = new CassandraCQLUnit(new ClassPathCQLDataSet(“simpleWithCreateKeyspace.cql”));公共静态......

回答 3 投票 2

在Cassandra nodetool修复期间打开的文件太多

我在一个节点上创建了一个nodetool repair命令。此节点发生故障,日志文件显示以下错误消息:INFO [STREAM-IN- / 192.168.2.100] 2015-02-13 21:36:23,077 StreamResultFuture ....

回答 1 投票 4

将从joinWithCassandraTable获取的CassandraRow转换为DataFrame

case class SourcePartition(id:String,host:String,bucket:Int)joinedRDDs = partitions.joinWithCassandraTable(“db_name”,“table_name”)joinedRDDs.values.foreach(println)我必须使用...

回答 1 投票 1

Cassandra有没有这种模式的模式?

我有2个表,基本上一切都是一样的,除了在第一个表中我们有PLAYER_ID作为最后一列,在第二个表中我们有NUM_OF_PLAYERS。所以这就是我...

回答 1 投票 0

如何从java获取聚合Cassandra行数据

我在Cassandra有一个表,其中包含int列价格和数量以及项目。以下是表值:商品价格数量x。 10. 100 y。 11. 200 z。 12. 300瓦。 13. 400现在......

回答 1 投票 0

使用object-sizeof依赖项会对内存产生什么影响

我使用object-sizeof依赖来了解批量大小。这是我在cassandra客户端上执行的批量插入查询数组:var queries = [...] var size_in_bytes = require('...

回答 2 投票 0

Cassandra数据库上数据分析的替代方案

我们需要对Cassandra数据库执行分析和报告。以下是我们迄今已确定的方法。 1)在cassandra顶部使用火花。缺点:我们会严重...

回答 1 投票 2

Thingsboard处理来自设备的数据并将其重新注入新的遥测数据

我正在开发一个物联网项目,该项目涉及一个传感器将其值传输到物联网平台。我目前正在测试的平台之一是Thingsboard,它是开源的,我觉得它很......

回答 1 投票 1

如何使用Apache Flink阅读Cassandra?

我的flink程序应该对每个输入记录进行Cassandra查找,并根据结果进行一些进一步的处理。但我目前仍在阅读Cassandra的数据。这是......

回答 1 投票 0

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