ggershinsky commented on code in PR #10201:
URL: https://github.com/apache/iceberg/pull/10201#discussion_r1591933618
##########
data/src/main/java/org/apache/iceberg/data/GenericReader.java:
##########
@@ -45,14 +45,14 @@
import org.apache.iceberg.util.PartitionUtil;
class GenericReader implements Serializable {
- private final FileIO io;
+ private final EncryptingFileIO io;
private final Schema tableSchema;
private final Schema projection;
private final boolean caseSensitive;
private final boolean reuseContainers;
GenericReader(TableScan scan, boolean reuseContainers) {
- this.io = scan.table().io();
+ this.io = EncryptingFileIO.combine(scan.table().io(),
scan.table().encryption());
Review Comment:
the table.io() comes from the catalog's table operations, and will already
be an EncryptingFileIO for encrypted tables.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
