Skip to content

Commit

Permalink
[flink] Change the access modifier of FileStoreLookupFunction#getRequ…
Browse files Browse the repository at this point in the history
…ireCachedBucketIds (apache#3532)
  • Loading branch information
WencongLiu authored Jun 17, 2024
1 parent b54e3be commit f2c8728
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down Expand Up @@ -127,6 +129,7 @@ public FileStoreLookupFunction(
}

public void open(FunctionContext context) throws Exception {
this.functionContext = context;
String tmpDirectory = getTmpDirectory(context);
open(tmpDirectory);
}
Expand Down Expand Up @@ -352,7 +355,7 @@ private static StreamingRuntimeContext extractStreamingRuntimeContext(Object run
*
* @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;
}
Expand Down

0 comments on commit f2c8728

Please sign in to comment.