@Override
  public void sinkConfInit(FlowProcess<? extends Configuration> flowProcess,
      Tap<Configuration, RecordReader, OutputCollector> tap, Configuration conf) {
    conf.setBoolean("mapred.mapper.new-api", false);
    conf.setClass("mapred.output.format.class", CorcOutputFormat.class, OutputFormat.class);
    conf.setClass("mapreduce.job.output.key.class", NullWritable.class, Writable.class);
    conf.setClass("mapreduce.job.output.value.class", Corc.class, Writable.class);
  }
@ Override public void sinkConfInit ( FlowProcess < ? extends Configuration > flowProcess , Tap < Configuration , RecordReader , OutputCollector > tap , Configuration conf ) { conf . setBoolean ( "mapred.mapper.new-api" , false ) ; conf . setClass ( "mapred.output.format.class" , CorcOutputFormat . class , OutputFormat . class ) ; conf . setClass ( "mapreduce.job.output.key.class" , NullWritable . class , Writable . class ) ; conf . setClass ( "mapreduce.job.output.value.class" , Corc . class , Writable . class ) ; }
Sets the {@link OutputFormat} to {@link CorcOutputFormat}, sets the key and values to {@link NullWritable} and
{@link Corc} respectively.