MapFileRead.java 文件源码

public static void main(String[] args) throws IOException {

  String uri = args[0];
  conf = new Configuration();
  fs = FileSystem.get(URI.create(uri),conf);
  path = new Path(uri); 
  try {
    reader = new MapFile.Reader(fs, uri, conf);
    WritableComparable key = (WritableComparable) ReflectionUtils.newInstance(reader.getKeyClass(),conf);
    Writable value = (Writable) ReflectionUtils.newInstance(reader.getValueClass(),conf); 
    while(reader.next(key,value)) {
      System.out.printf("%s\t%s\n", key, value);
    }
   } 
    finally {
      IOUtils.closeStream(reader);
    } 
}