文档首页 > > SDK参考> Java SDK> 队列相关

队列相关

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

创建队列

DLI提供创建队列的接口,您可以使用该接口创建队列。示例代码如下:
1
2
3
4
5
6
7
8
9
  private static void createQueue(DLIClient client) throws DLIException {
    //通过调用DLIClient对象的createQueue方法创建队列
    String qName = "queueName";
    int cu = 16;
    ChargingMode mode = ChargingMode.CHARGING_MODE_CU;
    String description = "test for sdk";
    Queue queue = client.createQueue(qName, cu, mode, description);
    System.out.println("---------- createQueue success ---------");
  }

删除队列

DLI提供删除队列的接口,您可以使用该接口删除队列。示例代码如下:
1
2
3
4
5
6
7
  private static void deleteQueue(DLIClient client) throws DLIException {
    //调用DLIClient对象的getQueue("queueName")方法获取queueName这个队列
    String qName = "queueName";
    Queue queue = client.getQueue(qName);
    //使用deleteQueue()方法删除queueName队列
    queue.deleteQueue();
}

获取默认队列

DLI提供查询默认队列的接口,您可以使用默认队列提交作业。示例代码如下:

1
2
3
4
5
private static void getDefaultQueue(DLIClient client) throws DLIException{
    //调用DLIClient对象的getDefaultQueue方法查询默认队列
     Queue queue = client.getDefaultQueue();
     System.out.println("defaultQueue is:"+ queue.getQueueName());
}

默认队列允许所有用户使用,DLI会限制用户使用默认队列的次数。

查询所有队列

DLI提供查询队列列表接口,您可以使用该接口并选择相应的队列来执行作业。示例代码如下:

1
2
3
4
5
6
7
8
9
  private static void listAllQueues(DLIClient client) throws DLIException {
    System.out.println("list all queues...");

    //通过调用DLIClient对象的listAllQueues方法查询队列列表
    List<Queue> queues = client.listAllQueues();
    for (Queue queue : queues) {
      System.out.println("Queue name:" + queue.getQueueName() + "  " + "cu:" + queue.getCuCount());
    }
  }
分享:

    相关文档

    相关产品

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问