private static String getSystemStreamName(RelNode relNode) {
    return relNode.getTable().getQualifiedName().stream().map(Object::toString).collect(Collectors.joining("."));
  }
Class representing the Samza SQL application config
samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java