public List<AnalysisJobBuilder> getConsumedOutputDataStreamsJobBuilders() {
        final List<AnalysisJobBuilder> consumedOutputDataStreamJobBuilders = new ArrayList<>();
        for (final ComponentBuilder builder : getComponentBuilders()) {
            for (final OutputDataStream outputDataStream : builder.getOutputDataStreams()) {
                if (builder.isOutputDataStreamConsumed(outputDataStream)) {
                    consumedOutputDataStreamJobBuilders.add(builder.getOutputDataStreamJobBuilder(outputDataStream));
                }
            }
        }
        return consumedOutputDataStreamJobBuilders;
    }
public List < AnalysisJobBuilder > getConsumedOutputDataStreamsJobBuilders ( ) { final List < AnalysisJobBuilder > consumedOutputDataStreamJobBuilders = new ArrayList < > ( ) ; for ( final ComponentBuilder builder : getComponentBuilders ( ) ) { for ( final OutputDataStream outputDataStream : builder . getOutputDataStreams ( ) ) { if ( builder . isOutputDataStreamConsumed ( outputDataStream ) ) { consumedOutputDataStreamJobBuilders . add ( builder . getOutputDataStreamJobBuilder ( outputDataStream ) ) ; } } } return consumedOutputDataStreamJobBuilders ; }
This gets all job builders from consumed {@link OutputDataStream}s. This
only pertains to immediate children.