关于apign点燃IgnitePredicate <EventAdapter>接口

问题描述

我正在使用 IgnitePredicate 界面来了解何时修改了缓存（放置或删除）。

@Override
    public boolean apply(EventAdapter e) {
        if (e instanceof CacheEvent) {
            CacheEvent cacheEvent = (CacheEvent)e;
            if (e.type() == EventType.EVT_CACHE_OBJECT_PUT) {
                MyClass obj = (MyClass)cacheEvent.newValue();//line 1
                MyClass obj = ((BinaryObject)cacheEvent.newValue()).deserialize()//line 2
            }
        }
        return true;
    }

我想通过上面的代码将新数据放入缓存。

首先，我正在使用代码行1，它可以正常工作。

此后，我发现它导致错误“ java.lang.ClassCastException：org.apache.ignite.internal.binary.BinaryObjectImpl无法转换为MyClass”。因此我将代码更改为第2行，但它导致另一个异常“无法将MyClass强制转换为oaiibBinaryObjectImpl”。newValue是MyClass对象。

我想知道为什么有时它是BinaryOjbectImpl，有时是MyClass对象。还是取决于我不知道的事情。或我的代码有问题。

谢谢。最好的问候。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

ignite