GJL commented on a change in pull request #11647: [FLINK-16960][runtime] Add
PipelinedRegion interface
URL: https://github.com/apache/flink/pull/11647#discussion_r404037243
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/topology/PipelinedRegion.java
##########
@@ -0,0 +1,38 @@
+package org.apache.flink.runtime.topology;
+
+/**
+ * A pipelined region is a set of vertices connected via pipelined data
+ * exchanges.
+ *
+ * @param <VID> the type of the vertex ids
+ * @param <RID> the type of the result ids
+ * @param <V> the type of the vertices
+ * @param <R> the type of the result
+ */
+public interface PipelinedRegion<VID extends VertexID, RID extends ResultID,
+ V extends Vertex<VID, RID, V, R>, R extends Result<VID, RID, V, R>> {
+
+ /**
+ * Returns vertices that are in this pipelined region.
+ *
+ * @return Iterable over all vertices in this pipelined region
+ */
+ Iterable<V> getVertices();
+
+ /**
+ * Returns the vertex with the specified vertex id.
+ *
+ * @param vertexId the vertex id used to look up the vertex
+ * @return the vertex with the specified id
+ * @throws IllegalArgumentException if there is no vertex in this
pipelined
+ * region with the specified vertex id
+ */
+ V getVertex(VID vertexId);
Review comment:
I assume the FLIP is wrong here:
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
