Code666 (代码贴、代码片段)

[Java] HBase 插入数据 →→→→→进入此内容的聊天室

来自 , 2021-03-05, 写在 Java, 查看 160 次.
URL http://www.code666.cn/view/3621f145
  1. HTable table = new HTable(hbaseConfig, tableName);
  2.  
  3. table.setAutoFlush(autoFlush);
  4.  
  5. List<Put> lp = new ArrayList<Put>();
  6.  
  7. int count = 10000;
  8.  
  9. byte[] buffer = new byte[1024];
  10.  
  11. Random r = new Random();
  12.  
  13. for (int i = 1; i <= count; ++i) {
  14.  
  15.        Put p = new Put(String.format(“row%09d”,i).getBytes());
  16.  
  17.        r.nextBytes(buffer);
  18.  
  19.        p.add(“f1″.getBytes(), null, buffer);
  20.  
  21.        p.add(“f2″.getBytes(), null, buffer);
  22.  
  23.        p.add(“f3″.getBytes(), null, buffer);
  24.  
  25.        p.add(“f4″.getBytes(), null, buffer);
  26.  
  27.        p.setWriteToWAL(wal);
  28.  
  29.        lp.add(p);
  30.  
  31.        if(i%1000==0){
  32.  
  33.            table.put(lp);
  34.  
  35.            lp.clear();
  36.  
  37.        }
  38.  
  39.     }

回复 "HBase 插入数据"

这儿你可以回复上面这条便签

captcha

贴代码片段 - Code666