You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/10/28 14:47:41 UTC
[07/50] incubator-beam git commit: This closes #1178
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 <kl...@google.com>
Authored: Tue Oct 25 13:12:17 2016 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------