Использование CqlOutputFormat для оператора INSERT

Question

Я довольно новичок в Кассандре. Я использую hadoop для массовой загрузки данных в кластер cassandra с помощью CqlOutputFormat. Я не могу найти достаточно примеров в интернете, чтобы адаптировать его к своему случаю.

Я специально использую его для вставки данных в кластер с помощью оператора,

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

Я не уверен, как context.write() должен выглядеть, чтобы это работало. Кажется, есть достаточно примеров, чтобы увидеть, как это должно работать для оператора update (Wordcount из примеров подойдет). Но может кто-нибудь сказать мне, как использовать это в режиме вставки?

Answer 1

CqlRecordWriter, используемый CqlOutputFormat, не поддерживает операторы вставки, а только операторы обновления, поэтому вам нужно будет использовать update для вставки ваших данных. По линии:

update pinseries set timeseries = ? where pin = ?

Я предполагаю, что пин-код - ваш первичный ключ.