java-classic-code/hadoop-auth/HBaseConnectionFactory.java

package com.primeton.dsp.datarelease.data.bdata;

import com.primeton.dsp.datarelease.server.model.DspHbaseResource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;

/**
 *
 * 根据参数不同，生成不动的测试连接实例
 *
 * <pre>
 *
 * Created by zhaopx.
 * User: zhaopx
 * Date: 2020/4/21
 * Time: 18:02
 *
 * </pre>
 *
 * @author zhaopx
 */
@Slf4j
public class HBaseConnectionFactory {


    /**
     * 生成不同的测试实例
     * @return
     */
    public static HBaseConnectionService getHBaseInstance(DspHbaseResource hbaseResource) {
        String authUser = hbaseResource.getAuthUser();
        if(StringUtils.isBlank(authUser) || "noauth".equalsIgnoreCase(hbaseResource.getAuthType())) {
            // 无需认证
            return new SimpleHBaseConnectionServiceImpl(hbaseResource);
        } else if("kerberos".equalsIgnoreCase(hbaseResource.getAuthType())){
            // kerberos 认证
            return new Krb5HBaseConnectionServiceImpl(hbaseResource);
        } else {
            //fi 华为
            return new FiHBaseConnectionServiceImpl(hbaseResource);
        }
    }
}