astyanax相关内容
如何使用 astyanax 客户端创建带有复合键的表.现在我已经用 cqlsh -3 创建了它,这就是它在 cli 中的样子: [default@KS] 描述 my_cf;列族:my_cf关键验证类:org.apache.cassandra.db.marshal.UTF8Type默认列值验证器:org.apache.cassandra.db.marshal.UTF8Type列排序方式:org.a
..
我有一个 cassandra 列族,它有一个像2012-09-30-05-42-00:30:5856869 我需要查询诸如 之类的东西 select * from cf where key like %5856869% 目前我正在使用 Astyanax ,在 astyanax 中也是可能的.如果不是,哪个实现会支持它. 解决方案 Cassandra 不支持 LIKE 查询.如果
..
我最近开始使用 Cassandra 数据库.现在我正在评估我们应该继续使用哪个 Cassandra 客户端. 我在 stackoverflow 上看到过各种关于 Cassandra 使用哪个客户端的帖子,但没有一个给出非常明确的答案. 我的团队要求我对此进行一些研究,并针对 Java 中的每个 Cassandra Client API 提出某些 优缺点. 正如我提到的,我最近参与
..
所以这是我的困境:我有一个域模型,其中包含一堆 Scala 中的案例类,例如 User 和 Organization.在我的数据访问层(dao、存储库等)中,我使用 astyanax(来自 netflix 的 Java 库),它是实体持久化程序,用于将对象保存到 cassandra 列族. 这是我的 cassandra/astyanax 支持的 DAO 的一些示例代码(是的,我知道我需要做一
..
到目前为止,我仅发现了“选择"示例. 或者可能与MutationBatch? MutationBatch m = keyspace.prepareMutationBatch(); ColumnListMutation cfmStandard = m.withRow(MY_CF, ...); 我的专栏家庭是: CREATE TABLE my_cf (
..
Astyanax 1.56.37连接到在Debian上运行的Cassandra 1.2.6: 当快速连续执行多个插入操作时,Cassandra群集仅包含一个位于10.10.1.141的节点,在看似随机的点上,我将在控制台中看到以下内容: - AddHost: 127.0.0.1 - RemoveHost: 10.10.1.141 每次我尝试连接到此键空间后,每次尝试都会失败,并显示
..
我正在尝试从具有double类型列的Cassandra表中获取Double值.我已经使用CQL3语法创建了该表: CREATE TABLE data_double ( datetime timestamp, value double, primary key (datetime) ); 我插入了一行: INSERT INTO data_double
..
我正在寻找一个像这样的数据模型.在此数据模型中,我正在使用复合键.我知道如何制作复合键.但是在这种情况下,我无法做到. User_Keys_By_Last_Name = { "Engineering" : {"anderson", 1 : "ac1263", "anderson", 2 : "724f02", ... }, "Sales" : { "adams", 1 : "b32
..
我正在使用astyanax连接池,其定义如下: ipSeeds = "LOAD_BALANCER_HOST:9160"; conPool.setSeeds(ipSeeds) .setDiscoveryType(NodeDiscoveryType.TOKEN_AWARE) .setConnectionPoolType(ConnectionPoolType.TOKEN_AWARE); 但是,
..
我是不熟悉astyanax并尝试一些示例程序并遇到此错误的方法.这是一个简单的编写,看起来像是在做一些基本错误的事情.不使用组合键. Caused by: InvalidRequestException(why:Not enough bytes to read value of component 0) at org.apache.cassandra.thrift.Cassandra
..
我在时间戳(T)中插入时间序列数据作为列名,在一列中存储24小时数据的宽列中。流数据是从数据生成器(4个实例,每个具有256个线程)将数据并行插入多行中写入。 CF2(宽列族): RowKey1(T1,V1)(T2,V3) ,V4)...... RowKey2(T1,V1)(T3,V3)..... : : 我现在尝试使用multiget从Cassandra读取此
..
我想用复合主键运行以下代码。 列 result = keyspace.prepareQuery(CF_COUNTER1) .getKey(rowKey) .getColumn(“Column1”) .execute()。getResult Long counterValue = result.getLongValue(); 研究似乎表明它可以是一
..
我们可以在Cassandra Column Family的每一列中有一个复合值吗? user-id column1-name 123(Column1-Value Column1-SchemaName Column1-LastModifiedDate) userId是rowKey。 每个列值将包含以下三个常量: 用于列值的ByteType 用于
..
我使用 Astyanax客户端从 Cassandra数据库中读取数据。我有一个单个集群与四个节点。我有复制因子2 。我试图理解 之间有什么区别。 setMaxConns和setMaxConnsPerHost pre> 方法在Astyanax客户端?我找不到正确的文档。 我有一个多线程代码,它产生多个线程,然后创建一个连接到Cassandra数据库只有一次(因为它
..
问题陈述: - 我正在将数据插入Cassandra数据库。我使用 Netflix / Astyanax客户端。 下面是将数据插入 Cassandra数据库使用 Astyanax客户端。 在我的下面的方法,它接受两个参数。一个是 userId ,我将使用 RowKey 和属性 map,它将包含列名作为键,它的列值作为地图中的值。 现在如何使用 Astyanax客户端到 ups
..
我有一个方案如下: TimeStamp 设备ID 设备名称 设备所有者 设备位置 我使用CQL创建了这个列族,并将主键定义为(TimeStamp,Device ID,Device Name)。通过一个可序列化对象,其中包含DeviceID,名称和字段名称的字段(存储设备所有者或设备位置 )。我已经使用Astyanax插入了一些记录。 根据我的理解,一行的列是通过组合设备I
..
我正在使用Astyanax客户端插入到Cassandra列族的复合列中。 创建列系列USER_DATA with key_validation_class ='UTF8Type' 和comparator ='CompositeType(UTF8Type,UTF8Type,DateType)' 和default_validation_class ='UTF8Type' 和gc_grace
..
我知道从0.8开始,Cassandra保证行更新是原子的。 但是,如果我准备(使用MutationBatch)几个行修改或修改跨几个列族,是否保证行将更新的顺序设置它们?例如如果我有 更新CF 1第1行 更新CF 1第2行 更新CF 2,第3行 可以更新CF 2,而CF 1 >更新CF 1,第1行第A列 更新CF 1第2行 更新CF 2第3行 更新CF 1,第1行
..
我有一个SessionDaoCassandraImpl类,使用Astyanax从Cassandra读取数据,我想用嵌入式Cassandra服务器测试。 CassandraUnit 似乎完美的,但我遇到了异常 错误 - 2012-11-21 14:54:34,754 - AbstractCassandraDaemon.activate(370)|启动期间遇到异常 java.lang.N
..
Astyanax是否通过使用CQL3的准备语句支持“插入”? 我使用最新的Astyanax库1.56.24和Cassandra 1.2.1。当我尝试用CQL3执行一个准备语句: keyspace.prepareQuery(conn.CF_CONTACTS) .withCql “INSERT INTO contacts(a,b)VALUES(?,?);”) .asPreparedSta
..