SchemaUtils { static Schema toBeamSchema(List<FieldSchema> fields) { return fields.stream().map(SchemaUtils::toBeamField).collect(toSchema()); }    }
@Test public void testParameterizedTypesToBeamTypes() { List<FieldSchema> listOfFieldSchema = new ArrayList<>(); listOfFieldSchema.add(new FieldSchema("parameterizedChar", "char(10)", null)); listOfFieldSchema.add(new FieldSchema("parameterizedVarchar", "varchar(100)", null)); listOfFieldSchema.add(new FieldSchema("parameterizedDecimal", "decimal(30,16)", null)); Schema expectedSchema = Schema.builder() .addNullableField("parameterizedChar", Schema.FieldType.STRING) .addNullableField("parameterizedVarchar", Schema.FieldType.STRING) .addNullableField("parameterizedDecimal", Schema.FieldType.DECIMAL) .build(); Schema actualSchema = SchemaUtils.toBeamSchema(listOfFieldSchema); Assert.assertEquals(expectedSchema, actualSchema); }