更新时间：2022-03-16 GMT+08:00
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
