Revision 54187
Added by Claudio Atzori over 5 years ago
| modules/dnet-mapreduce-jobs/branches/master/src/main/java/eu/dnetlib/data/mapreduce/util/OafHbaseUtils.java | ||
|---|---|---|
| 150 | 150 |
|
| 151 | 151 |
final OafRelDecoder relDecoder = OafRelDecoder.decode(rel); |
| 152 | 152 |
|
| 153 |
final byte[] cfRel = Bytes.toBytes(relDecoder.getCF()); |
|
| 153 |
final byte[] cfRel = Bytes.toBytes(relDecoder.getCFQ());
|
|
| 154 | 154 |
final byte[] qualifier = Bytes.toBytes(rel.getTarget()); |
| 155 | 155 |
|
| 156 | 156 |
return putRel.add(cfRel, qualifier, oaf.toByteArray()); |
Also available in: Unified diff
fixed creation of the coordinates (columnFamily) driving the Put operation