java - 将 CqlOutputFormat 用于 INSERT 语句

Question

我对 Cassandra 很陌生。我正在使用 hadoop 使用 CqlOutputFormat 将数据批量加载到 cassandra 集群中。我无法在互联网上找到足够的示例来根据我的用例定制它。

我专门使用它来使用语句将数据插入集群，

insert into pinseries (pin, timeseries) values(?, ?)

我不确定 context.write() 应该如何完成这项工作。似乎有足够的示例来了解它应该如何用于更新语句（示例中的字数会做）。但是有人可以告诉我如何在插入模式下使用它吗？

Answer 1

CqlOutputFormat 使用的 CqlRecordWriter 不支持插入语句，只支持更新语句，因此您需要使用更新来插入数据。沿着：

update pinseries set timeseries = ? where pin = ?

我假设pin是您的主键。