Closes #864
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7d46698f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7d46698f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7d46698f Branch: refs/heads/master Commit: 7d46698f2878e41369077c75f9347aafbeff0c5a Parents: 0d229f5 cdd88a9 Author: bchambers <[email protected]> Authored: Fri Sep 30 11:24:22 2016 -0700 Committer: bchambers <[email protected]> Committed: Fri Sep 30 11:24:22 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/DirectOptions.java | 13 +- .../beam/runners/direct/DirectRunner.java | 16 ++- .../direct/EncodabilityEnforcementFactory.java | 50 +++++--- .../beam/runners/direct/DirectRunnerTest.java | 66 ++++++++++ .../EncodabilityEnforcementFactoryTest.java | 122 +++++++++++++++---- 5 files changed, 215 insertions(+), 52 deletions(-) ----------------------------------------------------------------------
