diff --git a/src/main/java/EmpHBaseClient.java b/src/main/java/EmpHBaseClient.java index 43684e2..c27f1bf 100644 --- a/src/main/java/EmpHBaseClient.java +++ b/src/main/java/EmpHBaseClient.java @@ -10,18 +10,20 @@ import java.util.Map; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.HColumnDescriptor; +import org.apache.hadoop.hbase.HTableDescriptor; 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.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.client.Filter; import org.apache.hadoop.hbase.filter.BinaryComparator; import org.apache.hadoop.hbase.filter.CompareFilter; import org.apache.hadoop.hbase.filter.FilterList; @@ -126,7 +128,7 @@ public class EmpHBaseClient { // 新增查询ID 7500以上员工方法 public void findEmployeesWithEmpnoAbove7500() throws IOException { Scan scan = new Scan(); - FilterProtos.SingleColumnValueFilter filter = new SingleColumnValueFilter( + SingleColumnValueFilter filter = new SingleColumnValueFilter( Bytes.toBytes("empnum"), Bytes.toBytes("empno"), CompareFilter.CompareOp.GREATER_OR_EQUAL,