我目前正在研究hadoop。我想把我的java代码转换成hadoop。我希望我的代码与hdfs一起工作。i、 我的代码是正常的文件系统，我希望它与hdfs（高清文件系统）工作。我希望下面的代码在hadoop（hd文件系统）中工作。

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;

public class GZIPExample {

    public static void gzip() {
        int i = new File("/media/0052ADF152ADEC1A/all splits").list().length;
        System.out.println(i + "here");
        while (i > 0) {
            String file = "/media/0052ADF152ADEC1A/all splits/File" + i + ".txt";
            String gzipFile = "/media/0052ADF152ADEC1A/compress/Filegz" + i + ".gz";
            String newFile = "/media/0052ADF152ADEC1A/all/hadoop ebooks/test1.txt";

            compressGzipFile(file, gzipFile);

            decompressGzipFile(gzipFile, newFile);
            i--;
        }
    }

    private static void decompressGzipFile(String gzipFile, String newFile) {
        try {
            FileInputStream fis = new FileInputStream(gzipFile);
            GZIPInputStream gis = new GZIPInputStream(fis);
            FileOutputStream fos = new FileOutputStream(newFile);
            byte[] buffer = new byte[1024];
            int len;
            while ((len = gis.read(buffer)) != -1) {
                fos.write(buffer, 0, len);
            }
            //close resources
            fos.close();
            gis.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    private static void compressGzipFile(String file, String gzipFile) {
        try {
            FileInputStream fis = new FileInputStream(file);
            FileOutputStream fos = new FileOutputStream(gzipFile);
            GZIPOutputStream gzipOS = new GZIPOutputStream(fos);
            byte[] buffer = new byte[1024];
            int len;
            while ((len = fis.read(buffer)) != -1) {
                gzipOS.write(buffer, 0, len);
            }
            //close resources
            gzipOS.close();
            fos.close();
            fis.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}