Używam Apache Spark (Pyspark API for Python) ALS MLLIB do opracowania usługi, która wykonuje żywych rekomendacji dla użytkowników anonimowych (użytkownicy nieuczestniczący w szkoleniu zestaw) w mojej witrynie. W moim usecase trenuję model o oceny użytkowników w ten sposób:Apache Spark ALS - jak wykonać Live Zalecenia/fold anonimowy użytkownik
from pyspark.mllib.recommendation import ALS, MatrixFactorizationModel, Rating
ratings = df.map(lambda l: Rating(int(l[0]), int(l[1]), float(l[2])))
rank = 10
numIterations = 10
model = ALS.trainImplicit(ratings, rank, numIterations)
Teraz, za każdym razem użytkownik anonim wybierze element w katalogu, chcę składany w jej wektora w model ALS i uzyskaj rekomendacje (podobnie jak wywołanie recommendProducts()), ale unikaj ponownego szkolenia całego modelu.
Czy istnieje sposób na łatwe zrobienie złożenia nowego wektora użytkownika anonimowego po przeszkoleniu modelu ALS w Apache Spark?
góry dzięki
Aby wyjaśnić sprawę: czy chcesz po prostu uruchomić swój model na zestawie testowym, czy też chcesz mieć jakiś rodzaj rozwiązania "służącego modelowi" do zasilania strony internetowej w czasie rzeczywistym? –
Zdecydowanie chcę, aby rozwiązanie "modelująca" służyło do zasilania strony internetowej w czasie rzeczywistym! –
Oznaczam to pytanie jako duplikat, mam nadzieję, że będzie on miał więcej ekspozycji dzięki połączeniu: http://stackoverflow.com/questions/30509335/how-to-update-spark-matrixfactorizationmodel-forals –