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);

		}

	private void emitDedupRel(final Context context, final byte[] cf, final byte[] from, final byte[] to, final byte[] value) {

		final Put put = new Put(from).add(cf, to, value);

		try {

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

		} catch (IOException | InterruptedException e) {

import java.util.List;

import org.apache.hadoop.hbase.KeyValue;

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

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

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

				if (!Arrays.equals(nq, jq)) {

					final Put put = new Put(nq).add(family, jq, cellValue);

					rowKey.set(nq);

					context.write(rowKey, put);

import eu.dnetlib.data.transform.xml.AbstractDNetXsltFunctions;

import eu.dnetlib.pace.config.DedupConfig;

import org.apache.commons.lang.StringUtils;

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

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

import org.apache.hadoop.hbase.mapreduce.TableReducer;

			InterruptedException {

		final Put put = new Put(OafRowKeyDecoder.decode(rowkey).getKey().getBytes());

		put.add(Bytes.toBytes(family), qualifier, value);

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

	private void emit(final String msg, final Context context, final byte[] rowkey, final String family, final String qualifier, final byte[] value, final String label) {

		final Put put = new Put(rowkey).add(Bytes.toBytes(family), Bytes.toBytes(qualifier), value);

		try {

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

import java.util.Set;

import eu.dnetlib.data.mapreduce.JobParams;

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

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

import org.apache.hadoop.hbase.mapreduce.TableReducer;

			for (final String s : resultIds.get(personId)) {

				final byte[] id = Bytes.toBytes(s);

				final Put put = new Put(id).add(cf, col, val);

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

			}

			context.getCounter(getClass().getSimpleName(), "N. Put. (results)").increment(resultIds.get(personId).size());

import eu.dnetlib.data.proto.TypeProtos.Type;

import eu.dnetlib.pace.config.DedupConfig;

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

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

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

import org.apache.hadoop.hbase.mapreduce.TableMapper;

			final byte[] row = rowkey.copyBytes();

			final Delete delete = new Delete(row);

			delete.deleteFamily(cf);

import eu.dnetlib.data.proto.TypeProtos.Type;

import eu.dnetlib.data.transform.xml.AbstractDNetXsltFunctions;

import eu.dnetlib.pace.config.DedupConfig;

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(dedupConf.getWf().getEntityType());

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

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

			context.getCounter(dedupConf.getWf().getEntityType(), "bodies marked deleted").increment(1);

		}

import eu.dnetlib.actionmanager.actions.AtomicAction;

import eu.dnetlib.data.mapreduce.JobParams;

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

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

import org.apache.hadoop.hbase.util.Bytes;

		final byte[] keyOutBytes = Bytes.toBytes(aa.getTargetRowKey());

		keyOut.set(keyOutBytes);

		final Put put = new Put(keyOutBytes);

		put.add(Bytes.toBytes(aa.getTargetColumnFamily()), Bytes.toBytes(aa.getTargetColumn()), aa.getTargetValue());

		context.write(keyOut, put);

				final byte[] rowKey = Bytes.toBytes(row.getKey());

				final Put put = new Put(rowKey);

				for (final Column<String, byte[]> col : row) {

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

	private static Put getPut(final String rowkey) {

		final Put put = new Put(Bytes.toBytes(rowkey));

		return put;

	}