Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r188220497
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
MetricGroup getMetricGroup();
+ /**
+ * Returned value is guaranteed to be unique between operators within
the same job and to be
+ * stable and the same across job submissions.
+ *
+ * <p>This operation is currently only supported in Streaming
(DataStream) contexts.
+ *
+ * @return String representation of the operator's unique id.
+ */
+ @PublicEvolving
+ String getOperatorUniqueID();
--- End diff --
I slightly prefer the current approach. Looking at other methods, this
seems to be the "established" way for methods that do not exist in batch. Why
mixing up two different ways of dealing with them?
---
