public RelDataType convertToRelSchema(SqlSchema sqlSchema) {
    return convertRecordType(sqlSchema);
  }
Class that converts the {@link SqlSchema} to Calcite relational schema
samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java