(paimon) branch master updated: [flink] Change the access modifier of FileStoreLookupFunction#getRequireCachedBucketIds (#3532)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new f2c872876 [flink] Change the access modifier of 
FileStoreLookupFunction#getRequireCachedBucketIds (#3532)
f2c872876 is described below

commit f2c87287666e0e77859f85b43abdc30b1845cf14
Author: Wencong Liu <104502720+wencong...@users.noreply.github.com>
AuthorDate: Mon Jun 17 23:12:24 2024 +0800

    [flink] Change the access modifier of 
FileStoreLookupFunction#getRequireCachedBucketIds (#3532)
---
 .../java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
index 3fd73d2b9..65c9c7302 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
@@ -94,6 +94,8 @@ public class FileStoreLookupFunction implements Serializable, 
Closeable {
     // timestamp when cache expires
     private transient long nextLoadTime;
 
+    protected FunctionContext functionContext;
+
     public FileStoreLookupFunction(
             Table table, int[] projection, int[] joinKeyIndex, @Nullable 
Predicate predicate) {
         TableScanUtils.streamingReadingValidate(table);
@@ -127,6 +129,7 @@ public class FileStoreLookupFunction implements 
Serializable, Closeable {
     }
 
     public void open(FunctionContext context) throws Exception {
+        this.functionContext = context;
         String tmpDirectory = getTmpDirectory(context);
         open(tmpDirectory);
     }
@@ -352,7 +355,7 @@ public class FileStoreLookupFunction implements 
Serializable, Closeable {
      *
      * @return the set of bucket IDs to be cached
      */
-    private Set<Integer> getRequireCachedBucketIds() {
+    protected Set<Integer> getRequireCachedBucketIds() {
         // TODO: Implement the method when Flink support bucket shuffle for 
lookup join.
         return null;
     }