Hbase基本操作，

Hbase基本操作，

首先:
            conf = HBaseConfiguration.create();
            conf.set("hbase.zookeeper.property.clientPort", "2181");
            conf.set("hbase.zookeeper.quorum", "集群地址");
            conf.set("hbase.master", "地址+端口");
            conn = HConnectionManager.createConnection(conf);
            admin = new HBaseAdmin(conf);
 
 
插入  Put (更新同理)------------------------------------------------------
插入单条记录
String tablename = "proreply";
            String row = rowFixd;
            String columnFamily = "data";
            String[] columns = new String[] { "content", "rusername", "ctime" };
            String[] values = new String[] { "回复内容:........", "lxk",
                    DateFormatUtils.format(new Date(), "yyyy-mm-dd HH:mm:ss.ms") };
            HTableInterface table = null;
try {
                table = conn.getTable(tablename);
                Put put = new Put(Bytes.toBytes(row));
                for (int i = 0; i < columns.length; i++) {
                    put.add(Bytes.toBytes(columnFamily), Bytes.toBytes(String.valueOf(columns[i])),
                            values[i] == null ? null : values[i].getBytes("utf-8"));
                    table.put(put);
                }
                System.out.println("======插入记录完成======");
插入多条记录
//             table.setAutoFlush(false);
//             table.setWriteBufferSize(6 * 1024 * 1024);
            if (null != rowDatas && rowDatas.size() > 0) {
                for (RowData rowData : rowDatas) {
                    String row = rowData.getRow();
                    String[] columns = rowData.getColumns();
                    String columnFamily = rowData.getColumnFamily();
                    String[] values = rowData.getValues();
                    Put put = new Put(Bytes.toBytes(row));
                    for (int i = 0; i < columns.length; i++) {
                        put.add(Bytes.toBytes(columnFamily),
                                Bytes.toBytes(String.valueOf(columns[i])),
                                values[i] == null ? null : values[i]
                                        .getBytes("utf-8"));
                        put.setDurability(Durability.SKIP_WAL);
                        table.put(put);
//                         puts.add(put);
                    }
                }
//                 table.put(puts);
                // table.batch(puts);
//                 table.flushCommits();
 
删除-----------------------------------------------------------------------
 
        HTableInterface htable = conn.getTable("reguser".getBytes());
        Delete del = new Delete(Bytes.toBytes("chenzhenjian1448850414722"));
        del.compareTo(del);
        htable.delete(del);
 
查询-----------------------------------------------------------------------
查询所有记录
 
    HTableInterface htable = conn.getTable("表名".getBytes());
            Scan scan = new Scan();
            ResultScanner scanner = htable.getScanner(scan);
 
            for (Result result : scanner) {
                byte[] row = result.getRow();
                List<KeyValue> list = result.list();
 
                for (KeyValue keyValue : list) {
                    System.out.print("行键：" + new String(row));
                    System.out.print("\t列簇:" + new String(keyValue.getFamily()));
                    System.out.print("\t列名:" + new String(keyValue.getQualifier()));
                    System.out.print("\t时间:" + keyValue.getTimestamp());
                    System.out.println("\t列值:" + new String(keyValue.getValue()));
                }
            }
 
查询一行记录
Get g = new Get(rowKey.getBytes());
Result rs = table.get(g);
KeyValue[] raw = rs.raw();
Map<String, String> result = new HashMap<String, String>();
for (int i = 0; i < raw.length; i++) {
                byte[] row = raw[i].getRow();
                result.put("row", new String(row));
                byte[] family = raw[i].getFamily();
                byte[] qualifier = raw[i].getQualifier();
                byte[] value = raw[i].getValue();
                result.put(new String(family) + ":" + new String(qualifier),
                        new String(value));
            }
            return result;
查询过滤条件---------------------------------------------------------------------------
 
提取rowkey以[prefix]前缀开头
Filter filter=new RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryPrefixComparator(prefix.getBytes()));
Scan s=new Scan();
        s.setFilter(filter);
 
提取rowkey以[endfix]结尾
Filter filter=new RowFilter(CompareFilter.CompareOp.EQUAL,  new RegexStringComparator(".*"+endfix+"$"));
Scan s=new Scan();
        s.setFilter(filter);
 
提取rowkey以包含[value]
Filter filter=new RowFilter(CompareFilter.CompareOp.EQUAL,  new SubstringComparator(value));
Scan s=new Scan();
        s.setFilter(filter);
 
提取rowkey以[prefix]前缀开头、并且只包含rowkey、
Filter filter1=new RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryPrefixComparator(prefix.getBytes()));
KeyOnlyFilter filter2=new KeyOnlyFilter();
FilterList filtList =new FilterList(FilterList.Operator.MUST_PASS_ALL);
filtList.addFilter(filter1);
filtList.addFilter(filter2);
Scan s=new Scan();
        s.setFilter(filtList);
 
分页提取10条：rowkey以[prefix]前缀开头、
Filter filter1=new RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryPrefixComparator(prefix.getBytes()));
PageFilter filter2=new PageFilter(10);
FilterList filtList =new FilterList(FilterList.Operator.MUST_PASS_ALL);
filtList.addFilter(filter1);
filtList.addFilter(filter2);
Scan s=new Scan();
s.setFilter(filtList);
 
分页提取10条：仅获取data列族上某列上大于某时间戳的数据
PageFilter filter=new PageFilter(10);
Scan s=new Scan();
s.addColumn("data".getBytes(), colmnName.getBytes());
s.setFilter(filter);
if(0!=minStamp)
s.setTimeRange(minStamp, Long.MAX_VALUE);
return s;
 
分页提取10条：大于某时间戳的数据（针对所有列）
PageFilter filter=new PageFilter(10);
Scan s=new Scan();
s.setFilter(filter);
if(0!=minStamp)
s.setTimeRange(minStamp, Long.MAX_VALUE);
return s;