This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch process-func-api-poc-weijie in repository https://gitbox.apache.org/repos/asf/flink.git
commit b6c1dc51e864bd7fb9effe6d90c00ab738f3c044 Author: Xintong Song <[email protected]> AuthorDate: Sun Jun 4 12:01:10 2023 +0800 Introduce RuntimeContext interface. --- .../java/org/apache/flink/processfunction/api/ProcessFunction.java | 2 +- .../api/{ProcessFunction.java => RuntimeContext.java} | 5 +---- .../java/org/apache/flink/processfunction/examples/SimpleMap.java | 2 +- 3 files changed, 3 insertions(+), 6 deletions(-) diff --git a/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java b/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java index 3058727c4df..bbaa8c4cad2 100644 --- a/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java +++ b/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java @@ -20,5 +20,5 @@ package org.apache.flink.processfunction.api; @FunctionalInterface public interface ProcessFunction<IN, OUT> { - OUT processRecord(IN record); + OUT processRecord(IN record, RuntimeContext ctx); } diff --git a/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java b/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/RuntimeContext.java similarity index 89% copy from flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java copy to flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/RuntimeContext.java index 3058727c4df..5a26ea9196a 100644 --- a/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/ProcessFunction.java +++ b/flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/processfunction/api/RuntimeContext.java @@ -18,7 +18,4 @@ package org.apache.flink.processfunction.api; -@FunctionalInterface -public interface ProcessFunction<IN, OUT> { - OUT processRecord(IN record); -} +public interface RuntimeContext {} diff --git a/flink-process-function-parent/flink-process-function-examples/src/main/java/org/apache/flink/processfunction/examples/SimpleMap.java b/flink-process-function-parent/flink-process-function-examples/src/main/java/org/apache/flink/processfunction/examples/SimpleMap.java index 35f0a94ddf1..5bcfe8592a5 100644 --- a/flink-process-function-parent/flink-process-function-examples/src/main/java/org/apache/flink/processfunction/examples/SimpleMap.java +++ b/flink-process-function-parent/flink-process-function-examples/src/main/java/org/apache/flink/processfunction/examples/SimpleMap.java @@ -29,7 +29,7 @@ public class SimpleMap { ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); env.tmpFromSupplierSource(System::currentTimeMillis) .process( - tsLong -> + (tsLong, ctx) -> new SimpleDateFormat("yyyy/MM/dd HH:mm:ss.SSS") .format(new Date(tsLong))) // Don't use Lambda reference as PrintStream is not serializable.
