[ https://issues.apache.org/jira/browse/APEXCORE-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869809#comment-15869809 ]
ASF GitHub Bot commented on APEXCORE-604: ----------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/apex-core/pull/447 > Extend DAG API to allow accessing DAG objects. > ---------------------------------------------- > > Key: APEXCORE-604 > URL: https://issues.apache.org/jira/browse/APEXCORE-604 > Project: Apache Apex Core > Issue Type: Sub-task > Reporter: Tushar Gosavi > Assignee: Tushar Gosavi > > I am planing extend the DAG api to export internals of the DAG. > Current DAG does not provide a way to get the list of operators and > streams with their attributes. Also streamMeta does not provide > API to access end ports. > This type of information is needed when external translator (like > Samoa) are constructing the DAG, > and we need to apply some transformation or configure the DAG before > it is run. Planing to extend > DAG API with following. > InputPortMeta > public Operator.InputPort<?> getPortObject(); > OutputPortMeta > public Operator.OutputPort<?> getPortObject(); > streamMeta > public <T extends OutputPortMeta> T getSource(); > public <T extends InputPortMeta> Collection<T> getSinks(); > DAG > public abstract <T extends OperatorMeta> Collection<T> getOperators(); > public abstract <T extends StreamMeta> Collection<T> getStreams(); -- This message was sent by Atlassian JIRA (v6.3.15#6346)