Skip to content

Commit

Permalink
Fix comment in DeltaLakePageSourceProvider.createPageSource
Browse files Browse the repository at this point in the history
  • Loading branch information
radek-kondziolka committed Sep 21, 2023
1 parent 482f755 commit 78b3013
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -159,9 +159,8 @@ public ConnectorPageSource createPageSource(

// We reach here when we could not prune the split using file level stats, table predicate
// and the dynamic filter in the coordinator during split generation. The file level stats
// in DeltaLakeSplit#filePredicate could help to prune this split when a more selective dynamic filter
// in DeltaLakeSplit#statisticsPredicate could help to prune this split when a more selective dynamic filter
// is available now, without having to access parquet file footer for row-group stats.
// We avoid sending DeltaLakeSplit#splitPredicate to workers by using table.getPredicate() here.
TupleDomain<DeltaLakeColumnHandle> filteredSplitPredicate = TupleDomain.intersect(ImmutableList.of(
table.getNonPartitionConstraint(),
split.getStatisticsPredicate(),
Expand Down

0 comments on commit 78b3013

Please sign in to comment.