Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5400

Add accessor to folding states in RuntimeContext

    Details

      Description

      Now RuntimeContext does not provide the accessors to folding states. Therefore users cannot use folding states in their rich functions. I think we should provide the missing accessor.

        Issue Links

          Activity

          Hide
          StephanEwen Stephan Ewen added a comment -

          Fixed in d63f831a4b11bb927a8cc216b4901d9262e44053

          Thank you for the contribution!

          Show
          StephanEwen Stephan Ewen added a comment - Fixed in d63f831a4b11bb927a8cc216b4901d9262e44053 Thank you for the contribution!
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flink/pull/3053

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3053
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user StephanEwen commented on the issue:

          https://github.com/apache/flink/pull/3053

          Looks good to me, merging this...

          Show
          githubbot ASF GitHub Bot added a comment - Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3053 Looks good to me, merging this...
          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user shixiaogang opened a pull request:

          https://github.com/apache/flink/pull/3053

          FLINK-5400 Add accessor to folding states in RuntimeContext

          • Add accessors in RuntimeContext and KeyedStateStore
          • Fix errors in the comments for reducing states in RuntimeContext and KeyedStateStore

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/alibaba/flink flink-5400

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flink/pull/3053.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 #3053


          commit f9d733a60f4809049e778045144528e8aff4a951
          Author: xiaogang.sxg <xiaogang.sxg@alibaba-inc.com>
          Date: 2016-12-30T03:25:05Z

          Add accessor to folding states in RuntimeContext


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user shixiaogang opened a pull request: https://github.com/apache/flink/pull/3053 FLINK-5400 Add accessor to folding states in RuntimeContext Add accessors in RuntimeContext and KeyedStateStore Fix errors in the comments for reducing states in RuntimeContext and KeyedStateStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/alibaba/flink flink-5400 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3053.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 #3053 commit f9d733a60f4809049e778045144528e8aff4a951 Author: xiaogang.sxg <xiaogang.sxg@alibaba-inc.com> Date: 2016-12-30T03:25:05Z Add accessor to folding states in RuntimeContext

            People

            • Assignee:
              xiaogang.shi Xiaogang Shi
              Reporter:
              xiaogang.shi Xiaogang Shi
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development