final.java

finalCond.java

.followedBy("End").where(new IterativeCondition<Tuple2<String, Integer>>() {
            @Override
            public boolean filter(Tuple2<String, Integer> stringIntegerTuple2, Context<Tuple2<String, Integer>> context) throws Exception {
                List<Tuple2<String,Integer>> s = Lists.newArrayList(context.getEventsForPattern("End"));
                int i = s.size();
                int value = stringIntegerTuple2.getField(1);
                int prevValue = s.get(i-1).getField(1);
                return value>prevValue;
            }
        });