@Test
public void testRowType() {

    Row row = Row.of(1, "test", 56.7, CURRENT);
    StreamSchema<Row> schema = new StreamSchema<>(new RowTypeInfo(
            TypeExtractor.createTypeInfo(Integer.class),
            TypeExtractor.createTypeInfo(String.class),
            TypeExtractor.createTypeInfo(Double.class),
            TypeExtractor.createTypeInfo(Long.class)
    ), "id", "name", "price", "timestamp");
    StreamSerializer<Row> reader = new StreamSerializer<>(schema);
    Assert.assertArrayEquals(new Object[]{1, "test", 56.7, CURRENT}, reader.getRow(row));
}