Interrogazione di Hazelcast in oggetti personalizzati

Question

Sto utilizzando Hazelcast come mappa condivisa nella mia applicazione. La mia mappa è così:

Map<String, MyObject> 

e MyObject:

class MyObject implements Serializeble { 
    // Map FieldName -> FieldValue 
    Map<String, Object> myMap; 
} 

Così mi piacerebbe usare Hazelcast distributed query supporto per interrogare nel mio oggetto. Ho controllato che Hazelcast utilizza il metodo di ottenere per recuperare il valore dell'oggetto, ma nel mio caso non ho un GET, invece di mi piacerebbe implementare il mio getField come:

Object getField(String fieldName) { 
    return myMap[fieldName]; 
} 

e la forza Hazelcast chiamare questo metodo Per aggirare il problema, Ho messo il codice Hazelcast di utilizzare una CustomGetter nella classe

/hazelcast/src/main/java/com/hazelcast/query/impl/ReflectionHelper.java 

linea 144:

if (localGetter == null) { 
    localGetter = new CustomFieldGetter(name, obj); 
} 

e qui il mio CustomFieldGetter classe:

static class CustomFieldGetter extends Getter { 
    final Object value; 
    final Class type; 
    final String fieldName; 

    CustomFieldGetter(String fieldName, Object obj) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException { 
     super(null); 
     this.fieldName = fieldName; 
     this.value = obj.getClass().getMethod("getField", String.class).invoke(obj, fieldName); 
     this.type = value.getClass(); 
    } 

    @Override 
    Object getValue(Object obj) throws Exception { 
     return value; 
    } 

    @Override 
    Class getReturnType() { 
     return type; 
    } 

    @Override 
    boolean isCacheable() { 
     return false; 
    } 

    @Override 
    public String toString() { 
     return "FieldGetter [parent=" + parent + ", field=" + fieldName + "]"; 
    } 
} 

Ok fresco, Dopo la ricompilazione di Hazelcast e l'utilizzo di questo nuovo jar, sono riuscito a raggiungere le query utilizzando sql semplice. Ma per pagingQueries ho avuto alcuni errori.

Quindi la mia ultima domanda è: Mi piacerebbe evitare di modificare il codice Hazelcast (per ulteriori aggiornamenti). Hazelcast ha alcuni supporti su questo problema? C'è qualche altra soluzione per questo problema?

PS: Sto utilizzando la versione Hazelcast ->Hazelcast-3.3-RC3

Grazie in anticipo.

Answer 1

Un'opzione è quella di implementare l'interfaccia Portable. Quindi è possibile scrivere ciascuna voce come un campo separato. Ciò presuppone che il valore di ingresso implementa anche l'interfaccia portatile.

Guarda sample code come utilizzare Portable.