apache-storm

5зной

1ответ

Создание файла backtype.storm.tuple.Tuple для тестирования?

Я новичок в Storm и пытаюсь выяснить, как написать тест на болт, который проверяет метод execute(Tuple tuple) в подклассе BaseRichBolt. Проблема заключается в том, что Tuple является неизменным, и я н

1зной

1ответ

RabbitMQ блокировки при создании нового соединения в топологии штормового

Я новичок штурмовать я использую RabbitMQ в моем носике, что recieves кортежей из некоторой очереди и есть клиент работает под управлением одной другая машины, которая вставляет кортежи в эту очередь

4зной

1ответ

Строка проверки ошибок во время Счетчик запроса на Кассандре

У меня есть следующий счетчик запроса на мой код: private CounterSlice<String> queryLastCounts(Long key, String columnFamily, int maxLength) { SliceCounterQuery<Long, String> q

1зной

1ответ

Может ли Storm Trident делать только JOIN в партии?

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

5зной

2ответ

Storm> Howto Интеграция Java-обратного вызова в носик

Я пытаюсь интегрировать Storm (see here) в свой проект. Я понимаю понятия топологий, носиков и болтов. Но теперь я пытаюсь понять, как осуществляется реализация некоторых вещей. A) У меня есть полигло

14зной

4ответ

Как представить топологию в кластере производства штормов с помощью IDE

Перед тем как отправить топологию в производственный кластер с использованием IDE, я столкнулся с проблемой Must submit topologies using the 'storm' client script so that StormSubmitter knows which ja

1зной

1ответ

Шторм в качестве замены для многопоточного подхода потребителя/производителя для обработки больших объемов?

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

1зной

2ответ

Какое лучшее решение для больших данных для интерактивных запросов строк до 200 столбцов?