(incubator-paimon-trino) branch main updated: executeFilter for TableRead

[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-trino.git


The following commit(s) were added to refs/heads/main by this push:
     new 0242096  executeFilter for TableRead
0242096 is described below

commit 0242096006f3537047e42f1f5b86f8288611a5c0
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Mon Nov 20 20:38:07 2023 +0800

    executeFilter for TableRead
---
 .../main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java
 
b/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java
index b8bed14..f59078d 100644
--- 
a/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java
+++ 
b/paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java
@@ -86,7 +86,9 @@ public class TrinoPageSourceProvider implements 
ConnectorPageSourceProvider {
 
         try {
             return new TrinoPageSource(
-                    read.newRead().createReader(split.decodeSplit()), columns, 
limit);
+                    
read.newRead().executeFilter().createReader(split.decodeSplit()),
+                    columns,
+                    limit);
         } catch (IOException e) {
             throw new RuntimeException(e);
         }