public Set < String > getComponentStreams ( String componentId ) { if ( outputs . containsKey ( componentId ) ) { Set < String > streams = new HashSet <> ( ) ; List < TopologyAPI . OutputStream > olist = outputs . get ( componentId ) ; for ( TopologyAPI . OutputStream ostream : olist ) { streams . add ( ostream . getStream ( ) . getId ( ) ) ; } return streams ; } else { return null ; } }
Gets the set of streams declared for the specified component .