Tag: hector

如何访问Cassandra节点的本地数据

从我对Cassandra的了解不多，似乎数据局部性对于访问节点的客户端应用程序来说应该是透明的。 但是，如果我明确只想访问我所连接的节点本地的列族数据，该怎么办？ 这样的事情可能吗？ 我还没有找到一种从客户端API开箱即用的方法，但似乎我可以通过系统表获取一些这些信息，但我无法弄清楚如何做到这一点。 这个想法是执行mapreduce，但不使用Hadoop。 本地客户端将连接到其本地cassandra节点，对本地数据执行聚合，然后将其传递回上游。 这样的事情有可能吗？ 从它的外观来看，似乎有可能因为我已经看到Hadoop能够使用Cassandra的证据，但这些例子似乎是针对Hadoop而不是通用客户端。 本地客户端（与Casandra交谈）将使用Java。 我目前正在使用Hector，但我不确定它是否会提供任何数据位置信息。

如何在Cassandra中列出列族中的所有列名？

我正在使用Cassandra，我想制作一个数据浏览器，显示任何列族的内容。 我需要获取列名来配置UI网格。 是否可以收集所有行中的列名？

使用Hector在Cassandra中查询CompositeType列

这是我面临的情景样本。 说我有这个专栏系列： create column family CompositeTypeCF with comparator = ‘CompositeType(IntegerType,UTF8Type)’ and key_validation_class = ‘UTF8Type’ and default_validation_class = ‘UTF8Type’ 下面是一些使用Hector的示例Java代码，了解如何将一些数据插入此列族： Cluster cluster = HFactory.getOrCreateCluster(“Test Cluster”, “192.168.1.6:9160”); Keyspace keyspaceOperator = HFactory.createKeyspace(“CompositeTesting”, cluster); Composite colKey1 = new Composite(); colKey1.addComponent(1, IntegerSerializer.get()); colKey1.addComponent(“test1”, StringSerializer.get()); Mutator mutator = HFactory.createMutator(keyspaceOperator, StringSerializer.get()); Mutator addInsertion = mutator.addInsertion(“rowkey1”, “CompositeTypeCF”, HFactory.createColumn(colKey1, “Some Data”, new CompositeSerializer(), StringSerializer.get())); […]