PredictionIO - un moteur et plusieurs algorithmes

Question

Je suis coincé avec un moteur et plusieurs algorithmes et j'ai besoin d'aide.

J'ai un moteur et 2 algorithmes, appelons AL1 et AL2. Dans src/main/scala ayant 2 fichiers scala d'algorithme, nom AL1Algorithm.scala et AL2Algorithm.scala chaque algorithme a son propre param et modèle (AL1AlgorithmParams et AL1Model pour AL1 et AL2AlgorithmParams et AL2Model pour AL2). Il y a donc 2 fonctions de train et 2 fonctions de prédiction.

Je peux former 2 algorithmes en appelant pio train. Quand j'appelle send_query à tester, le programme retourne toujours le résultat de l'algorithme je mets sur le haut du fichier engine.json

Par exemple, si je mets AL1Algorithm sur le dessus, send_query se déroulera AL1Algorithm

"algorithms": [ 
    { 
     "name": "AL1Algorithm", 
     "params": { 
     "n": 100 
     } 
    }, 
    { 
     "name": "AL2Algorithm", 
     "params": { 
     "n": 100 
     } 
    } 

si je mets AL2Algorithm sur le dessus, send_query sera exécuté AL2Algorithm »

"algorithms": [ 
    { 
     "name": "AL2Algorithm", 
     "params": { 
     "n": 100 
     } 
    }, 
    { 
     "name": "AL1Algorithm", 
     "params": { 
     "n": 100 
     } 
    } 

Ma question est, puis-je appeler 2 algorithmes pour un send_query, comment distinguer l'algorithme devrait être appelé à send_query au lieu de engine.json. Il y a quelque chose de bizarre ici, je pense qu'il y a des problèmes avec ma configuration. Will Serving.scala produira les résultats de 2 algorithmes en même temps. Puis-je partager les résultats de chaque algorithme dans le service.

Merci beaucoup

Answer 1

Vous devez également modifier la fonction servir() Dans Serving.scala. la fonction serve() a 2 arguments. voir ci-dessous

def serve(query: Query, 
    predictedResults: Seq[PredictedResult]): PredictedResult 

La requête est envoyée aux deux algorithmes, et le PredictedResult retourné par les deux algorithmes sont passés à serve() fonction Seq[PredictedResult]. L'ordre Seq[] est identique à l'ordre de l'algorithme défini dans engine.json. Vous devez modifier ceci pour utiliser toutes les sorties PredictedResult par algorithme. Certains des exemples de modèles ne prennent par défaut que le 1er résultat (predictedResults.head)

Veuillez également voir "Étape 4. Modifier le service pour combiner plusieurs sorties d'algorithmes" dans this doc comme exemple.