@Override
  public void sinkPrepare(FlowProcess<? extends Configuration> flowProcess, SinkCall<Corc, OutputCollector> sinkCall)
      throws IOException {
    sinkCall.setContext(new Corc(typeInfo, converterFactory));
  }
@ Override public void sinkPrepare ( FlowProcess < ? extends Configuration > flowProcess , SinkCall < Corc , OutputCollector > sinkCall ) throws IOException { sinkCall . setContext ( new Corc ( typeInfo , converterFactory ) ) ; }
Creates an {@link Corc} instance and stores it in the context to be reused for all rows.