You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/06/04 06:31:09 UTC
[2/2] beam git commit: This closes #3284
This closes #3284
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1866a011
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1866a011
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1866a011
Branch: refs/heads/master
Commit: 1866a01138ac9095aa7d8dfb1d67c955678b393e
Parents: ef56ea4 fbc6cc5
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Sun Jun 4 08:30:30 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Sun Jun 4 08:30:30 2017 +0200
----------------------------------------------------------------------
runners/flink/pom.xml | 2 +-
.../translation/types/CoderTypeSerializer.java | 55 ++++++++++++++++++++
.../types/EncodedValueSerializer.java | 18 +------
.../state/FlinkBroadcastStateInternals.java | 29 +++++------
.../streaming/UnboundedSourceWrapperTest.java | 37 +++++++++++++
5 files changed, 109 insertions(+), 32 deletions(-)
----------------------------------------------------------------------