apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pramod Immaneni <pra...@datatorrent.com>
Subject Re: Extending DAG API for accessing objects in DAG.
Date Sun, 29 Jan 2017 00:13:49 GMT
I see the value. Also reviewing the PR.

On Mon, Jan 16, 2017 at 7:40 PM, Tushar Gosavi <tushar@datatorrent.com>
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 <tushar@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.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message