HBase Java编程示例_PHP教程

php中文网

发布时间：2016-07-12 08:57:20

1507人浏览过

来源于php中文网

原创

PaperFake

AI写论文

下载

hbase java编程示例

helloworld.zip

package elementary;
import java.io.ioexception;
import java.text.simpledateformat;
import java.util.arraylist;
import java.util.date;
import java.util.list;
import java.util.concurrent.atomic.atomicinteger;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
import java.util.concurrent.timeunit;
import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.hbase.cell;
import org.apache.hadoop.hbase.hbaseconfiguration;
import org.apache.hadoop.hbase.hcolumndescriptor;
import org.apache.hadoop.hbase.htabledescriptor;
import org.apache.hadoop.hbase.masternotrunningexception;
import org.apache.hadoop.hbase.tablename;
import org.apache.hadoop.hbase.zookeeperconnectionexception;
import org.apache.hadoop.hbase.client.delete;
import org.apache.hadoop.hbase.client.get;
import org.apache.hadoop.hbase.client.admin;
import org.apache.hadoop.hbase.client.bufferedmutator;
import org.apache.hadoop.hbase.client.bufferedmutatorparams;
import org.apache.hadoop.hbase.client.connection;
import org.apache.hadoop.hbase.client.connectionfactory;
import org.apache.hadoop.hbase.client.table;
import org.apache.hadoop.hbase.client.put;
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;
import org.apache.hadoop.util.threadutil;
public class helloworld {
private static configuration conf = null;
private static connection conn = null;
private static admin admin = null;
public static atomicinteger count = new atomicinteger();
/**
* 初始化配置
*/
static {
conf = hbaseconfiguration.create();
//如果沒有配置文件，一定要記得手動宣告
conf.set("hbase.zookeeper.quorum", "10.148.137.143");
conf.set("hbase.zookeeper.property.clientport", "2181");
}
static {
try {
conn = connectionfactory.createconnection();
admin = conn.getadmin();
} catch (ioexception e) {
e.printstacktrace();
}
}
static public class mythread extends thread
{
int _start;
string _tablename;
connection conn;
//bufferedmutator table;
table table;
public mythread(int start, string tablename) {
_start = start;
_tablename = tablename;
}
public void run() {
string tablename = _tablename;
thread current = thread.currentthread();
long thread_id = current.getid();
system.out.printf("thread[%d] run\n", thread_id);
try {
conn = connectionfactory.createconnection();
//bufferedmutatorparams params = new bufferedmutatorparams(tablename.valueof(tablename));
//params.writebuffersize(1024 * 4);
//table = conn.getbufferedmutator(params);
table = conn.gettable(tablename.valueof(tablename));
for (int j=_start; j
for (int i=0; i
// zkb_0_0
string zkb = "zkb_" + string.valueof(_start) + "_" + string.valueof(i);
put put = new put(bytes.tobytes(zkb));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field1"),bytes.tobytes(string.valueof(i+0)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field2"),bytes.tobytes(string.valueof(i+1)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field3"),bytes.tobytes(string.valueof(i+2)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field4"),bytes.tobytes(string.valueof(i+3)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field5"),bytes.tobytes(string.valueof(i+4)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field6"),bytes.tobytes(string.valueof(i+5)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field7"),bytes.tobytes(string.valueof(i+6)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field8"),bytes.tobytes(string.valueof(i+7)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field9"),bytes.tobytes(string.valueof(i+8)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field10"),bytes.tobytes(string.valueof(i+9)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field11"),bytes.tobytes(string.valueof(i+10)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field12"),bytes.tobytes(string.valueof(i+11)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field13"),bytes.tobytes(string.valueof(i+12)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field14"),bytes.tobytes(string.valueof(i+13)));
put.addcolumn(bytes.tobytes("grade"),bytes.tobytes("field15"),bytes.tobytes(string.valueof(i+14)));
//table.mutate(put);
table.put(put);
int m = helloworld.count.incrementandget();
if (m % 10000 == 0) {
date dt = new date();
simpledateformat sdf = new simpledateformat("yyyy-mm-dd hh:mm:ss aa");
string now = sdf.format(dt);
system.out.printf("[%s] thread[%d] m=%d, j=%d, i=%d\n", now, thread_id, m, j, i);
}
}
}
system.out.printf("thread[%d] over\n", thread_id);
}
catch (exception e) {
e.printstacktrace();
}
}
}
/**
* 建立表格
* @param tablename
* @param cfs
*/
public static void createtable(string tablename, string[] cfs){
try {
if (admin.tableexists(tablename.valueof(tablename))) {
system.out.println("table already exists!");
} else {
htabledescriptor tabledesc = new htabledescriptor(tablename.valueof(tablename));
for (int i = 0; i
hcolumndescriptor desc = new hcolumndescriptor(cfs[i]);
desc.setmaxversions(3650);
tabledesc.addfamily(desc);
}
byte[][] splitkeys = new byte[][] {
bytes.tobytes("zkb_0_0"),
bytes.tobytes("zkb_10_0"),
bytes.tobytes("zkb_20_0"),
bytes.tobytes("zkb_30_0"),
bytes.tobytes("zkb_40_0"),
bytes.tobytes("zkb_50_0"),
bytes.tobytes("zkb_60_0"),
bytes.tobytes("zkb_70_0"),
bytes.tobytes("zkb_80_0"),
bytes.tobytes("zkb_90_0"),
bytes.tobytes("zkb_100_0")
};
admin.createtable(tabledesc, splitkeys);
admin.close();
system.out.println("create table " + tablename + " ok.");
}
} catch (masternotrunningexception e) {
e.printstacktrace();
} catch (zookeeperconnectionexception e) {
e.printstacktrace();
} catch (ioexception e) {
e.printstacktrace();
}
}
/**
* 刪除表格
* @param tablename
*/
public static void deletetable(string tablename){
try {
//connection conn = connectionfactory.createconnection();
//admin admin = conn.getadmin();
admin.disabletable(tablename.valueof(tablename));
admin.deletetable(tablename.valueof(tablename));
system.out.println("delete table " + tablename + " ok.");
} catch (ioexception e) {
e.printstacktrace();
}
}
/**
* 刪除一筆資料
* @param tablename
* @param rowkey
*/
public static void delrecord (string tablename, string rowkey){
try {
table table = conn.gettable(tablename.valueof(tablename));
list list = new arraylist();
delete del = new delete(rowkey.getbytes());
list.add(del);
table.delete(list);
system.out.println("del recored " + rowkey + " ok.");
} catch (ioexception e) {
e.printstacktrace();
}
}
/**
* 取得一筆資料
* @param tablename
* @param rowkey
*/
public static void getonerecord (string tablename, string rowkey){
try {
table table = conn.gettable(tablename.valueof(tablename));
get get = new get(rowkey.getbytes());
result rs = table.get(get);
list list = rs.listcells();
for(cell cell:list){
system.out.print(new string(cell.getrowarray(),cell.getrowoffset(),cell.getrowlength()) + " " );
system.out.print(new string(cell.getfamilyarray(),cell.getfamilyoffset(),cell.getfamilylength()) + ":" );
system.out.print(new string(cell.getqualifierarray(),cell.getqualifieroffset(),cell.getqualifierlength()) + " " );
system.out.print(cell.gettimestamp() + " " );
system.out.print(new string(cell.getvaluearray(),cell.getvalueoffset(),cell.getvaluelength()) + " " );
system.out.println("");
}
} catch (ioexception e) {
e.printstacktrace();
}
}
/**
* 取得所有資料
* @param tablename
*/
public static void getallrecord (string tablename) {
try{
//connection conn = connectionfactory.createconnection();
table table = conn.gettable(tablename.valueof(tablename));
scan scan = new scan();
resultscanner resultscanner = table.getscanner(scan);
for(result rs:resultscanner){
list list = rs.listcells();
for(cell cell:list){
system.out.print(new string(cell.getrowarray(),cell.getrowoffset(),cell.getrowlength()) + " " );
system.out.print(new string(cell.getfamilyarray(),cell.getfamilyoffset(),cell.getfamilylength()) + ":" );
system.out.print(new string(cell.getqualifierarray(),cell.getqualifieroffset(),cell.getqualifierlength()) + " " );
system.out.print(cell.gettimestamp() + " " );
system.out.print(new string(cell.getvaluearray(),cell.getvalueoffset(),cell.getvaluelength()) + " " );
system.out.println("");
}
}
} catch (ioexception e){
e.printstacktrace();
}
}
/**
* 取得family清單
* @param tablename
* @return
*/
public static arraylist getallfamilyname(string tablename) {
arraylist familyname_list = new arraylist();
try{
//connection conn = connectionfactory.createconnection();
table table = conn.gettable(tablename.valueof(tablename));
htabledescriptor htabledescriptor = table.gettabledescriptor();
hcolumndescriptor[] hdlist = htabledescriptor.getcolumnfamilies();
for(int i=0;i
hcolumndescriptor hd = hdlist[i];
familyname_list.add(hd.getnameasstring());
}
} catch (ioexception e){
e.printstacktrace();
}
return familyname_list;
}
// java -cp helloworld.jar:`ls lib/*.jar|awk '{printf("%s:", $0)}'` elementary.helloworld 5
public static void main(string[] args) {
system.out.println("helloworldx");
if (args.length > 0)
system.out.println(args[0]);
int start = 0;
if (args.length > 1)
start = integer.valueof(args[1]);
if (start
start = 0;
int num_threads = 16;
if (args.length > 2)
num_threads = integer.valueof(args[2]);
try {
string tablename = "scores";
string[] familys = {"grade", "course"};
helloworld.createtable(tablename, familys);
//executorservice thread_pool = executors.newsinglethreadexecutor();
executorservice thread_pool = executors.newfixedthreadpool(num_threads);
thread[] pool = new helloworld.mythread[80];
for (int i=0; i
pool[i] = new helloworld.mythread(i, tablename);
thread_pool.execute(pool[i]);
}
thread_pool.shutdown();
system.out.println("over");
}
catch (exception e) {
e.printstacktrace();
}
}
}

