题目内容

//查询某个学生所选的所有课程列表学生1 @Test public void findCourseByStudent() throws IOException{ Table table = conn.getTable(tName); String stuId="student2016030421164483174"; ListcourseIds =new ArrayList(); Scan scan = new Scan(); RowFilter rf1 = new RowFilter(CompareOp.EQUAL, new RegexStringComparator(stuId+"_")); scan.setFilter(rf1); ResultScanner rs1 = table.getScanner(scan); Iteratorit = rs1.iterator(); while(it.hasNext()){ Result result = it.next(); byte[] rowKey = result.getRow(); courseIds.add(new String(rowKey,"utf8")); } for(String id : courseIds){ String courseId = id.split("_")[1]; Table courseTable = conn.getTable(tCourse); Get get = ( ) (courseId.getBytes()); Result result= courseTable.get(get); byte[] name = result. ( ) ("cf1".getBytes(), "name".getBytes()); System.out.println("课程ID:"+courseId+" 名称："+new String(name,"utf8")); } }

查看答案

搜索结果不匹配？点我反馈

更多问题

public void create() throws IOException{ Admin admin = conn.getAdmin(); if(admin.tableExists(tName)){ admin.disableTable(tName); ( ) ; } HTableDescriptor ht = new HTableDescriptor(tName); HColumnDescriptor hc = new HColumnDescriptor("cf1".getBytes()); hc.setMaxVersions(5); hc.setBlockCacheEnabled(true); hc.setBlocksize(180000); ht.addFamily(hc); admin.( ) (ht); System.out.println("表创建完成"); }

public void insert() throws IOException{ Table table = conn.getTable(tName); ListputList = new ArrayList(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); for(int i=1;i<20;i++){ String id=format.format(new Date()); id=id.replace("-", "").replace(" ", "").replace(":", ""); id = "student"+getRowKey(id); Put put = new Put(id.getBytes()); String name="Tom"+i; put.( ) ("cf1".getBytes(), "name".getBytes(), name.getBytes()); putList.( ) ; } table.put(putList); System.out.println("数据插入完成"); }

hbase.rootdir这个目录是 RegionServer 的共享目录，用来( ) 。特别注意的是 hbase.rootdir 里面的 HDFS 地址是要跟 Hadoop 的( )里面的 fs.defaultFS 的 HDFS 的 IP 地址或者域名、端口必须一致。

在开发工程中要配置Log4j，首先要创建什么？