This closes #1727
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b15d6de Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b15d6de Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b15d6de Branch: refs/heads/master Commit: 1b15d6de0c09dbffe462285a2368f066c6d4186d Parents: 6c1e469 37a18f7 Author: Thomas Weise <[email protected]> Authored: Tue Jan 3 13:39:26 2017 -0800 Committer: Thomas Weise <[email protected]> Committed: Tue Jan 3 13:39:26 2017 -0800 ---------------------------------------------------------------------- .../operators/ApexReadUnboundedInputOperator.java | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
