org.apache.paimon.flink.lookup

Class RefreshBlacklist

java.lang.Object

org.apache.paimon.flink.lookup.RefreshBlacklist

public class RefreshBlacklist
extends Object

Refresh black list for FileStoreLookupFunction.

Constructor Summary

Constructors

Constructor and Description
RefreshBlacklist(List<Pair<Long,Long>> timePeriodsBlacklist)

Method Summary

Modifier and Type	Method and Description
boolean	canRefresh()
static RefreshBlacklist	create(String blacklist)
long	nextBlacklistCheckTime()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RefreshBlacklist

public RefreshBlacklist(List<Pair<Long,Long>> timePeriodsBlacklist)

Method Detail

create

@Nullable
public static RefreshBlacklist create(String blacklist)

canRefresh

public boolean canRefresh()

nextBlacklistCheckTime

public long nextBlacklistCheckTime()