beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [2/2] beam git commit: Remove unused field in FlinkRunner
Date Fri, 24 Mar 2017 16:41:55 GMT
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 <tgroh@google.com>
Authored: Thu Mar 23 15:52:22 2017 -0700
Committer: Thomas Groh <tgroh@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


Mime
View raw message