CorcInputFormat implements InputFormat<NullWritable, Corc> { public static void setConverterFactoryClass(Configuration conf, Class<? extends ConverterFactory> converterFactoryClass) { conf.setClass(CONVERTER_FACTORY, converterFactoryClass, ConverterFactory.class); LOG.debug("Set input ConverterFactory class on conf: {}", converterFactoryClass); }  static void setConverterFactoryClass(Configuration conf,
      Class<? extends ConverterFactory> converterFactoryClass); static void setTypeInfo(Configuration conf, StructTypeInfo typeInfo); static void setSchemaTypeInfo(Configuration conf, StructTypeInfo schemaTypeInfo); static void setSearchArgument(Configuration conf, SearchArgument searchArgument); static void setSearchArgumentKryo(Configuration conf, String searchArgumentKryo); @Override InputSplit[] getSplits(JobConf conf, int numSplits); @Override RecordReader<NullWritable, Corc> getRecordReader(InputSplit inputSplit, JobConf conf, Reporter reporter); static String toKryo(SearchArgument sarg); static final String ENABLE_ROW_LEVEL_SEARCH_ARGUMENT; }
@Test public void converterFactory() { CorcInputFormat.setConverterFactoryClass(conf, DefaultConverterFactory.class); assertThat(conf.get(CorcInputFormat.CONVERTER_FACTORY), is("com.hotels.corc.DefaultConverterFactory")); }