Continuous Queries over Data Streams - Semantics and Implementation