D-Net

import java.text.DateFormat;

import java.text.ParseException;

import java.text.SimpleDateFormat;

/**

 * Created by eri on 1/14/16.

public class Test {

		value = value.replace("\\", "");

		*/

	     value = value.replace("\\", "");

*/

}

    private static String buildDatasource(OafEntity data, String DELIM) {

        String buff = getHeader(data, DELIM);

        //Datasourcetype

        //languages

        String dataStr = new String();

        for (StringField lang : metadata.getOdlanguagesList()) {

        buff += dataStr + DELIM;

        // Content type

        dataStr=" ";

        for (StringField c : metadata.getOdcontenttypesList()) {

        }

        buff += dataStr + DELIM;

        //Access info package

          dataStr = " ";

        for (StringField c : metadata.getAccessinfopackageList()) {

        }

        buff += dataStr + DELIM;

        //Policies

          dataStr = " ";

        for (FieldTypeProtos.KeyValue property : metadata.getPoliciesList()) {

        }

        buff += dataStr + DELIM;

        buff += getTrust(data, DELIM);

        return buff;

    }

        String dataStr = new String();

        for (String s : split) {

        }

        buff += dataStr + DELIM;

        //logourl

        // `country`,

        buff += metadata.getCountry().getClassid() + DELIM;

    private static String buildResult(OafEntity data,String DELIM) {

        String buff = getHeader(data,DELIM);

        //  pubtitle

        buff += clean(dataStr) + DELIM;

        // date of acceptance CHANGED THIS TO DATE FORMAT

        buff += metadata.getDateofacceptance().getValue() + DELIM;

        for (StructuredProperty p : data.getPidList()) {

            dataStr += clean(p.getValue()) + SEPERATOR;

        }

        buff += dataStr + DELIM;

        //language

        // RelevantDate

        dataStr = " ";

        for (StructuredProperty p : metadata.getRelevantdateList()) {

            dataStr += p.getValue();

            break;

        buff += dataStr + DELIM;

        //TODO Format     

        buff += " " + DELIM;

        buff += " " + DELIM;

        //Best License

        //Description

        dataStr = " ";

        buff += dataStr + DELIM;

        //Journal  

        // TODO ERI SOS : HERE IN GET JOUTNAL. GET DATA INFO I CAN FIND PROVENANCE AND SIMILARITY

        // TODO isRelatedTo

        //   resource type

        // type

        buff += metadata.getResulttype().getClassname() + DELIM;

        buff += getTrust(data,DELIM);

    private static String buildProject(OafEntity data,String DELIM) {

        String buff = getHeader(data,DELIM);

        //Code

        buff += metadata.getCode().getValue() + DELIM;

        // `Websiteurl`,

        dataStr = " ";

        for (StructuredProperty s : data.getPidList()) {

        }

        buff += dataStr + DELIM;

    public static String cleanId(String value) {

        if (value != null) {

            //   DO NOT CHANGE THIS: IT REMOVES ID PREFIX ( 5|datacite____::

            // to datacite____:: )

            // AND REPLACES OCCURENCES OF DELIM CHARS IN DATA

            value = value.replaceFirst(".*\\|", "");

        }

        return value;

    //TODO make them in pairs

    private static void getDedups(OafEntity valueEntity,String DELIM,ArrayList<String> returnList) {

        if (!valueEntity.getChildrenList().isEmpty()) {

            String header = "dedup" + DELIM + valueEntity.getType().name() + DELIM +

            return " " + DELIM;

        }

    }

    private static String getBestLicense(Result result) {

        FieldTypeProtos.Qualifier bestLicense = null;

        LicenseComparator lc = new LicenseComparator();

            // TODO DO NOT CHANGE THIS: IT REMOVES ID PREFIX ( 5|datacite____::

            // to datacite____:: )

            // AND REPLACES OCCURENCES OF DELIM CHARS IN DATA

            value = value.replaceAll("[\"\\r\\\\;]", "");

            value = value.replace(SEPERATOR, " ");

        }

        return value;

    }

}

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

import com.google.protobuf.InvalidProtocolBufferException;

import eu.dnetlib.data.mapreduce.hbase.index.config.EntityConfigTable;

import eu.dnetlib.data.mapreduce.hbase.index.config.IndexConfig;

import eu.dnetlib.data.mapreduce.hbase.index.config.LinkDescriptor;

import eu.dnetlib.data.proto.OafProtos.OafRelOrBuilder;

import eu.dnetlib.data.proto.RelTypeProtos.SubRelType;

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

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

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

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

        PROJECT,

        DATASOURCE,

        PERSON,

    }

    ;

            // TODO set this only when the configuration file has include dups

            // to fals for Results

            // or else were gonna get deleted by inference entries

            // entityConfigTable.includeDuplicates(type)) {

            //TODO eri: here allow entities deletedbyinfer

    }

    private void emitEntity(Context context, Oaf oaf, Type type, Oaf.Builder oafBuilder) {

            try {

                Text TextKeyOut = new Text("entities");

                context.write((TextKeyOut), new ImmutableBytesWritable(serialized.getBytes()));

            // Existing Hbase relations are generated here

            if (entityConfigTable.getDescriptors(type) != null && !entityConfigTable.getDescriptors(type).isEmpty()) {

                for (LinkDescriptor ld : entityConfigTable.getDescriptors(type)) {

                    try {

                        final Map<byte[], byte[]> columnMap = result.getFamilyMap(Bytes.toBytes(ld.getRelDescriptor().getIt()));

                        for (OafRel rel : relOaf) {

                            builder.getEntityBuilder().addCachedRel(rel);

                            try {

                                Text TextKeyOut = new Text("relations");

                                context.write((TextKeyOut), new ImmutableBytesWritable(buff.getBytes()));

                            } catch (Exception e) {

                                log.error("Error while writing Relation Proto to M/R output", e);

                            }

            }

        }

        for (String rel : relationsList) {

            try {

                Text TextKeyOut = new Text("relations");

            } catch (Exception e) {

                log.error("Error writing relations to output : " + rel);

            }

        }

    }

    private ArrayList<OafRel> decodeRelation(final Oaf body, final Context context, Map<byte[], byte[]> columnMap, final LinkDescriptor ld) throws IOException, InterruptedException {