apache-storm

0зной

1ответ

Как я могу вызвать nextTuple() определенное количество раз в секунду?

Есть ли способ вызова метода nextTuple носика определенного количества раз в секунду?

0зной

2ответ

Как выполнить несколько запросов в одном пакете на Кассандре

У меня есть таблица Кассандры, как показано ниже: create table experience.userstats (stream varchar, user varchar, computer varchar, experience varchar, amount int, primary key (experience, stream, us

0зной

1ответ

Как работает аккер, если я потребляю два раза от w болта?

У моей топологии есть boltA, который испускает один раз по умолчанию. Болты B и C подписываются на этот болт, используя группировку в случайном порядке. Как работает акринг в этом сценарии? Разве B и

0зной

1ответ

Apache storm Trident - динамическое создание топологий

Есть ли способ динамически создавать топологии в трезубцах? Не могли бы вы привести примеры?

0зной

1ответ

Найдено несколько ресурсов defaults.yaml. Вы, вероятно, собираете банки Storm с вашей топологической баночкой

Итак, я обновил вопрос и заголовок сейчас, потому что теперь я знаю проблему. Это рабочий журнал, я знаю, что есть много вопросов, подобных этому (here), но я не могу получить какие-либо решения для р

0зной

2ответ

Пропустить выходные поля через болт Apache Storm

В функции declareOutputFields моего болта (который расширяет BaseBasicBolt) есть простой способ объявить те же поля, которые я получил от предыдущего болта или желоба?