问题标签 [hector]

我一直在尝试使用以下一组行创建索引。

但我无法这样做。实际上，我动态地将数据存储在列中，并动态地创建这些列，之后为了更好的查询目的，我试图在某些特定列上放置索引。任何建议请如何做到这一点。

对于我的应用程序的操作监控，我正在寻找类似于常用的“SQL连接验证”查询的东西

选择 1;

在 Cassandra 中，使用 Hector 驱动程序。我尝试过查看 Cluster.getKnownPoolHosts() 和 .getConnectionManager().getActivePools() 之类的方法。但似乎它们的状态并没有持续更新，只有当我实际尝试通过查询访问 Cassandra 时。

我希望我的健康检查独立于任何需要存在的键空间或用户 CF，因此仅运行“虚拟”查询似乎很困难（反对什么？）。当然，它不应该占用大量内存或产生任何重大负载。

我可以强制 Hector 在不运行真正查询的情况下以某种方式更新其连接池状态吗？

（顺便说一句：CQL 甚至不接受“SELECT 1”作为有效查询。）

我正在寻找一个列族，我可以在其中添加超级列和普通列，如下例所示

可能吗？如果是，请建议提前致谢

我想根据超级列名检索不同的行 id 值。为此，我使用了此代码

但它不起作用。

我正在编写一个 java 代码来访问存储在 Cassandra 中的数据。我正在使用赫克托 API。

为了检索数据，我使用切片查询。但它似乎只支持五个算术运算符，并且也支持 AND 运算符。

有没有办法用 OR 运算符编写谓词或基于字符串中的包含功能进行查询。？？？

使用这行代码创建集群很简单：

编译正常，运行时出现以下错误。感谢任何建议。

错误：[java] INFO 连接。CassandraHostRetryService：停机主机重试服务以队列大小 -1 开始，重试延迟 10 秒 [java] 线程“主”java.lang.NoClassDefFoundError 中的异常：org/apache/cassandra/thrift/InvalidRequestException [java ] 在 me.prettyprint.cassandra.connection.ConcurrentHClientPool.(ConcurrentHClientPool.java:48) [java] 在 me.prettyprint.cassandra.connection.RoundRobinBalancingPolicy.createConnection(RoundRobinBalancingPolicy.java:68) [java] 在 me.prettyprint.cassandra .connection.HConnectionManager.(HConnectionManager.java:65) [java] 在 me.prettyprint.cassandra.service.AbstractCluster.(AbstractCluster.java:69) [java] 在 me.prettyprint.cassandra.service.AbstractCluster.(AbstractCluster. java:65) [java] 在 me.prettyprint.cassandra。service.ThriftCluster.(ThriftCluster.java:17) [java] 在 me.prettyprint.hector.api.factory.HFactory.createCluster(HFactory.java:176) [java] 在 me.prettyprint.hector.api.factory.HFactory .getOrCreateCluster(HFactory.java:155) [java] 在 me.prettyprint.hector.api.factory.HFactory.getOrCreateCluster(HFactory.java:128)

我的数据模型看起来像这样

现在我想让搜索结果过滤 startDate_mobileNo、Call_TYPE 和 endDate。这可以通过将 endDate 作为二级索引来完成。但是超级列中的二级索引是不可能的。所以我无法弄清楚如何进行。是的，我可以通过使用简单的 java 编码过滤结果数据来完成二级索引过滤部分。但我想这不是正确的想法，因为如果大数据可能内存不足。所以请给我一些想法。

提前致谢

我曾经在 Cassandra 中收到过 OOM 异常。我的是一个运行在功率适中的服务器上的单个实例，我正在做一些负载测试，所以这并不奇怪。

但是，我随后无法使用该实例。当我列出键空间时，只显示“系统”。但是当我尝试重新创建我正在测试的密钥空间时，Hector 以可怕的“所有主机池标记为已关闭。重试负担推给客户端”作为响应。消息，并且 Cassandra 日志具有以下堆栈跟踪：

旧的键空间仍在数据目录中，所以我移动了它，但这没有帮助。似乎系统数据在某处仍有无效引用。有谁知道如何解决这一问题？

编辑：来自 CLI，“描述集群”；仅描述“系统”键空间。但是当我“使用系统”时；然后“列出 schema_keyspaces；” 显示以下内容：

“芒果”是我无法再访问的键空间，但它在某种程度上仍然存在。有什么办法可以解决吗？

我想将一些文件流入和流出 cassandra，因为我们已经使用它而不是设置完整的 hadoop 分布式文件系统。是否有任何异步放置在 atyanax 或 hector 中，我在完成时提供回调，这样我可以避免 1000 次调用的 1 毫秒网络延迟，因为我写了 1000 个条目（在几行和几列之间拆分，所以它是流式传输的并行到几台服务器，然后所有响应/回调在完成流式传输时返回）。Hector 或 astyanax 是否支持这一点？

看起来 astyanax 支持查询回调，所以我想我可以使用主键将文件流回 astyanax？

谢谢，院长

我有以下代码：

我可以使用它编写一些值，但是当我重新启动 cassandra 时，它会失败。这是日志：

TIOStreamTransport.write(TIOStreamTransport.java:145) ... 9 更多 [15:11:17] 错误 [HConnectionManager] 将主机标记为已关闭主机 >localhost(127.0.0.1):9160 [15:11:17] 错误[HConnectionManager ] 关闭时的池状态：>:{localhost(127.0.0.1):9160}; IsActive?：真；主动：1；封锁：0；空闲：15；NumBeforeExhausted：49 [15:11:17] INFO [ConcurrentHClientPool] 关闭触发：{localhost(127.0.0.1):9160} [15:11:17] INFO [ConcurrentHClientPool] 关闭完成：{localhost(127.0.0.1) ：9160} [15:11:17] INFO [CassandraHostRetryService] 检测到已关闭的主机已添加到重试队列：localhost（127.0.0.1）：9160 [15:11:17] WARN [HConnectionManager] 无法在此主机上完成请求CassandraClient [15:11:17] 警告 [HConnectionManager] 例外：我。关闭。[15:11:17] 信息 [HConnectionManager] 客户端 CassandraClient 已释放到非活动或死池。关闭。[15:11:17] 信息 [HConnectionManager] 将主机 localhost(127.0.0.1):9160 添加到池中