diff --git a/src/main/java/HBaseEmpManager.java b/src/main/java/HBaseEmpManager.java index bd54574..80e79f6 100644 --- a/src/main/java/HBaseEmpManager.java +++ b/src/main/java/HBaseEmpManager.java @@ -178,4 +178,28 @@ public class HBaseEmpManager { System.out.println("Most Recently Promoted Employee: " + latestEmp + ", Promotion Date: " + latestDate); table.close(); } + + // 统计培训课程的参与人数 + private static void countTrainingParticipants() throws IOException { + Table table = connection.getTable(TableName.valueOf(TABLE_NAME)); + Scan scan = new Scan(); + scan.addColumn(Bytes.toBytes(CF_TRAINING), Bytes.toBytes("training_courses")); + + ResultScanner scanner = table.getScanner(scan); + Map countMap = new HashMap<>(); + + for (Result result : scanner) { + String courses = Bytes.toString(result.getValue(Bytes.toBytes(CF_TRAINING), Bytes.toBytes("training_courses"))); + for (String course : courses.split(", ")) { + countMap.put(course, countMap.getOrDefault(course, 0) + 1); + } + } + + System.out.println("培训课程统计:"); + for (Map.Entry entry : countMap.entrySet()) { + System.out.println(entry.getKey() + ": " + entry.getValue() + " 人"); + } + + table.close(); + } }