zoukankan      html  css  js  c++  java
  • Hbase API 写入操作代码,基于hbase-client 1.0.3版本

        <dependency>
          <groupId>org.apache.hbase</groupId>
          <artifactId>hbase-client</artifactId>
          <version>1.0.3</version>
        </dependency>
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.HBaseConfiguration;
    import org.apache.hadoop.hbase.TableName;
    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.Put;
    import org.apache.hadoop.hbase.client.Table;
    import org.apache.hadoop.hbase.util.Bytes;
    import java.io.IOException;
    
    public class HbaseTest01 {
        public static void main(String[] args) throws IOException{
            TableName name = TableName.valueOf("testtable");
            Configuration conf = HBaseConfiguration.create();
            Connection connection = ConnectionFactory.createConnection(conf);
            Table table = connection.getTable(name);
            
            BufferedMutator mutator = connection.getBufferedMutator(name);
            
            for (int i = 0; i < 1000000; i++){
                
                String rowStr = "row"+i;
                String valStr = "val"+i;
                
                Put put = new Put(Bytes.toBytes(rowStr));
                put.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("qual1"), Bytes.toBytes(valStr));
                
                mutator.mutate(put);
            }
            
            mutator.close();
            table.close();
            connection.close(); 
            System.out.println("done!");
        }
    }
  • 相关阅读:
    期权波动率模型及交易策略分析
    k阶原点距和k阶中心距各是说明什么数字特征
    在Linux中监视IO性能
    NUMA微架构
    Web网站的几个QPS
    Elasticsearch与Solr 选型
    相关连接(后续更新)
    linux_基本命令使用(后续更新)
    centos7.5安装kafka(支持外部连接)
    centos7.5单机安装安装zookeeper
  • 原文地址:https://www.cnblogs.com/zhengchunhao/p/5684111.html
Copyright © 2011-2022 走看看