D-Net

package eu.dnetlib.data.hadoop.hbase;

import java.util.List;

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

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

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

import eu.dnetlib.data.transform.Column;

import eu.dnetlib.data.transform.Row;

/**

 * The Class HBaseDeleteFeeder performs a batch of Delete operations.

 */

public class HBaseDeleteFeeder extends HbaseTableFeeder {

	/*

	 * (non-Javadoc)

	 * 

	 * @see eu.dnetlib.data.hadoop.hbase.HbaseTableFeeder#addOperation(java.util.List, eu.dnetlib.data.transform.Row)

	 */

	@Override

	protected void addOperation(final List<Mutation> buffer, final Row row) {

		final Delete delete = new Delete(Bytes.toBytes(row.getKey()));

		delete.setWriteToWAL(false);

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

			delete.deleteColumns(Bytes.toBytes(row.getColumnFamily()), Bytes.toBytes(col.getName()));

		}

		buffer.add(delete);

	}

}