[jira] [Created] (FLINK-16960) Add PipelinedRegion Interface to Topology

[Shang Yuanchun (Jira)]

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)