1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package org.apache.hadoop.hbase.hbql.statement;
22
23 import org.apache.hadoop.hbase.hbql.client.ExecutionResults;
24 import org.apache.hadoop.hbase.hbql.client.HBqlException;
25 import org.apache.hadoop.hbase.hbql.client.QueryExecutorPoolManager;
26 import org.apache.hadoop.hbase.hbql.impl.HConnectionImpl;
27
28 public class DropQueryExecutorPoolStatement extends GenericStatement implements ConnectionStatement {
29
30 private final String poolName;
31
32 public DropQueryExecutorPoolStatement(final StatementPredicate predicate, final String poolName) {
33 super(predicate);
34 this.poolName = poolName;
35 }
36
37 private String getPoolName() {
38 return this.poolName;
39 }
40
41 protected ExecutionResults execute(final HConnectionImpl conn) throws HBqlException {
42
43 final String msg;
44 if (!QueryExecutorPoolManager.queryExecutorPoolExists(this.getPoolName())) {
45 msg = "Query Executor pool " + this.getPoolName() + " does not exist";
46 }
47 else {
48 QueryExecutorPoolManager.dropQueryExecutorPool(this.getPoolName());
49 msg = "Query Executor pool " + this.getPoolName() + " dropped.";
50 }
51 return new ExecutionResults(msg);
52 }
53
54
55 public static String usage() {
56 return "DROP QUERY EXECUTOR POOL pool_name [IF bool_expr]";
57 }
58 }