hbase-sdk

基于HBase Client的相關(guān)API開發(fā)而來的一款輕量級的HBase ORM框架。提供SQL查詢功能，以類SQL的方式——HQL讀寫HBase數(shù)據(jù)。?

針對HBase 1.x和2.xAPI的不同之處，在其上做了一層統(tǒng)一的封裝。

hbase-sdk分為spring-boot-starter-hbase和hbase-sdk-core兩部分。

SpringBoot項目中引入spring-boot-starter-hbase，在普通的Java項目中則可以使用hbase-sdk-core。

---

hbase-sdk 是一款輕量級的ORM框架，封裝了對HBase數(shù)據(jù)表的讀寫操作和對集群的運維管理，并針對HBase1.x的API和2.xAPI的差異，做了統(tǒng)一的定義， 提供更加方便的調(diào)用API。同時，HQL的功能也已上線，提供了類SQL讀寫數(shù)據(jù)的能力，這將大大降低HBase Client API的使用門檻。API文檔地址:?

https://weixiaotome.gitee.io/hbase-sdk/

如果覺得這個項目不錯可以 star 支持或者打賞它。

功能特性

• [x] 消除不同版本API的差異，重新定義接口規(guī)范
• [x] 優(yōu)良的ORM特性，數(shù)據(jù)查詢結(jié)果集自動映射Java實體類
• [x] HQL，以類SQL的形式讀寫HBase的表中數(shù)據(jù)
• [x] 利用spring-boot-starter-hbase無縫與SpringBoot集成
• [x] HBatis，類似于myBatis，提供配置文件管理HQL的功能(努力規(guī)劃中)
• [x] 熔斷能力，提供API級別的主備集群自動切換功能，保障服務(wù)的高可用(努力規(guī)劃中)
• [x] JDK8+

快速開始

hbase-sdk 的每個版本經(jīng)過測試完成之后，都會編譯打包至各個模塊，最后發(fā)布到maven中央倉庫之中，只是最新版本的代碼有一定的延遲。如果你想在第一時間體驗該項目， 可以選擇在Gitee或Github中克隆源碼，在本地編譯并運行測試用例。

hbase-sdk 基于java8開發(fā)，如果你想自己編譯或體驗，請確保已經(jīng)安裝了Java8和maven3+。此外，如果你想在本地進行開發(fā)調(diào)試，建議在本地存在一個可連通的HBase環(huán)境。如果你想快速搭建一個HBase的開發(fā)環(huán)境，請參考：

https://www.jielongping.com/archives/dockerhbasetest

hbase-sdk 開發(fā)所用的工具為IDEA，所以也極力推薦導(dǎo)入項目到idea中。

1. 普通項目

Maven 配置：

創(chuàng)建一個基礎(chǔ)的 Maven 工程，HBase SDK API開發(fā)時基于的HBase版本主要是1.4.3和2.1.0。

所以，如果你的HBase版本是1.x，可以使用如下依賴。

<dependency>
????<groupId>com.github.CCweixiaogroupId>
????<artifactId>hbase-sdk-core_1.4artifactId>
????<version>2.0.6version>
dependency>

如果你的HBase版本是2.x，則可以使用如下依賴。

<dependency>
????<groupId>com.github.CCweixiaogroupId>
????<artifactId>hbase-sdk-core_2.1artifactId>
????<version>1.0.5version>
dependency>

hbase-sdk目前最新的版本是2.0.6。你可以在maven倉庫中搜索CCweixiao來獲取hbase-sdk相關(guān)jar包的最新版本。

https://mvnrepository.com/artifact/com.github.CCweixiao

當(dāng)然，如果你想重新編譯，以適配你自己的HBase版本，也可以選擇下載源碼，修改項目根pom.xml文件中的hbase.version，之后運行如下編譯命令：

git?clone?https://github.com/CCweixiao/hbase-sdk.git??or
git?clone?https://gitee.com/weixiaotome/hbase-sdk.git
cd?hbase-sdk
mvn?clean?install?-Dmaven.test.skip=true

2. 項目結(jié)構(gòu)

project

API核心類繼承結(jié)構(gòu)示意圖：

3. 在SpringBoot項目中使用

Maven 配置：

創(chuàng)建一個基于Maven的spring boot工程。

<dependency>
????<groupId>com.github.CCweixiaogroupId>
????<artifactId>spring-boot-starter-hbase_1.4artifactId>
????<version>2.0.6version>
dependency>

