自定义对象中的Hazelcast查询

Question

我正在应用程序中使用Hazelcast作为共享映射。我的地图是这样的：

Map<String, MyObject>

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

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

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

第144行：

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

这里是我的CustomFieldGetter类：

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 + "]";
    }
}

很酷，在重新编译Hazelcast之后，使用这个新的jar，我可以使用普通SQL访问查询。但对于pagingQueries，我有一些错误。

Answer 1

一种选择是实现可移植接口。然后您可以将每个条目作为一个单独的字段编写。这假设输入值也实现了可移植接口。

看看如何使用便携的示例代码。