Я новичок в шторме апачей, и я искал методы для проверки болта без фактического построения полной топологии. Просто хотел избежать макетов тестирования. Вместо этого я попытался вызвать методы болта, чтобы испустить выход в объекте OutputCollector. Но я пытался найти метод для получения данных из объекта OutputCollector и не нашел никакого метода как такового. Есть ли способ, которым я могу просто получить доступ к значениям, испускаемым в объекте OutputCollector?Испытание бури Болт
ответ
Если вы тестируете только с точки зрения штормовой затем
JUnit
бы это сделать. Но если вы пытаетесь проверить с распределенной вычислительной точки зрения
mrunit
инструмент тестирования должен быть полезным.
Я думаю, что mrunit для тестирования apache hadoop .. его для карты уменьшают рабочие места. Во всяком случае, я следил за junit framework. Но я был обеспокоен сбором кортежей, испущенных на объект OutputCollector –
, чтобы прочитать [link] (http://stackoverflow.com/questions/10996963/hadoop-how-does-outputcollector-work-during-mapreduce), чтобы понять что получено в OutputCollector. Я думаю, что это не то, что вы ищете ... – Raghuveer
Один подход к логике проверки болтов заключается в том, чтобы написать FakeDataGeneratorSpout , которые имитируют фактический источник вашей топологии. Build Test Main Topology Builder Класс, который может использовать FakeDataGeneratorSpout для целей тестирования.
Во-вторых, вы можете сохранить логику болтов в простом классе Java и написать junit для них, а затем вызвать этот проверенный метод из реальных болтов.
https://github.com/kartikbha/Storm-Dev-TestingFramework – kartik
- 1. Увеличивающая память бури
- 2. Есть ли что-нибудь в службе бури?
- 3. Как использовать бури Trident для пакетных кортежей?
- 4. Визуализация результатов бури
- 5. NimbusLeaderNotFoundException в Apache Бури
- 6. Бури втягивая несвежие зависимости
- 7. Остановка бури: правильный путь
- 8. Как это слово считает болт нить безопасной?
- 9. Частое Полный GC Апача бури
- 10. ошибка топологии вершины бури-стартера
- 11. многие-к-одному атрибуты Бури
- 12. Одновременно обрабатываются партии бури трезубца?
- 13. Apache Сторм болт болт сообщения остановки или слоеное
- 14. Болт: групповые разрешения
- 15. многопоточность грозового Болт параллелизм
- 16. OpenGL. Болт-шаровое столкновение
- 17. Последовательная ошибка, когда диспетчер бури запускает исполнитель
- 18. Штормовой болт без печати/каротажа Kafka Spout
- 19. Испытание утяжелителя
- 20. Болт пользовательских маршрутизации и расширение
- 21. Болт CMS - Ошибка> posix_getuid()
- 22. Firebase не может найти Болт
- 23. Firebase удаление, разрешение болт конфигурации
- 24. Storm HDFS Болт не работает
- 25. Болт CMS не возвращается ответ
- 26. Рельеф топологии бури с использованием кода Java
- 27. Как работа делится между работниками бури?
- 28. Настройка streamparse в удаленном кластере Бури
- 29. Невозможно получить доступ к новой установке болта с 404 на/болт/болт/пользователи/редактировать/
- 30. Ошибка: Существовал ошибка загрузки firebase.json: Болт не установлен, запустите НПМ установки -g firebase болт
вы можете увидеть пример здесь ..https: //github.com/kartikbha/log-processing-by-grouping/blob/master/src/com/poc/standard/LogGenerationSpout.java – kartik
https: // github. com/kartikbha/log-processing-by-grouping/tree/master/src/com/poc/standard/topology/test – kartik