or

<dependency>
????<groupId>com.github.CCweixiaogroupId>
????<artifactId>spring-boot-starter-hbase_2.1artifactId>
????<version>2.0.6version>
dependency>

spring-boot-starter-hbase這個模塊中已經(jīng)包含了hbase-sdk-core。

4. 引入hbase-client的依賴

除了引入hbase-sdk的相關(guān)依賴之外，你還需要引入hbase-client的依賴，hbase-client的版本目前建議為1.2.x、1.4.x、2.1.x。hbase-client1.x和2.x的新舊API有所差異。未來，hbase-sdk會持續(xù)完善該依賴的版本兼容。

<dependency>
????<groupId>org.apache.hbasegroupId>
????<artifactId>hbase-clientartifactId>
????<version>1.4.3version>
dependency>????????

or

<dependency>
????<groupId>org.apache.hbasegroupId>
????<artifactId>hbase-clientartifactId>
????<version>2.1.0version>
dependency>????????

5. 配置HBase數(shù)據(jù)庫連接

普通項目

//?數(shù)據(jù)讀寫API
HBaseTemplate?hBaseTemplate?=?new?HBaseTemplate("node1",?"2181");
//?管理員API
HBaseAdminTemplate?hBaseAdminTemplate?=?new?HBaseAdminTemplate("node1",?"2181");
//?HQL操作API
HBaseSqlTemplate?hBaseSqlTemplate?=?new?HBaseSqlTemplate("localhost",?"2181");

spring boot項目

application.yaml

spring:
??data:
????hbase:
??????quorum:?node1,node2,node3
??????node-parent:?/hbase
??????zk-client-port:?2181
??????root-dir:?/hbase
??????client-properties:?hbase.client.retries.number=3

@Autowired 依賴注入

@Service
public?class?UserService?{
????@Autowired
????private?HBaseTemplate?hBaseTemplate;
????@Autowired
????private?HBaseAdminTemplate?hBaseAdminTemplate;
}

集群管理

HBaseAdminTemplate封裝了HBaseAdmin的常用操作，比如namespace的管理、表的管理、以及快照管理等等，后續(xù)這些API將會更加完善。

admin-api

創(chuàng)建namespace

????@Test
????public?void?testCreateNamespace()?{
????????String?namespaceName?=?"LEO_NS";
????????
????????NamespaceDesc?namespaceDesc?=?new?NamespaceDesc();
????????namespaceDesc.setNamespaceName(namespaceName);
????????//?為namespace添加屬性
????????namespaceDesc?=?namespaceDesc.addNamespaceProp("desc",?"測試命名空間")
????????????????.addNamespaceProp("createBy",?"leo").addNamespaceProp("updateBy",?"admin");

????????hBaseTemplate.createNamespace(namespaceDesc);
????}

創(chuàng)建表

????@Test
????public?void?testCreateTable()?{
????????String?tableName?=?"LEO_NS:USER";

????????TableDesc?tableDesc?=?new?TableDesc();
????????tableDesc.setTableName(tableName);

????????tableDesc?=?tableDesc.addProp("tag",?"測試用戶表").addProp("createUser",?"leo");

????????FamilyDesc?familyDesc1?=?new?FamilyDesc.Builder()
????????????????.familyName("INFO")
????????????????.replicationScope(1)
????????????????.compressionType("NONE")
????????????????.timeToLive(2147483647)
????????????????.maxVersions(1).build();

????????FamilyDesc?familyDesc2?=?new?FamilyDesc.Builder()
????????????????.familyName("INFO2")
????????????????.replicationScope(0)
????????????????.compressionType("SNAPPY")
????????????????.timeToLive(864000)
????????????????.maxVersions(3).build();

????????tableDesc?=?tableDesc.addFamilyDesc(familyDesc1).addFamilyDesc(familyDesc2);

????????hBaseTemplate.createTable(tableDesc,?false);
????}

更多操作

可以參考相關(guān)API文檔或測試用例

數(shù)據(jù)讀寫

類似于Hibernate，你也可以使用hbase-sdk框架所提供的ORM特性，來實現(xiàn)對HBase的數(shù)據(jù)讀寫操作。

api-data

創(chuàng)建數(shù)據(jù)模型類

