资源简介
大数据mapreduce案例介绍,包括代码解释,详解MRS工作流程
代码片段和文件信息
package com.huawei.bigdata.hbase.examples;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HRegionInfo;
import org.apache.hadoop.hbase.HRegionLocation;
import org.apache.hadoop.hbase.HTableDescriptor;
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.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HbaseAdmin;
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.client.Table;
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.filter.FilterList.Operator;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.io.compress.Compression;
import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
import org.apache.hadoop.hbase.security.access.AccessControlClient;
import org.apache.hadoop.hbase.security.access.AccessControlLists;
import org.apache.hadoop.hbase.security.access.Permission;
import org.apache.hadoop.hbase.util.Bytes;
/**
* Hbase Development Instruction Sample Code The sample code uses user
* information as source datait introduces how to implement businesss process
* development using Hbase API
*/
public class HbaseExample {
private final static Log LOG = LogFactory.getLog(HbaseExample.class.getName());
private TableName tableName = null;
private Configuration conf = null;
private Connection conn = null;
public String TABLE_NAME = “hbase_sample_table“;
public HbaseExample(Configuration conf) throws IOException {
this.conf = conf;
this.tableName = TableName.valueOf(TABLE_NAME);
this.conn = ConnectionFactory.createConnection(conf);
}
public void test() throws Exception {
try {
testCreateTable();
testMultiSplit();
testPut();
testModifyTable();
testGet();
testScanData();
testSingleColumnValueFilter();
testFilterList();
testDelete();
dropTable();
testCreateMOBTable();
testMOBDataInsertion();
testMOBDataRead();
dropTable();
} catch (Exception e) {
throw e;
} finall
属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
目录 0 2018-01-16 17:39 src\
目录 0 2018-01-18 14:46 src\hba
文件 126 2018-01-16 17:39 src\hba
目录 0 2018-01-18 14:46 src\hba
文件 6327 2018-01-16 17:39 src\hba
文件 16274 2018-01-16 17:39 src\hba
文件 330 2018-01-16 17:39 src\hba
文件 141 2018-01-18 14:46 src\hba
文件 2839 2018-01-16 17:39 src\hba
文件 58 2018-01-16 17:39 src\hba
文件 269 2018-01-16 17:39 src\hba
文件 757 2018-01-16 17:39 src\hba
文件 3446 2018-01-16 17:39 src\hba
文件 5437 2018-01-18 14:46 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-18 14:46 src\hba
文件 29091 2018-01-16 17:39 src\hba
文件 4395 2018-01-16 17:39 src\hba
文件 25104 2018-01-16 17:39 src\hba
文件 5838 2018-01-18 14:46 src\hba
目录 0 2018-01-16 17:39 src\hba
目录 0 2018-01-16 17:39 src\hba
文件 21680 2018-01-16 17:39 src\hba
目录 0 2018-01-16 11:10 src\hdfs-examples\
目录 0 2018-03-22 15:35 src\hdfs-examples\conf\
............此处省略474个文件信息
- 上一篇:淘宝双十一高并发和高复杂度的导购营销系统架构演进
- 下一篇:无线物理层安全通信
评论
共有 条评论