Как использовать BulkOutputFormat для потоковой передачи данных на Cassandra из функции Hadoop Map? - PullRequest
1 голос
/ 11 января 2012

1) У меня есть ключ строки, столбец и значение в Map of Hadoop Job, и я узнал, что могу транслировать это напрямую в Cassandra, используя BulkOutputFormat .

2) Я просмотрел код, но понять, как его использовать, довольно сложно. Как я могу использовать этот API BulkOutputFormat для потоковой передачи данных на Cassandra?

Поскольку больше документации по этому вопросу еще не доступно, я прошу экспертов Кассандры помочь мне в этом. Небольшой фрагмент кода был бы очень полезен. Я планирую протестировать его с текущей версией разработки.

1 Ответ

0 голосов
/ 06 марта 2012

Изучая исходный код кассандры и кассандру JIRA, я нашел способ использовать BulkOutputFormat и описал его здесь: Использование BulkOutputFormat для загрузки данных на кассандру с помощью Hadoop

...