本文主要是介绍iceberg org.apache.iceberg.parquet.Parquet parquet file read，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
org.apache.iceberg.parquet.Parquet#read
public static ReadBuilder read(InputFile file) {return new ReadBuilder(file);
}
org.apache.iceberg.parquet.Parquet.ReadBuilder
public static class ReadBuilder {// 文件读范围: [start, start + length).private Long start = null;private Long length = null;// 文件所属 table 的 schemaprivate Schema schema = null;// org.apache.iceberg.expressions.Expressions#alwaysTrueprivate Expression filter = null;// readerprivate Function<MessageType, ParquetValueReader<?>> readerFunc = null;// 大小写敏感private boolean caseSensitive = true;
}
遍历迭代器
CloseableIterable<T> iter = builder.build();
this.currentIterator = iter.iterator();
while (this.currentIterator.hasNext()) {RowData data = this.currentIterator.next();res.add(data);
}
这篇关于iceberg org.apache.iceberg.parquet.Parquet parquet file read的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
