Hbase数据导入导出

package hbase;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HConnection;
import org.apache.hadoop.hbase.client.HConnectionManager;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;


@SuppressWarnings("deprecation")
public class HbaseExport {
	
	public static Date getPassSevenDays(int day){
		Calendar calendar = Calendar.getInstance();
		int year = calendar.get(Calendar.YEAR);
		int dayOfYear = calendar.get(Calendar.DAY_OF_YEAR);
		int j = 0;
		for(int i = 0;i < day; i++){
			calendar.set(Calendar.DAY_OF_YEAR, dayOfYear - j);
			if(calendar.get(Calendar.YEAR) < year){
				//跨年了
				j = 1;
				//更新 标记年
				year = year + 1;
				//重置日历
				calendar.set(year, Calendar.DECEMBER,31);
				//重新获取dayOfYear
				dayOfYear = calendar.get(Calendar.DAY_OF_YEAR);
			}else{
				j = j + 1;
			}
		}
		return calendar.getTime();
	}
	
	public static Scan setScanCondition(Scan scan) throws IOException{
		Date newDay = new Date();
		Date otherDays = getPassSevenDays(7);
		
		scan.setTimeRange(otherDays.getTime(),newDay.getTime());
		scan.addColumn("f1".getBytes(), "LS_certifier_no".getBytes());
		scan.addColumn("f1".getBytes(), "LS_location".getBytes());
		scan.addColumn("f1".getBytes(), "LS_phone_no".getBytes());
		scan.addColumn("f1".getBytes(), "LS_longitude".getBytes());
		scan.addColumn("f1".getBytes(), "LS_latitude".getBytes());
		scan.addColumn("f1".getBytes(), "date".getBytes());
		scan.addColumn("f1".getBytes(), "time".getBytes());
		scan.addColumn("f1".getBytes(), "hourOfDay".getBytes());

		return scan;
	}
	
	
	public static void main(String args[]) throws IOException{
		Configuration conf = HBaseConfiguration.create();
		HConnection connection = HConnectionManager.createConnection(conf);
		String tableName = "EVENT_LOG_LBS_HIS";
		HTableInterface table = connection.getTable(tableName);
		
		Scan scan = new Scan();
		setScanCondition(scan);
		
		ResultScanner rs = table.getScanner(scan);
		for(Result r : rs){
			List<String> lines = new ArrayList<String>();
			StringBuilder sb = new StringBuilder();
			sb.append(" rowkey=" + Bytes.toString(r.getRow()));
			for(Cell cell : r.rawCells()){
				String name = Bytes.toString(CellUtil.cloneQualifier(cell));
				String value = Bytes.toString(CellUtil.cloneValue(cell));
				System.out.println(name + "=" + value);
				sb.append("|" + name + "=" + value);
			}
			lines.add(sb.toString());
			System.out.println("--------------------------");
			writeFile(lines,"/home/hdfs/datas");
		}
		
	}
	
	public static void writeFile(List<String> lines,String filePath) throws FileNotFoundException{
		File file = new File(filePath);
		PrintWriter pw = new PrintWriter(new FileOutputStream(file,true));
		for(String line : lines){
			pw.append(line);
			pw.append("\n");
		}
		pw.flush();
		pw.close();
	}
	
}