Android Chrome 浏览器投屏时因网络中断导致崩溃的解决方案

Android Chrome 浏览器投屏时因网络或设备异常导致崩溃的解决方案

PHP怎样支持移动端视频播放_PHP移动端视频播放支持法【要点】

PHP 中将 HTML 标签安全替换为换行符的完整方案

怎么把php源码打包成apk_打包php源码成apk教程【指南】

相关专题

TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开，深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析，帮助开发者构建类型安全、结构清晰、易维护的前端工程体系，提高团队协作效率与代码质量。

2026.03.13

Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开，深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例，帮助开发者掌握 Python 在高并发场景中的高效开发方法，并提升系统资源利用率与整体运行性能。

2026.03.12

C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开，系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例，帮助开发者掌握构建高可用微服务系统的关键技术，提高系统的可扩展性与维护效率。

178

2026.03.11

Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开，系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示，帮助开发者构建稳定高效的 Go 并发任务处理系统，提高系统在高负载环境下的处理能力与稳定性。

2026.03.10

Kotlin Android模块化架构与组件化开发实践

本专题围绕 Kotlin 在 Android 应用开发中的架构实践展开，重点讲解模块化设计与组件化开发的实现思路。内容包括项目模块拆分策略、公共组件封装、依赖管理优化、路由通信机制以及大型项目的工程化管理方法。通过真实项目案例分析，帮助开发者构建结构清晰、易扩展且维护成本低的 Android 应用架构体系，提升团队协作效率与项目迭代速度。

