This closes #1178
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13af296d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13af296d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/13af296d Branch: refs/heads/apex-runner Commit: 13af296dec5fd5b9b4f922dac6ce1dc9b026cf60 Parents: 7abdcbf 2872019 Author: Kenneth Knowles <k...@google.com> Authored: Tue Oct 25 13:12:17 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Oct 25 13:12:17 2016 -0700 ---------------------------------------------------------------------- .../direct/WriteWithShardingFactory.java | 6 +- .../ConsumerTrackingPipelineVisitorTest.java | 32 +++---- .../beam/runners/direct/DirectRunnerTest.java | 40 +++++---- .../ImmutabilityCheckingBundleFactoryTest.java | 8 +- .../ImmutabilityEnforcementFactoryTest.java | 8 +- .../direct/KeyedPValueTrackingVisitorTest.java | 8 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 8 +- .../direct/ParDoMultiEvaluatorFactoryTest.java | 87 +++++++++--------- .../direct/ParDoSingleEvaluatorFactoryTest.java | 94 +++++++++----------- .../runners/direct/WatermarkManagerTest.java | 8 +- .../apache/beam/sdk/util/ValueWithRecordId.java | 8 +- 11 files changed, 146 insertions(+), 161 deletions(-) ----------------------------------------------------------------------