AggregationOutputDumpTool.java 文件源码

java
阅读 16 收藏 0 点赞 0 评论 0

项目:Pinot 作者:
private static void processFile(Path path) throws Exception {
  System.out.println("Processing file:" + path);
  SequenceFile.Reader reader = new SequenceFile.Reader(new Configuration(),
      Reader.file(path));
  System.out.println(reader.getKeyClass());
  System.out.println(reader.getValueClassName());
  WritableComparable<?> key = (WritableComparable<?>) reader.getKeyClass()
      .newInstance();
  Writable val = (Writable) reader.getValueClass().newInstance();

  while (reader.next(key, val)) {
    BytesWritable writable = (BytesWritable) key;
    DimensionKey dimensionKey = DimensionKey.fromBytes(writable.getBytes());
    System.out.println(dimensionKey);
  }
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号