container/src/main/java/com/streamsets/datacollector/runner/StageContext.java
@Override
  public Record cloneRecord(Record record, String sourceIdPostfix) {
    RecordImpl clonedRecord = ((RecordImpl) record).clone();
    HeaderImpl header = clonedRecord.getHeader();
    header.setSourceId(header.getSourceId() + "_" + sourceIdPostfix);
    header.setStagesPath("");
    return clonedRecord;
  }
@Override
  public Record cloneRecord(Record record, String sourceIdPostfix) {
    RecordImpl clonedRecord = ((RecordImpl) record).clone();
    HeaderImpl header = clonedRecord.getHeader();
    header.setSourceId(header.getSourceId() + "_" + sourceIdPostfix);
    header.setStagesPath("");
    return clonedRecord;
  }
@ Override public Record cloneRecord ( Record record , String sourceIdPostfix ) { RecordImpl clonedRecord = ( ( RecordImpl ) record ) . clone ( ) ; HeaderImpl header = clonedRecord . getHeader ( ) ; header . setSourceId ( header . getSourceId ( ) + "_" + sourceIdPostfix ) ; header . setStagesPath ( "" ) ; return clonedRecord ; }
Processor.Context
Processor . Context