如何使用Python删除Cassandra中的记录？ 我正在使用cassandra-driver并通过object mapper API访问我的数据。
浏览 10提问于2019-06-24得票数 0
回答已采纳
我到处都找过了，要使用Erlang中的Cassandra，你最终必须下载(其中包括)：：然后手动生成erlang库，然后复制lib文件和beams文件。如果有人能给我看一些用户友好的文档，我将不胜感激。
浏览 0提问于2010-04-25得票数 2
我正在Databricks notebook上编写pyspark脚本来插入/更新/查询cassandra表，但是我找不到从表中删除行的方法，我尝试了spark sql： spark.sql("DELETEfrom users_by_email where email_address IN ('abc@test.com')") 我也不认为使用dataframe删除数据是可能的。
浏览 25提问于2019-12-17得票数 0
回答已采纳
我使用以下代码将预测结果保存到使用spark Cassandra连接器的Cassandra DB中： CassandraJavaUtil.mapToRow(SensorData2Double.class)).saveToCassandra();
数据基于以秒为单位的时间戳因此，预测的写入
浏览 0提问于2017-06-22得票数 1
1回答
卡桑德拉井长增加测井详细度
、、、、
我是卡桑德拉蟒蛇的新客户。目前，我正在调试一个与本地cassandra客户端有关的问题。同样，我希望增加cassandra cqlengine客户端的日志记录详细度。我希望看到客户端在进行数据库调用时正在做什么的详细日志。无论如何，我都找不到用文档中定义的客户端api来做这件事。
我使用的是卡桑德拉版本的3.3.0和python
浏览 8提问于2017-03-08得票数 2
回答已采纳
我正在构建一个接近实时/微批处理的数据应用程序，使用Cassandra作为查找存储。每次增量运行有大约40K条记录，而Cassandra表有大约1.5亿条记录。在每次运行中，我需要查找id字段并从Cassandra获取一些属性。这些查找可以是随机的(不是任何时间/地区/国家的依赖)，因此没有明确的分区方案。我应该如何对Cassandra</em
浏览 19提问于2019-09-19得票数 0
我重复执行一个操作，在每次迭代时在我的Cassandra表中创建一条记录。但是，出于我的目的，我只需要存储有限数量的最新结果。陈旧的行并不有趣，而且数据库的大小也会迅速膨胀，因为该操作意味着要在许多天内每秒运行多次。
我基本上是使用Cassandra表作为缓冲区。这是设计出来的。有没有一种方法可以设置Cassandra限制一个表可以有多少行，并在推送新行时自动删除
浏览 3提问于2019-06-24得票数 1
我看到了一个奇怪的问题，Elasticsearch滚动或搜索API返回了一组我不能再通过I获取的文档。我使用Elassandra (Cassandra + ES)，它使用Elasticsearch作为辅助索引存储。Cassandra记录上有TTL，由于TTL而被删除，但ids仍然在Elasticsearch中。为什么这是一种奇怪的行为？我确实在Elasticsearch上刷新并强制出现了相应
浏览 1提问于2018-07-04得票数 0
1回答
我试图使用Titan Graph建立网络拓扑模型，我想从python应用程序中指定拓扑。 public Iterable<ISwitchObject> getSwitch();
PYTHONOBJECTS ----> B
浏览 0提问于2014-04-21得票数 3
回答已采纳
我在2.3.0版本中使用WSO2BAM，其中定义了一个流，其中保存了Cassandra数据源中的大量数据。目前，我的Hive脚本处理来自键空间的所有事件，其中99%的数据是不相关的。我的想法是在没有必要的情况下清除这些数据。{“名称”：“audit_usecs”，“类型”：“字符串”}，{“名称”：“user_name”，“类型”：“STRING”}}
我的意图是在收到具有特定payload_id_
浏览 4提问于2013-11-13得票数 0
我有15个字段的数十亿条记录，我想将它们插入到Cassandra中(使用Java api)。由于我的查询搜索关键字可以是记录的五个不同字段之一(即，对字段3或7或8或13或14的搜索查询)，因此我在Cassandra中创建了5个相同的表，使用不同的主键(类似于enter link description现在我读取一条记录
浏览 15提问于2018-12-27得票数 0
我正在考虑Cassandra是否可以为我们的服务器软件提供分布式数据库存储。
服务器软件是用Delphi编写的，但我很难找到如何从Delphi访问Cassandra数据库的描述。
浏览 1提问于2010-03-17得票数 2
当我执行Cassandra查询时，它总是返回空的结果，但是cassandra表中有记录。
当删除操作发生在同一个分区上时，我将面临这个问题。例如：分区A包含1条M记录，更早的时候，我在同一个分区A上删除了900 K记录。后来，我无法在相同分区上获得剩余的100 K记录。有时抛出ReadTimeoutException或返回空的结果.这是在使用querying框架数
浏览 7提问于2020-10-16得票数 3
有关例外的详情如下：ERROR 06:49:10 Exiting due to error while(CommitLogDescriptor.java:73) ~[apache-cassandra-2.1.9.jar:2.1.9]
at org.apache.cassandra.db.commitlog.CommitLogSegment<init>(CommitLogSegment.java:168) ~[apac
浏览 8提问于2015-09-28得票数 1
回答已采纳
我目前正在尝试将我的应用程序升级到Spark 3.0.1。为了创建表，我使用cassandra-driver、Python-Cassandra连接器删除并创建表。然后，我使用spark-cassandra连接器将数据帧写入到表中。只使用spark-cassandra连接器创建和删除表并不是一个很好的选择。在Spark 2.4中，drop-crea
浏览 42提问于2020-10-19得票数 1
我想查询我的Cassandra表，它的模式是 id text, firstname text, email text, );
我想使用login我在某处读到Spark在这些scenarios.So中非常有帮助，我想知道如何使用Spa
浏览 1提问于2018-03-23得票数 0
1回答
我正在使用Spark Cassandra连接器和python中的数据帧制作一个小的Spark应用程序，但我的写入速度非常慢。我正在从Cassandra读取一些数据到一个表中，然后对它们进行一些操作(这也会使集合变得更大)。3个运行在Docker容器中的Cassandra节点，每个节点都在运行CoreOS的不同节点上，具有2 GB的ram和2个在D
浏览 1提问于2017-03-29得票数 4
2回答
already satisfied: futures in /home/ubilab/.local/lib/python2.7/site-packages (from cassandra-driver) (3.2.0)
Requirement already satisfied: six>=1.9 in /usr/local/lib/python2.7/dist-packages (from cassandra</em
浏览 0提问于2018-11-28得票数 0
假设一个最简单的Cassandra表位于由2个节点组成的Cassandra集群上。然后node#2又出现了，它试图与node#1同步数据。Node#2声称它有node#1没有的记录。他们怎么知道它是一个删除操作，从node
浏览 2提问于2017-05-08得票数 1
回答已采纳
我用卡桑德拉装载机把一辆大的CSV装进卡桑德拉。我无法运行nodetool repair，因为它只在节点联机时才能工作。at org.apache.cassandra.io.util.SegmentedFile$Builder.complete(SegmentedFile.java:187) ~[apache-cassandra<em
浏览 2提问于2015-10-23得票数 32
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
