Fast5NamesCmd.java 文件源码

private static void runHadoopGetNames(String in) throws IOException {
    Configuration conf = new Configuration();
    FileSystem fs = FileSystem.get(conf);

    if (!fs.exists(new Path(in))) {
        System.out.println("Error: Hdfs file " + in + " does not exist!");
        System.exit(-1);
    }

    MapFile.Reader reader = null;

    try {
        reader = new MapFile.Reader(fs, in, conf);
        Text key = (Text) reader.getKeyClass().newInstance();
        BytesWritable value = (BytesWritable) reader.getValueClass().newInstance();
        while (reader.next(key, value)) {
            System.out.println(key.toString());
        }
    } catch (Exception e) {
        e.printStackTrace();
        if (reader != null) reader.close();
    }


}