trident

0зной

1ответ

Проблема с сериализацией клиента: прочитайте из Couchbase в функции Trident

В принципе, я хочу прочитать некоторые дополнительные атрибуты из Couchbase с атрибутами из кортежа, например, кортеж имеет поля ввода «{a, b, c}», я хочу для испускания кортежа «{a, b, c, d, e}», где

1зной

2ответ

Как обеспечить, чтобы шторм не записывал сообщение дважды в локальный файл?

Я строю топо, чтобы получать сообщения от kafka, а затем grep какое-то ключевое слово, если оно подходит, пишите в локальный файл. Я использую OpaqueTridentKafkaSpout of storm-kafka, чтобы гарантирова

2зной

1ответ

Запуск топологии Trident в тесте Storm TrackedTopology Test

Как запустить JUnit-тест топологии Trident, чтобы позволить кортежам проходить через топологию при тестировании и проверке вывода на каждом этапе? Я пробовал работать в рамках Storm's Testing, но это

1зной

1ответ

Как изменить баланс Сторм Trident Топология

От this ссылки документации я мог бы узнать, что изменение баланса топологии легко с ниже команд storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10 Но как я заново балансировать топол

0зной

1ответ

Несколько потоков в топологии Trident

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

3зной

1ответ

Как написать кортеж в redis, а также cassandra с использованием топологии трезубца

Я пишу топологию Trident для обработки потока данных из Kafka и подачи в Redis и Cassandra. Я могу записать данные в Кассандру. Теперь я хотел бы написать те же данные в Redis. Есть ли способ дублиров

1зной

1ответ

Количество слов с помощью шторма или Trident

Для простого подсчета слов программы в storm-starter, логика довольно прямо вперед: 1) разделить предложение на слова 2) испускают каждое слово 3) совокупный счетчик (хранить счетчик в карте) Однако е

4зной

1ответ

Неправильные значения штормового UI и капиллярный инструмент

Я спокоен с штормом Apache и пытался с топологией трезубцев для Kafka i.e TransactionalTridentKafkaSpout. Все работает отлично, кроме интерфейса Storm. Несмотря на то, что я не представил никаких данн