Remove deprecated AggregatorFactory from SDK
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aab46a0e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aab46a0e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/aab46a0e Branch: refs/heads/python-sdk Commit: aab46a0ec6e0e45208f64de7aabb9af643acd0ec Parents: a3f68d3 Author: Kenneth Knowles <k...@google.com> Authored: Thu Dec 15 20:13:25 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Dec 20 14:05:35 2016 -0800 ---------------------------------------------------------------------- .../apache/beam/sdk/transforms/Aggregator.java | 19 ------------------- 1 file changed, 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/aab46a0e/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Aggregator.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Aggregator.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Aggregator.java index 43f53a8..4119c53 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Aggregator.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Aggregator.java @@ -18,7 +18,6 @@ package org.apache.beam.sdk.transforms; import org.apache.beam.sdk.transforms.Combine.CombineFn; -import org.apache.beam.sdk.util.ExecutionContext; /** * An {@code Aggregator<InputT>} enables monitoring of values of type {@code InputT}, @@ -68,22 +67,4 @@ public interface Aggregator<InputT, OutputT> { * aggregator. */ CombineFn<InputT, ?, OutputT> getCombineFn(); - - /** - * @deprecated this is for use only by runners and exists only for a migration period. Please - * use the identical interface in org.apache.beam.runners.core - */ - @Deprecated - interface AggregatorFactory { - /** - * Create an aggregator with the given {@code name} and {@link CombineFn}. - * - * <p>This method is called to create an aggregator for a {@link DoFn}. It receives the - * class of the {@link DoFn} being executed and the context of the step it is being - * executed in. - */ - <InputT, AccumT, OutputT> Aggregator<InputT, OutputT> createAggregatorForDoFn( - Class<?> fnClass, ExecutionContext.StepContext stepContext, - String aggregatorName, CombineFn<InputT, AccumT, OutputT> combine); - } }