Destroy StreamExecutionEnv

[jay vyas]

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