@Override
  public Schema convertSchema(SI inputSchema, WorkUnitState workUnit) throws SchemaConversionException {
    Preconditions.checkArgument(workUnit.contains(ConfigurationKeys.CONVERTER_AVRO_SCHEMA_KEY));
    this.schema = new Schema.Parser().parse(workUnit.getProp(ConfigurationKeys.CONVERTER_AVRO_SCHEMA_KEY));
    return this.schema;
  }
@ Override public Schema convertSchema ( SI inputSchema , WorkUnitState workUnit ) throws SchemaConversionException { Preconditions . checkArgument ( workUnit . contains ( ConfigurationKeys . CONVERTER_AVRO_SCHEMA_KEY ) ) ; this . schema = new Schema . Parser ( ) . parse ( workUnit . getProp ( ConfigurationKeys . CONVERTER_AVRO_SCHEMA_KEY ) ) ; return this . schema ; }
Ignore input schema and parse in Avro schema from config