У нас есть обновление с Oracle Coherence версии 12.1.2 до 12.2.1.3ParallelAwareAggregator устарела в 12.2.1.3.Мы хотим ответить с помощью com.tangosol.util.InvocableMap.StreamingAggregator.StreamingAggregator изменен с ParallelAwareAggregator.
Как мы реализуем следующий методInvocableMap.StreamingAggregatorпоставка();логическое накопление (InvocableMap.Entryvar1);логический комбинат (P var1);P getPartialResult ();R finalizeResult ();
пример реализации StreamingAggreator был бы великолепен.текущая реализация ParallelAwareAggregator, какInvocableMap.EntryAggregatorgetParallelAggregator ();R aggregateResults (Коллекция
var1)P aggregatePartialResults (Коллекция
var1)Как нам заменить методом StreamingAggreator? Спасибо