a generic local algorithm for mining data streams in large distributed systems