public static class AsyncShardFetch.FetchResult<T extends BaseNodeResponse>
extends java.lang.Object
hasData()
before
fetching the actual data.Constructor | Description |
---|---|
FetchResult(ShardId shardId,
java.util.Map<DiscoveryNode,T> data,
java.util.Set<java.lang.String> ignoreNodes) |
Modifier and Type | Method | Description |
---|---|---|
java.util.Map<DiscoveryNode,T> |
getData() |
Returns the actual data, note, make sure to check
hasData() first and
only use this when there is an actual data. |
boolean |
hasData() |
Does the result actually contain data? If not, then there are on going fetch
operations happening, and it should wait for it.
|
void |
processAllocation(RoutingAllocation allocation) |
Process any changes needed to the allocation based on this fetch result.
|
public FetchResult(ShardId shardId, java.util.Map<DiscoveryNode,T> data, java.util.Set<java.lang.String> ignoreNodes)
public boolean hasData()
public java.util.Map<DiscoveryNode,T> getData()
hasData()
first and
only use this when there is an actual data.public void processAllocation(RoutingAllocation allocation)