Uses of Class
org.apache.flink.table.runtime.operators.deduplicate.window.RowTimeWindowDeduplicateOperatorBuilder
-
Packages that use RowTimeWindowDeduplicateOperatorBuilder Package Description org.apache.flink.table.runtime.operators.deduplicate.window -
-
Uses of RowTimeWindowDeduplicateOperatorBuilder in org.apache.flink.table.runtime.operators.deduplicate.window
Methods in org.apache.flink.table.runtime.operators.deduplicate.window that return RowTimeWindowDeduplicateOperatorBuilder Modifier and Type Method Description static RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. builder()RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. keepLastRow(boolean keepLastRow)RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. keySerializer(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySerializer)RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. rowtimeIndex(int rowtimeIndex)RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. shiftTimeZone(java.time.ZoneId shiftTimeZone)RowTimeWindowDeduplicateOperatorBuilderRowTimeWindowDeduplicateOperatorBuilder. windowEndIndex(int windowEndIndex)
-