免费注册
帮助文档(华北一、二)

  • 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");

        }

        /***