container/src/main/java/com/streamsets/datacollector/runner/ProtoContext.java
@Override
  public RecordReader createRecordReader(
      InputStream inputStream,
      long initialPosition,
      int maxObjectLen
  ) throws IOException {
    return RecordWriterReaderFactory.createRecordReader(inputStream, initialPosition, maxObjectLen);
  }
@Override
  public RecordReader createRecordReader(
      InputStream inputStream,
      long initialPosition,
      int maxObjectLen
  ) throws IOException {
    return RecordWriterReaderFactory.createRecordReader(inputStream, initialPosition, maxObjectLen);
  }
ContextExtensions