You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/04/06 12:03:07 UTC
[GitHub] [flink] GJL commented on a change in pull request #11647:
[FLINK-16960][runtime] Add PipelinedRegion interface
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:
users@infra.apache.org
With regards,
Apache Git Services