Repository: incubator-beam Updated Branches: refs/heads/master a5320607a -> f65795661
Remove empty unused method in TestStreamEvaluatorFactory Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ccfb78ea Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ccfb78ea Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ccfb78ea Branch: refs/heads/master Commit: ccfb78eac4d9b992d8694ad1f6347f50d80169c1 Parents: a532060 Author: Thomas Groh <tg...@google.com> Authored: Wed Aug 31 15:34:21 2016 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Wed Aug 31 15:34:21 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/TestStreamEvaluatorFactory.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/ccfb78ea/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java index 3dbd886..5fe771c 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java @@ -84,13 +84,6 @@ class TestStreamEvaluatorFactory implements TransformEvaluatorFactory { .orNull(); } - /** - * Release the provided {@link Evaluator} after completing an evaluation. The next call to {@link - * #createEvaluator(AppliedPTransform, EvaluationContext)} with the {@link AppliedPTransform} will - * return this evaluator. - */ - private void completeEvaluation(Evaluator<?> evaluator) {} - private static class Evaluator<T> implements TransformEvaluator<Object> { private final AppliedPTransform<PBegin, PCollection<T>, TestStream<T>> application; private final EvaluationContext context;