public class KeyPublisherResponse extends PublisherResponse
The keys array will hold all of the original keys for the mapped/flatmapped values.
The extraObjects array will only be required when using flatMap based operation. This is required as some flat map operations may return more than one value. In this case it is possible to overflow the results array (sized based on batch size). However since we are tracking by key we must retain all values that map to a given key in the response.
Constructor and Description |
---|
KeyPublisherResponse(Object[] results,
IntSet completedSegments,
IntSet lostSegments,
int size,
boolean complete,
Object[] extraObjects,
int extraSize,
Object[] keys,
int keySize) |
Modifier and Type | Method and Description |
---|---|
void |
forEachSegmentValue(ObjIntConsumer consumer,
int segment) |
Object[] |
getExtraObjects() |
int |
getExtraSize() |
String |
toString() |
emptyResponse, getCompletedSegments, getLostSegments, getResults, getSize, isComplete
public int getExtraSize()
public Object[] getExtraObjects()
public void forEachSegmentValue(ObjIntConsumer consumer, int segment)
forEachSegmentValue
in class PublisherResponse
public String toString()
toString
in class PublisherResponse
Copyright © 2021 JBoss by Red Hat. All rights reserved.