iceberg org.apache.iceberg.parquet.Parquet parquet file read

阅读: 评论:0

iceberg org.apache.iceberg.parquet.Parquet  parquet file read

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.pressions.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 = ();res.add(data);
}

 

本文发布于:2024-01-30 17:00:06,感谢您对本站的认可!

本文链接:https://www.4u4v.net/it/170660520721506.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:apache   org   iceberg   parquet   read
留言与评论(共有 0 条评论)
   
验证码:

Copyright ©2019-2022 Comsenz Inc.Powered by ©

网站地图1 网站地图2 网站地图3 网站地图4 网站地图5 网站地图6 网站地图7 网站地图8 网站地图9 网站地图10 网站地图11 网站地图12 网站地图13 网站地图14 网站地图15 网站地图16 网站地图17 网站地图18 网站地图19 网站地图20 网站地图21 网站地图22/a> 网站地图23