...
JIRA:
Jira | ||||||
---|---|---|---|---|---|---|
|
Jira | ||||||
---|---|---|---|---|---|---|
|
Jira | ||||||||
---|---|---|---|---|---|---|---|---|
|
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.
...