D-Net

package eu.dnetlib.data.mapreduce.hbase.lodExport.utils;

import org.apache.hadoop.io.Text;

import org.apache.hadoop.mapreduce.RecordWriter;

import org.apache.hadoop.mapreduce.TaskAttemptContext;

import java.io.DataOutputStream;

import java.io.IOException;

public class SingleRecordWriter extends RecordWriter<Text, Text> {

    private DataOutputStream out;

    public SingleRecordWriter(DataOutputStream stream) {

        out = stream;

        try {

            out.writeBytes("\r\n");

        } catch (Exception ex) {

        }

    }

    @Override

    public void close(TaskAttemptContext arg0) throws IOException, InterruptedException {

        //close our file

        out.close();

    }

    @Override

    public void write(Text key, Text value) throws IOException, InterruptedException {

        //write out our key

        if (key != null) {

            out.writeBytes("\n" + key.toString() + "\t");

        }

        out.writeBytes(String.valueOf(value) + ",");

    }

}