code: 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));
      }
docs: 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