编程实现一个类"MyFSDataInputStream”，该类继承"org.apache.hadoop.fs.FSDataInputStream”，要求如下。 (1)实现按行读取HDFS中指定文件的方法"readLine()”，如果读到文件末尾，则返回空，否则返回文件一行的文本。 (2)实现缓存功能，即利用"MyFSDataInputStream”读取若干字节数据时，首先查找缓，如果缓存中有所需数据,则直接由缓存提供,否则从 HDFS 中读取数据。 3.查看Java帮助手册或其他资料,用"java.net.URL"和"org.apache.hadoop.fs.FsURLStreamHandlerFactory”编程来输出 HDFS 中指定文件的文本到终端中。

以下是实现MyFSDataInputStream的代码：

import java.io.IOException;
import java.io.InputStreamReader;
import java.util.LinkedList;

import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class MyFSDataInputStream extends FSDataInputStream {
    private static final int DEFAULT_BUFFER_SIZE = 1024;
    private byte[] buffer;
    private int bufferPos;
    private int bufferSize;
    private InputStreamReader reader;
    private LinkedList<String> lines;

    public MyFSDataInputStream(FileSystem fs, Path file) throws IOException {
        super(fs.open(file));
        buffer = new byte[DEFAULT_BUFFER_SIZE];
        bufferPos = 0;
        bufferSize = 0;
        reader = new InputStreamReader(this);
        lines = new LinkedList<>();
    }

    public String readLine() throws IOException {
        if (lines.isEmpty()) {
            String line = null;
            int b = -1;
            while ((b = read()) != -1) {
                char c = (char) b;
                if (c == '\n') {
                    if (line == null) {
                        return "";
                    } else {
                        lines.add(line);
                        return line;
                    }
                } else {
                    if (line == null) {
                        line = "";
                    }
                    line += c;
                }
            }
            if (line == null) {
                return null;
            } else {
                lines.add(line);
                return line;
            }
        } else {
            return lines.removeFirst();
        }
    }

    @Override
    public synchronized int read() throws IOException {
        if (bufferPos >= bufferSize) {
            bufferSize = super.read(buffer);
            bufferPos = 0;
        }
        if (bufferSize == -1) {
            return -1;
        } else {
            return buffer[bufferPos++];
        }
    }
}

以下是使用MyFSDataInputStream实现从HDFS中读取文件并输出到终端的代码：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;

public class HDFSFileReader {
    public static void main(String[] args) throws Exception {
        String hdfsFile = "hdfs://localhost:9000/user/hadoop/test.txt";
        URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());
        URL url = new URL(hdfsFile);
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(url.toURI(), conf);
        Path path = new Path(url.getPath());
        MyFSDataInputStream in = new MyFSDataInputStream(fs, path);
        BufferedReader reader = new BufferedReader(in);
        String line = null;
        while ((line = reader.readLine()) != null) {
            System.out.println(line);
        }
        reader.close();
        in.close();
        fs.close();
    }
}

在以上代码中，我们首先使用`URL.setURLStreamHandlerFactory()`方法将`FsURLStreamHandlerFactory`注册为`URL`的URL流处理程序工厂，然后使用`FileSystem.get()`方法从HDFS中获取文件的`FileSystem`实例。接着，我们使用`MyFSDataInputStream`读取文件内容，并使用`BufferedReader`按行读取文件内容并输出到终端。最后，我们需要关闭所有打开的流和文件系统实例。