0
Я новичок как в Storm, так и в Cassandra. Я хочу использовать Болт для записи струн, выпущенных носиком, в семействе колонок в Кассандре. Я прочитал пример here, который для меня немного сложнее, поскольку он использует разные классы для записи в Cassandra DB. Кроме того, я хочу знать, сколько раз строки записываются в БД Cassandra. В этом примере для меня непонятно, как мы можем контролировать количество строк, введенных в БД Cassandra?Интеграция Storm Cassandra
Просто мне нужен болт, чтобы записать испускаемые строки носиком в семейство колонн Кассандры, например 200 записей?
Заранее благодарен!
Мой вопрос был написан после нескольких попыток работать над этими двумя подходами к интеграции. Наконец, я смог вставить записи в DB Cassandra, но я не знаю, как я могу это сделать! В частности, носик испускает, например, («test1», 123) болт. Болт вычисляет суммы, например, («test1», 123 + 100) и отправляет на болт кассандры. Наконец, болты Кассандры записывают это в БД. В этом пункте я вижу записи вроде этого -> («test», 2223). Как узнать, сколько раз запускается первый болт? Как я могу это контролировать? Так понятно? – Eni
@Enayat Вы можете подсчитать, сколько раз оно запускается либо путем ведения журнала, либо с помощью счетчика потока. Прошу прощения, но я не могу больше здесь. Вам нужно прочитать документацию Storm. – Chiron
Спасибо за ваш ответ. Я не хотел писать код, просто я думал, что, возможно, в файле конфигурации или где-то в настройке Кассандры мы можем определить количество запущенных болтов. Спасибо за ваше время! – Eni