Двоичные объекты в StreamReceiver и универсальные типы ⇐ JAVA

[Anonymous]

Я пытаюсь понять, как правильно работать с StreamReceiver, которые используются с IgniteDataStreamer, где установлен параметр KeepBinary(true). Рассмотрим этот код:

Код: Выделить всё

IgniteDataStreamer streamer = ignite.dataStreamer(cacheName);
streamer.keepBinary(true);
streamer.receiver(new MyReceiver());

Теперь дело в том, что MyReceiver должен реализовать StreamReceiver, но нет > StreamReceiver — иначе приведенный выше код не скомпилируется. В результате метод получения выглядит так:

Код: Выделить всё

public class MyReceiver implements StreamReceiver {
@Override
void receive(IgniteCache cache,
Collection entries) {
//
}
}

Теперь ключ и значение, которые входят в коллекцию записей, не являются MyPojoKey и MyPojoEntity! Поскольку метод KeepBinary был вызван выше с true, они являются BinaryObjectImpl, где BinaryObjectImpl — это тип Ignite, что возможно только благодаря стиранию типов в Java. Конечно, я могу привести их к правильному BinaryObject и затем работать с ними как таковые:

Код: Выделить всё

  void receive(IgniteCache cache,
Collection entries) {
entries.forEach(entry -> {
// Notice I can't do "MyPojoEntity en = entry.getValue()" - that would throw ClassCastException
BinaryObject binaryEntity = (BinaryObject)entry.getValue();

// Notice unchecked cast to raw IgniteCache - can't compile it otherwise!
((IgniteCache)cache).put(key, binaryEntity);

});
}

Приведенный выше код работает, как и ожидалось, хотя и с теми очень грязными трюками со стиранием типов, чтобы обойти то, что эффективно является загрязнением кучи Java. Так что это немного запутанно, не так ли?
Конечно, более простой и безопасный обходной путь, вероятно, заключается в том, чтобы MyReceiver реализовывал StreamReceiver , а затем используйте необработанный тип IgniteDataStreamer:

Код: Выделить всё

 // ...
((IgniteDataStreamer)streamer).receiver(new MyReceiver()); // Cast to raw IgniteDataStreamer
// ... and where MyReceiver now implements StreamReceiver

, и в этом случае, по крайней мере, MyReceiver может быть реализован как строго типизированный. Но все равно это выглядит как грязный хак, так что я подозреваю, что это я делаю что-то не так?

Подробнее здесь: https://stackoverflow.com/questions/784 ... eric-types