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);
}
}
AggregationOutputDumpTool.java 文件源码
java
阅读 15
收藏 0
点赞 0
评论 0
项目:Pinot
作者:
评论列表
文章目录