Uses of Class
org.apache.flink.table.runtime.operators.deduplicate.DeduplicateFunctionBase
-
Packages that use DeduplicateFunctionBase Package Description org.apache.flink.table.runtime.operators.deduplicate org.apache.flink.table.runtime.operators.deduplicate.asyncprocessing -
-
Uses of DeduplicateFunctionBase in org.apache.flink.table.runtime.operators.deduplicate
Subclasses of DeduplicateFunctionBase in org.apache.flink.table.runtime.operators.deduplicate Modifier and Type Class Description classProcTimeDeduplicateKeepFirstRowFunctionThis function is used to deduplicate on keys and keeps only first row.classProcTimeDeduplicateKeepLastRowFunctionThis function is used to deduplicate on keys and keeps only last row.classRowTimeDeduplicateFunctionThis function is used to deduplicate on keys and keeps only first or last row on row time. -
Uses of DeduplicateFunctionBase in org.apache.flink.table.runtime.operators.deduplicate.asyncprocessing
Subclasses of DeduplicateFunctionBase in org.apache.flink.table.runtime.operators.deduplicate.asyncprocessing Modifier and Type Class Description classAsyncStateRowTimeDeduplicateFunctionThis function is used to deduplicate on keys and keeps only first or last row on row time.
-