I have opened https://issues.apache.org/jira/browse/APEXCORE-604 for this. If there is no objection I will open an pull request for it.
- Tushar. On Mon, Jan 9, 2017 at 4:44 PM, Tushar Gosavi <tus...@datatorrent.com> wrote: > Hi All, > > 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(); > > Regards, > - Tushar.
