D-Net

import eu.dnetlib.pace.config.DedupConfig;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.client.Result;

import org.apache.hadoop.hbase.io.ImmutableBytesWritable;

			oafRoot.getDataInfoBuilder().setDeletedbyinference(true).setInferred(true).setInferenceprovenance(dedupConf.getWf().getConfigurationId());

			final byte[] family = Bytes.toBytes(type);

			final Put put = new Put(row).add(family, DedupUtils.BODY_B, oafRoot.build().toByteArray());

			context.write(new ImmutableBytesWritable(row), put);

			context.getCounter(type, "bodies marked deleted").increment(1);

		}