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))
def predictOnValues ( self , dstream ) : self . _validate ( dstream ) return dstream . mapValues ( lambda x : self . _model . predict ( x ) )
Make predictions on a keyed dstream.
        Returns a transformed dstream object.