OrcRowInputFormat extends FileInputFormat<Row> implements ResultTypeQueryable<Row> { public void addPredicate(Predicate predicate) { validatePredicate(predicate); this.conjunctPredicates.add(predicate); } OrcRowInputFormat(String path, String schemaString, Configuration orcConfig);  OrcRowInputFormat(String path, String schemaString, Configuration orcConfig, int batchSize);  OrcRowInputFormat(String path, TypeDescription orcSchema, Configuration orcConfig, int batchSize); void addPredicate(Predicate predicate); void selectFields(int... selectedFields); @Override void openInputFormat(); @Override void open(FileInputSplit fileSplit); @Override void close(); @Override void closeInputFormat(); @Override boolean reachedEnd(); @Override Row nextRecord(Row reuse); @Override TypeInformation<Row> getProducedType();  }
@Test(expected = IllegalArgumentException.class) public void testPredicateWithInvalidColumn() throws Exception { rowOrcInputFormat = new OrcRowInputFormat(getPath(TEST_FILE_NESTED), TEST_SCHEMA_NESTED, new Configuration()); rowOrcInputFormat.addPredicate( new OrcRowInputFormat.Equals("unknown", PredicateLeaf.Type.LONG, 42)); }