Hazelcast谓词SQL到映射

Question

我正在尝试构建一个方法，删除具有非空属性的条目，但我一直在谓词中失败，我不知道如何正确实现谓词，因为hazelcast没有将“Not NULL”或“IS NULL”作为where子句任何想法如何在映射中找到我需要搜索以删除它们的值？

方法

public int removeEntry(String CacheName, String claveReq, int id_interno_pe, String cod_nrbe_en, int num_sec_ac) {
    
    int counter = 0;
    IMap<String, ResponseSerializablePlus> map = clientInstance.getMap(CacheName);
    
    
//      Predicate claveReqQuery = Predicates.equal("claveReq", claveReq);
//      Predicate idInternoQuery = Predicates.equal("id_interno_pe", id_interno_pe);
//      Predicate codNrbeQuery = Predicates.equal("cod_nrbe_en", cod_nrbe_en);
//      Predicate numSecQuery = Predicates.equal("num_sec_ac", num_sec_ac);
//      Predicate query = Predicates.and(idInternoQuery,codNrbeQuery,numSecQuery);
    
    Predicate query = Predicates.sql("id_interno_pe IS NOT NULL"); 
    
    
    if (!map.isEmpty()) {
        for (ResponseSerializablePlus entry : map.values(query)) {
            System.out.println("Entry "+entry.toString()+" Found");
            map.delete(entry);
            
            counter++;
            
        }
        System.out.println("Map Size ->"+map.size());
        System.out.println("Deleted entries -> "+counter);
        return counter;
    }else {
        System.out.println("No matches");
        return 0;
    }
    }

主类响应SerializablePlus

public class ResponseSerializablePlus implements IdentifiedDataSerializable{

private int id_interno_pe;
private String cod_nrbe_en;
private int num_sec_ac;
private int statusCode;
private HashMap<String,List<String>> headers;
private byte[] content;
public ResponseSerializablePlus(int id_interno_pe, String cod_nrbe_en, int num_sec_ac, int statusCode,
        HashMap<String, List<String>> headers, byte[] content) {
    this.id_interno_pe = id_interno_pe;
    this.cod_nrbe_en = cod_nrbe_en;
    this.num_sec_ac = num_sec_ac;
    this.statusCode = statusCode;
    this.headers = headers;
    this.content = content;
}
public ResponseSerializablePlus() {
}
public void writeData(ObjectDataOutput out) throws IOException {
    out.writeInt(id_interno_pe);
    out.writeString(cod_nrbe_en);
    out.writeInt(num_sec_ac);
    out.writeInt(statusCode);
    out.writeObject(headers);
    out.writeByteArray(content);
    
}
public void readData(ObjectDataInput in) throws IOException {
    this.id_interno_pe = in.readInt();
    this.cod_nrbe_en = in.readString();
    this.num_sec_ac = in.readInt();
    this.statusCode = in.readInt();
    this.headers = in.readObject();
    this.content = in.readByteArray();
    
}
public int getFactoryId() {
    return ResponseSerializablePlusFactory.FACTORY_ID;
}
public int getClassId() {
    return ResponseSerializablePlusFactory.RESPONSE_SERIALIZABLE_PLUS_CLASS;
}
@Override
public String toString() {
    return "ResponseSerializablePlus [id_interno_pe=" + id_interno_pe + ", cod_nrbe_en=" + cod_nrbe_en
            + ", num_sec_ac=" + num_sec_ac + ", statusCode=" + statusCode + ", headers=" + headers + ", content="
            + Arrays.toString(content) + "]";
}
}

Answer 1

它确实不受支持，它是文档，以及替代选项。请看这里：https://github.com/hazelcast/hazelcast/blob/3cb8ce1fc3bb848aced6c87a30bf7b31aec16cf7/hazelcast/src/main/java/com/hazelcast/query/Predicates.java#L492-L497