@Test
public void testBuildTypeInformationForSiddhiStream() {

    String query = "define stream inputStream (timestamp long, name string, value double);"
        + "from inputStream select name, value insert into outputStream;";
    TypeInformation<Tuple3<Long, String, Double>> inputStreamType = SiddhiTypeFactory.getTupleTypeInformation(query, "inputStream");
    TypeInformation<Tuple2<String, Double>> outputStreamType = SiddhiTypeFactory.getTupleTypeInformation(query, "outputStream");
    Assert.assertNotNull(inputStreamType);
    Assert.assertNotNull(outputStreamType);
}