container/src/main/java/com/streamsets/datacollector/runner/StageContext.java
@Override
  public Record createRecord(Record originatorRecord, String sourceIdPostfix) {
    Preconditions.checkNotNull(originatorRecord, "originatorRecord cannot be null");
    RecordImpl record = new RecordImpl(stageInfo.getInstanceName(), originatorRecord, null, null);
    HeaderImpl header = record.getHeader();
    header.setSourceId(header.getSourceId() + "_" + sourceIdPostfix);
    header.setStagesPath("");
    return record;
  }
@Override
  public Record createRecord(Record originatorRecord, String sourceIdPostfix) {
    Preconditions.checkNotNull(originatorRecord, "originatorRecord cannot be null");
    RecordImpl record = new RecordImpl(stageInfo.getInstanceName(), originatorRecord, null, null);
    HeaderImpl header = record.getHeader();
    header.setSourceId(header.getSourceId() + "_" + sourceIdPostfix);
    header.setStagesPath("");
    return record;
  }
@ Override public Record createRecord ( Record originatorRecord , String sourceIdPostfix ) { Preconditions . checkNotNull ( originatorRecord , "originatorRecord cannot be null" ) ; RecordImpl record = new RecordImpl ( stageInfo . getInstanceName ( ) , originatorRecord , null , null ) ; HeaderImpl header = record . getHeader ( ) ; header . setSourceId ( header . getSourceId ( ) + "_" + sourceIdPostfix ) ; header . setStagesPath ( "" ) ; return record ; }
Processor.Context
Processor . Context