Package 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 Description
    FetchResult​(ShardId shardId, java.util.Map<DiscoveryNode,​T> data, java.util.Set<java.lang.String> ignoreNodes)  

  • Method Summary

    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.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • FetchResult

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

  • Method Details

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