У меня была рабочая топология Storm, которую я настраивал, добавив хук задачи, и теперь я получаю сообщение о том, что моя конфигурация не является json-serializable. Ошибка возникает, когда топология
Я пытаюсь написать топологию, которая выполняет следующее: носик, который присоединяется к Твиттеру (на основе ключевого слова) болта агрегации, что суммирует несколько твитов (скажем, N) в коллекции
Я новичок в Storm и изучал его возможности в соответствии с нашими требованиями CEP. Различные примеры, которые я наткнулся, реализуют носики как услугу опроса от брокера сообщений, базы данных. Как р
Я ищу пример кода, используя шторм-кассандру, который пишет в семейство столбцов кассандры с составной колонкой. Хотя он утверждает, что эта функция доступна в ветке 0.4.0, но примера нет. BTW проект
Я разрабатываю прототип реального времени для обработки довольно больших сумм (> 30G/day) потоковых числовых данных. Я хотел бы написать это в Clojure, так как язык, похоже, хорошо подходит для систем