Question

Cassandra 数据模型经常需要更新一个以上的列组以支持单一的“ write ” ( 即更新双向指数的两侧 ) 。在工作配置只允许指定一个输出列组时, 我怎样才能对 Hadoop 这样做?

Answer 1

通过使用以下地点的补丁补丁卡桑德拉1.1,可以做到这一点:

https://issues.apache.org/jira/browse/CASSANDRA-4208

一旦有了这个, 而不是 ConfigHelper. set OutputColumnFamily () , 你就会呼叫 ConfigHelper.setKeyspace () 。然后您就可以使用多输出 API来指定您在工作配置中的输出 CFC 如下 :

MultipleOutputs.addNamedOutput(job, "ColumnFamily1", ColumnFamilyOutputFormat.class, ByteBuffer.class, List.class);
MultipleOutputs.addNamedOutput(job, "ColumnFamily2", ColumnFamilyOutputFormat.class, ByteBuffer.class, List.class);

当您准备输出时,只需将名为 CF 的 CF 命名为输出名称:

output.write("ColumnFamily1", key, Collections.singletonList(mutation));

此处 output 是您减号中多输出实例的引用。

友情链接