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;
  }
Intercept given records with all the interceptors.

We're not cloning records during interception as we aim at changing their original form.