-
2 votesanswersviews
查询Cassandra多列
我正在使用Cassandra来存储股票信息 . 每个'行'都有一些基本字段,如:时间,价格,收盘价,开盘价,低价,高价等 . 在这些字段的顶部,我有一个浮点型值列表,其中包含一些内部系统计算 . 对象示例: Class stockentry time timestamp; price float; close float; open float; low... -
4 votesanswersviews
Cassandra - 重叠数据范围
我在Cassandra中有以下'Tasks'表 . Task_ID UUID - 分区键 Starts_On TIMESTAMP - 聚类列 Ends_On TIMESTAMP - 聚类列 我想运行一个CQL查询来获取给定日期范围的重叠任务 . 例如,如果我将两个时间戳(T1和T2)作为参数传递给查询,我想获得适用于该范围的所有任务(即重叠记录) . Cassandra最好的... -
28 votesanswersviews
二级索引如何在Cassandra中运行?
假设我有一个列族: CREATE TABLE update_audit ( scopeid bigint, formid bigint, time timestamp, record_link_id bigint, ipaddress text, user_zuid bigint, value text, PRIMARY KEY ((scopeid, formid)... -
1 votesanswersviews
在Cassandra上使用计数器处理自动增量ID的方法?
这不是关于在Cassandra上使用主键自动增量整数而不是UUID的问题,在这种情况下我想在Cassandra上生成像PostgreSQL这样的自动增量效果,不需要一定是可扩展的 . 我正在使用UUID作为表中条目的主键,但我需要为这些条目生成一个像bitly一样的shortid . 所以我试图创建一个应用程序,它抓取特定条目的索引并根据该索引生成一个shortid,然后将shortid设置为条目... -
0 votesanswersviews
使用带有varchar密钥的CQL3在Cassandra中分配大型结果集
我正在努力将旧的基于thrift的代码更新到CQL3 . 代码的一部分是遍历由20M行组成的表的整个数据集 . 由于内存使用,这部分最初崩溃了程序,因此我创建了一个RowIterator类,它使用TokenRanges(和Hector)迭代列族 . 当尝试使用CQL3重写它时,我在分析数据时遇到了麻烦 . 我在http://www.datastax.com/documentation/cql/3.... -
3 votesanswersviews
Cassandra的滑动窗TTL
我正在考虑Cassandra即将推出的潜在项目,我认为它可能非常适合 . 它让我感到困惑的一个潜在地方是数据保留的要求 . 基本上我们有这样的架构: CREATE TABLE Things ( user_id int thing_id int a text static b text static .... more static fields updated_at tim... -
4 votesanswersviews
Cassandra CQL3使用复合主键从表中选择行键
我正在使用Cassandra 1.2.7和使用CQL3的官方Java驱动程序 . 假设由一个表创建 CREATE TABLE foo ( row int, column int, txt text, PRIMARY KEY (row, column) ); 然后我想预制相当于 SELECT DISTINCT row FROM foo 至于我的理解,应该可以... -
1 votesanswersviews
使用主键和辅助键约束查询Cassandra
我在Cassandra中有一张表定义为 CREATE TABLE foo ("A" text, "B" text, "C" text, "D" text, "E" text, "F" text, PRMIARY KEY ("A", "... -
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; ... -
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...