先序
- JAVA1.8
- Hadoop 2.7.7
- HBase 2.0.5
- Gradle 5.3.1
- 依赖:
compile group: 'org.apache.hbase', name: 'hbase-client', version: '2.0.5'
创建连接
@Logger
public class HBaseUtils {
static java.util.logging.Logger logger = getLogger( "haya" );
private static Configuration config = HBaseConfiguration.create();
private static Connection con;
private static void setConfig(String address, String port) {
config.set( "hbase.zookeeper.quorum", address );
config.set( "hbase.zookeeper.property.clientPort", port );
}
public static Connection getConnection(String address, String port) throws IOException {
setConfig( address, port );
return con = ConnectionFactory.createConnection( config );
}
}
@Logger和static java.util.logging.Logger logger = getLogger( “haya” )是和日志有关的。
接下来创建两个成员变量Configuration config、Connection con。其中config是配置对象,把必要的信息设置到这个对象里,比如IP地址,端口号;然后调用ConnectionFactory工厂类的createConnection方法,把配置好的config对象传递进去,就会得到一个Connection对象。
至于为什么要把Configuration和Connection的实例对象设置为成员变量,是因为后面好多操作都要用到他俩。。。
创建表
public
版权声明:本文为HuaLingPiaoXue原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。