public?class?ModelEntity?{
????private?String?createBy;
????private?Long?createTime;

????public?String?getCreateBy()?{
????????return?createBy;
????}

????public?void?setCreateBy(String?createBy)?{
????????this.createBy?=?createBy;
????}

????public?Long?getCreateTime()?{
????????return?createTime;
????}

????public?void?setCreateTime(Long?createTime)?{
????????this.createTime?=?createTime;
????}
}
@HBaseTable(schema?=?"TEST",?name?=?"LEO_USER",?uniqueFamily?=?"info1")
public?class?UserEntity?extends?ModelEntity{
????@HBaseRowKey
????private?String?userId;

????private?String?username;
????private?int?age;
????private?List?addresses;private?Map?contactInfo;private?Double?pay;@HBaseColumn(name?=?"is_vip",?family?=?"INFO2",?toUpperCase?=?true)private?boolean?isVip;public?String?getUserId()?{return?userId;
????}public?void?setUserId(String?userId)?{this.userId?=?userId;
????}public?String?getUsername()?{return?username;
????}public?void?setUsername(String?username)?{this.username?=?username;
????}public?int?getAge()?{return?age;
????}public?void?setAge(int?age)?{this.age?=?age;
????}public?boolean?isVip()?{return?isVip;
????}public?void?setVip(boolean?vip)?{
????????isVip?=?vip;
????}public?List?getAddresses()?{return?addresses;
????}public?void?setAddresses(List?addresses)?{this.addresses?=?addresses;
????}public?Map?getContactInfo()?{return?contactInfo;
????}public?void?setContactInfo(Map?contactInfo)?{this.contactInfo?=?contactInfo;
????}public?Double?getPay()?{return?pay;
????}public?void?setPay(Double?pay)?{this.pay?=?pay;
????}@Overridepublic?String?toString()?{return?"UserEntity{"?+"userId='"?+?userId?+?'\''?+",?username='"?+?username?+?'\''?+",?age="?+?age?+",?addresses="?+?addresses?+",?contactInfo="?+?contactInfo?+",?pay="?+?pay?+",?isVip="?+?isVip?+'}';
????}
}

@HBaseTable(schema = "TEST", name = "LEO_USER", uniqueFamily = "info1")

HBaseTable注解用于定義HBase的表信息，schema用于定義該表的命名空間，如果不指定，默認是default， name用于定義該表的表名，如果不指定，表名則為類名的組合單詞拆分加'_'拼接，如：UserEntity對應(yīng)的表名為：user_entity。uniqueFamily用于定義如果所有的字段不特配置列簇名，則使用此處配置的列簇名。

@HBaseRowKey private String userId;

該注解表示userId字段為rowKey字段。

@HBaseColumn(name = "is_vip", family = "INFO2", toUpperCase = true) private boolean isVip; 該注解用于定義一個字段信息，name用于定義字段名，如果不指定，則默認使用字段名的組合單詞拆分加'_'拼接，如：isVip，對應(yīng)的字段名是：is_vip. family用于定義該字段屬于INFO2列簇，toUpperCase表示字段名是否轉(zhuǎn)大寫，默認false，不做操作。

保存數(shù)據(jù)

???@Test
????public?void?testSaveUser()?{
????????UserEntity?userEntity?=?new?UserEntity();
????????userEntity.setUserId("10001");
????????userEntity.setUsername("leo");
????????userEntity.setAge(18);
????????userEntity.setVip(true);
????????userEntity.setAddresses(Arrays.asList("北京",?"上海"));
????????userEntity.setCreateBy("admin");
????????userEntity.setCreateTime(System.currentTimeMillis());

????????Map?contactInfo?=?new?HashMap<>(2);
????????contactInfo.put("email",?"2326130720@qq.com");
????????contactInfo.put("phone",?"18739577988");
????????contactInfo.put("address",?"浦東新區(qū)");
????????userEntity.setContactInfo(contactInfo);
????????userEntity.setPay(100000.0d);try?{
????????????hBaseTemplate.save(userEntity);
????????????System.out.println("用戶數(shù)據(jù)保存成功！");
????????}?catch?(Exception?e)?{
????????????e.printStackTrace();
????????}
????}

除此之外，保存數(shù)據(jù)時也可以不必構(gòu)造數(shù)據(jù)模型類，而直接構(gòu)造map數(shù)據(jù)模型。

