目  录

一、实验目的

二、实验环境

三、实验内容与完成情况

3.1 用Hadoop提供的HBase Shell命令完成以下任务

3.2 现有以下关系型数据库中的表和数据，要求将其转换为适合于HBase存储的表并插入数据：

四、问题和解决方法

五、心得体会

一、实验目的

        1. 理解HBase在Hadoop体系结构中的角色。

        2. 熟悉使用HBase操作常用的Shell命令。

        3. 数据HBase操作常用的Java API。

二、实验环境

        1. 硬件要求：笔记本电脑一台

        2. 软件要求：VMWare虚拟机、Ubuntu 18.04 64、JDK1.8、Hadoop-3.1.3、HBase-2.2.2、Windows11操作系统、Eclipse

三、实验内容与完成情况

3.1 用Hadoop提供的HBase Shell命令完成以下任务

        （1）列出HBase所有表的相关信息，如表名、创建时间等。

        ①使用以下Shell命令列出HBase所有的表的相关信息，如表名、创建时间等：

list

        ②利用Eclipse软件在HBase类中创建listTables方法列出HBase所有的表的相关信息，如表名、创建时间等：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException;
import java.util.List;public class HBaseExample {private static Configuration configuration;private static Connection connection;private static Admin admin;public static void main(String[] args) throws IOException {// 初始化连接init();// 列出所有表格listTables();// 关闭连接close();}// 列出所有表格public static void listTables() throws IOException {// 获取所有表格的描述符List<TableDescriptor> tableDescriptors = admin.listTableDescriptors();// 打印每个表的名称for (TableDescriptor tableDescriptor : tableDescriptors) {TableName tableName = tableDescriptor.getTableName();System.out.println("Table: " + tableName);}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Failed to initialize connection: " + e.getMessage());e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Failed to close connection: " + e.getMessage());e.printStackTrace();}}
}

        （2）在终端输出指定表的所有记录数据。

        ①使用以下Shell命令在终端输出指定表的所有记录数据：

scan 's1'

        ②利用Eclipse软件在HBase类中创建getData和printRecoder方法实现输出指定表的所有记录数据：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;
import java.util.List;public class HBaseExample {private static Configuration configuration;private static Connection connection;private static Admin admin;public static void main(String[] args) throws IOException {// 初始化连接init();// 获取并打印指定表的数据getData("Student");// 关闭连接close();}// 获取并打印指定表的数据public static void getData(String tableName) throws IOException {// 使用 try-with-resources 来确保自动关闭资源try (Table table = connection.getTable(TableName.valueOf(tableName));ResultScanner scanner = table.getScanner(new Scan())) {for (Result result : scanner) {printRecord(result);}} catch (IOException e) {System.err.println("Error retrieving data from table: " + tableName);e.printStackTrace();}}// 打印一条记录的详细信息public static void printRecord(Result result) {for (Cell cell : result.rawCells()) {String row = Bytes.toString(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength());String family = Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength());String qualifier = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());long timestamp = cell.getTimestamp();System.out.println("Row: " + row);System.out.println("Column Family: " + family);System.out.println("Column: " + qualifier);System.out.println("Value: " + value);System.out.println("Timestamp: " + timestamp);System.out.println("---------------------------");}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection.");e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection.");e.printStackTrace();}}
}

        （3）向已经创建好的表添加和删除指定的列族或列。

        ①使用以下Shell命令创建表s1：

 create 's1','score'

        ②使用以下Shell命令在s1中添加数据：

put 's1','zhangsan','score:Math','69'

        ③使用以下Shell命令在s1中删除指定的列：

delete 's1','zhangsan','score:Math'

        ④利用Eclipse软件在HBase类中创建insterRow和deleRow方法实现添加和删除指定的列族或列：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;public class HBaseExample {private static Configuration configuration;private static Connection connection;private static Admin admin;public static void main(String[] args) throws IOException {// 初始化连接init();// 向表插入数据insertRow("Student", "s1", "info", "name", "zhangsan");insertRow("Student", "s1", "score", "Math", "69");// 删除指定的数据deleteRow("Student", "s1", "score", "Math");// 关闭连接close();}// 向表中插入数据public static void insertRow(String tableName, String rowKey, String colFamily, String col, String val) throws IOException {try (Table table = connection.getTable(TableName.valueOf(tableName))) {Put put = new Put(rowKey.getBytes());put.addColumn(colFamily.getBytes(), col.getBytes(), val.getBytes());table.put(put);} catch (IOException e) {System.err.println("Error inserting row into table " + tableName);e.printStackTrace();}}// 删除指定的数据public static void deleteRow(String tableName, String rowKey, String colFamily, String col) throws IOException {try (Table table = connection.getTable(TableName.valueOf(tableName))) {Delete delete = new Delete(rowKey.getBytes());// 删除指定列族delete.addFamily(Bytes.toBytes(colFamily));// 删除指定列delete.addColumn(Bytes.toBytes(colFamily), Bytes.toBytes(col));table.delete(delete);} catch (IOException e) {System.err.println("Error deleting row from table " + tableName);e.printStackTrace();}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection.");e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection.");e.printStackTrace();}}
}

        （4）清空指定的表的所有记录数据。

        ①使用以下Shell命令清空指定的表的所有记录数据：

truncate 's1'

        ②利用Eclipse软件在HBase类中创建clearRows方法实现清空指定的表的所有记录数据：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;public class HBaseExample {private static Configuration configuration;private static Connection connection;private static Admin admin;public static void main(String[] args) throws IOException {// 初始化连接init();// 清空指定表的数据clearRows("Student");// 关闭连接close();}// 清空指定表的数据public static void clearRows(String tableName) throws IOException {try (Table table = connection.getTable(TableName.valueOf(tableName))) {Scan scan = new Scan();ResultScanner scanner = table.getScanner(scan);for (Result result : scanner) {Delete delete = new Delete(result.getRow());table.delete(delete);}} catch (IOException e) {System.err.println("Error clearing rows in table: " + tableName);e.printStackTrace();}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection.");e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection.");e.printStackTrace();}}
}

        （5）统计表的行数。

        ①使用以下Shell命令统计表的行数：

count 's1'

        ②利用Eclipse软件在HBase类中创建countRows方法实现统计表的行数：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;public class HBaseExample {private static Configuration configuration;private static Connection connection;private static Admin admin;public static void main(String[] args) throws IOException {// 初始化连接init();// 统计指定表的行数countRows("Student");// 关闭连接close();}// 统计表的行数public static void countRows(String tableName) throws IOException {try (Table table = connection.getTable(TableName.valueOf(tableName));ResultScanner scanner = table.getScanner(new Scan())) {int num = 0;for (Result result : scanner) {num++;}System.out.println("行数: " + num);} catch (IOException e) {System.err.println("Error counting rows in table: " + tableName);e.printStackTrace();}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection.");e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection.");e.printStackTrace();}}
}

3.2 现有以下关系型数据库中的表和数据，要求将其转换为适合于HBase存储的表并插入数据：

        （1）使用Shell命令将学生表、课程表、选课表的数据信息添加到对应的数据表中。

        ①使用以下Shell命令创建学生表：

create 'Student','S_No','S_Name','S_Sex','S_Age'

        ②使用以下Shell命令在学生表中插入对应的数据信息：

put 'Student','s001','S_No','2015001'

put 'Student','s001','S_Name','Zhangsan'

put 'Student','s001','S_Sex','male'

put 'Student','s001','S_Age','23'

put 'Student','s002','S_No','2015002'

put 'Student','s002','S_Name','Mary'

put 'Student','s002','S_Sex','female'

put 'Student','s002','S_Age','22'

put 'Student','s003','S_No','2015003'

put 'Student','s003','S_Name','Lisi'

put 'Student','s003','S_Sex','male'

put 'Student','s003','S_Age','24'

        ③使用以下Shell命令创建课程表：

create 'Course','C_No','C_Name','C_Credit'

        ④使用以下Shell命令在课程表中插入对应的数据信息：

put 'Course','c001','C_No','123001'

put 'Course','c001','C_Name','Math'

put 'Course','c001','C_Credit','2.0'

put 'Course','c002','C_No','123002'

put 'Course','c002','C_Name','Computer'

put 'Course','c002','C_Credit','5.0'

put 'Course','c003','C_No','123003'

put 'Course','c003','C_Name','English'

put 'Course','c003','C_Credit','3.0'

        ⑤使用以下Shell命令创建选课表：

create 'SC','SC_Sno','SC_Cno','SC_Score'

        ⑥使用以下Shell命令在选课表中插入对应的数据信息：

put 'SC','sc001','SC_Sno','2015001'

put 'SC','sc001','SC_Cno','123001'

put 'SC','sc001','SC_Score','86'

put 'SC','sc002','SC_Sno','2015001'

put 'SC','sc002','SC_Cno','123003'

put 'SC','sc002','SC_Score','69'

put 'SC','sc003','SC_Sno','2015002'

put 'SC','sc003','SC_Cno','123002'

put 'SC','sc003','SC_Score','77'

put 'SC','sc004','SC_Sno','2015002'

put 'SC','sc004','SC_Cno','123003'

put 'SC','sc004','SC_Score','99'

put 'SC','sc005','SC_Sno','2015003'

put 'SC','sc005','SC_Cno','123001'

put 'SC','sc005','SC_Score','98'

        （2）请编程实现 createTable(String tableName, String[] fields)

        创建表，参数 tableName 为表的名称，字符串数组 fields 为存储记录各个字段名称的数组。要求当 HBase 已经存在名为 tableName 的表的时候，先删除原有的表，然后再创建新的表。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;
import java.util.List;public class HBaseExample {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException {init();String a = "score";createTable("s1", new String[]{a});close();}// 创建表，字段数组对应列族public static void createTable(String tableName, String[] fields) throws IOException {TableName tablename = TableName.valueOf(tableName);// 如果表已经存在，则删除原有表if (admin.tableExists(tablename)) {System.out.println("数据表已经存在!");admin.disableTable(tablename);admin.deleteTable(tablename); // 删除原来的表}// 构建表描述符TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(tablename);// 设置列族for (String field : fields) {tableDescriptorBuilder.setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(field)).build());}// 创建表admin.createTable(tableDescriptorBuilder.build());System.out.println("表创建成功: " + tableName);}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection.");e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection.");e.printStackTrace();}}
}

        （3）请编程实现 addRecord(String tableName, String row, String[] fields, String[] values)向表 tableName 、行 row （用 S_Name 表示）和字符串数组 fields 指定的单元格中添加 对应的数据 values 。其中， fields 中每个元素如果对应的列族下还有相应的列限定符的话， 用“ columnFamily:column ”表示。例如，同时向“ Math ”、“ Computer Science ”、“ English ” 三 列添 加 成 绩 时 ， 字 符 串 数 组 fields 为 {“Score:Math”, ”Score:Computer Science”, ”Score:English”} ，数组 values 存储这三门课的成绩。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;
import java.util.List;public class HBaseExample {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException {init();String[] fields = {"score:Math", "score:Chinese"};String[] values = {"58", "77"};addRecord("s1", "1", fields, values);close();}// 向表添加记录public static void addRecord(String tableName, String row, String[] fields, String[] values) throws IOException {Table table = connection.getTable(TableName.valueOf(tableName));try {for (int i = 0; i < fields.length; i++) {Put put = new Put(row.getBytes());String[] cols = fields[i].split(":");if (cols.length == 2) {put.addColumn(cols[0].getBytes(), cols[1].getBytes(), values[i].getBytes());table.put(put);} else {System.out.println("字段格式不正确，应该为列族:列名 格式。");}}} catch (IOException e) {System.err.println("Error while adding record: " + e.getMessage());throw e;  // Rethrow to allow the caller to handle it as needed} finally {table.close();}}// 初始化 HBase 连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection: " + e.getMessage());e.printStackTrace();}}// 关闭 HBase 连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection: " + e.getMessage());e.printStackTrace();}}
}

（4）请编程实现 scanColumn(String tableName, String column)浏览表 tableName 某一列的数据，如果某一行记录中该列数据不存在，则返回 null 。要 求当参数 column 为某一列族名称时，如果底下有若干个列限定符，则要列出每个列限定符代表的列的数据；当参数 column 为某一列具体名称（例如“ Score:Math ”）时，只需要列出该列的数据。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;import java.io.IOException;
import org.apache.hadoop.hbase.Cell;public class HBaseExample {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException {init();scanColumn("s1", "score");close();}// 扫描指定列族并打印结果public static void scanColumn(String tableName, String column) throws IOException {Table table = connection.getTable(TableName.valueOf(tableName));Scan scan = new Scan();scan.addFamily(Bytes.toBytes(column)); // 扫描指定列族try (ResultScanner scanner = table.getScanner(scan)) {for (Result result : scanner) {showCell(result); // 打印每一行的内容}}}// 格式化输出结果public static void showCell(Result result) {for (Cell cell : result.rawCells()) {String rowName = new String(Bytes.toString(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()));String columnFamily = new String(Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()));String columnName = new String(Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()));String value = new String(Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()));long timestamp = cell.getTimestamp();System.out.println("Row Name: " + rowName);System.out.println("Timestamp: " + timestamp);System.out.println("Column Family: " + columnFamily);System.out.println("Column: " + columnName);System.out.println("Value: " + value);System.out.println("--------------------------------");}}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {System.err.println("Error initializing HBase connection: " + e.getMessage());e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {System.err.println("Error closing HBase connection: " + e.getMessage());e.printStackTrace();}}
}

        （5）请编程实现 modifyData(String tableName, String row, String column)修改表 tableName ，行 row （可以用学生姓名 S_Name 表示），列 column 指定的单元格的数据。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;public class HBase {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException {init();modifyData("s1", "Math", "score", "1");close();}// 修改数据public static void modifyData(String tableName, String columnFamily, String column, String val) throws IOException {init();Table table = connection.getTable(TableName.valueOf(tableName));// 创建Put操作，指定row keyPut put = new Put("1".getBytes()); // 这里使用 "1" 作为row key// 将数据添加到指定的列族和列名put.addColumn(columnFamily.getBytes(), column.getBytes(), val.getBytes());// 执行Put操作table.put(put);table.close();}// 初始化连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {e.printStackTrace();}}// 关闭连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {e.printStackTrace();}}
}

        （6）请编程实现 deleteRow(String tableName, String row)删除表 tableName 中 row 指定的行的记录。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.TableName;public class HBase {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException {init();deleteRow("s1", "1");  // 删除表 "s1" 中行键为 "1" 的数据close();}// 删除指定的行数据public static void deleteRow(String tableName, String row) throws IOException {init();Table table = connection.getTable(TableName.valueOf(tableName));// 创建一个Delete对象，传入要删除的rowKeyDelete delete = new Delete(row.getBytes());// 如果只想删除特定列的数据，可以使用以下方式:// delete.addColumn(Bytes.toBytes("score"), Bytes.toBytes("Math"));// 删除整行数据table.delete(delete);table.close();}// 初始化HBase连接public static void init() {configuration = HBaseConfiguration.create();configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();} catch (IOException e) {e.printStackTrace();}}// 关闭HBase连接public static void close() {try {if (admin != null) {admin.close();}if (connection != null) {connection.close();}} catch (IOException e) {e.printStackTrace();}}
}

四、问题和解决方法

        1. 实验问题：Hadoop无法启动或启动失败。

解决方法：检查Hadoop配置文件中的路径和参数设置，确保正确设置以及文件的可访问性，对配置文件进行修改后对应问题得到解决。

        2. 实验问题：Hadoop的任务无法运行或失败。

解决方法：检查任务配置文件中的输入输出路径是否正确，并确保输入数据存在，更改输入输出路径后问题得到解决。

        3. 实验问题：执行命令时提示"命令未找到"。

解决方法：确保命令拼写正确，并检查命令是否安装在系统路径中。可以使用which命令来确定命令的路径，并将其添加到系统路径中。

        4. 实验问题：没有足够的权限执行某个命令。

解决方法：尝试使用sudo命令以管理员权限运行命令，或者联系系统管理员赋予所需的权限。

        5. 实验问题：在连接 HBase 时，出现连接异常。

解决方法：检查 HBase 的配置文件是否正确，并确保 HBase 服务已启动。

        6. 实验问题：在创建表时，出现表已存在的错误。

解决方法：在创建表之前，先判断表是否已存在，如果存在则先删除表再创建。

        7. 实验问题：在创建表时，指定的列族不存在。

解决方法：在创建表时，需要指定表的列族，如果指定的列族不存在，则先创建列族。

        8. 实验问题：在插入数据时，出现数据格式错误。

解决方法：检查插入的数据是否符合 HBase 的数据类型要求，如字符串需要使用 Bytes.toBytes()方法转换为字节数组。

        9. 实验问题：在查询数据时，出现空指针异常。

解决方法：在查询数据之前，先判断表是否存在，如果不存在则先创建表。

        10. 实验问题：在删除表时，出现表不存在的错误。

解决方法：在删除表之前，先判断表是否存在，如果不存在则不进行删除操作。

        11. 实验问题：在删除表时，出现表被禁用的错误。

解决方法：在删除表之前，先判断表是否被禁用，如果被禁用则先启用表再删除。

        12. 实验问题：在清空表数据时，出现数据仍存在的错误。

解决方法：在清空表数据之前，先判断表是否存在，如果不存在则不进行清空操作。

        13. 实验问题：在统计表行数时，出现表不存在的错误。

解决方法：在统计表行数之前，先判断表是否存在，如果不存在则不进行统计操作。

        14. 实验问题：在创建表时，出现权限不足的错误。

解决方法：使用具有足够权限的用户执行创建表操作。

        15. 实验问题：在插入数据时，出现连接超时的错误。

解决方法：检查网络连接是否正常，并增加连接超时时间。

        16. 实验问题：在查询数据时，出现查询速度慢的问题。

解决方法：优化查询语句，尽量减少全表扫描的情况，可以使用过滤器或者二级索引来提高查询效率。

        17. 实验问题：在查询数据时，出现数据丢失的问题。

解决方法：检查数据是否正确插入，并确保查询语句正确。

        18. 实验问题：在创建表时，出现表名不合法的错误。

解决方法：检查表名是否符合 HBase 的命名规范，如只能包含字母、数字和下划线。

        19. 实验问题：在插入数据时，出现主键重复的错误。

解决方法：检查插入的数据是否已存在，如果存在则更新数据。

        20. 实验问题：压缩或解压缩文件。

解决方法：使用tar命令进行文件压缩和解压缩。例如，使用tar -czvf archive.tar.gz directory可以将一个目录压缩为.tar.gz文件。

        21. 实验问题：在删除表时，出现删除失败的错误。

解决方法：检查表是否已被其他操作占用，如禁用状态、正在进行的写操作等。

        22. 实验问题：快速访问最近使用的命令。

解决方法：使用命令历史和快捷键。按下上箭头键可以在命令历史中向上导航，并按下回车键执行选中的命令。使用Ctrl + R可以进行反向搜索并执行最近使用的命令。

        23. 实验问题：在清空表数据时，出现清空失败的错误。

解决方法：检查表是否已被其他操作占用，如禁用状态、正在进行的写操作等。

        24. 实验问题：应用程序崩溃或卡死。

解决方法：由于库依赖错误、磁盘空间不足、损坏的配置文件导致的。重装应用程序后问题得到解决。

        25. 实验问题：在Eclipse集成开发环境中编写代码时字体太小不利于观察。

解决方法：点击Window->Preferences->在搜索栏中输入font->General-> Appearance->Colors and Fonts->Basic->Text Font->点击Edit进行字体的设置->点击确认即完成了字体大小的设置。

        26. 实验问题：编写Java代码进行中文输出时出现了乱码现象。

解决方法：鼠标右击->Run As->Run Configurations->Common->在Other后填写gbk然后点击Run进行运行后中文可以正常输出。

        27. 实验问题：建立类后无法运行，显示没有主程序。

解决方法：填写主类运行信息语句public static void main(String[] args)或者继续在包内新建一个主类，通过类组合的形式进行类的运行。

        28. 实验问题：在调用一些类的成员变量的时候显示错误。

解决方法：所调用的类成员变量为私有类型，私有类型只能在类内访问，类外无法对其直接进行访问，在类内构造公有函数形成一个对外接口，在其他类内直接通过调用这个函数来访问其类内部的私有成员即可。

        29. 实验问题：在查询数据时，出现查询结果不准确的问题。

解决方法：检查查询语句是否正确，并确保数据已正确插入。

五、心得体会

        1、在操作HBase之前，应先判断表是否存在，避免空指针异常。

        2、删除表前应先判断表是否存在，避免表不存在的错误。

        3、合理使用权限管理命令，可以确保系统的安全性。

        4、通过使用>、>>和|等操作符，我可以将命令的输出导入到文件中，或者将多个命令连接起来以实现更复杂的数据流操作。

        5、删除表前应先判断表是否被禁用，避免表被禁用的错误。

        6、清空表数据前应先判断表是否存在，避免数据仍存在的错误。

        7、统计表行数前应先判断表是否存在，避免表不存在的错误。

        8、创建表时需使用具有足够权限的用户，避免权限不足的错误。

        9、在使用单引号和双引号的时候要特别注意，输出单个字符时可以使用单引号，如果同时输出多个字符时只能使用双引号进行输出，不然会报错。

        10、在使用一些标点符号的时候要特别注意，代码内的标点符号均为英文，所以在注释和写代码切换的时候要特别的注意。

        11、插入数据时需检查网络连接是否正常，避免连接超时的错误。

        12、查询数据时应优化查询语句，减少全表扫描，提高查询速度。

        13、查询数据时需确保数据正确插入，避免数据丢失的问题。

        14、创建表时需检查表名是否合法，符合HBase命名规范。

        15、插入数据时需检查数据是否已存在，避免主键重复的错误。

        16、删除表时需检查表是否被其他操作占用，避免删除失败的错误。

        17、清空表数据时需检查表是否被其他操作占用，避免清空失败的错误。

        18、统计表行数时需检查表是否被其他操作占用，避免统计失败的错误。

        19、查询数据时需确保查询语句正确，避免查询结果不准确的问题。

        20、HBase表名只能包含字母、数字和下划线，不合法的表名会导致创建失败。

        21、HBase支持使用过滤器和二级索引来提高查询效率，HBase使用Bytes()方法将数据转换为字节数组进行存储。

        22、在操作HBase时，应注意数据的正确插入和更新，避免数据不一致的问题。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/pingmian/88839.shtml
繁体地址，请注明出处：http://hk.pswp.cn/pingmian/88839.shtml
英文地址，请注明出处：http://en.pswp.cn/pingmian/88839.shtml

如若内容造成侵权/违法违规/事实不符，请联系英文站点网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

微服务初步入门

微服务初步入门

服务拆分原则 单一职责原则 单一职责原则原本是面向对象设计的一个基本原则&#xff0c;是指一个类应该专注于单一的功能&#xff0c;不要存在多于一个导致类变更的原因 在微服务架构中&#xff0c;是指一个微服务只负责一个功能或者业务领域&#xff0c;每个服务应该由清晰的定…
阅读更多...
Liunx操作系统笔记5

Liunx操作系统笔记5

用户管理命令&#xff1a; useradd命令&#xff1a; useradd命令的功能是创建并设置用户信息。使用useradd命令可以自动完成用户信息、基本组、家目录等的创建工作&#xff0c;并在创建过程中对用户初始信息进行定制。语法格式:useradd 参数 用户名常用参数: -M 不建立用…
阅读更多...
spring-ai-alibaba 接入Tushare查询股票行情

spring-ai-alibaba 接入Tushare查询股票行情

最近spring-ai-alibaba主干分支新增了对Tushare的支持&#xff0c;一起来看看如何使用简单样例老样子&#xff0c;分三步进行&#xff1a;第一步&#xff1a;添加依赖<dependency><groupId>com.alibaba.cloud.ai</groupId><artifactId>spring-ai-aliba…
阅读更多...
Java使用Langchai4j接入AI大模型的简单使用(一)

Java使用Langchai4j接入AI大模型的简单使用(一)

一、LangChain4j 简介 LangChain4j 是 Java 生态中的 LangChain 实现&#xff0c;是一个用于构建大语言模型(LLM)应用程序的框架。它提供了与各种LLM服务集成的能力&#xff0c;并简化了构建复杂AI应用的过程。 LangChain4j官方文档&#xff1a;Integrations | LangChain4j …
阅读更多...
Linux —— A / 基础指令

Linux —— A / 基础指令

建议学习路径&#xff1a;Linux系统与系统编程 ⇒ Linux网络和网络编程 ⇒ MySQL一、初识shell命令 1.1、关于 Linux 桌面很多同学的 Linux 启动进⼊图形化的桌⾯. 这个东西⼤家以后就可以忘记了。以后的工作中没有机会使用图形界面。思考: 为什么不使用图形界面? 1.2、下…
阅读更多...
[论文阅读] 人工智能 + 软件工程 | 用大语言模型+排名机制，让代码评论自动更新更靠谱

[论文阅读] 人工智能 + 软件工程 | 用大语言模型+排名机制，让代码评论自动更新更靠谱

LLMCup&#xff1a;用大语言模型排名机制&#xff0c;让代码评论自动更新更靠谱 LLMCup: Ranking-Enhanced Comment Updating with LLMsarXiv:2507.08671 LLMCup: Ranking-Enhanced Comment Updating with LLMs Hua Ge, Juan Zhai, Minxue Pan, Fusen He, Ziyue Tan Comments: …
阅读更多...
悲观锁 乐观锁

悲观锁 乐观锁

悲观锁 乐观锁 在没有加锁的秒杀场景下 每秒打进来的请求是巨大的 高并发场景下 我们发现不仅异常率高的可怕 库存竟然还变成了负数 这产生的结果肯定是很大损失的 那为什么会出现超卖问题呢 我们假设有下面两个线程线程1查询库存&#xff0c;发现库存充足&#xff0c;创建订单…
阅读更多...
如何使用Cisco DevNet提供的免费ACI学习实验室（Learning Labs）？（Grok3 回答）

如何使用Cisco DevNet提供的免费ACI学习实验室（Learning Labs）？（Grok3 回答）

Cisco DevNet 提供的免费 ACI&#xff08;Application Centric Infrastructure&#xff09;学习实验室&#xff08;Learning Labs&#xff09;是帮助用户学习和实践 Cisco ACI 技术&#xff08;包括 APIC 控制器&#xff09;的优秀资源&#xff0c;适合网络工程师、开发者和准备…
阅读更多...
Combine的介绍与使用

Combine的介绍与使用

目录一、Combine 框架介绍二、核心概念三、基础使用示例3.1、创建 Publisher & 订阅3.2、操作符链式调用3.3、Subject 使用&#xff08;手动发送值&#xff09;3.4、网络请求处理3.5、组合多个 Publisher3.6、错误处理四、核心操作符速查表 Operator五、UIKit 绑定示例六、…
阅读更多...
【Java笔记】七大排序

【Java笔记】七大排序

目录1. 直接插入排序2. 希尔排序3. 选择排序4. 堆排序(重要)5. 冒泡排序6. 快速排序&#xff08;重要&#xff09;6.1 Hoare 法6.1.1 Hoare 法优化6.2 挖坑法&#xff08;重点&#xff09;6.3 快速排序的非递归写法7. 归并排序海量数据的排序问题8. 总结1. 直接插入排序 时间复…
阅读更多...
H.264编解码（NAL）

H.264编解码（NAL）

在我们的日常生活中&#xff0c;比如有缓存电影或者是发送视频的需求。如果没有视频压缩&#xff0c;一部手机只能存几分钟视频&#xff0c;1TB 硬盘也装不下几部电影&#xff0c;用 4G 网络发一段 1 分钟视频&#xff0c;可能需要几十分钟&#xff08;甚至传不完&#xff09;&…
阅读更多...
新手向:Python自动化办公批量重命名与整理文件系统

新手向:Python自动化办公批量重命名与整理文件系统

本文将详细介绍如何使用Python实现一个强大的文件批量重命名与整理工具&#xff0c;帮助开发者自动化这一繁琐过程。本教程面向Python初学者&#xff0c;通过一个完整的项目案例&#xff0c;讲解文件系统操作的核心技术。我们将构建的工具将具备以下功能&#xff1a;基于正则表…
阅读更多...
C++ 左值右值、左值引用右值引用、integral_constant、integral_constant的元模板使用案例

C++ 左值右值、左值引用右值引用、integral_constant、integral_constant的元模板使用案例

C 左值右值、左值引用右值引用、integral_constant、integral_constant的元模板使用案例一、左值右值1.左值2.右值二、左值引用右值引用1.左值引用2.右值引用总结三、integral_constant四、integral_constant的元模板使用案例1.求最大整数2.内存对齐alignof关键字元模板计算内存…
阅读更多...
c++算法一

c++算法一

1.双指针总结&#xff1a;1.复写0这道题&#xff0c;告诉我们要正难其反&#xff0c;我们从后向前进行重写&#xff0c;删除某些数字的时候&#xff0c;我们可以从前向后遍历&#xff0c;但是增加一些数字的时候会对后面的数据进行覆盖&#xff0c;所以要从后向前进行2.快乐数涉…
阅读更多...
LeetCode-283. 移动零(Java)

LeetCode-283. 移动零(Java)

283. 移动零 给定一个数组 nums&#xff0c;编写一个函数将所有 0 移动到数组的末尾&#xff0c;同时保持非零元素的相对顺序。 请注意 &#xff0c;必须在不复制数组的情况下原地对数组进行操作。 示例 1: 输入: nums [0,1,0,3,12] 输出: [1,3,12,0,0] 示例 2: 输入: n…
阅读更多...
【数据库】慢SQL优化 - MYSQL

【数据库】慢SQL优化 - MYSQL

一、数据库故障的关键点 引起数据库故障的因素有操作系统层面、存储层面&#xff0c;还有断电断网的基础环境层面&#xff08;以下称为外部因素&#xff09;&#xff0c;以及应用程序操作数据库和人为操作数据库这两个层面&#xff08;以下称内部因素&#xff09;。这些故障中外…
阅读更多...
桶排序算法深度剖析

桶排序算法深度剖析

&#x1f50d; 桶排序算法深度剖析 &#x1f3af; 核心原理图解⚙️ 完整算法流程 #mermaid-svg-LyB6SpaZ132X4Wtn {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-LyB6SpaZ132X4Wtn .error-icon{fill:#552222;}#mer…
阅读更多...
对S32K144做的BMS安装快速开发Simulink库及BMS例程介绍

对S32K144做的BMS安装快速开发Simulink库及BMS例程介绍

前言 本章介绍BMS硬件功能及SimuLink库为主&#xff0c;捎带介绍一些例程内容 注意&#xff1a;例程所用的协议均是自定义的 自做的SimuLink库也会不定期更新 BMS例程的内容不定期维护添加 当前的BMS没有主动均衡功能&#xff0c;这个有考虑后期加上&#xff0c;当前还处于…
阅读更多...
urlencode、html实体编码、unicode

urlencode、html实体编码、unicode

目录 urlencode html实体编码 Unicode编码 urlencode URL编码也称为百分号编码&#xff0c;用于将URL中的特殊字符转换为安全传输的格式。英文数字一般不编码 特点&#xff1a; 使用%后跟两个十六进制数字表示字符 空格编码为或%20 保留字符&#xff08;; / ? : & …
阅读更多...
【HarmonyOS】元服务概念详解

【HarmonyOS】元服务概念详解

【HarmonyOS】元服务概念详解 最近几年&#xff0c;我们手里的设备越来越多——手机、平板、手表、车机……光是管理这些设备上的APP就够头疼了&#xff1a;下载要流量、安装占内存、换个设备又得重新弄一遍。有没有更简单的方式&#xff1f;HarmonyOS推出的“元服务”&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023