Class CommonRangeBoundaries<T>
- java.lang.Object
-
- org.apache.flink.api.common.distributions.CommonRangeBoundaries<T>
-
- All Implemented Interfaces:
Serializable
,RangeBoundaries<T>
@Internal public class CommonRangeBoundaries<T> extends Object implements RangeBoundaries<T>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CommonRangeBoundaries(TypeComparator<T> typeComparators, Object[][] boundaries)
-
-
-
Constructor Detail
-
CommonRangeBoundaries
public CommonRangeBoundaries(TypeComparator<T> typeComparators, Object[][] boundaries)
-
-
Method Detail
-
getRangeIndex
public int getRangeIndex(T record)
Description copied from interface:RangeBoundaries
Get the range index of record.- Specified by:
getRangeIndex
in interfaceRangeBoundaries<T>
- Parameters:
record
- The input record.- Returns:
- The range index.
-
-