How does this interface with IndependentPipeline, given that a single input at a time is given to the extractor