@ Override public Map < String , SerializedValue < OptionalFailure < Object > > > getAccumulatorsSerialized ( ) { return aggregateUserAccumulators ( ) . entrySet ( ) . stream ( ) . collect ( Collectors . toMap ( Map . Entry :: getKey , entry -> serializeAccumulator ( entry . getKey ( ) , entry . getValue ( ) ) ) ) ; }
Gets a serialized accumulator map .