@Override
  public SamzaRelConverter create(SystemStream systemStream, RelSchemaProvider relSchemaProvider, Config config) {
    return new JsonRelConverter();
  }
SamzaRelConverter that can convert {@link SamzaSqlRelMessage} to json string byte array.
samza-tools/src/main/java/org/apache/samza/tools/json/JsonRelConverterFactory.java