trident

0зной

1ответ

Как построить топологию Storm Trident, которая будет сохраняться в HBase

Я хочу построить топологию трезубца, которая получит кортежи из Kafka, сгруппируйте их по одному полю и сохраните все сгруппированные кортежи в HBase. Причина для группировки заключается в том, что оп

0зной

1ответ

Шторм для пакетной обработки

Я новичок в Storm и имею несколько основных вопросов. Мой вариант использования для шторма - это поток и пакетная обработка. Использовать случай № 1: Топология шторма берет в кортеж как поток и обраба

1зной

1ответ

Apache Storm обработка только один

В настоящее время мы используем Apache Storm 0.9.5 в режиме кластеризации с топологией для обработки записей Amazon Kinesis (носик) и храним их в хранилище данных Redshift (болт). Наш кластер Storm ра

1зной

1ответ

Испускать несколько потоков в Storm Trident

Как я могу испускать несколько потоков из того же болта в Storm Trident? У меня есть болт, который выполняет некоторые вычисления и на основе результата я хочу передать некоторые значения одному поток

1зной

1ответ

Apache Storm Trident .each() функция описание

Я хочу использовать TridentTopology Apache Storm в проекте. Мне трудно понять функцию .each() из класса storm.trident.Stream. Ниже приведен пример кода приведены в их учебнике для справки: TridentTopo

0зной

1ответ

Как сохранить значения из Trident/Storm в списке (с использованием Java API)

Я пытаюсь создать несколько тестов Unit, чтобы убедиться, что некоторые части моей топологии Trident делают то, что они предполагают. Я хотел бы получить все значения, полученные после запуска тополог