Запустите MapReduce Jar в облачных данных Spring

Question

Мне нужно запустить приложение весенней загрузки mapreduce в облачном потоке данных Spring. Обычно приложения, зарегистрированные в scdf, выполняются с помощью команды "java -jar jar-name". Но моя программа - это mapreduce, и она должна выполняться с использованием "hadoop jar jar-name". Как мне этого добиться? Какой подход лучше использовать для запуска приложения mapreduce в формате scdf? Можно ли напрямую зарегистрировать приложения mapreduce?

Я использую локальный сервер потока данных для регистрации приложения.

Answer 1

В SCDF формат команды для запуска файла JAR управляется программой развертывания. Например, есть локальный развертыватель. Cloud Foundry и т.д. Учитывая, что сам развертыватель является SPI , вы можете легко реализовать свой собственный или даже развернуть / расширить local-deployer и изменить только то, что нужно.