code: def predictOnValues(self, dstream):
          
          self._validate(dstream)
          return dstream.mapValues(lambda x: self._model.predict(x))
docs: Make predictions on a keyed dstream.
          Returns a transformed dstream object.