第一次提交

Author: WTree

.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+
+### VS Code ###
+.vscode/
+
+.mvn/

pom.xml

@@ -0,0 +1,60 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.common.data.hbase.read</groupId>
+    <artifactId>hbase-read-alone</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <msgpack.version>0.8.20</msgpack.version>
+        <jackson.version>2.9.10</jackson.version>
+        <hadoop.version>2.10.1</hadoop.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.msgpack</groupId>
+            <artifactId>msgpack-core</artifactId>
+            <version>${msgpack.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.hadoop</groupId>
+            <artifactId>hadoop-client</artifactId>
+            <version>${hadoop.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>javax.servlet</groupId>
+                    <artifactId>servlet-api</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.sun.jersey</groupId>
+                    <artifactId>jersey-core</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.sun.jersey</groupId>
+                    <artifactId>jersey-client</artifactId>
+                </exclusion>
+            </exclusions>
+
+        </dependency>
+        <dependency>
+            <groupId>org.apache.hbase</groupId>
+            <artifactId>hbase-client</artifactId>
+            <version>2.1.10</version>
+        </dependency>
+
+
+
+    </dependencies>
+
+</project>

readme.md

@@ -0,0 +1,64 @@
+使用这个库，读取HBase时可以像JPB的方式一样去获取数据，使用api相关的工程
+
+使用教程
+
+1、使用前的准备要配置好HBase 集群的连接
+
+2、配置仓库地址
+
+[![](https://jitpack.io/v/WTree/HBase-Reader.svg)](https://jitpack.io/#WTree/HBase-Reader)
+
+```
+	<repositories>
+		<repository>
+		    <id>jitpack.io</id>
+		    <url>https://jitpack.io</url>
+		</repository>
+	</repositories>
+	
+	
+	
+	<dependency>
+	    <groupId>com.github.WTree</groupId>
+	    <artifactId>HBase-Reader</artifactId>
+	    <version>v0.1</version>
+	</dependency>
+	 
+``` 
+
+3、配置要读取的实体
+
+``` 
+@HBaseInfo(tableName = "product", tableNameSpace = "ay")
+public class ProductInfo implements IFieldCheck, Serializable {
+
+    @HBaseFieldName(PackType = EnumPack.PACK_BYTES, HBaseKey = "i")
+    private String id;
+    
+    @HBaseFieldName(PackType = EnumPack.PACK_BYTES, HBaseKey = "t")
+    private String title;
+    
+    @HBaseFieldName(PackType = EnumPack.PACK_BYTES, HBaseKey = "p")
+    private String price;
+    
+    //这个为了允许实体里面的部分字段为空
+    @Override
+    public boolean isEmptyValue() {
+        return StringUtils.isEmpty(id);
+    }
+
+```
+
+4、读取
+
+```
+  byte[] rowKey = DigestUtils.sha1Hex("34514").getBytes();
+  //这个callBack是为了只读取部分字段而设置的
+  IGetFieldCallBack callBack = () -> new String[]{"id", "price"};
+  //getConnection() 自己集群的连接池
+  ProductInfo info = HBaseReadHelper.read(getConnection(), ProductInfo.class, callBack, rowKey);
+
+  //如果想把几个想读的字段直接转成JSON 对象，可以使用这个
+  BeanFactoryInterceptorHelper.intercept(info, callBack.fieldValue())
+  
+```

src/main/java/com/common/data/hbase/read/AbstractHBaseInfo.java

@@ -0,0 +1,35 @@
+package com.common.data.hbase.read;
+
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
+/**
+ * @author wtree
+ */
+public abstract class AbstractHBaseInfo {
+
+    @JsonIgnore
+    private byte[] row;
+
+    /**
+     * 优先获取这里的字段
+     */
+    @JsonIgnore
+    private String tableName;
+
+    public byte[] getRow() {
+        return row;
+    }
+
+    public void setRow(byte[] row) {
+        this.row = row;
+    }
+
+    public String getTableName() {
+        return tableName;
+    }
+
+    public void setTableName(String tableName) {
+        this.tableName = tableName;
+    }
+}