class ConnectSchemas {

  public static ConnectSchema columnsToConnectSchema(final List<? extends SimpleColumn> columns) {
    final SqlToConnectTypeConverter converter = SchemaConverters.sqlToConnectConverter();

    final SchemaBuilder builder = SchemaBuilder.struct();
    for (final SimpleColumn column : columns) {
      final Schema colSchema = converter.toConnectSchema(column.type());
      builder.field(column.name().text(), colSchema);
    }

    return (ConnectSchema) builder.build();
  }

  private  ConnectSchemas();

}