????@Test
????public?void?testToSave()?{
????????Map?data?=?new?HashMap<>();
????????data.put("info1:addresses",?Arrays.asList("廣州",?"深圳"));
????????data.put("info1:username",?"leo");
????????data.put("info1:age",?18);
????????data.put("INFO2:IS_VIP",?true);
????????data.put("info1:pay",?10000.1d);
????????data.put("info1:create_by",?"tom");
????????data.put("info1:create_time",?System.currentTimeMillis());
????????Map?contactInfo?=?new?HashMap<>(2);
????????contactInfo.put("email",?"2326130720@qq.com");
????????contactInfo.put("phone",?"18739577988");
????????contactInfo.put("address",?"浦東新區(qū)");
????????data.put("info1:contact_info",?contactInfo);
????????hBaseTemplate.save("TEST:LEO_USER",?"10002",?data);
????????System.out.println("用戶數(shù)據(jù)保存成功！");
????}

批量保存數(shù)據(jù)

????@Test
????public?void?testToSaveBatch()?{
????????Map>?data?=?new?HashMap<>();
????????Map?data1?=?new?HashMap<>();
????????data1.put("info1:username",?"kangkang");
????????data1.put("info1:age",?18);
????????data1.put("INFO2:IS_VIP",?true);
????????Map?data2?=?new?HashMap<>();
????????data2.put("info1:username",?"jane");
????????data2.put("info1:age",?18);
????????data2.put("INFO2:IS_VIP",?false);
????????data.put("12003",?data1);
????????data.put("11004",?data2);
????????hBaseTemplate.saveBatch("TEST:LEO_USER",?data);
????????System.out.println("用戶數(shù)據(jù)批量保存成功！");
????}

根據(jù)RowKey查詢

????@Test
????public?void?testGet()?{
????????UserEntity?userEntity?=?hBaseTemplate.getByRowKey("10001",?UserEntity.class);
????????final?UserEntity?userEntity1?=?hBaseTemplate.getByRowKey("10002",?UserEntity.class);
????????System.out.println("用戶數(shù)據(jù)獲取成功！");
????????System.out.println(userEntity);
????}
????@Test
????public?void?testGetToMap()?{
????????Map?userInfo?=?hBaseTemplate.getByRowKey("TEST:LEO_USER",?"10001");
????????System.out.println(Boolean.valueOf(userInfo.get("INFO2:IS_VIP").toString()));
????????System.out.println(userInfo);
????}

scan查詢

????@Test
????public?void?testFind()?{
????????final?List?userEntities?=?hBaseTemplate.findAll(10,?UserEntity.class);
????????System.out.println(userEntities);
????????System.out.println("用戶數(shù)據(jù)批量查詢");
????}@Testpublic?void?testFindByPrefix()?{final?List?userEntities?=?hBaseTemplate.findByPrefix("11",?10,?UserEntity.class);
????????System.out.println("用戶數(shù)據(jù)批量查詢");
????}

刪除數(shù)據(jù)

????@Test
????public?void?testDeleteData()?{
????????hBaseTemplate.delete("TEST:LEO_USER",?"12003");
????????hBaseTemplate.delete("TEST:LEO_USER",?"11004",?"INFO2");
????????hBaseTemplate.delete("TEST:LEO_USER",?"10001",?"info1",?"addresses");
????????System.out.println("數(shù)據(jù)刪除完成");
????}
????@Test
????public?void?testDeleteBatch()?{
????????hBaseTemplate.deleteBatch("TEST:LEO_USER",?Arrays.asList("10001",?"10002"));
????????hBaseTemplate.deleteBatch("TEST:LEO_USER",?Collections.singletonList("10003"),?"INFO2");
????????hBaseTemplate.deleteBatch("TEST:LEO_USER",?Collections.singletonList("10004"),
????????????????"info1",?"age",?"username");
????}

HQL

hbase-sdk 從2.0.6版本開始，開始提供HQL功能，一種以類SQL的方式讀寫HBase集群的數(shù)據(jù)，降低API的使用復(fù)雜度。HQL的操作依賴HBaseSqlTemplate來完成， 因此使用之前，必須構(gòu)造好HBaseSqlTemplate的對象實例。

hql

構(gòu)造HBaseSqlTemplate的示例。

????private?HBaseSqlTemplate?hBaseSqlTemplate;

