Package org.apache.flink.state.rocksdb
Class RocksDBIncrementalCheckpointUtils.RangeCheckResult
- java.lang.Object
-
- org.apache.flink.state.rocksdb.RocksDBIncrementalCheckpointUtils.RangeCheckResult
-
- Enclosing class:
- RocksDBIncrementalCheckpointUtils
public static final class RocksDBIncrementalCheckpointUtils.RangeCheckResult extends Object
Helper class that represents the result of a range check of the actual keys in a RocksDB instance against the proclaimed key-group range of the instance. In short, this checks if the instance contains any keys (or tombstones for keys) that don't belong in the instance's key-groups range.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
allInRange()
byte[]
getActualMaxKey()
byte[]
getActualMinKey()
int
getKeyGroupPrefixBytes()
byte[]
getProclaimedMaxKey()
byte[]
getProclaimedMinKey()
boolean
isLeftInRange()
boolean
isRightInRange()
String
toString()
-
-
-
Method Detail
-
allInRange
public boolean allInRange()
-
getProclaimedMinKey
public byte[] getProclaimedMinKey()
-
getProclaimedMaxKey
public byte[] getProclaimedMaxKey()
-
getActualMinKey
public byte[] getActualMinKey()
-
getActualMaxKey
public byte[] getActualMaxKey()
-
getKeyGroupPrefixBytes
public int getKeyGroupPrefixBytes()
-
isLeftInRange
public boolean isLeftInRange()
-
isRightInRange
public boolean isRightInRange()
-
-