...

JIRA: 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

This KIP combines KIP-149 and provides an atomic solution to rich functions in Streams. 

Rich functions are one of the essential parts of stream processing. There are several use-cases where users cannot express their business logic with current un-rich methods especially when init(Some params), close() methods are needed.Another motivation of this KIP is to introduce . For example:

• on-demand commit()

...

•  feature
• having access to RecordContext within an operator
• having access to read-only key for XXXWithKey interfaces

Public Interfaces

The following methods will be added to related classes.

...