对insert语句使用cqloutputformat

zte4gxcn 于 2021-05-30 发布在 Hadoop

关注(0)|答案(1)|浏览(412)

我对Cassandra还很陌生。我使用hadoop使用cqloutputformat将数据批量加载到cassandra集群中。我在互联网上找不到足够的例子使它适合我的用例。
我专门用它把数据插入到集群中，

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

我不确定context.write（）应该是什么样子的。似乎有足够的例子来说明update语句应该如何工作（例子中的wordcount就可以了）。但是有人能告诉我如何在插入模式下使用它吗？

1条答案

cqloutputformat使用的cqlrecordwriter不支持insert语句only update语句，因此需要使用update插入数据。沿着以下路线：

update pinseries set timeseries = ? where pin = ?

我假设pin是你的主键。