container/src/main/java/com/streamsets/datacollector/runner/FullPipeBatch.java
private List<Record> intercept(List<Record> records, List<? extends Interceptor> interceptors) throws StageException {
    for(Interceptor interceptor : interceptors)  {
      records = interceptor.intercept(records);
    }

    return records;
  }
private List<Record> intercept(List<Record> records, List<? extends Interceptor> interceptors) throws StageException {
    for(Interceptor interceptor : interceptors)  {
      records = interceptor.intercept(records);
    }

    return records;
  }
private List < Record > intercept ( List < Record > records , List < ? extends Interceptor > interceptors ) throws StageException { for ( Interceptor interceptor : interceptors ) { records = interceptor . intercept ( records ) ; } return records ; }
Intercept given records with all the interceptors.

We're not cloning records during interception as we aim at changing their original form.
Intercept given records with all the interceptors .