复合密钥应在asynchbaseserializer中工作
下面是示例代码段。
在类级别声明 privae List<PutRequest> puts = null; ```
/**
* Method joinRowKeyContent. (with EMPTY string separation)
*
* Joiner is google guava class
* @param objArray Object...
*
* @return String
*/
public static String joinRowKeyContent(Object... objArray) {
return Joiner.on("").appendTo(new StringBuilder(), objArray).toString();
}

/**
* Method preParePutRequestForBody.
*
* @param rowKeyBytes
* @param timestamp
*/
private void preParePutRequest(final byte[] rowKeyBytes, final long timestamp) {
// Process

        LOG.debug("Processing ..." + Bytes.toString(rowKeyBytes));

    final PutRequest putreq = new PutRequest(table, rowKeyBytes, colFam, Bytes.toBytes("yourcolumn"), yourcolumnasBytearray, timestamp);
    puts.add(putreq);
}

你的get actions方法看起来像。。。

@Override
public List getActions() {
//create rowkey like this
final String rowKey = joinRowKeyContent(driver_id, timestamp, longitude , latitude);

// call prepare put requests method here 
final byte[] rowKeyBytes = Bytes.toBytes(rowKey);
            puts.clear();
 preParePutRequest(rowKeyBytes ,<timestamp>)
        return puts;
    }