This closes #3765: [BEAM-2753] Fixes translation of WriteFiles side inputs
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/097aec7a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/097aec7a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/097aec7a Branch: refs/heads/master Commit: 097aec7a36a01145e1f4e0332a3172ae9243bfa7 Parents: 1cd87e3 783f26f Author: Eugene Kirpichov <ekirpic...@gmail.com> Authored: Wed Aug 30 16:29:10 2017 -0700 Committer: Eugene Kirpichov <ekirpic...@gmail.com> Committed: Wed Aug 30 16:29:10 2017 -0700 ---------------------------------------------------------------------- .../core/construction/PipelineTranslation.java | 55 ++++++---- .../direct/WriteWithShardingFactory.java | 13 +-- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 106 +++++++++++++------ 3 files changed, 112 insertions(+), 62 deletions(-) ----------------------------------------------------------------------
