org.elasticsearch.gateway

Class AsyncShardFetch.FetchResult<T extends BaseNodeResponse>

java.lang.Object

org.elasticsearch.gateway.AsyncShardFetch.FetchResult<T>

Enclosing class:

AsyncShardFetch<T extends BaseNodeResponse>

public static class AsyncShardFetch.FetchResult<T extends BaseNodeResponse>
extends java.lang.Object

The result of a fetch operation. Make sure to first check hasData() before fetching the actual data.

Constructor Summary

Constructors

Constructor and Description
FetchResult(ShardId shardId, java.util.Map<DiscoveryNode,T> data, java.util.Set<java.lang.String> ignoreNodes)

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FetchResult

public FetchResult(ShardId shardId,
                   java.util.Map<DiscoveryNode,T> data,
                   java.util.Set<java.lang.String> ignoreNodes)

Method Detail

hasData

public boolean hasData()

Does the result actually contain data? If not, then there are on going fetch operations happening, and it should wait for it.

getData

public 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.

processAllocation

public void processAllocation(RoutingAllocation allocation)

Process any changes needed to the allocation based on this fetch result.