D-Net

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

import java.io.BufferedWriter;

import java.io.OutputStreamWriter;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.Path;

import org.apache.log4j.Logger;

public class HdfsWriter {

    public static void write(String data, String filename) throws Exception {

        Configuration conf = new Configuration();

        FileSystem hdfs = FileSystem.get(conf);

        try {

            Path exportPath = new Path(hdfs.getUri() + filename);

            BufferedWriter br = new BufferedWriter(new OutputStreamWriter(hdfs.create(exportPath, false)));

            // TO append data to a file, use fs.append(Path f)

            br.write(data);

            br.close();

        } catch (Exception e) {

            throw new Exception("Error while writing file ", e);

        }

    }

}