You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2018/03/07 15:39:54 UTC

[beam] 01/01: Merge pull request #4813: [BEAM-3794] Make StateInternals short state method defaulting to the implementation all runners use to simplify the contract the user has to implement

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 3ca6e8c517fc0bd2b0fc7202b680a9f85bd7f597
Merge: d497bfa 24ff5b6
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Wed Mar 7 16:39:48 2018 +0100

    Merge pull request #4813: [BEAM-3794] Make StateInternals short state method defaulting to the implementation all runners use to simplify the contract the user has to implement
    
    [BEAM-3794] Make StateInternals short state method defaulting to the implementation all runners use to simplify the contract the user has to implement

 .../beam/runners/apex/translation/utils/ApexStateInternals.java  | 6 ------
 .../org/apache/beam/runners/core/InMemoryStateInternals.java     | 6 ------
 .../main/java/org/apache/beam/runners/core/StateInternals.java   | 5 ++++-
 .../beam/runners/direct/CopyOnAccessInMemoryStateInternals.java  | 5 -----
 .../wrappers/streaming/state/FlinkBroadcastStateInternals.java   | 9 ---------
 .../wrappers/streaming/state/FlinkKeyGroupStateInternals.java    | 9 ---------
 .../wrappers/streaming/state/FlinkSplitStateInternals.java       | 9 ---------
 .../wrappers/streaming/state/FlinkStateInternals.java            | 9 ---------
 .../apache/beam/runners/spark/stateful/SparkStateInternals.java  | 6 ------
 9 files changed, 4 insertions(+), 60 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
iemejia@apache.org.