[FLINK-16960] Add PipelinedRegion Interface to Topology

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Gary Yao
• Reporter: Gary Yao
• Created: 03/Apr/20 07:49
• Updated: 14/Apr/20 17:30
• Resolved: 14/Apr/20 17:30

Description

interface Topology {
...
  Iterable<PipelinedRegion> getAllPipelinedRegions();

  PipelinedRegion getPipelinedRegionOfVertex(VID vertexId);
...
}

interface PipelinedRegion {
  Iterable<V> getVertices();

  V getVertex(VID vertexId);

  Iterable<R> getConsumedResults();
}

 

Issue Links

• links to: GitHub Pull Request #11647