This closes apache#2310

mransley · Mar 24, 2017 · 7412427 · 7412427
2 parents 14aba81 + 92cdc08
commit 7412427
Showing 1 changed file with 0 additions and 18 deletions.
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
@@ -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.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 static FlinkRunner fromOptions(PipelineOptions options) {
  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