Скорость ввода данных в Apache Storm

Question

Я читаю текстовые данные из файла и обрабатываю их для получения результатов с помощью Apache Storm. Я хочу поэкспериментировать с разными скоростями ввода данных. Я хочу знать, как я буду изменять скорость ввода данных в Apache Storm в этой настройке. Также входная скорость передачи данных составляет:

Количество кортежей, выбрасываемых spout / Time

Answer 1

По умолчанию Storm будет вытягивать кортежи из носика как можно быстрее. Вы можете взаимодействовать с этим с помощью нескольких настроек:

topology.max.spout.pending определяет, сколько кортежей может быть отправлено в топологию до того, как Storm задушит носик и подождет, пока некоторые из кортежей будут активированы. По умолчанию это не ограничено.

topology.sleep.spout.wait.strategy.time.ms определяет, сколько миллисекунд Storm будет делать паузу между вызовами на nextTuple на носике, если вызов на nextTuple не производит вывод. По умолчанию это 1 мс.