Hector:如何查询复合类型的各个部分
我使用 CompositeType 存储数据,如下所示: RowKey: 101390 => (column=1320987600000:P:350.0:symbol, value=AAPL/F6LbE.O, timestamp=132077171156…
Hector querySuperColumn 与 countSubColumns 不匹配
我有一个超级列族: Logger { superKey : { nameKey : {name1:val1, name2:val2, ..., name8945:val8945} } } 这是一个代码: ThriftSuperCfTemplate …
如何从 cassandra 和 hector 中获取反列的值?
您好,我正在尝试使用 hector 从 cassandra 获取数据。 有两种方法可以做到这一点。 一个是像这样的 cqlQuery: CqlQuery cqlQuery = new CqlQuery(co…
cassandra DB 的 Hector API 中的 SliceQuery 抛出 HInvalidRequestException:InvalidRequestException(原因:Key 可能不为空)
我将用户名和密码作为以 userName 键控的 ColumnFamily 的列。 使用比较器 = UTF8Type 创建列族 TestUserInfo column_metadata = [{column_name:用户…
Cassandra 客户端 - 将列检查为字符串
我是 Cassandra 和 Cassandra 的新手。我正在使用 Hector Java 客户端进行写入/读取。 我有以下代码来插入值 - Mutator mutator = HFactory.createMut…
计算列数,CountQuery 与 SliceQuery 操作非常慢
我编写了一个“人口普查”程序来迭代列族中的所有行,并在每行中对列进行计数,记录最大值和行键。我花了更多的时间在 Hector 客户端上,但也编写了一…
Hector (Cassandra) 序列化异常
问:我正在使用 hector(cassandra 客户端)并将 UTF8 类型值存储在列中,在客户端,我使用 hector 的 StringSerializer 来序列化/反序列化值。它适用…
如何为列族定义复合键,然后使用 Hector 引用它?
我在哪里可以找到这方面的样本? 我的大部分代码使用 ColumnFamilyTemplate 对数据记录进行 CRUD,请参见下文。定义复合键后,我是否仍然可以使用 Col…
赫克托·斯卡拉类型不匹配
可能出什么问题了? val is = IntegerSerializer.get mutator.addInsertion(deviceId, COLUMN_FAMILY_CARSTATUS, createColumn("mileage", 111, ss, i…
Cassandra启动问题
首先,我读了这个这个 。 我无法让 Cassandra 再次启动并运行。 我使用 Hector 作为客户端来连接到 Cassandra 0.8.2 和 Cassandra 0.8.2 的实例。加载…
Cassandra Hector 加载器应用程序内存不足
这个简单的应用程序采用带有标头的逗号 delim 文件并将其放入 Cassandra 中。 它适用于小文件,但是内存只会增加,直到内存不足异常杀死它。 我缺少什…
赫克托+ Cassandra:获取列族列表
我正在尝试获取当前使用的键空间中的所有列族,因为我想摆脱错误: InvalidRequestException(why:[column family]已经存在于键空间中) 我的逻辑是获取…
Hector 的批处理突变与使用 Hadoop 作业将数据加载到 Cassandra 中的比较?
有人可以强调 Hector 的批量突变和使用 Hadoop 作业将数据加载到 Cassandra 的优缺点吗? 我知道在 Hector 中你可以执行如下操作: mutator.addInsert…
Cassandra 中副本之间的计数器值不一致
我有一个 3 台机器的 Cassandra 集群,使用机架不知道的放置策略,复制因子为 2。 列族定义如下: create column family UserGeneralStats with compa…