hbase数据可以覆盖

HBase是一个高可用性、高容错性、分布式的NoSQL数据库系统，它的数据模型是一种基于列的存储结构，其提供了针对海量数据的实时读写能力。但是，在HBase中存储的数据也有可能会覆盖。下面就来解析一下HBase数据覆盖原因以及如何避免数据覆盖。

一、HBase数据覆盖的原因

HBase数据覆盖通常是由于多线程并发写入相同的数据导致的，这时两个线程同时向同一个单元格写入数据，很有可能覆盖了另一个线程的写入。如下图所示：

为了更好的说明问题，下面基于Java编程语言，通过代码演示来说明。

二、HBase数据覆盖示例

假设有两个线程同时向同一个HBase表的同一个单元格写入数据，如下所示：

public class WriteThread extends Thread {
    private static final String tableName = "testtable";
    private static final String familyName = "info";
    private static final String columnName = "col1";

    private Connection connection;
    private Table table;

    public WriteThread(Connection connection) throws IOException {
        this.connection = connection;
        this.table = connection.getTable(TableName.valueOf(tableName));
    }

    @Override
    public void run() {
        try {
            Put put = new Put(Bytes.toBytes("row1"));
            put.addColumn(Bytes.toBytes(familyName), Bytes.toBytes(columnName), Bytes.toBytes(String.valueOf(Thread.currentThread().getId())));
            table.put(put);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", "localhost");
        Connection connection = ConnectionFactory.createConnection(configuration);
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        executorService.execute(new WriteThread(connection));
        executorService.execute(new WriteThread(connection));

        executorService.shutdown();
        executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
        connection.close();
    }
}

上述代码演示了两个线程并发地向同一个HBase表的同一个单元格写入数据。由于两个线程同时写入，所以很有可能出