瞭解BinaryObjects中的點火

Question

我有一些數據，我將以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 
    //... 
} 

在堆棧跟蹤的底部，我得到這個：

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

是什麼意思？我是正確的，點燃嘗試反序列化二進制對象的某種類型，但沒有找到一個類型，通過我提供的類型名稱？

Answer 1

嘗試之前設置keepBinary標誌上的拖纜，以添加任何數據到它：

strmr.keepBinary(true);