CorcInputFormat implements InputFormat<NullWritable, Corc> { static Filter getFilter(Configuration conf, StructTypeInfo typeInfo) { if (conf.getBoolean(ENABLE_ROW_LEVEL_SEARCH_ARGUMENT, true)) { SearchArgument searchArgument = getSearchArgument(conf); if (searchArgument != null) { return new SearchArgumentFilter(searchArgument, typeInfo); } } return Filter.ACCEPT; }  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 getFilterNoSearchArgument() { StructTypeInfo typeInfo = new StructTypeInfoBuilder().add("a", TypeInfoFactory.stringTypeInfo).build(); assertThat(CorcInputFormat.getFilter(conf, typeInfo), is(Filter.ACCEPT)); }