@Override
  public Schema getSourceSchema() {
    return sourceSchema;
  }
@Test
  public void properlyFormattedNestedSchemaTest() throws IOException {
    this.schemaProvider = new FilebasedSchemaProvider(
        Helpers.setupSchemaOnDFS("streamer-config", "file_schema_provider_valid.avsc"), jsc);
    assertEquals(this.schemaProvider.getSourceSchema(), generateProperFormattedSchema());
  }