TestSequenceFile.java 文件源码

public static void main(String[] args) throws IOException {
        Configuration conf = new Configuration();
        FileSystem fileSystem = FileSystem.get(conf);
//      
//      SequenceFile.Writer w = SequenceFile.createWriter(fileSystem, conf, new Path("seq"), Text.class, BytesWritable.class);
//      for (int i = 0; i < 1; i++) {
//          ASTRoot.Builder ast = ASTRoot.newBuilder();
//          ast.addImports("a.b.C");
//          w.append(new Text(i + ""), new BytesWritable(ast.build().toByteArray()));
//          System.out.println("Parse before writing to sequence file: " + ASTRoot.parseFrom(ast.build().toByteArray()).getImportsList());
//      }
//      w.close();

        Text key = new Text();
        BytesWritable val = new BytesWritable();
        SequenceFile.Reader r = new SequenceFile.Reader(fileSystem, new Path("/Users/nmtiwari/nmt/githubCacheJSon/tmprepcache/ast-nmtiwari-0-1453911429.seq"), conf);
        while (r.next(key, val)) {
            System.out.println("next project");
            byte[] bytes = val.getBytes();
            System.out.print("Parse after writing to sequence file: ");
            //System.out.println(ASTRoot.parseFrom(bytes).getImportsList());
            System.out.println(ASTRoot.parseFrom(CodedInputStream.newInstance(bytes, 0, val.getLength())));
        }
        r.close();
    }