文档首页 > > SDK参考> Java SDK> Flink作业模板相关

Flink作业模板相关

分享
更新时间:2020/06/23 GMT+08:00

新建作业模板

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);
    }
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!非常感谢您的反馈,我们会继续努力做到更好!
反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问