HBase过滤器使用方法(三)- - - - - -批量把导入 - 行业资讯 - 肥雀云

一、应用线程导入

,,,, 1,创建把方法

public class 嗯{ 　　public static Configuration 配置=new 配置();; 　　静态{ 　　config.set (“hbase.zookeeper.property.clientPoint”、“2181”); 　　config.set (“hbase.zookeeper.quorum”、“hbase”); 　　config.set (“dfs.socket.timeout”,“180000”); 　　} 　　,,,public static void (String 表名,String RowKey String 家庭,String 限定符,String 价值){ 　　,,,HTable h=零; 　　,,,试着{ 　　,,,,,,,h=new HTable(配置表); 　　,,,,,,,Put 把=new 把(Bytes.toBytes (RowKey)); 　　,,,,,,,put.add (Bytes.toBytes(家庭),Bytes.toBytes(预选赛),Bytes.toBytes(值)); 　　,,,,,,,h.put(把); 　　,,,}捕捉(Exception e) {e.printStackTrace();}{终于　　,,,,,,,try { 　　,,,,,,,h.close (); 　　,,,,,,,},catch (IOException e), { 　　,,,,,,,,,,,e.printStackTrace (); 　　,,,,,,,,,,,} 　　,,,,,,,} 　　,,,} 　　}

,,,, 2,创建线程

,,,,,,,,

,,,,public class PutXX { 　　,,,public static void main (String [], args), { 　　,,,,,,,run1 r1=new run1 (); 　　,,,,,,,Thread rr1=new 线程(r1); 　　,,,,,,,rr1.start (); 　　,,,,,,,run2 r2=new run2 (); 　　,,,,,,,Thread rr2=new 线程(r2); 　　,,,,,,,rr2.start (); 　　,,,,,,,//这里创建两个线程,需要可以继续创建~ 　　} 　　} 　　class run1 implements Runnable { 　　public void run (), { 　　(int i=0; i<=10000000;我+ +){ 　　,,,mmm.put(“元”,“+我+”,,“属性”,,“yuan_name”,“xx”+ i); 　　,,,System.out.println(我); 　　,,,} 　　} 　　} 　　class run2 implements Runnable { 　　public void run (), { 　　(int i=10000001; i<=20000000;我+ +){ 　　,,,mmm.put(“元”,“+我+”,,“属性”,,“yuan_name”,“xx”+ i); 　　,,,System.out.println(我); 　　,,,} 　　} 　　}

,,& lt; 2015.2.2>

,,,,数据导入速度慢。之前把方法每执行一次就要新一个新HTable然后释放资源. .太墨迹了

,,,,新把

,,,,

public static void NBput (String 表名,int RowKey String 家庭,String 限定符,String 价值){ 　　,,,,,,,HTable h=零; 　　,,,,,,,try { 　　,,,,,,,,,,,h=new HTable(配置表); 　　,,,,,,,,,,,,(int i=RowKey i<=(RowKey + 10000000);我+ +){ 　　,,,,,,,,,,,String 行=" + + "; 　　,,,,,,,,,,,Put 把=new 把(Bytes.toBytes(行)); 　　,,,,,,,,,,,put.add (Bytes.toBytes(家庭),Bytes.toBytes(预选赛),Bytes.toBytes(值)); 　　,,,,,,,,,,,h.put(把); 　　,,,,,,,,,,,System.out.println(我); 　　,,,,,,,} 　　,,,,,,,,,,,},catch (IOException e), { 　　,,,,,,,,,,,,,,,e.printStackTrace (); 　　,,,,,,,,,,,最后}{ 　　,,,,,,,,,,,try { 　　,,,,,,,,,,,,,,,h.close (); 　　,,,,,,,,,,,},catch (IOException e), { 　　,,,,,,,,,,,,,,,e.printStackTrace (); 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null