grails - 如何在Grails和Hadoop之间编写连接脚本？

Question

我需要将Grails中生成的文件动态复制到Hadoop。我将如何在Grails中为此编写代码？每当生成文件时，都应将其复制到Hadoop中。如果传入文件已经存在，则应在Hadoop中对其进行更新。

Answer 1

我使用shell脚本连接grails和hadoop。

我已在myjob.sh(工作流程脚本)中使用了所有命令来运行hadoop作业。

我添加了代码以在 Controller 中执行shell脚本

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()
}