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()
    );
  }
Called by PipelineRunner when push origin started a new batch to prepare context for it.

@param batchContext BatchContext associated with the starting batch.