Delete unused remnants in DirectExecutionContext
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dc585510 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dc585510 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dc585510 Branch: refs/heads/master Commit: dc585510e6b4def3a0442114d77e96f2b5d4880f Parents: acce24c Author: Kenneth Knowles <[email protected]> Authored: Mon May 22 17:46:12 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue May 23 11:16:27 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/DirectExecutionContext.java | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/dc585510/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java ---------------------------------------------------------------------- diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java index 651af8f..8452565 100644 --- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java +++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java @@ -56,9 +56,8 @@ class DirectExecutionContext { } /** - * Returns the {@link BaseStepContext} associated with the given step. + * Returns the {@link StepContext} associated with the given step. */ - @Override public DirectStepContext getOrCreateStepContext(String stepName, String transformName) { final String finalStepName = stepName; final String finalTransformName = transformName; @@ -71,14 +70,6 @@ class DirectExecutionContext { } /** - * Returns a collection view of all of the {@link BaseStepContext}s. - */ - @Override - public Collection<? extends DirectStepContext> getAllStepContexts() { - return Collections.unmodifiableCollection(cachedStepContexts.values()); - } - - /** * Step Context for the {@link DirectRunner}. */ public class DirectStepContext implements StepContext {
