private RelDataType convertRecordType(SqlSchema schema) {
    List<RelDataTypeField> relFields = getRelFields(schema.getFields());
    return new RelRecordType(relFields);
  }
Class that converts the {@link SqlSchema} to Calcite relational schema
samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java