1

我一直读到，如果您的应用程序经常更改并且经常添加功能，Cassandra 就很好。

这是有道理的，因为您没有任何固定架构，您可以向行添加列以满足您的需要，而不是运行 ALTER TABLE 查询，这可能会为非常大的表冻结数小时的数据库。

但是，我有一个我无法解决的假设性问题。假设我有：

CREATE COLUMN FAMILY Students
    with comparator='CompositeType(UTF8Type,UTF8Type),
    and key_validation_class=UUIDType;

每个学生都有一些通用列（你知道，meta:username、meta:password、meta:surname 等），而且每个学生都可以学习 N 门课程。这种 NN 关系是使用非规范化解决的，将 N 列添加到每个学生（课程：ID1，课程：ID2）。

另一方面，我可能有一个 Courses CF，其中每一行都包含以下所有学生 UUID。

所以我可以问“XXX学习了哪些课程”和“哪些学生学习了YYY课程”。

问题是：如果我没有创建第二个列族怎么办？也许在构建应用程序时，让学生学习特定课程并不是必需的。

这是一个简单的例子，但我相信它很常见。“使用 Cassandra，您可以根据查询而不是关系来计划 CF”。我现在需要那个查询，而起初它并不需要。

给定一个包含数千个条目的学生表，您将如何填写 Courses CF？这是 Hadoop、Pig 还是 Hive 的工作（我从未接触过这些，只是猜测）。

4

2 回答 2

3

Pig（使用 Hadoop 集成）实际上非常适合这种类型的工作，因为您不仅可以使用 CassandraStorage 读取数据，还可以将数据写回 Cassandra。它为您提供并行处理能力，以最少的时间和开销完成工作。否则，另一种方法是自己编写一些东西来进行提取，然后编写新的 CF。

这是一个 Pig 示例，它从一个 CF 中的一组数据计算平均值并将它们输出到另一个：

rows = LOAD 'cassandra://HadoopTest/TestInput' USING CassandraStorage() AS (key:bytearray,cols:bag{col:tuple(name:chararray,value)});
columns = FOREACH rows GENERATE flatten(cols) AS (name,value);
grouped = GROUP columns BY name;
vals = FOREACH grouped GENERATE group, columns.value AS values;
avgs = FOREACH vals GENERATE group, 'Pig_Average' AS name, (long)SUM(values.value)/COUNT(values.value) AS average;    
cass_group = GROUP avgs BY group;   
cass_out = FOREACH cass_group GENERATE group, avgs.(name, average);
STORE cass_out INTO 'cassandra://HadoopTest/TestOutput' USING CassandraStorage();
于 2012-12-07T17:35:08.743 回答
0

如果您使用现有的 cassandra 文件，则必须展开数据。由于 NOSQL 文件是单向的，这在 Cassandra 本身中可能是一个非常耗时的操作。数据必须以与第一个文件相反的顺序排序。坦率地说，我相信您将不得不返回用于填充第一个文件的原始数据并从中填充这个新文件。

于 2014-01-18T06:01:06.770 回答