I see the value. Also reviewing the PR. On Mon, Jan 16, 2017 at 7:40 PM, Tushar Gosavi <[email protected]> wrote:
> 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 <[email protected]> > 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. >
