大数据全系列 教程
1869个小节阅读:465.9k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
package com.itbaizhan.calllog;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Table;
import org.junit.After;
import org.junit.Before;
import java.io.IOException;
public class CallLogDemo {
//命名空间的定义
private String namespace = "itbaizhan";
//表名称
private String tableName = "phone_log";
//表名称对应的TableName对象
private TableName tableNameObj;
//表DDL对象
private Admin admin;
//表数据的DML对象
private Table table;
//连接对象
private Connection connection;
@Before
public void before(){
Configuration configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum","node2,node3,node4");
try {
connection = ConnectionFactory.createConnection(configuration);
admin = connection.getAdmin();
tableNameObj = TableName.valueOf(namespace+":"+tableName);
table = connection.getTable(tableNameObj);
} catch (IOException e) {
e.printStackTrace();
}
}
@After
public void after() throws IOException {
if(table!=null){
table.close();
}
if(admin!=null){
admin.close();
}
if(connection!=null){
connection.close();
}
}
}