beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [4/4] beam git commit: This closes #1960
Date Thu, 16 Feb 2017 11:26:10 GMT
This closes #1960


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/137fee95
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/137fee95
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/137fee95

Branch: refs/heads/master
Commit: 137fee95b3c1f7bd98f9983d29effcbe5acff899
Parents: f03f6ac 7d32b93
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Feb 16 12:13:54 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Thu Feb 16 12:13:54 2017 +0100

----------------------------------------------------------------------
 runners/flink/pom.xml                           |    2 +-
 runners/flink/runner/pom.xml                    |    6 +
 .../flink/DefaultParallelismFactory.java        |    3 +-
 .../FlinkStreamingTransformTranslators.java     |   20 +-
 .../FlinkStreamingTranslationContext.java       |    8 +
 .../wrappers/streaming/DoFnOperator.java        |  408 ++++---
 .../wrappers/streaming/FlinkStateInternals.java | 1055 ------------------
 .../wrappers/streaming/WindowDoFnOperator.java  |  389 +------
 .../streaming/io/BoundedSourceWrapper.java      |    5 -
 .../streaming/io/UnboundedSourceWrapper.java    |   23 +-
 .../state/FlinkBroadcastStateInternals.java     |  865 ++++++++++++++
 .../state/FlinkKeyGroupStateInternals.java      |  487 ++++++++
 .../state/FlinkSplitStateInternals.java         |  260 +++++
 .../streaming/state/FlinkStateInternals.java    | 1053 +++++++++++++++++
 .../state/KeyGroupCheckpointedOperator.java     |   35 +
 .../state/KeyGroupRestoringOperator.java        |   32 +
 .../wrappers/streaming/state/package-info.java  |   22 +
 .../beam/runners/flink/PipelineOptionsTest.java |   25 +-
 .../flink/streaming/DoFnOperatorTest.java       |  109 +-
 .../FlinkBroadcastStateInternalsTest.java       |  245 ++++
 .../FlinkKeyGroupStateInternalsTest.java        |  262 +++++
 .../streaming/FlinkSplitStateInternalsTest.java |  101 ++
 .../streaming/FlinkStateInternalsTest.java      |   27 +-
 .../streaming/UnboundedSourceWrapperTest.java   |   16 +
 24 files changed, 3814 insertions(+), 1644 deletions(-)
----------------------------------------------------------------------



Mime
View raw message