HBasedistributeddatalibrary

Row Key | Column Family:Column Qualifier | Timestamp | Value
--------|--------------------------------|-----------|-------
row1    | cf1:col1                      | 123456789 | value1
row1    | cf1:col2                      | 123456789 | value2
row1    | cf2:col1                      | 123456789 | value3
row2    | cf1:col1                      | 123456789 | value4

# 1.  under 载HBase
$ wget https://dlcdn.apache.org/hbase/2.4.11/hbase-2.4.11-bin.tar.gz

# 2. 解压HBase
$ tar -xzvf hbase-2.4.11-bin.tar.gz
$ mv hbase-2.4.11 /opt/hbase

# 3. configurationenvironmentvariable
$ export HBASE_HOME=/opt/hbase
$ export PATH=$PATH:$HBASE_HOME/bin

# 4. configurationHBase
$ cp $HBASE_HOME/conf/hbase-env.sh.template $HBASE_HOME/conf/hbase-env.sh
$ echo "export JAVA_HOME=/opt/java" >> $HBASE_HOME/conf/hbase-env.sh
$ echo "export HBASE_CLASSPATH=/opt/hadoop/etc/hadoop" >> $HBASE_HOME/conf/hbase-env.sh
$ echo "export HBASE_MANAGES_ZK=false" >> $HBASE_HOME/conf/hbase-env.sh

# 5. configurationhbase-site.xml
$ vim $HBASE_HOME/conf/hbase-site.xml

  
    hbase.rootdir
    hdfs://localhost:9000/hbase
  
  
    hbase.cluster.distributed
    true
  
  
    hbase.zookeeper.quorum
    localhost
  
  
    hbase.zookeeper.property.dataDir
    /opt/zookeeper/data
  


# 6. configurationregionservers
$ echo "localhost" > $HBASE_HOME/conf/regionservers

# 7. 启动HBase
$ start-hbase.sh

# 8. verificationHBase启动
$ jps
# 应该看 to HMaster and HRegionServerprocess

# 启动HBase Shell
$ hbase shell

# 列出所 has 表
hbase(main):001:0> list

# creation表
hbase(main):002:0> create 'users', 'cf1', 'cf2'

# 查看表structure
hbase(main):003:0> describe 'users'

# 插入data
hbase(main):004:0> put 'users', 'row1', 'cf1:name', 'Alice'
hbase(main):005:0> put 'users', 'row1', 'cf1:age', '30'
hbase(main):006:0> put 'users', 'row1', 'cf2:email', 'alice@example.com'
hbase(main):007:0> put 'users', 'row2', 'cf1:name', 'Bob'
hbase(main):008:0> put 'users', 'row2', 'cf1:age', '28'
hbase(main):009:0> put 'users', 'row2', 'cf2:email', 'bob@example.com'

# 获取单行data
hbase(main):010:0> get 'users', 'row1'

# 获取指定列族 data
hbase(main):011:0> get 'users', 'row1', 'cf1'

# 获取指定列 data
hbase(main):012:0> get 'users', 'row1', 'cf1:name'

# 扫描表
hbase(main):013:0> scan 'users'

# 扫描指定范围 data
hbase(main):014:0> scan 'users', {STARTROW => 'row1', ENDROW => 'row2'}

# updatedata
hbase(main):015:0> put 'users', 'row1', 'cf1:age', '31'

# delete指定列
hbase(main):016:0> delete 'users', 'row1', 'cf2:email'

# delete指定行
hbase(main):017:0> deleteall 'users', 'row2'

# 禁用表
hbase(main):018:0> disable 'users'

# delete表
hbase(main):019:0> drop 'users'

# 退出HBase Shell
hbase(main):020:0> exit

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBaseExample {
    private static final String TABLE_NAME = "users";
    private static final String CF1 = "cf1";
    private static final String CF2 = "cf2";
    private static final String ROW_KEY = "row1";

    public static void main(String[] args) throws IOException {
        // 1. creationconfiguration
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.zookeeper.quorum", "localhost");

        // 2. 连接HBase
        Connection connection = ConnectionFactory.createConnection(config);
        Admin admin = connection.getAdmin();

        try {
            // 3. creation表
            TableName tableName = TableName.valueOf(TABLE_NAME);
            if (!admin.tableExists(tableName)) {
                TableDescriptorbuilder tableDesc = TableDescriptorbuilder.newbuilder(tableName);
                ColumnFamilyDescriptor cf1Desc = ColumnFamilyDescriptorbuilder.newbuilder(Bytes.toBytes(CF1)).build();
                ColumnFamilyDescriptor cf2Desc = ColumnFamilyDescriptorbuilder.newbuilder(Bytes.toBytes(CF2)).build();
                tableDesc.setColumnFamily(cf1Desc);
                tableDesc.setColumnFamily(cf2Desc);
                admin.createTable(tableDesc.build());
                System.out.println("Table created: " + TABLE_NAME);
            }

            // 4. 获取表instance
            Table table = connection.getTable(TableName.valueOf(TABLE_NAME));

            try {
                // 5. 插入data
                Put put = new Put(Bytes.toBytes(ROW_KEY));
                put.addColumn(Bytes.toBytes(CF1), Bytes.toBytes("name"), Bytes.toBytes("Alice"));
                put.addColumn(Bytes.toBytes(CF1), Bytes.toBytes("age"), Bytes.toBytes("30"));
                put.addColumn(Bytes.toBytes(CF2), Bytes.toBytes("email"), Bytes.toBytes("alice@example.com"));
                table.put(put);
                System.out.println("Data inserted");

                // 6. 获取data
                Get get = new Get(Bytes.toBytes(ROW_KEY));
                Result result = table.get(get);
                byte[] name = result.getValue(Bytes.toBytes(CF1), Bytes.toBytes("name"));
                byte[] age = result.getValue(Bytes.toBytes(CF1), Bytes.toBytes("age"));
                byte[] email = result.getValue(Bytes.toBytes(CF2), Bytes.toBytes("email"));
                System.out.println("Name: " + Bytes.toString(name));
                System.out.println("Age: " + Bytes.toString(age));
                System.out.println("Email: " + Bytes.toString(email));

                // 7. 扫描表
                Scan scan = new Scan();
                ResultScanner scanner = table.getScanner(scan);
                for (Result res : scanner) {
                    System.out.println("Row: " + Bytes.toString(res.getRow()));
                    for (Cell cell : res.listCells()) {
                        String cf = Bytes.toString(CellUtil.cloneFamily(cell));
                        String qualifier = Bytes.toString(CellUtil.cloneQualifier(cell));
                        String value = Bytes.toString(CellUtil.cloneValue(cell));
                        System.out.println("  " + cf + ":" + qualifier + " = " + value);
                    }
                }
                scanner.close();
            } finally {
                table.close();
            }
        } finally {
            admin.close();
            connection.close();
        }
    }
}