Gustavo de Morais created FLINK-41474:
-----------------------------------------

             Summary: Add DEDUPLICATE_WINDOW PTF
                 Key: FLINK-41474
                 URL: https://issues.apache.org/jira/browse/FLINK-41474
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Runtime
            Reporter: Gustavo de Morais
            Assignee: Vas Shabu


Add the built-in {{DEDUPLICATE_WINDOW}} PTF with {{duration}}. A per-key 
event-time window opens with the key's first record, and the first or last 
record is emitted when the watermark passes the window end. Output is 
insert-only with {{rowtime}} set to the window end. Late records are dropped.



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to