Revision 58162
Added by Claudio Atzori about 4 years ago
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/propagation/Utils.java | ||
|---|---|---|
| 17 | 17 |
|
| 18 | 18 |
public final class Utils {
|
| 19 | 19 |
public static OafProtos.OafEntity getEntity(Result value, TypeProtos.Type type) throws InvalidProtocolBufferException {
|
| 20 |
final Map<byte[],byte[]> map = value.getFamilyMap(Bytes.toBytes(type.toString())); |
|
| 21 |
|
|
| 22 |
final byte[] body = map.get(Bytes.toBytes("body"));
|
|
| 20 |
final byte[] body = value.getValue(Bytes.toBytes(type.toString()), Bytes.toBytes("body"));
|
|
| 23 | 21 |
if (body != null){
|
| 24 | 22 |
OafProtos.Oaf oaf = OafProtos.Oaf.parseFrom(body); |
| 25 | 23 |
if(oaf.getDataInfo().getDeletedbyinference()) |
Also available in: Unified diff
read only the body qualifier instead of the entire column family