Package org.apache.flink.runtime.operators.udf

Class Summary

Class	Description
AssignRangeIndex<IN>	This mapPartition function require a DataSet with RangeBoundaries as broadcast input, it generate Tuple2 which includes range index and record itself as output.
RangeBoundaryBuilder<T>	Build RangeBoundaries with input records.
RemoveRangeIndex<T>