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);
  }
@ Override public RecordReader createRecordReader ( InputStream inputStream , long initialPosition , int maxObjectLen ) throws IOException { return RecordWriterReaderFactory . createRecordReader ( inputStream , initialPosition , maxObjectLen ) ; }
ContextExtensions
ContextExtensions