Package org.elasticsearch.cluster.routing.allocation.command

Class AbstractAllocateAllocationCommand

java.lang.Object
org.elasticsearch.cluster.routing.allocation.command.AbstractAllocateAllocationCommand
All Implemented Interfaces:
AllocationCommand, NamedWriteable, Writeable, org.elasticsearch.common.xcontent.ToXContent, org.elasticsearch.common.xcontent.ToXContentObject
Direct Known Subclasses:
AllocateReplicaAllocationCommand, BasePrimaryAllocationCommand
public abstract class AbstractAllocateAllocationCommand
extends java.lang.Object
implements AllocationCommand
Abstract base class for allocating an unassigned shard to a node

  • Field Details

    • index

      protected final java.lang.String index

    • shardId

      protected final int shardId

    • node

      protected final java.lang.String node

  • Constructor Details

  • Method Details

    • createAllocateParser

      protected static <T extends AbstractAllocateAllocationCommand.Builder<?>> org.elasticsearch.common.xcontent.ObjectParser<T,​java.lang.Void> createAllocateParser​(java.lang.String command)

    • writeTo

      public void writeTo​(StreamOutput out) throws java.io.IOException
      Description copied from interface: Writeable
      Write this into the StreamOutput.
      Specified by:
      writeTo in interface Writeable
      Throws:
      java.io.IOException

    • index

      public java.lang.String index()
      Get the index name
      Returns:
      name of the index

    • shardId

      public int shardId()
      Get the shard id
      Returns:
      id of the shard

    • node

      public java.lang.String node()
      Get the id of the node
      Returns:
      id of the node

    • explainOrThrowMissingRoutingNode

      protected RerouteExplanation explainOrThrowMissingRoutingNode​(RoutingAllocation allocation, boolean explain, DiscoveryNode discoNode)
      Handle case where a disco node cannot be found in the routing table. Usually means that it's not a data node.

    • explainOrThrowRejectedCommand

      protected RerouteExplanation explainOrThrowRejectedCommand​(boolean explain, RoutingAllocation allocation, java.lang.String reason)
      Utility method for rejecting the current allocation command based on provided reason

    • explainOrThrowRejectedCommand

      protected RerouteExplanation explainOrThrowRejectedCommand​(boolean explain, RoutingAllocation allocation, java.lang.RuntimeException rte)
      Utility method for rejecting the current allocation command based on provided exception

    • initializeUnassignedShard

      protected void initializeUnassignedShard​(RoutingAllocation allocation, RoutingNodes routingNodes, RoutingNode routingNode, ShardRouting shardRouting)
      Initializes an unassigned shard on a node and removes it from the unassigned
      Parameters:
      allocation - the allocation
      routingNodes - the routing nodes
      routingNode - the node to initialize it to
      shardRouting - the shard routing that is to be matched in unassigned shards

    • initializeUnassignedShard

      protected void initializeUnassignedShard​(RoutingAllocation allocation, RoutingNodes routingNodes, RoutingNode routingNode, ShardRouting shardRouting, @Nullable UnassignedInfo unassignedInfo, @Nullable RecoverySource recoverySource)
      Initializes an unassigned shard on a node and removes it from the unassigned
      Parameters:
      allocation - the allocation
      routingNodes - the routing nodes
      routingNode - the node to initialize it to
      shardRouting - the shard routing that is to be matched in unassigned shards
      unassignedInfo - unassigned info to override
      recoverySource - recovery source to override

    • toXContent

      public org.elasticsearch.common.xcontent.XContentBuilder toXContent​(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params) throws java.io.IOException
      Specified by:
      toXContent in interface org.elasticsearch.common.xcontent.ToXContent
      Throws:
      java.io.IOException

    • extraXContent

      protected void extraXContent​(org.elasticsearch.common.xcontent.XContentBuilder builder) throws java.io.IOException
      Throws:
      java.io.IOException

    • equals

      public boolean equals​(java.lang.Object obj)
      Overrides:
      equals in class java.lang.Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class java.lang.Object