brewery_example.java

String sql = "INSERT INTO sinkTopic "
                + "SELECT sensor, "
                + "TUMBLE_START(ts, INTERVAL '1' MINUTE) as tumbleStart, "
                + "TUMBLE_END(ts, INTERVAL '1' MINUTE) as tumbleEnd, "
                + "AVG(temp) AS avgTemp "
                + "FROM sourceTopic "
                + "WHERE sensor IS NOT null "
                + "GROUP BY TUMBLE(ts, INTERVAL '1' MINUTE), sensor";

        tableEnv.sqlUpdate(sql);