fly6516s_Education.test/BD-exp-5
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix import errors

Browse Source
This commit is contained in:
fly6516 2025-03-26 01:48:21 +00:00
parent 082fab718a
commit e73d1d95a9
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/EmpHBaseClient.java
View File

@ -10,18 +10,20 @@ import java.util.Map;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration; 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.TableName;
import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.HTableDescriptor; //import org.apache.hadoop.hbase.client.HTableDescriptor;
import org.apache.hadoop.hbase.client.HColumnDescriptor; //import org.apache.hadoop.hbase.client.HColumnDescriptor;
import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table; 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.BinaryComparator;
import org.apache.hadoop.hbase.filter.CompareFilter; import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter.FilterList; import org.apache.hadoop.hbase.filter.FilterList;
@ -126,7 +128,7 @@ public class EmpHBaseClient {
// 新增查询ID 7500以上员工方法 // 新增查询ID 7500以上员工方法
public void findEmployeesWithEmpnoAbove7500() throws IOException { public void findEmployeesWithEmpnoAbove7500() throws IOException {
Scan scan = new Scan(); Scan scan = new Scan();
FilterProtos.SingleColumnValueFilter filter = new SingleColumnValueFilter( SingleColumnValueFilter filter = new SingleColumnValueFilter(
Bytes.toBytes("empnum"), Bytes.toBytes("empnum"),
Bytes.toBytes("empno"), Bytes.toBytes("empno"),
CompareFilter.CompareOp.GREATER_OR_EQUAL, CompareFilter.CompareOp.GREATER_OR_EQUAL,