(incubator-paimon-presto) branch main updated: Enable TableRead.executeFilter

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-paimon-presto.git


The following commit(s) were added to refs/heads/main by this push:
     new 0bd0664  Enable TableRead.executeFilter
0bd0664 is described below

commit 0bd066458a44eb3aa2900847d599686ca9b82e16
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Mon Nov 27 13:27:00 2023 +0800

    Enable TableRead.executeFilter
---
 .../main/java/org/apache/paimon/presto/PrestoPageSourceProvider.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/paimon-presto-common/src/main/java/org/apache/paimon/presto/PrestoPageSourceProvider.java
 
b/paimon-presto-common/src/main/java/org/apache/paimon/presto/PrestoPageSourceProvider.java
index ec33cf0..94eeda6 100644
--- 
a/paimon-presto-common/src/main/java/org/apache/paimon/presto/PrestoPageSourceProvider.java
+++ 
b/paimon-presto-common/src/main/java/org/apache/paimon/presto/PrestoPageSourceProvider.java
@@ -78,7 +78,8 @@ public class PrestoPageSourceProvider implements 
ConnectorPageSourceProvider {
                 .ifPresent(read::withFilter);
 
         try {
-            return new 
PrestoPageSource(read.newRead().createReader(split.decodeSplit()), columns);
+            return new PrestoPageSource(
+                    
read.newRead().executeFilter().createReader(split.decodeSplit()), columns);
         } catch (IOException e) {
             throw new RuntimeException(e);
         }