This is an automated email from the ASF dual-hosted git repository.
hequn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a86387bfa9ac525223b8e16b0a747d35893c9302
Author: hequn.chq <hequn....@alibaba-inc.com>
AuthorDate: Sat Aug 15 12:41:57 2020 +0800
[FLINK-18943][python] Rename AbstractPythonFunctionOperator to
AbstractOneInputPythonFunctionOperator
---
.../operators/python/DataStreamPythonStatelessFunctionOperator.java | 5 +++--
...tionOperator.java => AbstractOneInputPythonFunctionOperator.java} | 4 ++--
.../runtime/operators/python/AbstractStatelessFunctionOperator.java | 4 ++--
3 files changed, 7 insertions(+), 6 deletions(-)
diff --git
a/flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java
b/flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java
index 1b32df4..a2ec04c 100644
---
a/flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java
+++
b/flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java
@@ -30,7 +30,7 @@ import
org.apache.flink.datastream.runtime.runners.python.beam.BeamDataStreamPyt
import org.apache.flink.datastream.runtime.typeutils.python.PythonTypeUtils;
import org.apache.flink.fnexecution.v1.FlinkFnApi;
import org.apache.flink.python.PythonFunctionRunner;
-import
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator;
+import
org.apache.flink.streaming.api.operators.python.AbstractOneInputPythonFunctionOperator;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.table.functions.python.PythonEnv;
import org.apache.flink.table.runtime.util.StreamRecordCollector;
@@ -43,7 +43,8 @@ import java.util.Map;
* {@link DataStreamPythonStatelessFunctionOperator} is responsible for
launching beam runner which will start a python
* harness to execute user defined python function.
*/
-public class DataStreamPythonStatelessFunctionOperator<IN, OUT> extends
AbstractPythonFunctionOperator<IN, OUT> {
+public class DataStreamPythonStatelessFunctionOperator<IN, OUT>
+ extends AbstractOneInputPythonFunctionOperator<IN, OUT> {
private static final long serialVersionUID = 1L;
diff --git
a/flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperator.java
b/flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java
similarity index 91%
rename from
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperator.java
rename to
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java
index 1295b8f..0ae4ed9 100644
---
a/flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperator.java
+++
b/flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java
@@ -27,13 +27,13 @@ import
org.apache.flink.streaming.api.operators.OneInputStreamOperator;
* Base class for all one input stream operators to execute Python functions.
*/
@Internal
-public abstract class AbstractPythonFunctionOperator<IN, OUT>
+public abstract class AbstractOneInputPythonFunctionOperator<IN, OUT>
extends AbstractPythonFunctionOperatorBase<OUT>
implements OneInputStreamOperator<IN, OUT>, BoundedOneInput {
private static final long serialVersionUID = 1L;
- public AbstractPythonFunctionOperator(Configuration config) {
+ public AbstractOneInputPythonFunctionOperator(Configuration config) {
super(config);
}
diff --git
a/flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java
b/flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java
index f68d8a3..a3ae165 100644
---
a/flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java
+++
b/flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java
@@ -26,7 +26,7 @@ import
org.apache.flink.core.memory.DataInputViewStreamWrapper;
import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
import org.apache.flink.fnexecution.v1.FlinkFnApi;
import org.apache.flink.python.PythonFunctionRunner;
-import
org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator;
+import
org.apache.flink.streaming.api.operators.python.AbstractOneInputPythonFunctionOperator;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.table.data.RowData;
import org.apache.flink.table.functions.python.PythonFunctionInfo;
@@ -55,7 +55,7 @@ import java.util.stream.Collectors;
*/
@Internal
public abstract class AbstractStatelessFunctionOperator<IN, OUT, UDFIN>
- extends AbstractPythonFunctionOperator<IN, OUT> {
+ extends AbstractOneInputPythonFunctionOperator<IN, OUT> {
private static final long serialVersionUID = 1L;
