java - PutRequestを使用した複数列ファミリー

Question

Flume-NG 1.3.0で使用するカスタムHbaseSinkを作成org.hbase.async.PutRequest中であり、同じ行に複数の列ファミリーを使用してを実行する必要があります。コンストラクターなどが表示されませんPut.add(columnFamily, columnName, value)。

誰かが私がこれを行う方法に光を当てることができますか？

Answer 1

この問題の解決策も見つけようとしましたが、参照が見つかりませんでした。だからここに私が私のアプリケーションでやったことです

`

public void addRecord(String tableName, String rowKey, String family, HashMap<String, String> hash) {
        try {
            HTable table = new HTable(conf, tableName);
            Put put = new Put(Bytes.toBytes(rowKey));

            Iterator<String> it = hash.keySet().iterator();
            while (it.hasNext()) {
                String key = it.next();
                String val = hash.get(key);
                put.add(Bytes.toBytes(family), Bytes.toBytes(key), Bytes.toBytes(val));
            }
            table.put(put);

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

`

ここで、HashMap ハッシュには列名とその値が含まれています。