@Test
public void testTupleType() {

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