@Override
  public Schema getSourceSchema() {
    return sourceSchema;
  }
@Test
  public void renameBadlyFormattedSchemaWithAltCharMaskConfiguredTest() throws IOException {
    TypedProperties props = Helpers.setupSchemaOnDFS("streamer-config", "file_schema_provider_invalid.avsc");
    props.put(SANITIZE_SCHEMA_FIELD_NAMES.key(), "true");
    props.put(SCHEMA_FIELD_NAME_INVALID_CHAR_MASK.key(), "_");
    this.schemaProvider = new FilebasedSchemaProvider(props, jsc);
    assertEquals(this.schemaProvider.getSourceSchema(), generateRenamedSchemaWithConfiguredReplacement());
  }