-
1 votesanswersviews
cassandra机架和复制因素
我有2个CASSANDRA DC DC1 +-----+ |RAC1 | +-----+ |node1| +-----+ |node2| +-----+ |node3| +-----+ |node4| +-----+ DC2 +-----+-----+-----+ |RAC1 |RAC2 |RAC3 | +-----+-----+-----+ |node1|node1|node1| ... -
1 votesanswersviews
使用Astyanax变异批处理将Map插入到Cassandra CQL3列族中
我有一个Cassandra CQL3列系列,具有以下结构 CREATE TABLE mytable( A text, B text, C text, mymap map<text,text>, D text, PRIMARY KEY (A,B,C) ); 我正在尝试使用Astyanax将一堆数据插入其中 . 我正在使用的Cassandra版本是1.2,所以我不... -
7 votesanswersviews
Cassandra:如何使用CQL插入具有良好性能的新宽行
我正在评估 Cassandra . 我正在使用datastax驱动程序和CQL . 我想存储一些具有以下内部结构的数据,其中每个更新的名称都不同 . +-------+-------+-------+-------+-------+-------+ | | name1 | name2 | name3 | ... | nameN | | time +-------+-------... -
0 votesanswersviews
分区键部件URL的空值无效
我有以下代码尝试在spark中加入2个cassandra表 . val imageKeywords = sc.cassandraTable[ImageMetadata]("images", "metadata") val imageAndPageKeywords = imageKeywords .joinWithCassandraTable[Pages... -
2 votesanswersviews
Cassandra表创建失败,错误请求:输入不匹配
我创建了一个Cassandra键空间跟踪器: CREATE KEYSPACE tracker WITH replication = { 'class': 'SimpleStrategy', 'replication_factor': '3' }; 然后我可以在这个键空间中成功创建一个表: cqlsh:tracker> CREATE TABLE tracker.click_windo... -
4 votesanswersviews
插入错误与cassandra CQL3-Hex字节转换错误
当我使用cassandra -jdbc将数据惰性化到表中时我得到错误java.sql.SQLSyntaxErrorException:无法将'ani'解析为十六进制字节 在localhost:9160连接到测试群集 . [cqlsh 2.3.0 | Cassandra 1.2.0 | CQL规范3.0.0 | Thrift协议19.35.0]使用CQL3创建表 cqlsh:testkeyspac... -
0 votesanswersviews
使用二进制协议的Cassandra cql版本
在我的命令行showConnected到localhost:9160的测试群集 . 版本,但cql3二进制协议主机是不同的我应该做什么,而不是在cassandra中使用thrift到二进制协议 . -
4 votesanswersviews
Cassandra - 重叠数据范围
我在Cassandra中有以下'Tasks'表 . Task_ID UUID - 分区键 Starts_On TIMESTAMP - 聚类列 Ends_On TIMESTAMP - 聚类列 我想运行一个CQL查询来获取给定日期范围的重叠任务 . 例如,如果我将两个时间戳(T1和T2)作为参数传递给查询,我想获得适用于该范围的所有任务(即重叠记录) . Cassandra最好的... -
5 votesanswersviews
在使用Datastax API(使用新的二进制协议)时在Cassandra中创建列族或表
我已经开始使用Cassandra数据库了 . 我打算用Datastax API来插入/读入cassandra数据库 . 我对这个Datastax API(使用新的二进制协议)完全不熟悉,我也找不到很多具有一些适当示例的文档 . 当我使用Netflix客户端(Astyanax客户端)使用Cassandra CLI时,我创建了像这样的列族 - create column family profile ... -
4 votesanswersviews
如何使用带有Datastax Java驱动程序的CQL向Cassandra添加任意列?
我最近开始对 CQL 感兴趣,因为我正在考虑使用Datastax Java驱动程序 . 以前,我使用 column family 而不是表,我使用的是Astyanax驱动程序 . 我需要澄清一些事情 - 我在 生产环境 集群中使用以下列族定义 . 我可以动态插入任意列(及其值),而无需实际修改列族模式 . create column family FAMILY_DATA with key_vali... -
0 votesanswersviews
尝试通过单元在Cassandra中创建列族时出现InvalidQueryException
我有一个3节点cassandra集群,通过我在Java中的单元测试,我首先创建一个键空间,然后在该键空间内创建一个列族 . 有时单元测试通过但随机我不断收到以下错误 . 我在2.1.0中使用最新的datastax 2.1.4 java驱动程序和cassandra版本 . com.symc.edp.database.nosql.NoSQLPersistenceException: com.datas... -
2 votesanswersviews
查询Cassandra多列
我正在使用Cassandra来存储股票信息 . 每个'行'都有一些基本字段,如:时间,价格,收盘价,开盘价,低价,高价等 . 在这些字段的顶部,我有一个浮点型值列表,其中包含一些内部系统计算 . 对象示例: Class stockentry time timestamp; price float; close float; open float; low... -
1 votesanswersviews
Cassandra:要插入数千条记录
我正在使用带有C驱动程序的Cassandra,并且在插入数千行时我发现性能非常慢 . 我正在使用VM Ubuntu 12.04 LTS与8Go Ram和4CPU . 我有一个包含15800条记录的ascii文件,我正在尝试读取每条记录并填充我的cassandra数据库表 . “COPY”命令大约需要1分30秒 . 在逐个阅读每条记录后进行查询需要大约6-7分钟,并且需要一次批量查询(持续30分钟... -
1 votesanswersviews
Cassandra插入失败
我们在cassandra表中编写数据时遇到了问题 . 流程如下:我们使用一些主键删除 XXX 中的所有记录 . 然后在循环中插入新的 . execute("DELETE FROM XXX WHERE key = {SOME_UUID}"); for(int i = 0; i < 5; ++i) { execute("INSERT INTO XXX (k... -
1 votesanswersviews
Datastax Cassandra中的动态列族
因为有一种方法可以通过CQL 3在Cassandra中创建动态列族,即使用具有COMPACT STORAGE的复合主键 . 用于在动态列族(宽行)中插入数据,这将是有效的方式,datastax java驱动程序或Thrift API . 由于我正在使用Datastax,而Datastax强烈建议使用非紧凑表来进行新开发,尽管非紧凑表在内部不那么“紧凑”,那么我应该如何创建动态列族,使用CO... -
2 votesanswersviews
在CQL查询中使用Cassandra 'com.datastax.bdp.search.solr.Cql3SolrSecondaryIndex'
com.datastax.bdp.search.solr.Cql3SolrSecondaryIndex是Datastax为Solr集成引入的自定义Cassandra索引类型 . 我的主要问题是:_1565043已经尝试了一些带有索引列过滤器的CQL查询,但它们总是以RPC超时结束 . My use case: 我有一个表,其中查询通常涉及多列的过滤器 . 自从Cassandra 's native... -
0 votesanswersviews
Cassandra复合关键性能
我正在使用Cassandra来保存日志,而在客户端我想要显示某天的所有日志 . 当然有一天会有成千上万的日志记录,我需要使用分页 . 我看到在cassandra中的分页不像“本机”,我们需要使用一些“技巧”,比如保存最后一个检索记录,并在该记录之后查找更多记录 . 我的想法是保存uuid和日期为主键,然后按日期命令列familly,所以我可以传递uuid和date,cassandra应该在该记录后... -
0 votesanswersviews
查询以获取cassandra中多个范围的记录
我有以下型号: CREATE TABLE IF NOT EXISTS log ( date varchar, timeid timeuuid, message varchar, ip varchar, time timestamp, user bigint, file varchar, line int, func varchar, level int, ... -
2 votesanswersviews
Cassandra CQL选择查询不返回时间戳为clusterkey的记录
Cassandra CQL:使用组合键和集群键创建的表 . 当我尝试从分区键执行select *然后我能够检索所有数据,它也适用于关系运算符(<或>) . 但是当我使用具有适当值的等于(=)运算符查询特定簇密钥时,它返回0行 . Table: CREATE TABLE entity_data ( received_date timestamp, entity text, receive... -
2 votesanswersviews
cassandra结果分页
假设,我有一个从cassandra读取数据的应用程序,并以每行10行或20行的行显示给用户 . 有没有办法在cassandra有效地做到这一点?假设,我有一个表'ks1.cf1',分区键'pk'和聚类列'ck',每个分区有超过1000行,我想一次向用户显示每个分区10行 . 一种方法是运行 SELECT * FROM ks1.cf1 LIMIT 10; 并获取最后一行并根据聚类列(值为'ck')执... -
4 votesanswersviews
cassandra在索引列上选择,并且不支持PRIMARY KEY的IN子句
在Cassandra,我正在使用cql: select msg from log where id in ('A', 'B') and filter1 = 'filter' (其中 id 是分区键, filter1 是辅助索引, filter1 不能用作群集列) 这给出了回复: Select on indexed columns and with IN clause for the PRIMAR... -
2 votesanswersviews
在CQL上使用IN运算符分区键和(聚类键或索引列)
我有一个警报表 . 我想在2列上使用IN运算符并在一列上使用大于运算符来查询它 . 我没试过下面的事情 . 有人可以告诉我DB设计使查询工作吗?我的环境细节:[cqlsh 5.0.1 | Cassandra 2.1.2 | CQL规范3.2.0 |原生协议v3] 在分区键中使用'type': CREATE TABLE alerts ( serialNumber text, time... -
1 votesanswersviews
使用复合分区键在Cassandra中进行CQL查询
我的主要问题是在具有复合分区键的表上对Cassandra结果集进行分页 . 但是,我试图通过一个简单的场景缩小范围 . 说,我有一张 table , CREATE TABLE numberofrequests ( cluster text, date text, time text, numberofrequests int, PRIMARY KEY ((cluster, date... -
1 votesanswersviews
Cassandra使用thrift在CQL3中准备语句
我正在寻找有关预准备语句(ps)livecycle的信息 . 我正在使用apache提供的BasePoolableObjectFactory来 Build 连接池 . 然后,使用TSocket和TTransport,我正在从Cassadra.Client类创建一个对象 . 该对象具有执行cql3查询的方法 . 该对象还有准备和执行cql3查询的方法,即我们可以使用thrift编写预处理语句 . 准... -
2 votesanswersviews
Cassandra cppdriver查询字符串缓冲区溢出?
我一直在为CQL3.0编写Cassandra cppdriver的包装器,我遇到了一些奇怪的行为,我不确定它是典型的还是错误的 . 作为参考,我正在使用9月4日(来自存储库)的cppdriver代码版本,libuv0.10以及发布在datastax网站上的歌曲/播放列表示例(http://www.datastax.com/documentation/cql/3.1/cql/ddl/ddl_musi... -
4 votesanswersviews
Cassandra批处理语句 - 执行顺序
我有一个Cassandra的批处理语句,它包含一个删除和相同分区键的insert语句,其中delete是第一个语句,insert是第二个 . 批处理语句如何执行这些语句?是否按照相同的顺序,我们添加了语句? -
1 votesanswersviews
Cassandra中的用户定义类型(UDT)行为
如果有人在使用UDT(用户定义类型)方面有一些经验,我想了解向后兼容性如何工作 . 说我有以下UDT CREATE TYPE addr ( street1 text, zip text, state text ); 如果我修改“addr”UDT以获得更多属性(例如zip_code2 int和name text): CREATE TYPE addr ( street1 text, ... -
0 votesanswersviews
cassandra-spring摄取命令不起作用
我已经 Build 了一个cassandra集群并使用spring-cassandra框架1.53 . (http://docs.spring.io/spring-data/cassandra/docs/1.5.3.RELEASE/reference/html/) 我想在我的cassandra集群中写入数百万个数据集 . 使用executeAsync的解决方案运行良好,但Spring框架中的“摄... -
0 votesanswersviews
Cassandra选择ttl()的TTL值不正确
I have a 3 node cluster with replication factor : 2. 考虑的列族有 default_time_to_live = 3600 哪个是使用alter table设置的: cqlsh:summary> alter table match with default_time_to_live=3600; 将数据插入columnfamily并立即查询后... -
6 votesanswersviews
如果在更新时未指定TTL,则Cassandra TTL在主键上设置为0,但如果是,则主键上的TTL不会更改
Cassandra中的这种行为似乎违反直觉,我想知道为什么会发生这种情况,并可能解决这个问题 . 想象一下,我有一个包含三列的表: pk ,主键, text 类型, foo , bigint 和 bar ,另一个 text . insert into keyspace.table (pk, foo, bar) values ('first', 1, 'test') using ttl 60; ...