static RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.builder() |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer) |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.keepLastRow(boolean keepLastRow) |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer) |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.rowtimeIndex(int rowtimeIndex) |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.shiftTimeZone(java.time.ZoneId shiftTimeZone) |
RowTimeWindowDeduplicateOperatorBuilder |
RowTimeWindowDeduplicateOperatorBuilder.windowEndIndex(int windowEndIndex) |