????@Before
????public?void?testInitHBaseSqlTemplate()?{
????????hBaseSqlTemplate?=?new?HBaseSqlTemplate("localhost",?"2181");

????????List?hBaseColumnSchemas?=?createHBaseColumnSchemaList();
????????HBaseTableSchema?hBaseTableSchema?=?new?HBaseTableSchema();
????????hBaseTableSchema.setTableName("LEO_USER");
????????hBaseTableSchema.setDefaultFamily("g");//hBaseTableSchema.setRowKeyHandlerName("string");
????????HBaseTableConfig?hBaseTableConfig?=?new?DefaultHBaseTableConfig(hBaseTableSchema,?hBaseColumnSchemas);
????????hBaseSqlTemplate.setHBaseTableConfig(hBaseTableConfig);
????}public?List?createHBaseColumnSchemaList()?{
????????????List?hBaseColumnSchemas?=?new?ArrayList<>();
????????????HBaseColumnSchema?hBaseColumnSchema1?=?new?HBaseColumnSchema();
????????????hBaseColumnSchema1.setFamily("g");
????????????hBaseColumnSchema1.setQualifier("id");
????????????hBaseColumnSchema1.setTypeName("string");
????????????HBaseColumnSchema?hBaseColumnSchema2?=?new?HBaseColumnSchema();
????????????hBaseColumnSchema2.setFamily("g");
????????????hBaseColumnSchema2.setQualifier("name");
????????????hBaseColumnSchema2.setTypeName("string");
????????????HBaseColumnSchema?hBaseColumnSchema3?=?new?HBaseColumnSchema();
????????????hBaseColumnSchema3.setFamily("g");
????????????hBaseColumnSchema3.setQualifier("age");
????????????hBaseColumnSchema3.setTypeName("int");
????????????HBaseColumnSchema?hBaseColumnSchema4?=?new?HBaseColumnSchema();
????????????hBaseColumnSchema4.setFamily("g");
????????????hBaseColumnSchema4.setQualifier("address");
????????????hBaseColumnSchema4.setTypeName("string");
????????????hBaseColumnSchemas.add(hBaseColumnSchema1);
????????????hBaseColumnSchemas.add(hBaseColumnSchema2);
????????????hBaseColumnSchemas.add(hBaseColumnSchema3);
????????????hBaseColumnSchemas.add(hBaseColumnSchema4);return?hBaseColumnSchemas;
????????}

構(gòu)造hBaseSqlTemplate示例需要先構(gòu)造HBaseTableConfig，HBaseTableConfig的兩個成員變量，

????protected?HBaseTableSchema?hBaseTableSchema;
????protected??List?hBaseColumnSchemaList;

分別用來表的Schema信息和HBase表對應(yīng)列的元數(shù)據(jù)信息。

針對HBase表列的數(shù)據(jù)類型轉(zhuǎn)換，目前內(nèi)置的實現(xiàn)有：

Boolean、Byte、Char、Date、Double、Float、Hex、Int、Long、Short、String

通過實現(xiàn)LiteralInterpreter接口，你可以定義自己的列數(shù)據(jù)類型轉(zhuǎn)換實現(xiàn)。

{
?"tableName":"TEST:USER",
?"defaultFamily":"INFO",
?"columnSchema":[
??{
???"family":"INFO",
???"qualifier":"name",
???"typeName":"string"
??},
??{
???"family":"INFO2",
???"qualifier":"age",
???"typeName":"int"
??}
?]
}

通過實現(xiàn)相應(yīng)的接口，你可以選擇加載HBase表、列元數(shù)據(jù)信息的方式。如：類型myBatis在XML文件中加載。

HBaseSqlTemplate的實例準備好之后，就可以使用HQL來進行數(shù)據(jù)讀寫。

insert

insert?into?LEO_USER?(?g:id?,?g:name?,?g:age?,?g:address?)?values?(?'10001',?'leo1'?,?'18',?'shanghai'?)?where?rowKey?is?stringkey?(?'a10002'?)?ts?is?'1604160000000'

insert?into?LEO_USER?(?g:id?,?g:name?,?g:age?,?g:address?)?values?(?'10002',?'leo2'?,?'17',?'beijing'?)?where?rowKey?is?stringkey?(?'a10002'?)