2026.03.09

JavaScript浏览器渲染机制与前端性能优化实践

本专题围绕 JavaScript 在浏览器中的执行与渲染机制展开，系统讲解 DOM 构建、CSSOM 解析、重排与重绘原理，以及关键渲染路径优化方法。内容涵盖事件循环机制、异步任务调度、资源加载优化、代码拆分与懒加载等性能优化策略。通过真实前端项目案例，帮助开发者理解浏览器底层工作原理，并掌握提升网页加载速度与交互体验的实用技巧。

102

2026.03.06

Rust内存安全机制与所有权模型深度实践

本专题围绕 Rust 语言核心特性展开，深入讲解所有权机制、借用规则、生命周期管理以及智能指针等关键概念。通过系统级开发案例，分析内存安全保障原理与零成本抽象优势，并结合并发场景讲解 Send 与 Sync 特性实现机制。帮助开发者真正理解 Rust 的设计哲学，掌握在高性能与安全性并重场景中的工程实践能力。

227

2026.03.05

PHP高性能API设计与Laravel服务架构实践

本专题围绕 PHP 在现代 Web 后端开发中的高性能实践展开，重点讲解基于 Laravel 框架构建可扩展 API 服务的核心方法。内容涵盖路由与中间件机制、服务容器与依赖注入、接口版本管理、缓存策略设计以及队列异步处理方案。同时结合高并发场景，深入分析性能瓶颈定位与优化思路，帮助开发者构建稳定、高效、易维护的 PHP 后端服务体系。

532

2026.03.04