Class ForStPriorityQueueConfig
- java.lang.Object
-
- org.apache.flink.state.forst.sync.ForStPriorityQueueConfig
-
- All Implemented Interfaces:
Serializable
public class ForStPriorityQueueConfig extends Object implements Serializable
The configuration of rocksDB priority queue state implementation.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ForStPriorityQueueConfig()
ForStPriorityQueueConfig(ForStStateBackend.PriorityQueueStateType priorityQueueStateType, int rocksDBPriorityQueueSetCacheSize)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ForStPriorityQueueConfig
buildWithPriorityQueueType(ForStStateBackend.PriorityQueueStateType type)
static ForStPriorityQueueConfig
fromOtherAndConfiguration(ForStPriorityQueueConfig other, ReadableConfig config)
ForStStateBackend.PriorityQueueStateType
getPriorityQueueStateType()
Gets the type of the priority queue state.int
getRocksDBPriorityQueueSetCacheSize()
Gets the cache size of rocksDB priority queue set.void
setPriorityQueueStateType(ForStStateBackend.PriorityQueueStateType type)
-
-
-
Constructor Detail
-
ForStPriorityQueueConfig
public ForStPriorityQueueConfig()
-
ForStPriorityQueueConfig
public ForStPriorityQueueConfig(ForStStateBackend.PriorityQueueStateType priorityQueueStateType, int rocksDBPriorityQueueSetCacheSize)
-
-
Method Detail
-
getPriorityQueueStateType
public ForStStateBackend.PriorityQueueStateType getPriorityQueueStateType()
Gets the type of the priority queue state. It will fall back to the default value if it is not explicitly set.
-
setPriorityQueueStateType
public void setPriorityQueueStateType(ForStStateBackend.PriorityQueueStateType type)
-
getRocksDBPriorityQueueSetCacheSize
public int getRocksDBPriorityQueueSetCacheSize()
Gets the cache size of rocksDB priority queue set. It will fall back to the default value if it is not explicitly set.
-
fromOtherAndConfiguration
public static ForStPriorityQueueConfig fromOtherAndConfiguration(ForStPriorityQueueConfig other, ReadableConfig config)
-
buildWithPriorityQueueType
public static ForStPriorityQueueConfig buildWithPriorityQueueType(ForStStateBackend.PriorityQueueStateType type)
-
-