Package org.apache.flink.table.runtime.operators.deduplicate.window.combines

Class Summary

Class	Description
RowTimeDeduplicateRecordsCombiner	An implementation of RecordsCombiner that stores the first/last records of incremental input records into the window state.
RowTimeDeduplicateRecordsCombiner.Factory	Factory to create RowTimeDeduplicateRecordsCombiner.