Remove unused field in FlinkRunner These overrides are performed in FlinkStreamingPipelineTranslator
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/92cdc089 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/92cdc089 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/92cdc089 Branch: refs/heads/master Commit: 92cdc0891f33afdc0ef7545fbd812532555631ff Parents: 14aba81 Author: Thomas Groh <tg...@google.com> Authored: Thu Mar 23 15:52:22 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri Mar 24 09:41:42 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/flink/FlinkRunner.java | 18 ------------------ 1 file changed, 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/92cdc089/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java index 5610dd4..096f030 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java @@ -18,7 +18,6 @@ package org.apache.beam.runners.flink; import com.google.common.base.Joiner; -import com.google.common.collect.ImmutableMap; import java.io.File; import java.net.URISyntaxException; import java.net.URL; @@ -36,7 +35,6 @@ import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.options.PipelineOptionsValidator; import org.apache.beam.sdk.runners.PipelineRunner; import org.apache.beam.sdk.runners.TransformHierarchy; -import org.apache.beam.sdk.transforms.Combine; import org.apache.beam.sdk.transforms.PTransform; import org.apache.beam.sdk.transforms.View; import org.apache.beam.sdk.values.PValue; @@ -59,9 +57,6 @@ public class FlinkRunner extends PipelineRunner<PipelineResult> { */ private final FlinkPipelineOptions options; - /** Custom transforms implementations. */ - private final Map<Class<?>, Class<?>> overrides; - /** * Construct a runner from the provided options. * @@ -102,19 +97,6 @@ public class FlinkRunner extends PipelineRunner<PipelineResult> { private FlinkRunner(FlinkPipelineOptions options) { this.options = options; this.ptransformViewsWithNonDeterministicKeyCoders = new HashSet<>(); - - ImmutableMap.Builder<Class<?>, Class<?>> builder = ImmutableMap.<Class<?>, Class<?>>builder(); - if (options.isStreaming()) { - builder.put(Combine.GloballyAsSingletonView.class, - FlinkStreamingViewOverrides.StreamingCombineGloballyAsSingletonView.class); - builder.put(View.AsMap.class, FlinkStreamingViewOverrides.StreamingViewAsMap.class); - builder.put(View.AsMultimap.class, FlinkStreamingViewOverrides.StreamingViewAsMultimap.class); - builder.put(View.AsSingleton.class, - FlinkStreamingViewOverrides.StreamingViewAsSingleton.class); - builder.put(View.AsList.class, FlinkStreamingViewOverrides.StreamingViewAsList.class); - builder.put(View.AsIterable.class, FlinkStreamingViewOverrides.StreamingViewAsIterable.class); - } - overrides = builder.build(); } @Override
