Gary Yao created FLINK-16960: -------------------------------- Summary: Add PipelinedRegion Interface to Topology Key: FLINK-16960 URL: https://issues.apache.org/jira/browse/FLINK-16960 Project: Flink Issue Type: Sub-task Reporter: Gary Yao Assignee: Gary Yao
{code} interface Topology { ... Iterable<PipelinedRegion> getAllPipelinedRegions(); PipelinedRegion getPipelinedRegionOfVertex(VID vertexId); ... } interface PipelinedRegion { Iterable<V> getVertices(); Iterable<V> getVertex(VID vertexId); Iterable<R> getConsumedResults(); } {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)