dawidwys commented on a change in pull request #17929:
URL: https://github.com/apache/flink/pull/17929#discussion_r760130868
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BoundedMultiInput.java
##########
@@ -19,13 +19,25 @@
import org.apache.flink.annotation.PublicEvolving;
-/** Interface for the multi-input operators that can process EndOfInput event.
*/
+/**
+ * Interface for multi-input operators that need to be notified about the
logical/semantical end of
+ * input.
+ *
+ * @see BoundedOneInput
+ */
@PublicEvolving
public interface BoundedMultiInput {
/**
- * It is notified that no more data will arrive on the input identified by
the {@code inputId}.
- * The {@code inputId} is numbered starting from 1, and `1` indicates the
first input.
+ * It is notified that no more data will arrive from the input identified
by the {@code
+ * inputId}. The {@code inputId} is numbered starting from 1, and `1`
indicates the first input.
+ *
+ * <p><b>WARNING:</b> It is not safe to use this method to commit any
transactions or other side
+ * effects! You can use this method to e.g. flush data buffered for the
given input or implement
+ * an ordered reading from multiple inputs via {@link InputSelectable}.
+ *
+ * <p><b>NOTE:</b> Classes should not implement both {@link
BoundedOneInput} and {@link
+ * BoundedMultiInput} at the same time!
Review comment:
:facepalm: sorry, fixing
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
