Многополосная функция Storm

Question

Я новичок в Storm. Недавно я пытаюсь использовать многоязычные функции Storm. Однако у меня есть очень наивные путаницы.

1. Я думал, что взаимодействие MultiLang Шторма должен прийти с storm.py, storm.js или storm.rb сценария в MultiLang/ресурсов/папки. Но я видел их только в версии Storm 2.0.0, не найденной ни в одной предыдущей версии. Я правильно понял? И /multilang/resources/storm.py отличается от $ STORM_HOME/bin/storm.py, это правильно?

2. Я могу использовать расширения ShellBolt и ShellSpout, чтобы все компоненты топологии (носики и болты) работали на других языках, не так ли?

Как и прежде, я занимаюсь только оборудованием, поэтому это поле может быть для меня новым. Кто-нибудь поможет мне в решении этих проблем? Благодарю.

Answer 1

1. Они перемещаются в отдельные модули, и вы можете просто добавить необходимый многоканальный модуль в качестве зависимости в вашем помпе. Обратитесь к https://github.com/apache/storm/blob/1.x-branch/examples/storm-starter/pom.xml.

bin/storm.py используется для предоставления различных команд storm <command>, а не о поддержке мультиланг.

2. Несомненно. Пожалуйста, см. SplitSentence в https://github.com/apache/storm/blob/1.x-branch/examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java