File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed
plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change 98
98
import static io .trino .plugin .iceberg .IcebergSessionProperties .getSplitSize ;
99
99
import static io .trino .plugin .iceberg .IcebergTypes .convertIcebergValueToTrino ;
100
100
import static io .trino .plugin .iceberg .IcebergUtil .getColumnHandle ;
101
- import static io .trino .plugin .iceberg .IcebergUtil .getFileModifiedTimePathDomain ;
101
+ import static io .trino .plugin .iceberg .IcebergUtil .getFileModifiedTimeDomain ;
102
102
import static io .trino .plugin .iceberg .IcebergUtil .getModificationTime ;
103
103
import static io .trino .plugin .iceberg .IcebergUtil .getPartitionDomain ;
104
104
import static io .trino .plugin .iceberg .IcebergUtil .getPartitionKeys ;
@@ -224,7 +224,7 @@ public IcebergSplitSource(
224
224
.map (IcebergColumnHandle .class ::cast ))
225
225
.map (IcebergColumnHandle ::getId )
226
226
.collect (toImmutableSet ());
227
- this .fileModifiedTimeDomain = getFileModifiedTimePathDomain (tableHandle .getEnforcedPredicate ());
227
+ this .fileModifiedTimeDomain = getFileModifiedTimeDomain (tableHandle .getEnforcedPredicate ());
228
228
this .cachingHostAddressProvider = requireNonNull (cachingHostAddressProvider , "cachingHostAddressProvider is null" );
229
229
this .executor = requireNonNull (executor , "executor is null" );
230
230
}
Original file line number Diff line number Diff line change @@ -1173,7 +1173,7 @@ public static Domain getPathDomain(TupleDomain<IcebergColumnHandle> effectivePre
1173
1173
return domain ;
1174
1174
}
1175
1175
1176
- public static Domain getFileModifiedTimePathDomain (TupleDomain <IcebergColumnHandle > effectivePredicate )
1176
+ public static Domain getFileModifiedTimeDomain (TupleDomain <IcebergColumnHandle > effectivePredicate )
1177
1177
{
1178
1178
IcebergColumnHandle fileModifiedTimeColumn = fileModifiedTimeColumnHandle ();
1179
1179
Domain domain = effectivePredicate .getDomains ().orElseThrow (() -> new IllegalArgumentException ("Unexpected NONE tuple domain" ))
Original file line number Diff line number Diff line change 63
63
import static io .trino .plugin .iceberg .IcebergErrorCode .ICEBERG_INVALID_METADATA ;
64
64
import static io .trino .plugin .iceberg .IcebergMetadataColumn .isMetadataColumnId ;
65
65
import static io .trino .plugin .iceberg .IcebergSessionProperties .isExtendedStatisticsEnabled ;
66
- import static io .trino .plugin .iceberg .IcebergUtil .getFileModifiedTimePathDomain ;
66
+ import static io .trino .plugin .iceberg .IcebergUtil .getFileModifiedTimeDomain ;
67
67
import static io .trino .plugin .iceberg .IcebergUtil .getModificationTime ;
68
68
import static io .trino .plugin .iceberg .IcebergUtil .getPartitionDomain ;
69
69
import static io .trino .plugin .iceberg .IcebergUtil .getPathDomain ;
@@ -145,7 +145,7 @@ public static TableStatistics makeTableStatistics(
145
145
146
146
Domain partitionDomain = getPartitionDomain (effectivePredicate );
147
147
Domain pathDomain = getPathDomain (effectivePredicate );
148
- Domain fileModifiedTimeDomain = getFileModifiedTimePathDomain (effectivePredicate );
148
+ Domain fileModifiedTimeDomain = getFileModifiedTimeDomain (effectivePredicate );
149
149
Schema snapshotSchema = schemaFor (icebergTable , snapshotId );
150
150
TableScan tableScan = icebergTable .newScan ()
151
151
.filter (toIcebergExpression (effectivePredicate .filter ((column , domain ) -> !isMetadataColumnId (column .getId ()))))
You can’t perform that action at this time.
0 commit comments