[ https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504348#comment-16504348 ]
ASF GitHub Bot commented on FLINK-9538: --------------------------------------- GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/6134 [FLINK-9538] Make KeyedStateFunction an interface ## What is the purpose of the change *This pull request makes KeyedStateFunction an interface* ## Brief change log - *Change abstract class `KeyedStateFunction` to be an interface* - *Change abstract method `process` to be an interface method* ## Verifying this change This change is already covered by existing tests, such as *StateBackendTestBase*. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / **no**) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / **no**) - The serializers: (yes / **no** / don't know) - The runtime per-record code paths (performance sensitive): (yes / **no** / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know) - The S3 file system connector: (yes / **no** / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / **no**) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / **not documented**) You can merge this pull request into a Git repository by running: $ git pull https://github.com/yanghua/flink FLINK-9538 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/6134.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #6134 ---- commit c6e4cb6cef99306f402e6e7e50c066f8a60e41f4 Author: yanghua <yanghua1127@...> Date: 2018-06-07T07:27:25Z [FLINK-9538] Make KeyedStateFunction an interface ---- > Make KeyedStateFunction an interface > ------------------------------------ > > Key: FLINK-9538 > URL: https://issues.apache.org/jira/browse/FLINK-9538 > Project: Flink > Issue Type: Improvement > Reporter: Dawid Wysakowicz > Assignee: vinoyang > Priority: Major > > I suggest to change the KeyedStateFunction from abstract class to interface > (FunctionalInterface in particular) to enable passing lambdas. -- This message was sent by Atlassian JIRA (v7.6.3#76005)