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

队列相关

前提条件

创建队列

DLI提供创建队列的接口，您可以使用该接口创建队列。示例代码如下： 
1
2
3
4
5
6
7
8
 
  private static void createQueue(DLIClient client) throws DLIException {
    //通过调用DLIClient对象的createQueue方法创建队列
    String qName = "queueName";
    int cu = 16;
    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());
    }
  }
父主题： Java SDK