mapreduce, hbase et scan

Question

J'ai un travail MapReduce qui étend la classe TableMapper. J'utilise TableMapperReduceUtil initTableMapperJob pour configurer l'analyse initiale qui fonctionne correctement. Basé sur la touche de ligne récupérée de l'analyse, je veux exécuter un Get (en utilisant une clé de ligne qui est une valeur dans la ligne d'analyse initiale) sur la même table dans ma méthode MapReduce Map. Comment accéder à la connexion Hbase à la même table à partir de la méthode Map?

Answer 1

Probablement vous pouvez créer une nouvelle connexion de cette manière:

Configuration config = context.getConfiguration(); 
Connection conn = ConnectionFactory.createConnection(config); 

Mais je pense que dans votre cas, il sera plus facile à utiliser Spark on HBase