控制台
华北一（售罄） 华北二
华北三
华北一（售罄） 华北二 华北三
实名认证 备案
免费注册
帮助文档（华北一、二）
    当前位置:  浪潮云服务官网>>文档中心>>


  • 4.1 使用JAVA读取HBase（实现创建表格、插入数据，展示数据操作）

    此示例需要您先登陆托管Hadoop集群master1节点，以下操作默认在master1节点执行。

    4.1.1 构建JAVA代码

     

    mkdir  -p /data/hbase-example

    cd /data/hbase-example

    touch HbaseJob.java

    HbaseJob.java代码如下

     

    import java.util.ArrayList;

    import java.util.List;

    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.KeyValue;

    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.HTable;

    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;

    public class HbaseJob {

        static Configuration conf=null;

        static{

            conf=HBaseConfiguration.create();//hbase的配置信息

        }

        public static void main(String[] args)throws Exception {

            HbaseJob t=new HbaseJob();

            t.createTable("person", new String[]{"name","age"});

            t.insertRow("person", "1", "age", "hehe", "100");

            t.insertRow("person", "2", "age", "haha", "101");

            t.showAll("person");

        }

        /***