@Override
  public RelSchemaProvider create(SystemStream systemStream, Config config) {
    return new FileSystemAvroRelSchemaProvider(systemStream, config);
  }
Relational schemas provider which reads system schema from a given directory
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/FileSystemAvroRelSchemaProviderFactory.java