java - 了解ignite中的BinaryObjects

我有一些要以BinaryObject格式存储的数据。我正在使用DataStreamer将数据放入缓存，并使用StreamReceiver处理它们。这是我创建BinaryObject的方法：

String typeName; // Some arbitrary string, does not correspond to any FQCN
BinaryObjectBuilder bldr = ignite.binary().builder();
String key;
//init
IgniteDataStreamer<String, BinaryObject> strmr = ignite.dataStreamer(typeName);
//set receiver
strmr.addData(key, bldr.build());

但是在接收器代码中我有这个：

@Override
public void receive(IgniteCache<String, BinaryObject> cache, Collection<Map.Entry<String, BinaryObject>> entries) throws IgniteException {
    String key = entry.getKey();
    BinaryObject value = entry.getValue(); //< ----Here is where problems come
    //...
}

在stackTrace的底部，我得到了：

java.lang.ClassNotFoundException: Unknown pair [platformId=0, typeId=-462125592]

这是什么意思？我是否可以尝试将二进制对象反序列化为某种类型，但是没有找到一个由我提供的类型名称引起的类？

最佳答案

在向其添加任何数据之前，尝试在流媒体上设置keepBinary标志：

strmr.keepBinary(true);