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.QueryExecutorPool;
26 import org.apache.hadoop.hbase.hbql.client.QueryExecutorPoolManager;
27 import org.apache.hadoop.hbase.hbql.impl.HConnectionImpl;
28
29 public class ShowQueryExecutorPoolsStatement extends GenericStatement implements ConnectionStatement {
30
31 public ShowQueryExecutorPoolsStatement() {
32 super(null);
33 }
34
35 protected ExecutionResults execute(final HConnectionImpl conn) throws HBqlException {
36
37 final ExecutionResults retval = new ExecutionResults();
38 retval.out.println("Query Executor Pools: ");
39 for (final String name : QueryExecutorPoolManager.getQueryExecutorPoolNames()) {
40 final QueryExecutorPool executorPool = QueryExecutorPoolManager.getQueryExecutorPool(name);
41 retval.out.println("\t" + executorPool.getName() + "(" +
42 "MAX_EXECUTOR_POOL_SIZE: " + executorPool.getMaxPoolSize()
43 + ", MIN_THREAD_COUNT: " + executorPool.getMinThreadCount()
44 + ", MAX_THREAD_COUNT: " + executorPool.getMaxThreadCount()
45 + ", KEEP_ALIVE_SECS: " + executorPool.getKeepAliveSecs()
46 + ", THREADS_READ_RESULTS: " + executorPool.getThreadsReadResults()
47 + ", COMPLETION_QUEUE_SIZE: " + executorPool.getCompletionQueueSize()
48 + ")");
49 }
50 retval.out.flush();
51 return retval;
52 }
53
54 public static String usage() {
55 return "SHOW QUERY EXECUTOR POOLS";
56 }
57 }