container/src/main/java/com/streamsets/datacollector/runner/SourcePipe.java
public void prepareBatchContext(BatchContextImpl batchContext) {
    PipeBatch pipeBatch = batchContext.getPipeBatch();

    // Start stage in the pipe batch and persist reference to batch maker in the batch context
    BatchMakerImpl batchMaker = pipeBatch.startStage(this);
    batchContext.setBatchMaker(batchMaker);

    batchContext.setOriginStageName(
      getStage().getInfo().getInstanceName(),
      getStage().getInfo().getLabel()
    );
  }
public void prepareBatchContext(BatchContextImpl batchContext) {
    PipeBatch pipeBatch = batchContext.getPipeBatch();

    // Start stage in the pipe batch and persist reference to batch maker in the batch context
    BatchMakerImpl batchMaker = pipeBatch.startStage(this);
    batchContext.setBatchMaker(batchMaker);

    batchContext.setOriginStageName(
      getStage().getInfo().getInstanceName(),
      getStage().getInfo().getLabel()
    );
  }
public void prepareBatchContext ( BatchContextImpl batchContext ) { PipeBatch pipeBatch = batchContext . getPipeBatch ( ) ; // Start stage in the pipe batch and persist reference to batch maker in the batch context BatchMakerImpl batchMaker = pipeBatch . startStage ( this ) ; batchContext . setBatchMaker ( batchMaker ) ; batchContext . setOriginStageName ( getStage ( ) . getInfo ( ) . getInstanceName ( ) , getStage ( ) . getInfo ( ) . getLabel ( ) ) ; }
Called by PipelineRunner when push origin started a new batch to prepare context for it.

@param batchContext BatchContext associated with the starting batch.
Called by PipelineRunner when push origin started a new batch to prepare context for it .