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.
