public static SqlToConnectTypeConverter sqlToConnectConverter() {
    return SQL_TO_CONNECT_CONVERTER;
  }
@Test
  public void shouldConvertGeneralizedUnionTypeFromSqlToConnect() {
    // Given:
    SqlStruct sqlStruct = SqlStruct.builder()
        .field("connect_union_field_0", SqlPrimitiveType.of(SqlBaseType.STRING))
        .field("connect_union_field_1", SqlPrimitiveType.of(SqlBaseType.BOOLEAN))
        .field("connect_union_field_2", SqlPrimitiveType.of(SqlBaseType.INTEGER))
        .build();

    // When:
    Schema connectSchema = sqlToConnectConverter().toConnectSchema(sqlStruct);

    // Then:
    assertThat(connectSchema.type(), is(Schema.Type.STRUCT));
    assertFalse(connectSchema.schema().parameters().isEmpty());
    assertTrue(connectSchema.schema().parameters().containsKey(JsonSchemaData.GENERALIZED_TYPE_UNION));
  }