更新时间：2022-03-16 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());
}
}
|
父主题： Java SDK
