code: @Override
    public void sourcePrepare(FlowProcess<? extends Configuration> flowProcess, SourceCall<Corc, RecordReader> sourceCall)
        throws IOException {
      sourceCall.setContext((Corc) sourceCall.getInput().createValue());
    }
docs: Creates an {@link Corc} instance and stores it in the context to be reused for all rows.