CsvBulkImportUtil { public static void configurePreUpsertProcessor(Configuration conf, Class<? extends ImportPreUpsertKeyValueProcessor> processorClass) { conf.setClass(CsvToKeyValueMapper.UPSERT_HOOK_CLASS_CONFKEY, processorClass, ImportPreUpsertKeyValueProcessor.class); }  static void initCsvImportJob(Configuration conf, String tableName, char fieldDelimiter, char quoteChar, char escapeChar,
            String arrayDelimiter,  List<ColumnInfo> columnInfoList, boolean ignoreInvalidRows); static void configurePreUpsertProcessor(Configuration conf,
            Class<? extends ImportPreUpsertKeyValueProcessor> processorClass);  }
@Test public void testConfigurePreUpsertProcessor() { Configuration conf = new Configuration(); CsvBulkImportUtil.configurePreUpsertProcessor(conf, MockProcessor.class); ImportPreUpsertKeyValueProcessor processor = CsvToKeyValueMapper.loadPreUpsertProcessor(conf); assertEquals(MockProcessor.class, processor.getClass()); }