【HBase】用Java操作HBase

  • Post author:
  • Post category:java




先序

  • 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 版权协议,转载请附上原文出处链接和本声明。