91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

  • 大小: 750KB
    文件類型: .rar
    金幣: 2
    下載: 0 次
    發(fā)布日期: 2021-05-16
  • 語言: Java
  • 標簽: hbase??

資源簡介

java從本地讀文件并上傳Hbase

資源截圖

代碼片段和文件信息


/**
?*?Created?by?Jiao?on?2017/4/3.
?*/


import?java.io.IOException;
import?java.io.BufferedReader;
import?java.io.File;
import?java.io.FileInputStream;
import?java.io.InputStreamReader;



import?java.net.URI;
import?java.util.ArrayList;
import?java.util.Hashtable;
import?java.util.Iterator;

import?java.util.List;
import?java.text.NumberFormat;
import?org.apache.hadoop.conf.Configuration;

import?org.apache.hadoop.hbase.HbaseConfiguration;
import?org.apache.hadoop.hbase.HColumnDescriptor;
import?org.apache.hadoop.hbase.HTableDescriptor;
import?org.apache.hadoop.hbase.client.HbaseAdmin;
import?org.apache.hadoop.hbase.client.HTablePool;
import?org.apache.hadoop.io.IOUtils;
import?org.apache.hadoop.fs.Path;

import?org.apache.hadoop.fs.FileSystem;
import?org.apache.hadoop.fs.FSDataInputStream;
import?org.apache.hadoop.hbase.client.HTable;
import?org.apache.hadoop.hbase.TableName;
import?org.apache.hadoop.hbase.client.Put;


public?class?project?{
????public?static?void?main(String[]?args)?throws?IOException?{

//writeback?to?hbase
Configuration?Hbase_CONFIG?=?new?Configuration();
// Hbase_CONFIG.set(“hbase.zookeeper.quorum“?“192.168.0.104“);

String?tableName?=?“HB_MEM_“;
String?family=“cf“;
????????HbaseAdmin?hbaseAdmin?=?new?HbaseAdmin(Hbase_CONFIG);

????????if?(hbaseAdmin.tableExists(tableName))?{?//check
????????????hbaseAdmin.disableTable(tableName);
????????????hbaseAdmin.deleteTable(tableName);
????????????System.out.println(tableName?+?“?is?existdetele....“);
????????}

????????HTableDescriptor?htd?=?new?HTableDescriptor(TableName.valueOf(tableName));
????????HColumnDescriptor?cf=?new?HColumnDescriptor(family);
????????htd.addFamily(cf);
????????hbaseAdmin.createTable(htd);
????????hbaseAdmin.close();
HTable?Hbasetable?=?new?HTable(Hbase_CONFIGTableName.valueOf(tableName));

String?filePath?=?“/root/input_2“;
File?file=new?File(filePath);
InputStreamReader?in_stream?=?new?InputStreamReader(new?FileInputStream(file));??
????????BufferedReader?in?=?new?BufferedReader(in_stream);
????????String?s;
int?i=0;


????????while?((s=in.readLine())!=null?)?{

????????????String[]?words?=?s.split(“?“);
????????????String?key?=?words[0];
????String?value=words[1];
????????????
????Put?put?=?new?Put(key.getBytes());

????????????put.add(family.getBytes()?“value“.getBytes()?value.getBytes());

????????????System.out.println(“Save?to?Hbase!?key:“+key+“?“+“value:“+value);
????????????Hbasetable.put(put);
????????}
????????Hbasetable.close();
????????System.out.println(“put?successful!!!“);
???
????}
}



?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件????2580373??2017-05-22?09:14??project\input_2

?????文件???????2575??2017-05-22?10:23??project\project.java

?????目錄??????????0??2017-05-22?10:23??project

-----------?---------??----------?-----??----

??????????????2582948????????????????????3


評論

共有 條評論