Utilisation du cache distribué dans LoadFunc dans Apache Pig

Question

Comment puis-je utiliser le cache distribué dans la fonction de chargement de données personnalisées sur laquelle j'implémente LoadFunc UDF? Dans le EvalFunc UDF, il fournit une méthode getCacheFiles().

Answer 1

Découvrez this. Vous pouvez également transmettre un fichier à ajouter au cache via le constructeur et le définir dans la méthode setLocation. Là vous avez accès à l'objet Job.