@Test public void testRemoveFields() throws IllegalArgumentException, IOException { Schema convertedSchema1 = convertSchema("/converter/recursive_schema_1.avsc", "YwchQiH.OjuzrLOtmqLW"); Schema expectedSchema1 = parseSchema("/converter/recursive_schema_1_converted.avsc"); Assert.assertEquals(convertedSchema1, expectedSchema1); Schema convertedSchema2 = convertSchema("/converter/recursive_schema_2.avsc", "FBuKC.wIINqII.lvaerUEKxBQUWg,eFQjDj.TzuYZajb"); Schema expectedSchema2 = parseSchema("/converter/recursive_schema_2_converted.avsc"); Assert.assertEquals(convertedSchema2, expectedSchema2); Schema convertedSchema3 = convertSchema("/converter/recursive_schema_2.avsc", "field.that.does.not.exist"); Schema expectedSchema3 = parseSchema("/converter/recursive_schema_2_not_converted.avsc"); Assert.assertEquals(convertedSchema3, expectedSchema3); }
public Schema removeFields(Schema schema) { return removeFields(schema, Maps.<String, Schema> newHashMap()); }
AvroSchemaFieldRemover { public Schema removeFields(Schema schema) { return removeFields(schema, Maps.<String, Schema> newHashMap()); } }
AvroSchemaFieldRemover { public Schema removeFields(Schema schema) { return removeFields(schema, Maps.<String, Schema> newHashMap()); } AvroSchemaFieldRemover(String fieldNames); private  AvroSchemaFieldRemover(); }
AvroSchemaFieldRemover { public Schema removeFields(Schema schema) { return removeFields(schema, Maps.<String, Schema> newHashMap()); } AvroSchemaFieldRemover(String fieldNames); private  AvroSchemaFieldRemover(); Schema removeFields(Schema schema); }
AvroSchemaFieldRemover { public Schema removeFields(Schema schema) { return removeFields(schema, Maps.<String, Schema> newHashMap()); } AvroSchemaFieldRemover(String fieldNames); private  AvroSchemaFieldRemover(); Schema removeFields(Schema schema);  }