From 082fab718a0ef2a5674dc80ab0013991fa45bbad Mon Sep 17 00:00:00 2001 From: fly6516 Date: Wed, 26 Mar 2025 09:45:46 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=20HBase=20=E6=93=8D?= =?UTF-8?q?=E4=BD=9C=E7=9B=B8=E5=85=B3=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增 HBase配置和连接代码 - 添加表描述符、列族描述符等导入 - 实现数据插入、查询等功能的基础设施 --- src/main/java/EmpHBaseClient.java | 29 +++++++++++++++++++++++++++-- 1 file changed, 27 insertions(+), 2 deletions(-) diff --git a/src/main/java/EmpHBaseClient.java b/src/main/java/EmpHBaseClient.java index aefaf74..43684e2 100644 --- a/src/main/java/EmpHBaseClient.java +++ b/src/main/java/EmpHBaseClient.java @@ -1,8 +1,33 @@ - - import java.io.BufferedReader; import java.io.FileReader; import java.io.IOException; +import java.time.LocalDate; +import java.util.ArrayList; +import java.util.Comparator; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.TableName; +import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.Connection; +import org.apache.hadoop.hbase.client.ConnectionFactory; +import org.apache.hadoop.hbase.client.HTableDescriptor; +import org.apache.hadoop.hbase.client.HColumnDescriptor; +import org.apache.hadoop.hbase.client.Put; +import org.apache.hadoop.hbase.client.Result; +import org.apache.hadoop.hbase.client.ResultScanner; +import org.apache.hadoop.hbase.client.Scan; +import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.client.Filter; +import org.apache.hadoop.hbase.filter.BinaryComparator; +import org.apache.hadoop.hbase.filter.CompareFilter; +import org.apache.hadoop.hbase.filter.FilterList; +import org.apache.hadoop.hbase.filter.SingleColumnValueFilter; +import org.apache.hadoop.hbase.util.Bytes; +import org.apache.commons.codec.digest.DigestUtils; public class EmpHBaseClient { private Configuration conf;