public HbaseClient(String host, int port, String doAsUser, int timeout, boolean useTransport) {
        this.host = host;
        this.port = port;
        this.doAsUser = doAsUser;
        this.timeout = timeout;
        this.useTransport = useTransport;
        String url = "http://" + this.host + ":" + this.port;
        // TSocket
        if (BooleanUtils.isTrue(this.useTransport)) {
            transport = new TSocket(this.host, this.port,timeout,timeout);
        }

        try {
            httpClient = new THttpClient(url);
        } catch (TTransportException e) {
            //log.error("HbaseClient ThttpClient failed!" + e.getMessage(), e);
            throw new RuntimeException(e);
        }
        httpClient.setCustomHeader(DO_AS, this.doAsUser);
        httpClient.setConnectTimeout(timeout);
        httpClient.setReadTimeout(timeout);
        httpClient.open();
        TProtocol protocol = new TBinaryProtocol(httpClient);
        client = new Hbase.Client(protocol);
        //log.info("HbaseClient create success!");
    }