apache-storm

-1зной

4ответ

Мы получаем огромное количество XML-данных через API. Чтобы обработать этот большой набор данных, мы планировали сделать это в Hadoop. Вам нужна ваша помощь в понимании того, как эффективно переносить

8зной

2ответ

Как получить доступ к объекту из контекста топологии в болт при использовании шторма?

Нам нужно передать объект при создании топологии, чтобы болт мог получить к нему доступ и выполнить дальнейшую обработку на основе этого объекта. Можно ли передать объект через TopplogyContext, и если

2зной

1ответ

Должен ли я использовать Trident для вычисления глобального значения кортежей в Storm?

Я хочу вычислить со Storm среднее из входящих кортежей, сделанных из [int id, int value]. Как вы можете видеть, я не могу разбить данные с помощью группировки полей. Мне нужна топологическая архитекту

14зной

6ответ

Как отключить/отключить функцию ведения журнала из Storm

Я хочу отключить функцию ведения журнала, предлагаемую по умолчанию при запуске из локального кластера. В настоящее время он регистрирует столько информации на консоли. Ниже приведен пример журнала: 2

10зной

1ответ

Storm-Kafka несколько носиков, как разделить нагрузку?

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

1зной

1ответ

Создание файла csv в болтах

Я хочу записать вывод Bolt в файл csv. Подумайте, читаю ли я данные с носика и передаю его на болт, болт делаю некоторые вычисления и затем накладываю эти данные на файл csv, хотя у меня есть 2 отверс

24зной

1ответ

что PATH в системе MAC (UNIX)

им пытаются настроить проект, шторм от мерзавца https://github.com/nathanmarz/storm/wiki/Setting-up-development-environment Download a Storm release , unpack it, and put the unpacked bin/ directory on

1зной

2ответ

STORM ERROR java.lang.UnsatisfiedLinkError?

не Compile никаких проблем, но после запуска ..... 26183 [Thread-34] ERROR backtype.storm.util - Async loop died! java.lang.UnsatisfiedLinkError: org.zeromq.ZMQ$Socket.finalize()V at org.zeromq.