HBase中的TTL与MinVersion的关系

2021-09-04 13:07:32

HBase版本：1.3.1

TTL（Time-To-Live）：每个Cell的数据超时时间（当前时间 - 最后更新的时间）

MinVersion：如果当前存储的所有时间版本都早于TTL，至少MIN_VERSION个最新版本会保留下来。这样确保在你的查询以及数据早于TTL时有结果返回。

===先做一个实验===

1、创建一个表TEST1

包含两个列族df、ex，其中列族ex为测试对象：VERSIONS => 4, MIN_VERSIONS => 2, TTL => 3分钟

2、向该表中生产10条数据

生产数据的代码如下所示：

package api;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.*;

public class table_put_sample1 {

    public static void main(String[] args) throws Exception {

        Configuration conf = HBaseConfiguration.create();

        conf.set("hbase.zookeeper.quorum", "192.168.1.80,192.168.1.81,192.168.1.82");

        Connection connection = ConnectionFactory.createConnection(conf);

        Table table = connection.getTable(TableName.valueOf(constants.TABLE_NAME));

        for (int i = 0; i < 10; i++) {

            Put put = new Put("row01".getBytes());

            put.addColumn(constants.COLUMN_FAMILY_DF.getBytes(), "name".getBytes(), random.getName());

            put.addColumn(constants.COLUMN_FAMILY_DF.getBytes(), "sex".getBytes(), random.getSex());

            put.addColumn(constants.COLUMN_FAMILY_EX.getBytes(), "height".getBytes(), random.getHeight());

            put.addColumn(constants.COLUMN_FAMILY_EX.getBytes(), "weight".getBytes(), random.getWeight());

            table.put(put);

            System.out.print("[------]put i=" + i + "\n");

            Thread.sleep(1000);

        }

        table.close();

        connection.close();

    }

}