Thomas Weise created FLINK-8648:

             Summary: Allow for customization of emitRecordAndUpdateState in 
Kinesis connector
                 Key: FLINK-8648
             Project: Flink
          Issue Type: Task
          Components: Kinesis Connector
            Reporter: Thomas Weise
            Assignee: Thomas Weise

It should be possible to override the method to intercept the emit behavior, in 
this case for the purpose of custom watermark support.


This message was sent by Atlassian JIRA

Reply via email to