3.2 java操作任务

步骤1: 书写 java 代码, 并打成 jar 包

package com.atguigu.azkabantest;

import java.io.FileOutputStream;
import java.io.IOException;

public class JavaTest {
    public void run() throws IOException {
        // 根据需求编写具体代码
        FileOutputStream fos = new FileOutputStream("/opt/module/azkaban/output.txt");
        fos.write("this is a java progress... by Azkaban".getBytes());
        fos.close();
    }

    public static void main(String[] args) throws IOException {
        JavaTest azkabanTest = new JavaTest();
        azkabanTest.run();
    }

}

步骤2: 将 jar 包放入 /opt/module/azkaban/jobs/libs 目录下

步骤3: 创建 job 文件

java.job

#java job
type=javaprocess
java.class=com.atguigu.azkabantest.JavaTest
classpath=/opt/module/azkaban/jobs/libs/*

步骤4: 打包 job 文件

zip java.zip java.job

步骤5: 在 web 界面创建 project

步骤6: 查看执行结果