[hotfix][runtime] Remove the unused StreamOperatorFactory#isOperatorS…

…electiveReading method
deepfield · Aug 30, 2019 · 8ca6a09 · 8ca6a09
1 parent dc74248
commit 8ca6a09
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 16 deletions.
diff --git a/...ng-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOperatorFactory.java b/...ng-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOperatorFactory.java
@@ -92,11 +92,6 @@ public boolean isStreamSource() {
  return operator instanceof StreamSource;
  }
 
- @Override
- public boolean isOperatorSelectiveReading(ClassLoader classLoader) {
- return operator instanceof InputSelectable;
- }
-
  @Override
  public boolean isOutputTypeConfigurable() {
  return operator instanceof OutputTypeConfigurable;

diff --git a/...ng-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java b/...ng-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java
@@ -58,11 +58,6 @@ default boolean isStreamSource() {
  return false;
  }
 
- /**
- * Test whether the operator is selective reading one.
- */
- boolean isOperatorSelectiveReading(ClassLoader classLoader);
-
  /**
  * If the stream operator need access to the output type information at {@link StreamGraph}
  * generation. This can be useful for cases where the output type is specified by the returns

diff --git a/...-blink/src/main/java/org/apache/flink/table/runtime/operators/CodeGenOperatorFactory.java b/...-blink/src/main/java/org/apache/flink/table/runtime/operators/CodeGenOperatorFactory.java
@@ -20,7 +20,6 @@
 
 import org.apache.flink.streaming.api.graph.StreamConfig;
 import org.apache.flink.streaming.api.operators.ChainingStrategy;
-import org.apache.flink.streaming.api.operators.InputSelectable;
 import org.apache.flink.streaming.api.operators.Output;
 import org.apache.flink.streaming.api.operators.StreamOperator;
 import org.apache.flink.streaming.api.operators.StreamOperatorFactory;
@@ -58,11 +57,6 @@ public ChainingStrategy getChainingStrategy() {
  return strategy;
  }
 
- @Override
- public boolean isOperatorSelectiveReading(ClassLoader classLoader) {
- return InputSelectable.class.isAssignableFrom(getStreamOperatorClass(classLoader));
- }
-
  @Override
  public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader) {
  return generatedClass.getClass(classLoader);