@Test
public void testAtomicType() {

    StreamSchema<String> schema = new StreamSchema<>(TypeExtractor.createTypeInfo(String.class),
            "word");
    StreamSerializer<String> reader = new StreamSerializer<>(schema);
    Assert.assertArrayEquals(new Object[]{"Siddhi"}, reader.getRow("Siddhi"));
}