文档首页/ 数据湖探索 DLI/ SDK参考/ Java SDK/ Flink作业模板相关
更新时间：2024-03-06 GMT+08:00
查看PDF
分享

Flink作业模板相关

前提条件

新建作业模板

DLI提供新建Flink作业模板的接口。您可以使用该接口新建一个Flink作业模板。示例代码如下：

1
2
3
4
5
6
 
public static void createFlinkJobTemplate(DLIClient client) throws DLIException{
    CreateFlinkJobTemplateRequest body = new CreateFlinkJobTemplateRequest();
    body.name("template");
    FlinkJobTemplateCreateResponse  result = client.createFlinkJobTemplate(body);
    System.out.println(result);
}

更新作业模板

DLI提供更新Flink作业模板的接口。您可以使用该接口修改一个Flink作业模板。示例代码如下：

1
2
3
4
5
6
7
 
   public static void updateFlinkJobTemplate(DLIClient client) throws DLIException{
        Long templateId = 277L;//模板Id
        UpdateFlinkJobTemplateRequest body = new UpdateFlinkJobTemplateRequest();
        body.name("template-update");
        GlobalResponse result = client.updateFlinkJobTemplate(body,templateId);
        System.out.println(result);
    }

删除作业模板

DLI提供删除Flink作业模板的接口。您可以使用该接口删除已经创建的作业模板，如果当前模板被引用也允许删除模板。示例代码如下：

1
2
3
4
5
 
public static void deleteFlinkJobTemplate(DLIClient client) throws DLIException{
    Long templateId = 277L;//模板Id
    FlinkJobTemplateDeleteResponse result = client.deleteFlinkJobTemplate(templateId);
    System.out.println(result);
}

查询作业模板列表

DLI提供查询Flink作业模板的接口。您可以使用该接口查询作业模板列表。本示例排序方式选择降序desc，将会列出作业模板ID小于cursor的作业模板列表信息。示例代码如下：

1
2
3
4
5
6
7
 
   public static void getFlinkJobTemplates(DLIClient client) throws DLIException{
        Long offset = 789L; // Long | 模板偏移量。
        Integer limit = 56; // Integer | 查询条数限制
        String order = "asc"; // String | 查询结果排序, 升序和降序两种可选
        FlinkJobTemplateListResponse result = client.getFlinkJobTemplates(offset,limit,order);
        System.out.println(result);
    }
父主题： Java SDK