flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jay vyas <jayunit100.apa...@gmail.com>
Subject Destroy StreamExecutionEnv
Date Sun, 04 Oct 2015 22:15:32 GMT
Hi folks.

How do we end a stream execution environment?

I have a unit test which runs a streaming job, and want the unit test to
die after the first round of output is processed...


DataStream<Tuple2<Map, Integer>> counts =
    dataStream.map(
        new MapFunction<String, Tuple2<Map, Integer>>() {
          @Override
          public Tuple2<Map, Integer> map(String s) throws Exception {
            Map transaction = MAPPER.readValue(s, Map.class);
            return new Tuple2<>(transaction, 1);
          }
        });
counts.print();



-- 
jay vyas

Mime
View raw message