????@Test
????public?void?testInsertSql()?{
????????String?sql?=?"insert?into?LEO_USER?(?g:id?,?g:name?,?g:age?,?g:address?)?values?(?'10001',?'leo'?,?'18',?'shanghai'?)?where?rowKey?is?stringkey?(?'a10002'?)?ts?is?'1604160000000'";
????????hBaseSqlTemplate.insert(sql);
????????System.out.println("insert?successfully!");
????}

select

select?(?g:id?,?g:name?,?g:age?,?g:address?)?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10002'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)??maxversion?is?2??startTS?is?'1604160000000'?,?endTS?is?'1604160000001'?limit?1,?10?

select?*?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10002'?)?(?(?name?equal?'leo1'?and?age?less?'20'?)?or?(?id?greater?'10000'?)?)??maxversion?is?2??startTS?is?'1604160000000'?,?endTS?is?'1604160000001'?limit?10
????@Test
????public?void?testSelectSql()?{
????????String?sql?=?"select?(?g:id?,?g:name?,?g:age?,?g:address?)?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10002'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)??maxversion?is?2??startTS?is?'1604160000000'?,?endTS?is?'1604160000001'?limit?10?";
????????sql?=?"select?*?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10002'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)??maxversion?is?2??startTS?is?'1604160000000'?,?endTS?is?'1604160000001'?limit?10?";

????????final?List>?listList?=?hBaseSqlTemplate.select(sql);
????????listList.forEach(dataList?->?{
????????????dataList.forEach(data?->?{
????????????????System.out.println(data.getRowKey());
????????????????System.out.println(data.getFamilyStr());
????????????????System.out.println(data.getQualifierStr());
????????????????System.out.println(data.getTsDate());
????????????????System.out.println("########################################");
????????????});
????????});
????}

delete

delete?(?id?,?name?)?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10003'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)?ts?is?'1604160000000'
delete?*?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10003'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)?ts?is?'1604160000000'
delete?*?from?LEO_USER?where?rowKey?is?stringkey?(?'a10002'?)?(?name?equal?'leo2'?or?age?less?'21'?)?ts?is?'1604160000000'
????@Test
????public?void?testDeleteSql(){
????????String?sql?=?"delete?(?id?,?name?)?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10003'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)?ts?is?'1604160000000'";
????????sql?=?"delete?*?from?LEO_USER?where?startKey?is?stringkey?(?'a10001'?)?,?endKey?is?stringkey?(?'a10003'?)?(?(?name?equal?'leo'?and?age?less?'12'?)?or?(?id?greater?'10000'?)?)?ts?is?'1604160000000'";
????????sql?=?"delete?*?from?LEO_USER?where?rowKey?is?stringkey?(?'a10002'?)?(?name?equal?'leo'?or?age?less?'21'?)?ts?is?'1604160000000'";

????????hBaseSqlTemplate.delete(sql);
????}

特別鳴謝

HQL的語法設(shè)計以及antlr4的語法解析，有參考alibaba的開源項目 simplehbase，在此特別感謝。simplehbase感覺是一個被遺棄的項目，針對的HBase版本是0。94， 已經(jīng)有超過6年沒有維護了。

hbase-sdk 在simplehbase的基礎(chǔ)上進行重組和解耦，以兼容hbase-sdk原有的框架設(shè)計，并便于以后的擴展。

hbase-sdk 目前的不足

非HQL的數(shù)據(jù)讀寫API還不豐富，特別是數(shù)據(jù)過濾的查詢API。

HQL的antlr4解析功能不太完善，比如，目前HQL對中文要求不太好，同時，HQL對語法的要求比較嚴格，多一個空格少一個空格貌似都會引起語法錯誤。后續(xù)會針對這些缺點一一優(yōu)化。

未來計劃

• HBatis，類似于MyBatis的ORM框架，以XML管理SQL的方式維護集群數(shù)據(jù)的讀寫操作
• 集成Hystrix熔斷框架，實現(xiàn)API層面的主備集群自動切換功能
• 還有更多

更新日志

v2.0.6 2020-11-29

• HQL功能上線

v2.0.5 2020-11-14

• 新增功能與代碼優(yōu)化

v2.0.3 2020-10-08

• 大量重構(gòu)和優(yōu)化

v1.0.5 2020-09-07

• 完善基礎(chǔ)API的功能
• 完成ORM特性
• 模塊拆分
• ......

總結(jié)

以上是生活随笔為你收集整理的java连接hbase_HBase 工具 | hbasesdk 推出HQL功能的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。