This closes #3258
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/711faffe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/711faffe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/711faffe Branch: refs/heads/master Commit: 711faffefeb91052efc0e3f45f7c9fb42df05151 Parents: 2cb4b03 838035a Author: Dan Halperin <[email protected]> Authored: Tue May 30 08:58:36 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue May 30 08:58:36 2017 -0700 ---------------------------------------------------------------------- .../functions/FlinkDoFnFunction.java | 8 +- .../functions/FlinkStatefulDoFnFunction.java | 8 +- .../wrappers/streaming/DoFnOperator.java | 77 +++++++++++++++----- 3 files changed, 70 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
