This closes #3590: [BEAM-2628] Makes AvroSource not open files while splitting
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d9160fa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d9160fa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1d9160fa Branch: refs/heads/master Commit: 1d9160fa3337704b9fbdc423796925be78b0087e Parents: 7e63d2c d4026da Author: Eugene Kirpichov <kirpic...@google.com> Authored: Thu Jul 20 16:59:27 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Thu Jul 20 16:59:27 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroSource.java | 265 ++++++------------- .../org/apache/beam/sdk/io/AvroSourceTest.java | 37 +-- 2 files changed, 92 insertions(+), 210 deletions(-) ----------------------------------------------------------------------
