Tushar Gosavi created APEXCORE-604:
--------------------------------------
Summary: 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.4#6332)
