private void replayEventsOverResultSet ( QueryResult queryResult ) throws Exception { Map < Integer , Future < Object > > future = readAccumulators ( ) ; for ( Map . Entry < Integer , Future < Object > > entry : future . entrySet ( ) ) { int partitionId = entry . getKey ( ) ; Object eventsInOneAcc = entry . getValue ( ) . get ( ) ; if ( eventsInOneAcc == null ) { continue ; } eventsInOneAcc = mapServiceContext . toObject ( eventsInOneAcc ) ; List < QueryCacheEventData > eventDataList = ( List < QueryCacheEventData > ) eventsInOneAcc ; for ( QueryCacheEventData eventData : eventDataList ) { if ( eventData . getDataKey ( ) == null ) { // this means a map-wide event like clear-all or evict-all // is inside the accumulator buffers removePartitionResults ( queryResult , partitionId ) ; } else { add ( queryResult , newQueryResultRow ( eventData ) ) ; } } } }
Replay events over the result set of initial query . These events are received events during execution of the initial query .