import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class HDFSread {

    public static void main(String[] args) throws IOException
    {
        // obtenir un object représentant HDFS
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(conf);

        // nom du fichier à lire
        Path nomcomplet = new Path("apitest.txt");

        if (! fs.exists(nomcomplet)) {
            System.out.println("Le fichier n'existe pas");
        } else {

            // ouvrir et lire le fichier
            FSDataInputStream inStream = fs.open(nomcomplet);
            String data = inStream.readUTF();
            System.out.println(data);
            inStream.close();

        }

        // fermer HDFS
        fs.close();
    }
}