You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2023/06/07 08:22:10 UTC
[flink] 09/14: Introduce RuntimeContext interface.
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 <to...@gmail.com>
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.