Hazelcast 中 EntryProcessor 的自定义序列化功能

问：

我们是否有 EntryProcessor 或 ExecutorService 的自定义序列化功能？Hazelcast文档没有在这方面指定任何内容。文档中没有提供与 EntryProcessor 的自定义序列化相关的示例。我们正在寻找 EntryProcessor 的可移植序列化。

public class SampleEntryProcessor implements EntryProcessor<SampleDataKey, SampleDataValue , SampleDataValue >,Portable {

/**
 * 
 */
private static final long serialVersionUID = 1L;

private SampleDataValue sampleDataValue ;

public SampleDataValue process(Map.Entry<SampleDataKey, SampleDataValue > entry) {
    
    //Sample logic here
    return null;
}


@Override
public int getFactoryId() {
    return 1;
}

@Override
public int getClassId() {
    return 1;
}

@Override
public void writePortable(PortableWriter writer) throws IOException {
    writer.writePortable("i", sampleDataValue );
    
}

@Override
public void readPortable(PortableReader reader) throws IOException {
    sampleDataValue = reader.readPortable("i");
}

}

更新：当我尝试调用处理器时，出现如下错误。

Exception in thread "main" java.lang.ClassCastException: com.hazelcast.internal.serialization.impl.portable.DeserializedPortableGenericRecord cannot be cast to com.hazelcast.map.EntryProcessor
at com.hazelcast.client.impl.protocol.task.map.MapExecuteOnKeyMessageTask.prepareOperation(MapExecuteOnKeyMessageTask.java:42)
at com.hazelcast.client.impl.protocol.task.AbstractPartitionMessageTask.processInternal(AbstractPartitionMessageTask.java:45)