NullPointerException dans Custom Dstinct Mapper

Question

J'utilise Hazelcast 3.6.1 et implémente des fonctionnalités agrégées distinctes en utilisant mapreduce personnalisé pour obtenir des résultats de type facette.

public class DistinctMapper implements Mapper<String, Employee, String, Long>{ 

    private transient SimpleEntry<String, Employee> entry = new SimpleEntry<String, Employee>(); 

    private static final Long ONE = Long.valueOf(1L); 

    private Supplier<String, Employee, String> supplier; 

    public DistinctMapper(Supplier<String, Employee, String> supplier) { 
     this.supplier = supplier; 
    } 

    @Override 
    public void map(String key, Employee value, Context<String, Long> context) { 
     System.out.println("Object "+ entry + " and key "+key); 
     entry.setKey(key); 
     entry.setValue(value); 
     String fieldValue = (String) supplier.apply(entry); 
     //getValue(value, fieldName); 
     if (null != fieldValue){ 
      context.emit(fieldValue, ONE); 
     } 
    } 
} 

et mapper échoue avec NullPointerException. et l'instruction sysout indique que l'objet d'entrée est null.

SimpleEntry: https://github.com/hazelcast/hazelcast/blob/v3.7-EA/hazelcast/src/main/java/com/hazelcast/mapreduce/aggregation/impl/SimpleEntry.java

Pouvez-vous me rappeler la question dans le code ci-dessus? Merci.

Answer 1

entry champ est transitoire. Cela signifie qu'il n'est pas sérialisé, donc lorsque l'objet DistinctMapper est désérialisé sur un noeud hazecalst, sa valeur est null. Suppression du transitoire résoudra le NullPointerException.

Sur la note de côté: Pourquoi avez-vous besoin de ce champ de saisie? Cela ne semble pas avoir d'utilité.