This closes #2126
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e072a03 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e072a03 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2e072a03 Branch: refs/heads/master Commit: 2e072a0320b57f39e24870cc898fab7fabb44b02 Parents: 2a23374 e7f825c Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Feb 28 15:29:22 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Feb 28 15:29:22 2017 +0100 ---------------------------------------------------------------------- runners/flink/runner/pom.xml | 1 - .../flink/FlinkBatchTransformTranslators.java | 16 ----- .../functions/FlinkStatefulDoFnFunction.java | 64 ++++++++++++++++++++ 3 files changed, 64 insertions(+), 17 deletions(-) ----------------------------------------------------------------------
