說明:JAVA離線任務應用支持JAVA7和8兩個版本。
JAVA離線任務應用zip包的規范如下:
zip包里面根目錄請勿出現start.sh和start_flow.sh
zip包結構參照如下
xxx.zip ## 上傳的zip包中僅包含算法代碼即可,不要含有start.sh、start_flow.sh兩個文件 - elastic-test-1.0-SNAPSHOT.jar - 其他需要的算法文件
其中elastic-test-1.0-SNAPSHOT.jar是由mvn 打包出來的(jar包名稱根據實際情況替換),其main class可以參照如下,pom自行編寫即可,生成對應elastic-test-1.0-SNAPSHOT.jar即可。
(備注:在數據開發配置了輸入輸出參數時,可以通過環境變量ZERG_APP_PARAM獲取。)
public class JobTest { public JobTest() { } public static void main(String[] args) { System.out.println("job running here"); if (args != null && args.length > 0) { String[] var1 = args; int var2 = args.length; for(int i = 0; i < var2; ++i) { String s = var1[i]; System.out.println("Param: " + s); } } else { System.out.println("No param"); } System.out.println("hello world!"); System.out.println("job running success!"); } }
在含有elastic-test-1.0-SNAPSHOT.jar和其他算法需要文件的目錄下面,執行類似如下打包命令,得到java_job_test.zip
zip -r java_job_test.zip ./*
將打好的zip包上傳到對應添加應用處即可。
編寫離線任務應用腳本
在添加離線任務應用處,離線任務應用腳本處編寫可參照如下
#!/bin/bash cd `dirname $0` echo "--------start------->>" java -jar elastic-test-1.0-SNAPSHOT.jar "$1" echo "--------end------->>"
編寫完成,保存即可。
文檔內容是否對您有幫助?