This closes #2481
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0e39a97 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0e39a97 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0e39a97 Branch: refs/heads/master Commit: e0e39a97560933f99eaee98549877fd5f8f49a52 Parents: e53f959 6622914 Author: Dan Halperin <dhalp...@google.com> Authored: Mon Apr 10 10:16:06 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Apr 10 10:16:06 2017 -0700 ---------------------------------------------------------------------- .../translation/ApexPipelineTranslator.java | 2 +- runners/core-construction-java/pom.xml | 15 + .../UnboundedReadFromBoundedSource.java | 542 ++++++++++++++++++ .../UnboundedReadFromBoundedSourceTest.java | 373 +++++++++++++ runners/core-java/pom.xml | 5 - .../core/UnboundedReadFromBoundedSource.java | 542 ------------------ .../UnboundedReadFromBoundedSourceTest.java | 373 ------------- .../beam/runners/dataflow/DataflowRunner.java | 3 +- .../DataflowUnboundedReadFromBoundedSource.java | 547 ------------------- ...aflowUnboundedReadFromBoundedSourceTest.java | 79 --- .../beam/runners/spark/TestSparkRunner.java | 2 +- 11 files changed, 934 insertions(+), 1549 deletions(-) ----------------------------------------------------------------------
