我需要将grails中生成的文件动态复制到hadoop中。我将如何在grails中为此编写代码?无论何时生成文件,都应该将其复制到hadoop中。如果传入文件已经存在,应该在hadoop中更新它。
cdmah0mi1#
我使用shell脚本连接grails和hadoop。我拥有运行hadoop作业的所有命令 myjob.sh (工作流脚本)我在控制器中添加了执行shell脚本的代码
myjob.sh
def scriptCom="/folderlocation/shellscript.sh" println "[[Running $scriptCom]]" def proc = scriptCom.execute() def oneMinute = 60000 proc.waitForOrKill(oneMinute) if(proc.exitValue()!=0){ println "[[return code: ${proc.exitValue()}]]" println "[[stderr: ${proc.err.text}]]" return null }else{ println "[[stdout:$revisionid]]" return proc.in.text.readLines() }
1条答案
按热度按时间cdmah0mi1#
我使用shell脚本连接grails和hadoop。
我拥有运行hadoop作业的所有命令
myjob.sh
(工作流脚本)我在控制器中添加了执行shell脚本的代码