HBase 示例

2024 年 8 月 28 日 | 阅读 2 分钟

让我们看一个 HBase 示例，将文件中的数据导入 HBase 表中。

用例

我们必须通过 Java API 创建 HBase 表，并将文件中存在的数据导入其中。

Data_file.txt 包含以下数据

1,India,Bihar,Champaran,2009,April,P1,1,5
2,India, Bihar,Patna,2009,May,P1,2,10
3,India, Bihar,Bhagalpur,2010,June,P2,3,15
4,United States,California,Fresno,2009,April,P2,2,5
5,United States,California,Long Beach,2010,July,P2,4,10
6,United States,California,San Francisco,2011,August,P1,6,20

Java 代码如下所示

此数据必须输入到通过 JAVA API 创建的新 HBase 表中。必须创建以下列族

列族 region 有三个列限定符：country、state、city

列族 Time 有两个列限定符：year、month

Jar 文件

编写代码时，请确保存在以下 jar 文件，因为它们是 HBase 所必需的。

commons-loging-1.0.4
commons-loging-api-1.0.4
hadoop-core-0.20.2-cdh3u2
hbase-0.90.4-cdh3u2
log4j-1.2.15
zookeper-3.3.3-cdh3u0

程序代码

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.StringTokenizer;

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.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;


public class readFromFile {
	public static void main(String[] args) throws IOException{
		if(args.length==1)
			{
			Configuration conf = HBaseConfiguration.create(new Configuration());
			HBaseAdmin hba = new HBaseAdmin(conf);
			if(!hba.tableExists(args[0])){
				HTableDescriptor ht = new HTableDescriptor(args[0]);
				ht.addFamily(new HColumnDescriptor("sample"));
				ht.addFamily(new HColumnDescriptor("region"));
				ht.addFamily(new HColumnDescriptor("time"));
				ht.addFamily(new HColumnDescriptor("product"));
				ht.addFamily(new HColumnDescriptor("sale"));
				ht.addFamily(new HColumnDescriptor("profit"));
				hba.createTable(ht);
				System.out.println("New Table Created");
				
				HTable table = new HTable(conf,args[0]);
			
				File f = new File("/home/training/Desktop/data");
				BufferedReader br = new BufferedReader(new FileReader(f));
				String line = br.readLine();
				int i =1;
				String rowname="row";
				while(line!=null && line.length()!=0){
					System.out.println("Ok till here");
					StringTokenizer tokens = new StringTokenizer(line,",");
					rowname = "row"+i;
					Put p = new Put(Bytes.toBytes(rowname));
					p.add(Bytes.toBytes("sample"),Bytes.toBytes("sampleNo."),
Bytes.toBytes(Integer.parseInt(tokens.nextToken())));
					p.add(Bytes.toBytes("region"),Bytes.toBytes("country"),Bytes.toBytes(tokens.nextToken()));
					p.add(Bytes.toBytes("region"),Bytes.toBytes("state"),Bytes.toBytes(tokens.nextToken()));
					p.add(Bytes.toBytes("region"),Bytes.toBytes("city"),Bytes.toBytes(tokens.nextToken()));
					p.add(Bytes.toBytes("time"),Bytes.toBytes("year"),Bytes.toBytes(Integer.parseInt(tokens.nextToken())));
					p.add(Bytes.toBytes("time"),Bytes.toBytes("month"),Bytes.toBytes(tokens.nextToken()));
					p.add(Bytes.toBytes("product"),Bytes.toBytes("productNo."),Bytes.toBytes(tokens.nextToken()));
					p.add(Bytes.toBytes("sale"),Bytes.toBytes("quantity"),Bytes.toBytes(Integer.parseInt(tokens.nextToken())));
					p.add(Bytes.toBytes("profit"),Bytes.toBytes("earnings"),Bytes.toBytes(tokens.nextToken()));
					i++;
					table.put(p);
					line = br.readLine();
				}
					br.close();
					table.close();
				}
			else
				System.out.println("Table Already exists.Please enter another table name");
		}
		else
			System.out.println("Please Enter the table name through command line");		
	}
}

下一主题Hive

HBase 示例

用例

Jar 文件

程序代码

联系信息

关注我们

教程

面试题

在线编译器

Python

Java

.Net Framework

AI, ML and Data Science

Cloud Technology

B.Tech and MCA

Web Technology

PHP

Software Testing

Technical Interview

Java Interview

Python

Web Interview

Database Interview

B.Tech / MCA

Important Interview

Software Testing Interview

Company Interviews

Online Compilers

Multiple Choice Questions

Hadoop 教程

Hadoop 模块

Hadoop - MapReduce

HBase

Hive 教程

Pig

Sqoop

Spark 教程

其他

面试题

HBase 示例

用例

Jar 文件

程序代码

相关帖子

RDBMS 与 HBase

HBase 写入

HBase 教程

HBase MemStore

HBase 命令

HBase 模型

什么是 HBase

HBase 读取

HBase 安装

订阅 Tpoint Tech

联系信息

关注我们

教程

面试题

在线编译器