Transform a mysql into a CEP stream