<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def predictOnValues(self, dstream):
 """ Make predictions on a keyed dstream. Returns a transformed dstream object. """

        self._validate(dstream)
        return dstream.mapValues(lambda x: self._model.predict(x))