simple match expression

SimpleCEP.java

// define a simple pattern and condition to detecto from data stream
Pattern<Sensor,?> highTempPattern = Pattern.<Sensor>begin("first").where(new SimpleCondition<Sensor>() {
	@Override
	public boolean filter(Sensor sensor) throws Exception {
		return sensor.getTemperature() > 60;
	}
});
// get resulted data stream from input data stream based on the defined CEP pattern
DataStream<Sensor> result = CEP.pattern(inputStream.keyBy(new KeySelector<Sensor, Integer>() {
	@Override
	public Integer getKey(Sensor sensor) throws Exception {
		return sensor.getDeviceId();
	}
}), highTempPattern).process(new PatternProcessFunction<Sensor, Sensor>() {
	@Override
	public void processMatch(Map<String, List<Sensor>> map, Context context, Collector<Sensor> collector) throws Exception {
		collector.collect(map.get("first").get(0));
	}
});