第1关：金融类 RowKey 设计
package step1;
import org.f.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class Task {
    /**
    * 生成 RowKey
    *
    * @param sellerId  卖家ID
    * @param timestamp 时间戳
    * @param orderId  订单ID
    * @return RowKey
    */
    public String createRowKey(String sellerId, String timestamp, String orderId) {
        /********** begin **********/
        String rowKey = sellerId + "-" + timestamp + "-" + orderId;
        return rowKey;
        /********** end **********/
    }
    /**
    * 查询某个卖家某段时间内的交易记录
    *
    * @param sellerId      卖家ID
    * @param startTimestamp 开始时间戳
    * @param endTimestamp  截止时间戳
    * @return map 存储 (rowkey,value)
    */
    public Map<String, String> findLogByTimestampRange(String sellerId, String startTimestamp, String endTimestamp) throws Exception {
        Map<String, String> map = new HashMap<>();
        /********** begin **********/
        Configuration conf = new Configuration();
        conf.set("keeper.quorum", "127.0.0.1:2181");
        Connection connection = ateConnection(conf);
        Scan scan = new Scan();
        String startRow = sellerId + "-" + startTimestamp;
        String stopRow = sellerId + "-" + (endTimestamp + 1);
        scan.Bytes());
        scan.Bytes());
        Table table = Table(TableName.valueOf("deal"));
        ResultScanner scanner = Scanner(scan);
        for (Result result : scanner) {
            String key = Row());
            List<Cell> cells = result.listCells();
            for (Cell c : cells) {
                String value = String(CellUtil.cloneValue(c));
                map.put(key, value);
            }
        }
     
     
     
        /********** end **********/
        return map;
    }
}
第2关：车联网 RowKey 设计
package step2;
import org.f.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class Task {
    static String[] chars = {"0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "a", "b", "c", "d", "e", "f"};
    /**
    * MD5 加密
    * @param str 需要加密的文本
    * @return 加密后的内容
    */
    public static String StringInMd5(String str) {
        MessageDigest md5 = null;
        try {
            md5 = Instance("md5");
            byte[] result = md5.Bytes());
            StringBuilder sb = new StringBuilder(32);
            for (int i = 0; i < result.length; i++) {
                byte x = result[i];
                int h = 0x0f & (x >>> 4);
                int l = 0x0f & x;
                sb.append(chars[h]).append(chars[l]);
            }
            String();
        } catch (NoSuchAlgorithmException e) {
            throw new RuntimeException(e);
        }
    }
    /**
    * 生成 row
    *
    * @param carId    汽车ID
    * @param timestamp 时间戳
    * @return rowkey
    */
    public String createRowKey(String carId, String timestamp) {
        /********** begin **********/
hbase属于什么数据库        String prefix = StringInMd5(carId);
        String rowKey = prefix.substring(0, 5) + "-" + carId + "-" + timestamp;
        return rowKey;
        /********** end **********/
    }
    /**
    * 查询某辆车在某个时间范围的交易记录
    *
    * @param carId          车辆ID
    * @param startTimestamp 开始时间戳
    * @param endTimestamp  截止时间戳
    * @return map 存储 (rowkey,value)
    */
    public Map<String, String> findLogByTimestampRange(String carId, String startTimestamp, String endTimestamp) throws Exception {
        Map<String, String> map = new HashMap<>();