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.AsyncExecutor;
24 import org.apache.hadoop.hbase.hbql.client.AsyncExecutorManager;
25 import org.apache.hadoop.hbase.hbql.client.ExecutionResults;
26 import org.apache.hadoop.hbase.hbql.client.HBqlException;
27 import org.apache.hadoop.hbase.hbql.impl.HConnectionImpl;
28
29 public class ShowAsyncExecutorsStatement extends GenericStatement implements ConnectionStatement {
30
31 public ShowAsyncExecutorsStatement() {
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("Async Executors: ");
39 for (final String name : AsyncExecutorManager.getAsyncExecutorNames()) {
40 final AsyncExecutor asyncExecutor = AsyncExecutorManager.getAsyncExecutor(name);
41 retval.out.println("\t" + asyncExecutor.getName() + "("
42 + "MIN_THREAD_COUNT: " + asyncExecutor.getMinThreadCount()
43 + ", MAX_THREAD_COUNT: " + asyncExecutor.getMaxThreadCount()
44 + ", KEEP_ALIVE_SECS: " + asyncExecutor.getKeepAliveSecs()
45 + ")");
46 }
47 retval.out.flush();
48 return retval;
49 }
50
51 public static String usage() {
52 return "SHOW ASYNC EXECUTORS";
53 }
54 }