public ComponentBuilder findComponentBuilder(final AnalysisJobBuilder analysisJobBuilder) {
        if (analysisJobBuilder == _rootJobBuilder) {
            return null;
        }
        for (final ComponentBuilder osComponenBuilder : getComponentBuildersWithOutputDataStreams(_rootJobBuilder)) {
            for (final OutputDataStream outputDataStream : osComponenBuilder.getOutputDataStreams()) {
                final AnalysisJobBuilder osJobBuilder =
                        osComponenBuilder.getOutputDataStreamJobBuilder(outputDataStream);
                if (osJobBuilder == analysisJobBuilder) {
                    return osComponenBuilder;
                }
            }
        }

        throw new IllegalArgumentException(
                "No component publishing to " + LabelUtils.getScopeLabel(analysisJobBuilder));
    }
public ComponentBuilder findComponentBuilder ( final AnalysisJobBuilder analysisJobBuilder ) { if ( analysisJobBuilder == _rootJobBuilder ) { return null ; } for ( final ComponentBuilder osComponenBuilder : getComponentBuildersWithOutputDataStreams ( _rootJobBuilder ) ) { for ( final OutputDataStream outputDataStream : osComponenBuilder . getOutputDataStreams ( ) ) { final AnalysisJobBuilder osJobBuilder = osComponenBuilder . getOutputDataStreamJobBuilder ( outputDataStream ) ; if ( osJobBuilder == analysisJobBuilder ) { return osComponenBuilder ; } } } throw new IllegalArgumentException ( "No component publishing to " + LabelUtils . getScopeLabel ( analysisJobBuilder ) ) ; }
Will find the {@link ComponentBuilder} that publishes records (via an
{@link OutputDataStream}) to a certain {@link AnalysisJobBuilder}.

@param analysisJobBuilder
the {@link AnalysisJobBuilder} to find the publisher for.
@return