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 booleanallInRange()byte[]getActualMaxKey()byte[]getActualMinKey()intgetKeyGroupPrefixBytes()byte[]getProclaimedMaxKey()byte[]getProclaimedMinKey()booleanisLeftInRange()booleanisRightInRange()StringtoString()
-
-
-
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()
-
-