R
- the type of results returnedpublic static interface ClusterStreamManager.ResultsCallback<R>
Modifier and Type | Method and Description |
---|---|
void |
onCompletion(Address address,
Set<Integer> completedSegments,
R results)
Essentially the same as
onIntermediateResult(Address address, Object)
except that this is the last time this callback will be invoked and it tells which segments were completed |
Set<Integer> |
onIntermediateResult(Address address,
R results)
Called back for intermediate data returned from an operation.
|
void |
onSegmentsLost(Set<Integer> segments)
Called back when a segment is found to have been lost that is no longer remote
This method should return as soon as possible and not block in any fashion.
|
Set<Integer> onIntermediateResult(Address address, R results)
CacheStream.iterator()
, CacheStream.spliterator()
,
CacheStream.forEach(Consumer)
and Stream.toArray()
.address
- Which node this data came fromresults
- The results obtained so far.void onCompletion(Address address, Set<Integer> completedSegments, R results)
onIntermediateResult(Address address, Object)
except that this is the last time this callback will be invoked and it tells which segments were completedaddress
- Which node this data came fromresults
- The last batch of results for this operatorvoid onSegmentsLost(Set<Integer> segments)
segments
- The segments that were requested but are now localCopyright © 2020 JBoss, a division of Red Hat. All rights reserved.